XEtcd

Dec 24, 2020

Changes in this version

+ func CreateDefaultClient(config *Config) error

+ func NewEtcdClient(ctx context.Context, cfg *Config, zapLoggerConf *zap.Config) (cli *clientv3.Client, err error)

+ func NewStarter() *starter

+ func XClient() *clientv3.Client

+ func XFClient(f func(c *clientv3.Client) error) error

+ type Config struct

+ AutoSyncInterval uint

+ DialKeepAliveTime uint

+ DialKeepAliveTimeout uint

+ DialTimeout uint

+ Endpoints []string

+ MaxCallRecvMsgSize int

+ MaxCallSendMsgSize int

+ Password string

+ PermitWithoutStream bool

+ RejectOldCluster bool

+ Username string

+ func DefaultConfig() *Config

+ type EtcdCommon struct

+ func XEtcdCommon() *EtcdCommon

+ func (c *EtcdCommon) Get(key string) (*clientv3.GetResponse, error)

+ func (c *EtcdCommon) GetCount(key string) (*clientv3.GetResponse, error)

+ func (c *EtcdCommon) GetWithContext(ctx context.Context, key string) (*clientv3.GetResponse, error)

+ func (c *EtcdCommon) GetWithPrefix(ctx context.Context, key string) (*clientv3.GetResponse, error)

+ func (c *EtcdCommon) Put(key, value string) error

+ func (c *EtcdCommon) PutWithContext(ctx context.Context, key, value string) error

+ func (c *EtcdCommon) PutWithLease(ctx context.Context, key, value string, ttl int64) (clientv3.LeaseID, error)