etcdclient

Documentation

Index

• Constants
• 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
• 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
  • func New(opts ...Option) *Client
  • func (this *Client) NewMutex(key string, ttl int) (*Mutex, error)
• type ETCD_ACTION
  • func (this ETCD_ACTION) ToString() string
• type Mutex
  • func CreateMutex(c *clientv3.Client, key string, ttl int) (*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

Constants

const (
	ETCD_DELETE = iota
	ETCD_PUT
)

Functions

func LogAction

func LogAction(action ETCD_ACTION) zap.Field

func LogKey

func LogKey(key string) zap.Field

func LogOk

func LogOk(v bool) zap.Field

func LogResp

func LogResp(resp interface{}) zap.Field

func WithAuth

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

func WithEndPoints

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

func WithTimeout

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

Types

type Client

type Client struct {
	clientv3.KV
	clientv3.Watcher
	*clientv3.Client
	// contains filtered or unexported fields
}

func New

func New(opts ...Option) *Client

func (*Client) NewMutex

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

type ETCD_ACTION

type ETCD_ACTION int32

func (ETCD_ACTION) ToString

func (this ETCD_ACTION) ToString() string

type Mutex

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

func CreateMutex

func CreateMutex(c *clientv3.Client, key string, ttl int) (*Mutex, error)

func (*Mutex) Lock

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

func (*Mutex) RefreshLockTTL

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

func (*Mutex) Unlock

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

type Option

type Option func(client *Client)