etcd

May 10, 2022

Changes in this version

+ const DefaultDialTimeout

+ const DefaultLockLeaseTime

+ var ErrEmptyEndpoints = errors.New("length of etcd endpoints must be greater than 0")

+ type Client struct

+ func Dial(conf *Config, serverInfo *sync.ServerInfo) (*Client, error)

+ func (c *Client) Close() error

+ func (c *Client) Dial() error

+ func (c *Client) Initialize() error

+ func (c *Client) Members() map[string]*sync.ServerInfo

+ func (c *Client) NewLocker(ctx context.Context, key sync.Key) (sync.Locker, error)

+ func (c *Client) Publish(ctx context.Context, publisherID *time.ActorID, event sync.DocEvent)

+ func (c *Client) PublishToLocal(ctx context.Context, publisherID *time.ActorID, event sync.DocEvent)

+ func (c *Client) Subscribe(ctx context.Context, subscriber types.Client, keys []key.Key) (*sync.Subscription, map[string][]types.Client, error)

+ func (c *Client) Unsubscribe(ctx context.Context, keys []key.Key, sub *sync.Subscription) error

+ func (c *Client) UpdatePresence(ctx context.Context, publisher *types.Client, keys []key.Key) (*sync.DocEvent, error)

+ type Config struct

+ DialTimeout string

+ Endpoints []string

+ LockLeaseTime string

+ Password string

+ Username string

+ func (c *Config) ParseDialTimeout() time.Duration

+ func (c *Config) ParseLockLeaseTime() time.Duration

+ func (c *Config) Validate() error