etcd

Documentation

Index

• type EmbeddedEtcd
  • func NewEmbeddedEtcd(port int, dataDir string) (*EmbeddedEtcd, error)
  • func NewEmbeddedEtcdFromConfig() (*EmbeddedEtcd, error)
  • func (se *EmbeddedEtcd) Stop() error
• type EtcdClient
  • func NewEtcdClient(etcdServers []string, clientTimeout time.Duration) (*EtcdClient, error)
  • func NewEtcdClientFromConfig() (*EtcdClient, error)
  • func (client *EtcdClient) GetInt64(key string) (int64, error)
  • func (client *EtcdClient) SetInt64(key string, value int64) error
  • func (client *EtcdClient) Stop()

Types

type EmbeddedEtcd

type EmbeddedEtcd struct {
	Port int
	// contains filtered or unexported fields
}

EmbeddedEtcd provides a single node etcd server.

func NewEmbeddedEtcd

func NewEmbeddedEtcd(port int, dataDir string) (*EmbeddedEtcd, error)

func NewEmbeddedEtcdFromConfig

func NewEmbeddedEtcdFromConfig() (*EmbeddedEtcd, error)

func (*EmbeddedEtcd) Stop

func (se *EmbeddedEtcd) Stop() error

type EtcdClient

type EtcdClient struct {
	Client  *etcd.Client
	KeysApi etcd.KeysAPI
}

func NewEtcdClient

func NewEtcdClient(etcdServers []string, clientTimeout time.Duration) (*EtcdClient, error)

func NewEtcdClientFromConfig

func NewEtcdClientFromConfig() (*EtcdClient, error)

func (*EtcdClient) GetInt64

func (client *EtcdClient) GetInt64(key string) (int64, error)

func (*EtcdClient) SetInt64

func (client *EtcdClient) SetInt64(key string, value int64) error

func (*EtcdClient) Stop

func (client *EtcdClient) Stop()