etcd

Documentation

Index

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

Constants

const (
	DialKeepAlive = 3 * time.Second
	DialTimeout   = 3 * time.Second
)

const (
	EventDel = "DELETE"
	EventPut = "PUT"
)

const (
	TTLDuration = 30 * time.Second
)

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 map[string]string) error
	Dewatch(prefix string) error

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

func New

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