mutex

Dec 19, 2022

Changes in this version

+ const ProdMutexPrefix

+ const TestMutexPrefix

+ func GetEtcdClient(host string, timeout time.Duration, user string, pass string) (*clientv3.Client, error)

+ func GetEtcdTLSClient(host string, tls *tls.Config, timeout time.Duration) (*clientv3.Client, error)

+ func GetMutex(session *concurrency.Session, prefix string) *concurrency.Mutex

+ func GetSession(client *clientv3.Client) (*concurrency.Session, error)

+ type Lock struct

+ Client *clientv3.Client

+ Mutex *concurrency.Mutex

+ Session *concurrency.Session

+ func (e *Lock) Close() error

+ func (e *Lock) Release() error

+ func (e *Lock) TryAcquire() error