README
¶
Distributed Locker
Install
$ go get github.com/zoer/locker
Usage
package main
import (
"context"
"log"
etcd "github.com/coreos/etcd/clientv3"
)
func main() {
// connect to Etcd instance
cl, err := clientv3.NewFromURL("127.0.0.1:2379")
if err != nil {
log.Fatalf("unable connect to Etcd")
}
lkr := NewEtcd(cl)
// cancel the lock via context timeout after 30 seconds
ctx, _ := context.WithTimeout(context.TODO(), 30*time.Second)
l, err := lkr.Lock(ctx, WithKey("lock-key"))
if err != nil {
log.Fatalf("unable get a lock: %v", err)
}
defer l.Unlock()
// ...
}
TODO
- Etcd
- Consul
- Redis
Documentation
¶
Overview ¶
Example ¶
// connect to Etcd instance
cl, err := clientv3.NewFromURL("127.0.0.1:2379")
if err != nil {
log.Fatalf("unable connect to Etcd")
}
lkr := NewEtcd(cl)
// cancel the lock via context timeout after 30 seconds
ctx, cancel := context.WithTimeout(context.TODO(), 30*time.Second)
defer cancel()
l, err := lkr.Lock(ctx, WithKey("lock-key"))
if err != nil {
log.Fatalf("unable get a lock: %v", err)
}
defer l.Unlock()
// ...
Output:
Index ¶
Examples ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Option ¶
type Option func(*options)
Option represents the lock option
func WithWaitTTL ¶
WithWaitTTL sets the wait for receiving the lock TTL.
Source Files
Click to show internal directories.
Click to hide internal directories.