etcdlock

package

v0.1.4 Latest Latest Go to latest Published: Sep 3, 2026 License: MIT Imports: 7 Imported by: 1

Details

This section is empty.

This section is empty.

This section is empty.

type Mutex struct {
	// contains filtered or unexported fields
}

Mutex is an etcd session based distributed lock.

func New(pool *Pool, key string, timeout time.Duration) (*Mutex, error)

New creates a Mutex on key over a pooled session; Lock and Unlock each give up after timeout.

func (m *Mutex) Lock(ctx context.Context) (context.Context, error)

func (m *Mutex) Unlock(ctx context.Context) error

type Pool struct {
	// contains filtered or unexported fields
}

Pool keeps etcd sessions alive between locks.

func NewPool(cli *clientv3.Client, ttl time.Duration) *Pool

NewPool builds a pool whose sessions carry a lease of ttl.