pketcd

Documentation

Index

• type EtcdClient
  • func NewEtcdClient(config clientv3.Config) (*EtcdClient, error)
  • func (cli *EtcdClient) GetClient() *clientv3.Client
  • func (cli *EtcdClient) Locker(ctx context.Context, lockKey string, leaseTtl int64) (bool, error)
  • func (cli *EtcdClient) SetNx(ctx context.Context, key, value string, ops ...clientv3.OpOption) (int, error)
  • func (cli *EtcdClient) SvcDiscover(ctx context.Context, prefixKey string, whenGet func(string, string), ...) error
  • func (cli *EtcdClient) SvcRegister(ctx context.Context, prefixKey string, value string, leaseTtl int64) error
  • func (cli *EtcdClient) Unlocker(ctx context.Context, lockKey string) error

Types

type EtcdClient

type EtcdClient struct {
	Kv clientv3.KV
	// contains filtered or unexported fields
}

func NewEtcdClient

func NewEtcdClient(config clientv3.Config) (*EtcdClient, error)

func (*EtcdClient) GetClient

func (cli *EtcdClient) GetClient() *clientv3.Client

func (*EtcdClient) Locker

func (cli *EtcdClient) Locker(ctx context.Context, lockKey string, leaseTtl int64) (bool, error)

func (*EtcdClient) SetNx

func (cli *EtcdClient) SetNx(ctx context.Context, key, value string, ops ...clientv3.OpOption) (int, error)

func (*EtcdClient) SvcDiscover

func (cli *EtcdClient) SvcDiscover(ctx context.Context, prefixKey string, whenGet func(string, string), whenDel func(string, string)) error

func (*EtcdClient) SvcRegister

func (cli *EtcdClient) SvcRegister(ctx context.Context, prefixKey string, value string, leaseTtl int64) error

func (*EtcdClient) Unlocker

func (cli *EtcdClient) Unlocker(ctx context.Context, lockKey string) error