etcd

Documentation

Index

• type Client
  • func (c *Client) AcquireLock(lockName string) (*concurrency.Mutex, *concurrency.Session, error)
  • func (c *Client) Close() error
  • func (c *Client) Connect(endpoints []string, dialTimeout time.Duration) error
  • func (c *Client) CreateLease(ttl int64) (clientv3.LeaseID, error)
  • func (c *Client) Get(key string, timeout time.Duration) (string, error)
  • func (c *Client) KeepAliveLease(id clientv3.LeaseID) error
  • func (c *Client) ListMembers() error
  • func (c *Client) Put(key, value string, timeout time.Duration) error
  • func (c *Client) ReleaseLock(m *concurrency.Mutex, s *concurrency.Session) error
  • func (c *Client) Txn() error
  • func (c *Client) WatchKey(key string)

Types

type Client

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

func (*Client) AcquireLock

func (c *Client) AcquireLock(lockName string) (*concurrency.Mutex, *concurrency.Session, error)

AcquireLock 分布式锁

func (*Client) Close

func (c *Client) Close() error

Close 关闭连接

func (*Client) Connect

func (c *Client) Connect(endpoints []string, dialTimeout time.Duration) error

Connect 建立连接

func (*Client) CreateLease

func (c *Client) CreateLease(ttl int64) (clientv3.LeaseID, error)

CreateLease 租约管理

func (*Client) Get

func (c *Client) Get(key string, timeout time.Duration) (string, error)

Get 读取

func (*Client) KeepAliveLease

func (c *Client) KeepAliveLease(id clientv3.LeaseID) error

KeepAliveLease 保持租约激活

func (*Client) ListMembers

func (c *Client) ListMembers() error

ListMembers 成员管理

func (*Client) Put

func (c *Client) Put(key, value string, timeout time.Duration) error

Put 放置/更新

func (*Client) ReleaseLock

func (c *Client) ReleaseLock(m *concurrency.Mutex, s *concurrency.Session) error

ReleaseLock 释放锁

func (*Client) Txn

func (c *Client) Txn() error

Txn 事务

func (*Client) WatchKey

func (c *Client) WatchKey(key string)

WatchKey 监听一个key