etcd

Documentation

Index

• type Config
  • func DefaultConfig() *Config
• type Etcd
  • func New(ctx context.Context, endpoints []string, config *Config) Etcd

Types

type Config

type Config struct {
	CACert        string
	CertFile      string
	DialKeepAlive time.Duration
	DialOptions   []grpc.DialOption
	DialTimeout   time.Duration
	KeyFile       string
	Password      string
	Username      string
}

func DefaultConfig

func DefaultConfig() *Config

type Etcd

type Etcd interface {
	Register(key, val string, ttl time.Duration) error
	Deregister(key string) error

	Watch(prefix string, ch chan struct{}) error
	Dewatch(prefix string) error

	GetEntries(prefix string) ([]string, error)
	LeaseID() int64
}

func New

func New(ctx context.Context, endpoints []string, config *Config) Etcd