etcd

Documentation

Index

• type EtcdClient
  • func InitEtcdClient(c *EtcdConfig) (*EtcdClient, error)
  • func (cli *EtcdClient) Close() error
  • func (cli *EtcdClient) Delete(key string, timeout time.Duration) error
  • func (cli *EtcdClient) GetMetadata(key string, timeout time.Duration) (string, error)
  • func (cli *EtcdClient) GetNodes(key string, timeout time.Duration) ([]string, error)
  • func (cli *EtcdClient) Lock(key, val string, ttl int64) (*LockResult, error)
  • func (cli *EtcdClient) Put(key, metadata string, timeout time.Duration) error
  • func (cli *EtcdClient) Unlock(res *LockResult)
  • func (cli *EtcdClient) Update(key, update string, timeout time.Duration) (string, error)
  • func (cli *EtcdClient) Watch(key string, cb func(int32, string, string))
• type EtcdConfig
• type LockResult

Types

type EtcdClient

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

func InitEtcdClient

func InitEtcdClient(c *EtcdConfig) (*EtcdClient, error)

func (*EtcdClient) Close

func (cli *EtcdClient) Close() error

func (*EtcdClient) Delete

func (cli *EtcdClient) Delete(key string, timeout time.Duration) error

func (*EtcdClient) GetMetadata

func (cli *EtcdClient) GetMetadata(key string, timeout time.Duration) (string, error)

func (*EtcdClient) GetNodes

func (cli *EtcdClient) GetNodes(key string, timeout time.Duration) ([]string, error)

func (*EtcdClient) Lock

func (cli *EtcdClient) Lock(key, val string, ttl int64) (*LockResult, error)

etcd 分布式锁

func (*EtcdClient) Put

func (cli *EtcdClient) Put(key, metadata string, timeout time.Duration) error

func (*EtcdClient) Unlock

func (cli *EtcdClient) Unlock(res *LockResult)

func (*EtcdClient) Update

func (cli *EtcdClient) Update(key, update string, timeout time.Duration) (string, error)

func (*EtcdClient) Watch

func (cli *EtcdClient) Watch(key string, cb func(int32, string, string))

type EtcdConfig

type EtcdConfig struct {
	Endpoints   []string      `json:"endpoints"`
	DialTimeout time.Duration `json:"dialTimeout"`
}

type LockResult

type LockResult struct {
	IsLock  bool
	LeaseID clientv3.LeaseID
	Cancel  context.CancelFunc
}