lock

type ConsulAPIWrapper ¶

type ConsulAPIWrapper struct {
	DefaultConfig func() *consulapi.Config
	NewClient     func(config *consulapi.Config) (*consulapi.Client, error)
}

type ConsulCombinationLock ¶

type ConsulCombinationLock struct {
	ConsulLock ConsulLock
	LocalLock  LocalLock
}

func (lock ConsulCombinationLock) Lock() error

func (lock ConsulCombinationLock) Unlock() error

type ConsulCombinationLockClient ¶

type ConsulCombinationLockClient struct {
	ConsulClient *ConsulLockClient
	LocalClient  *LocalLockClient
}

func NewConsulCombinationLockClient(consulAddress, consulBaseFolder string, consulLockOptions *consulapi.LockOptions) (*ConsulCombinationLockClient, error)

func (c ConsulCombinationLockClient) LockKey(key string) (Lock_i, error)

type ConsulLock ¶

type ConsulLock struct {
	Key        string
	ConsulLock *consulapi.Lock
	LockCh     <-chan struct{}
}

func (lock ConsulLock) Lock() error

func (lock ConsulLock) Unlock() error

type ConsulLockClient ¶

type ConsulLockClient struct {
	Client      *consulapi.Client
	LockOptions *consulapi.LockOptions
	BaseFolder  string
}

func NewConsulLockClient(address, baseFolder string, lockOptions *consulapi.LockOptions) (ConsulLockClient, error)

func (c ConsulLockClient) LockKey(key string) (Lock_i, error)

type LocalLock ¶

type LocalLock struct {
	Client *LocalLockClient
	Key    string
}

func (lock LocalLock) Lock() error

func (lock LocalLock) Unlock() error

type LocalLockClient ¶

type LocalLockClient struct {
	Keys           *c.Cache
	ExpirationTime time.Duration
}

The LocalLock is an implementation of the LockClient_i/Lock_i structure That is designed to be used in a non-distributed environment It uses a cache of Mutexes which are locked and unlocked according to a specified key

func NewLocalLockClient() *LocalLockClient

func (c *LocalLockClient) LockKey(key string) (Lock_i, error)

type LockClient_i ¶

type LockClient_i interface {
	LockKey(key string) (Lock_i, error)
}

type Lock_i ¶

type Lock_i interface {
	Lock() error
	Unlock() error
}

Lock_i is an instance of a Lock in the set of LockClient_i locks It requires 3 methods for implementation

• Lock: which attempts to establish a lock on its key
• Unlock: which attempts to remove a lock on its key
• Destroy: which deletes the Lock_i's key from its parent client