gxetcd

May 15, 2021

Changes in this version

type Client

+ func (c *Client) Put(k, v string, opts ...clientv3.OpOption) error

May 4, 2021

Changes in this version

+ var ErrCompareFail = perrors.New("txn compare fail")

+ var ErrKVListSizeIllegal = perrors.New("k/v List is empty or kList's size is not equal to the size of vList")

+ var ErrRevision int64 = -1

type Client

+ func NewConfigClientWithErr(opts ...Option) (*Client, error)

+ func (c *Client) BatchCreate(kList []string, vList []string) error

+ func (c *Client) GetValAndRev(k string) (string, int64, error)

+ func (c *Client) UpdateWithRev(k, v string, rev int64, opts ...clientv3.OpOption) error

+ func (c *Client) WatchWithOption(k string, opts ...clientv3.OpOption) (clientv3.WatchChan, error)

Mar 10, 2021

Changes in this version

type Client

+ func (c *Client) GetChildren(k string) ([]string, []string, error)

+ func (c *Client) GetCtx() context.Context

+ func (c *Client) GetEndPoints() []string

+ func (c *Client) GetRawClient() *clientv3.Client

type Options

+ Client *Client

+ Endpoints []string

+ Heartbeat int

+ Name string

+ Timeout time.Duration

Mar 4, 2021

Changes in this version

+ const ConnDelay

+ const MaxFailTimes

+ const MetadataETCDV3Client

+ const RegistryETCDV3Client

+ var ErrKVPairNotFound = perrors.New("k/v pair not found")

+ var ErrNilETCDV3Client = perrors.New("etcd raw client is nil")

+ type Client struct

+ Wait sync.WaitGroup

+ func NewClient(name string, endpoints []string, timeout time.Duration, heartbeat int) (*Client, error)

+ func NewConfigClient(opts ...Option) *Client

+ func (c *Client) CleanKV() error

+ func (c *Client) Close()

+ func (c *Client) Create(k string, v string) error

+ func (c *Client) Delete(k string) error

+ func (c *Client) Done() <-chan struct{}

+ func (c *Client) Get(k string) (string, error)

+ func (c *Client) GetChildrenKVList(k string) ([]string, []string, error)

+ func (c *Client) RegisterTemp(k, v string) error

+ func (c *Client) Update(k, v string) error

+ func (c *Client) Valid() bool

+ func (c *Client) Watch(k string) (clientv3.WatchChan, error)

+ func (c *Client) WatchWithPrefix(prefix string) (clientv3.WatchChan, error)

+ type Option func(*Options)

+ func WithEndpoints(endpoints ...string) Option

+ func WithHeartbeat(heartbeat int) Option

+ func WithName(name string) Option

+ func WithTimeout(timeout time.Duration) Option

+ type Options struct