etcd

Documentation

Index

• type EtcdLock
  • func NewEtcdLock() *EtcdLock
  • func (e *EtcdLock) Close() error
  • func (e *EtcdLock) Features() []lock.Feature
  • func (e *EtcdLock) Init(metadata lock.Metadata) error
  • func (e *EtcdLock) LockKeepAlive(ctx context.Context, request *lock.LockKeepAliveRequest) (*lock.LockKeepAliveResponse, error)
  • func (e *EtcdLock) OnLogLevelChanged(outputLevel logger.LogLevel)
  • func (e *EtcdLock) TryLock(ctx context.Context, req *lock.TryLockRequest) (*lock.TryLockResponse, error)
  • func (e *EtcdLock) Unlock(ctx context.Context, req *lock.UnlockRequest) (*lock.UnlockResponse, error)

Types

type EtcdLock

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

Etcd lock store

func NewEtcdLock

func NewEtcdLock() *EtcdLock

NewEtcdLock returns a new etcd lock

func (*EtcdLock) Close

func (e *EtcdLock) Close() error

Close shuts down the client's etcd connections.

func (*EtcdLock) Features

func (e *EtcdLock) Features() []lock.Feature

Features is to get EtcdLock's features

func (*EtcdLock) Init

func (e *EtcdLock) Init(metadata lock.Metadata) error

Init EtcdLock

func (*EtcdLock) LockKeepAlive

func (e *EtcdLock) LockKeepAlive(ctx context.Context, request *lock.LockKeepAliveRequest) (*lock.LockKeepAliveResponse, error)

LockKeepAlive try to renewal lease

func (*EtcdLock) OnLogLevelChanged

func (e *EtcdLock) OnLogLevelChanged(outputLevel logger.LogLevel)

func (*EtcdLock) TryLock

func (e *EtcdLock) TryLock(ctx context.Context, req *lock.TryLockRequest) (*lock.TryLockResponse, error)

Node tries to acquire a etcd lock

func (*EtcdLock) Unlock

func (e *EtcdLock) Unlock(ctx context.Context, req *lock.UnlockRequest) (*lock.UnlockResponse, error)

Node tries to release a etcd lock