setcd

Documentation

Index

• type EtcdInstance
  • func NewEtcdInstance(cluster []string) (*EtcdInstance, error)
  • func NewEtcdInstanceWichApi(api client.KeysAPI) *EtcdInstance
  • func (m *EtcdInstance) CreateDir(ctx context.Context, path string) error
  • func (m *EtcdInstance) Get(ctx context.Context, path string) (string, error)
  • func (m *EtcdInstance) GetNode(ctx context.Context, path string) (*client.Node, error)
  • func (m *EtcdInstance) RefreshTtl(ctx context.Context, path string, ttl time.Duration) error
  • func (m *EtcdInstance) Regist(ctx context.Context, path, val string, heatbeat time.Duration, ...) error
  • func (m *EtcdInstance) Set(ctx context.Context, path, val string) error
  • func (m *EtcdInstance) SetNx(ctx context.Context, path, val string) error
  • func (m *EtcdInstance) SetTtl(ctx context.Context, path, val string, ttl time.Duration) error
  • func (m *EtcdInstance) Watch(ctx context.Context, path string, hander func(*client.Response))

Types

type EtcdInstance

type EtcdInstance struct {
	Api client.KeysAPI
}

func NewEtcdInstance

func NewEtcdInstance(cluster []string) (*EtcdInstance, error)

func NewEtcdInstanceWichApi

func NewEtcdInstanceWichApi(api client.KeysAPI) *EtcdInstance

func (*EtcdInstance) CreateDir

func (m *EtcdInstance) CreateDir(ctx context.Context, path string) error

func (*EtcdInstance) Get

func (m *EtcdInstance) Get(ctx context.Context, path string) (string, error)

func (*EtcdInstance) GetNode

func (m *EtcdInstance) GetNode(ctx context.Context, path string) (*client.Node, error)

func (*EtcdInstance) RefreshTtl

func (m *EtcdInstance) RefreshTtl(ctx context.Context, path string, ttl time.Duration) error

func (*EtcdInstance) Regist

func (m *EtcdInstance) Regist(ctx context.Context, path, val string, heatbeat time.Duration, ttl time.Duration) error

func (*EtcdInstance) Set

func (m *EtcdInstance) Set(ctx context.Context, path, val string) error

func (*EtcdInstance) SetNx

func (m *EtcdInstance) SetNx(ctx context.Context, path, val string) error

func (*EtcdInstance) SetTtl

func (m *EtcdInstance) SetTtl(ctx context.Context, path, val string, ttl time.Duration) error

func (*EtcdInstance) Watch

func (m *EtcdInstance) Watch(ctx context.Context, path string, hander func(*client.Response))