etcd

Documentation

Index

• type Config
• type Etcd
  • func New(id string, cfg *Config) (*Etcd, error)
  • func (e *Etcd) Close() error
  • func (e *Etcd) Delete(ctx context.Context, key string) error
  • func (e *Etcd) Exists(ctx context.Context, key string) (bool, error)
  • func (e *Etcd) Get(ctx context.Context, key string) ([]byte, error)
  • func (e *Etcd) ID() string
  • func (e *Etcd) IsReady(ctx context.Context) bool
  • func (e *Etcd) Leader() string
  • func (e *Etcd) LeaderChange() <-chan bool
  • func (e *Etcd) List(ctx context.Context, prefix string) ([]persistence.Entry, error)
  • func (e *Etcd) Set(ctx context.Context, key string, value []byte) error

Types

type Config

type Config struct {
	Addrs    []string `yaml:"addrs"`
	Username string   `yaml:"username"`
	Password string   `yaml:"password"`
	TLS      struct {
		Enable        bool   `yaml:"enable"`
		CertFile      string `yaml:"cert_file"`
		KeyFile       string `yaml:"key_file"`
		TrustedCAFile string `yaml:"ca_file"`
	} `yaml:"tls"`
	ElectPath string `yaml:"elect_path"`
}

type Etcd

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

func New

func New(id string, cfg *Config) (*Etcd, error)

func (*Etcd) Close

func (e *Etcd) Close() error

func (*Etcd) Delete

func (e *Etcd) Delete(ctx context.Context, key string) error

func (*Etcd) Exists

func (e *Etcd) Exists(ctx context.Context, key string) (bool, error)

func (*Etcd) Get

func (e *Etcd) Get(ctx context.Context, key string) ([]byte, error)

func (*Etcd) ID

func (e *Etcd) ID() string

func (*Etcd) IsReady

func (e *Etcd) IsReady(ctx context.Context) bool

func (*Etcd) Leader

func (e *Etcd) Leader() string

func (*Etcd) LeaderChange

func (e *Etcd) LeaderChange() <-chan bool

func (*Etcd) List

func (e *Etcd) List(ctx context.Context, prefix string) ([]persistence.Entry, error)

func (*Etcd) Set

func (e *Etcd) Set(ctx context.Context, key string, value []byte) error