dmutex

Documentation

Index

• type DMutexEtcd
  • func NewDMutexEtcd(c *etcdclient.Client, timeout int) *DMutexEtcd
  • func (m *DMutexEtcd) Lock(pfx string) (*concurrency.Mutex, error)
  • func (m *DMutexEtcd) Unlock(mi *concurrency.Mutex) error

Types

type DMutexEtcd

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

func NewDMutexEtcd

func NewDMutexEtcd(c *etcdclient.Client, timeout int) *DMutexEtcd

func (*DMutexEtcd) Lock

func (m *DMutexEtcd) Lock(pfx string) (*concurrency.Mutex, error)

func (*DMutexEtcd) Unlock

func (m *DMutexEtcd) Unlock(mi *concurrency.Mutex) error