This package provides a Go client for creating distributed locks in MongoDB.
Install the package with "go get".
go get "github.com/square/mongo-lock"
In order to use it, you must have an instance of MongoDB running with a collection that can be used to store locks. All of the examples here will assume the collection name is "locks", but you can change it to whatever you want.
There is one index that is required in order for this package to work:
db.locks.createIndex( { resource: 1 }, { unique: true } )
The following indexes are recommend to help the performance of certain queries:
db.locks.createIndex( { "exclusive.lockId": 1 } )
db.locks.createIndex( { "exclusive.expiresAt": 1 } )
db.locks.createIndex( { "shared.locks.lockId": 1 } )
db.locks.createIndex( { "shared.locks.expiresAt": 1 } )
The Client.CreateIndexes method can be called to create all of the required and recommended indexes.
To minimize the risk of losing locks when one or more nodes in your replica set fail, setting the write acknowledgement for the session to "majority" is recommended.
Here is an example of how to use this package:
package main
import (
"context"
"log"
"time"
"go.mongodb.org/mongo-driver/mongo"
"go.mongodb.org/mongo-driver/mongo/options"
"go.mongodb.org/mongo-driver/mongo/writeconcern"
"github.com/square/mongo-lock"
)
func main() {
// Create a Mongo session and set the write mode to "majority".
mongoUrl := "youMustProvideThis"
database := "dbName"
collection := "collectionName"
ctx, cancel := context.WithTimeout(context.Background(), time.Second*30)
defer cancel()
m, err := mongo.Connect(ctx, options.Client().
ApplyURI(mongoUrl).
SetWriteConcern(writeconcern.New(writeconcern.WMajority())))
if err != nil {
log.Fatal(err)
}
defer func() {
if err = m.Disconnect(ctx); err != nil {
panic(err)
}
}()
// Configure the client for the database and collection the lock will go into.
col := m.Database(database).Collection(collection)
// Create a MongoDB lock client.
c := lock.NewClient(col)
// Create the required and recommended indexes.
c.CreateIndexes(ctx)
lockId := "abcd1234"
// Create an exclusive lock on resource1.
err = c.XLock(ctx, "resource1", lockId, lock.LockDetails{})
if err != nil {
log.Fatal(err)
}
// Create a shared lock on resource2.
err = c.SLock(ctx, "resource2", lockId, lock.LockDetails{}, -1)
if err != nil {
log.Fatal(err)
}
// Unlock all locks that have our lockId.
_, err = c.Unlock(ctx, lockId)
if err != nil {
log.Fatal(err)
}
}
This package can be used to create both shared and exclusive locks. To create a lock, all you need is the name of a resource (the object that gets locked) and a lockId (lock identifier). Multiple locks can be created with the same lockId, which makes it easy to unlock or renew a group of related locks at the same time. Another reason for using lockIds is to ensure the only the client that creates a lock knows the lockId needed to unlock it (i.e., knowing a resource name alone is not enough to unlock it).
Here is a list of rules that the locking behavior follows
- A resource can only have one exclusive lock on it at a time.
- A resource can have multiple shared locks on it at a time [1][2].
- A resource cannot have both an exclusive lock and a shared lock on it at the same time.
- A resource can have no locks on it at all.
[1] It is possible to limit the number of shared locks that can be on a resource at a time (see the docs for Client.SLock for more details). [2] A resource can't have more than one shared lock on it with the same lockId at a time.
- TTLs: You can optionally set a time to live (TTL) when creating a lock. If you do not set one, the lock will not have a TTL. TTLs can be renewed via the Client.Renew method as long as all of the locks associated with a given lockId have a TTL of at least 1 second (or no TTL at all). There is no automatic process to clean up locks that have outlived their TTL, but this package does provide a Purger that can be run in a loop to accomplish this.
Resources are the only documents stored in MongoDB. Locks on a resource are stored within the resource documents, like so:
{
"resource" : "resource1",
"exclusive" : {
"lockId" : null,
"owner" : null,
"host" : null,
"createdAt" : null,
"renewedAt" : null,
"expiresAt" : null,
"acquired" : false
},
"shared" : {
"count" : 1,
"locks" : [
{
"lockId" : "abcd",
"owner" : "john",
"host" : "host.name",
"createdAt" : ISODate("2018-01-25T01:58:47.243Z"),
"renewedAt" : null,
"expiresAt" : null,
"acquired" : true,
}
]
}
}
Note: shared locks are stored as an array instead of a map (keyed on lockId) so that shared lock fields can be indexed. This helps with the performance of unlocking, renewing, and getting the status of locks.
To work on mongo-lock, clone it to your $GOPATH.
You must use dep to pull in dependencies and populate your local vendor/ directory.
cd $GOPATH/src/github.com/square/mongo-lock
dep ensure
By default, tests expect a MongoDB instance to be running at "localhost:3000", and they write to a db "test" and randomly generated collection name. These defaults, however, can be overwritten with environment variables.
export TEST_MONGO_URL="your_url"
export TEST_MONGO_DB="your_db"
The randomly generated collection is dropped after each test.
If you have docker, you can easily spin up a MongoDB instance for testing by running docker run --rm -p "3000:27017" mongo.
This will start a MongoDB instance on localhost:3000, and it will remove the image when it's done.
Run the tests from the root directory of this repo like so:
go test `go list ./... | grep -v "/vendor/"` --race
Copyright 2018 Square, Inc.
Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.