etcd

Documentation

Index

• type Client
  • func (client *Client) WatchPrefix(ctx context.Context, prefix string) (*Watch, error)
• type Config
  • func (config *Config) Build() *Client
• type Watch
  • func (w *Watch) C() chan *clientv3.Event
  • func (w *Watch) IncipientKeyValues() []*mvccpb.KeyValue

Types

type Client

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

Client ...

func (*Client) WatchPrefix

func (client *Client) WatchPrefix(ctx context.Context, prefix string) (*Watch, error)

NewWatch ...

type Config

type Config struct {
	Endpoints        []string      `json:"endpoints"`
	CertFile         string        `json:"certFile"`
	KeyFile          string        `json:"keyFile"`
	CaCert           string        `json:"caCert"`
	BasicAuth        bool          `json:"basicAuth"`
	UserName         string        `json:"userName"`
	Password         string        `json:"-"`
	ConnectTimeout   time.Duration `json:"connectTimeout"` // 连接超时时间
	Secure           bool          `json:"secure"`
	AutoSyncInterval time.Duration `json:"autoAsyncInterval"` // 自动同步member list的间隔
	TTL              int           // 单位：s
}

Config ...

func (*Config) Build

func (config *Config) Build() *Client

type Watch

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

Watch A watch only tells the latest revision

func (*Watch) C

func (w *Watch) C() chan *clientv3.Event

C ...

func (*Watch) IncipientKeyValues

func (w *Watch) IncipientKeyValues() []*mvccpb.KeyValue

IncipientKeyValues incipient key and values