etcdclient

Oct 12, 2021

Changes in this version

+ const ETCD_DELETE

+ const ETCD_PUT

+ func LogAction(action ETCD_ACTION) zap.Field

+ func LogKey(key string) zap.Field

+ func LogOk(v bool) zap.Field

+ func LogResp(resp interface{}) zap.Field

+ type ETCD_ACTION int32

+ func (this ETCD_ACTION) ToString() string

May 30, 2021

Changes in this version

+ func WithAuth(user string, pass string) func(client *Client)

+ func WithEndPoints(endPoints ...string) func(client *Client)

+ func WithTimeout(timeout time.Duration) func(client *Client)

+ type Client struct

+ func New(opts ...Option) *Client

+ func (this *Client) NewMutex(key string, ttl int) (*Mutex, error)

+ type Mutex struct

+ func CreateMutex(key string, ttl int, machines []string) (*Mutex, error)

+ func (this *Mutex) Lock() (err error)

+ func (this *Mutex) RefreshLockTTL(ttl time.Duration) (err error)

+ func (this *Mutex) Unlock() (err error)

+ type Option func(client *Client)