etcd

Documentation

Index

• Constants
• type Cli
  • func NewEtcdCli(config *CliConfig) (*Cli, error)
  • func (cli *Cli) Campaign(ctx context.Context, id, prefix string, ttl int64) error
  • func (cli *Cli) Delete(ctx context.Context, key string) error
  • func (cli *Cli) Get(ctx context.Context, key string) (string, error)
  • func (cli *Cli) GetWithPrefix(ctx context.Context, prefix string) ([]string, []string, error)
  • func (cli *Cli) Keepalive(ctx context.Context, key, value string, ttl int64) (int64, error)
  • func (cli *Cli) Leader(ctx context.Context, prefix string) (id string, err error)
  • func (cli *Cli) Put(ctx context.Context, key, value string) error
  • func (cli *Cli) PutWithNotExist(ctx context.Context, key, value string) error
  • func (cli *Cli) PutWithNotExistTTL(ctx context.Context, key, value string, ttl int64) (int64, error)
  • func (cli *Cli) PutWithTTL(ctx context.Context, key, value string, ttl int64) (int64, error)
  • func (cli *Cli) Revoke(ctx context.Context, leaseId int64) error
  • func (cli *Cli) Transfer(ctx context.Context, from, to string, value string) error
  • func (cli *Cli) Watch(key string) *WatchKeyResponse
  • func (cli *Cli) WatchWithPrefix(prefix string) *WatchKeyResponse
• type CliConfig
• type KeyChange
• type KeyChangeChan
• type KeyChangeEvent
• type WatchKeyResponse

Constants

const (
	KeyCreateChangeEvent = iota + 1 //  create event
	KeyUpdateChangeEvent            //  update event
	KeyDeleteChangeEvent            //  delete event
	KeyCancelChangeEvent            //  cancel event

)

Types

type Cli

type Cli struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

etcd cli

func NewEtcdCli

func NewEtcdCli(config *CliConfig) (*Cli, error)

new etcd cli

func (*Cli) Campaign

func (cli *Cli) Campaign(ctx context.Context, id, prefix string, ttl int64) error

campaign become leader

func (*Cli) Delete

func (cli *Cli) Delete(ctx context.Context, key string) error

delete a key

func (*Cli) Get

func (cli *Cli) Get(ctx context.Context, key string) (string, error)

get with key

func (*Cli) GetWithPrefix

func (cli *Cli) GetWithPrefix(ctx context.Context, prefix string) ([]string, []string, error)

get with prefix

func (*Cli) Keepalive

func (cli *Cli) Keepalive(ctx context.Context, key, value string, ttl int64) (int64, error)

func (*Cli) Leader

func (cli *Cli) Leader(ctx context.Context, prefix string) (id string, err error)

find leader

func (*Cli) Put

func (cli *Cli) Put(ctx context.Context, key, value string) error

put a key

func (*Cli) PutWithNotExist

func (cli *Cli) PutWithNotExist(ctx context.Context, key, value string) error

func (*Cli) PutWithNotExistTTL

func (cli *Cli) PutWithNotExistTTL(ctx context.Context, key, value string, ttl int64) (int64, error)

func (*Cli) PutWithTTL

func (cli *Cli) PutWithTTL(ctx context.Context, key, value string, ttl int64) (int64, error)

put a key with ttl

func (*Cli) Revoke

func (cli *Cli) Revoke(ctx context.Context, leaseId int64) error

func (*Cli) Transfer

func (cli *Cli) Transfer(ctx context.Context, from, to string, value string) error

transfer a key

func (*Cli) Watch

func (cli *Cli) Watch(key string) *WatchKeyResponse

func (*Cli) WatchWithPrefix

func (cli *Cli) WatchWithPrefix(prefix string) *WatchKeyResponse

type CliConfig

type CliConfig struct {
	Endpoints   []string
	UserName    string
	Password    string
	DialTimeout time.Duration
}

etcd cli config

type KeyChange

type KeyChange struct {
	Event KeyChangeEvent
	Key   string
	Value string
}

type KeyChangeChan

type KeyChangeChan <-chan *KeyChange

type KeyChangeEvent

type KeyChangeEvent int32

type WatchKeyResponse

type WatchKeyResponse struct {
	Watcher     clientv3.Watcher
	KeyChangeCh chan *KeyChange
}