etcd

Documentation

Index

• Constants
• type EtcdEngine
  • func NewEtcdEngine(cert, key, ca string, eps []string) (*EtcdEngine, error)
  • func (ee *EtcdEngine) CAS(key string, version int64, val []byte) (res int64, err error)
  • func (ee *EtcdEngine) Close()
  • func (ee *EtcdEngine) Del(key string) error
  • func (ee *EtcdEngine) Get(key string) (res []*store.KVPair, err error)
  • func (ee *EtcdEngine) RegisterWatcher(params interface{}, key string, watcher store.ChangeWatcher, ...)
  • func (ee *EtcdEngine) SetWithRelease(key string, val []byte, ttl time.Duration, keepAlive bool) (err error)

Constants

const (
	ETCD_OP_GET = "GET"
	ETCD_OP_CAS = "CAS"
)

Types

type EtcdEngine

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

func NewEtcdEngine

func NewEtcdEngine(cert, key, ca string, eps []string) (*EtcdEngine, error)

func (*EtcdEngine) CAS

func (ee *EtcdEngine) CAS(key string, version int64, val []byte) (res int64, err error)

func (*EtcdEngine) Close

func (ee *EtcdEngine) Close()

func (*EtcdEngine) Del

func (ee *EtcdEngine) Del(key string) error

func (*EtcdEngine) Get

func (ee *EtcdEngine) Get(key string) (res []*store.KVPair, err error)

func (*EtcdEngine) RegisterWatcher

func (ee *EtcdEngine) RegisterWatcher(params interface{}, key string, watcher store.ChangeWatcher, eventType store.OpType)

func (*EtcdEngine) SetWithRelease

func (ee *EtcdEngine) SetWithRelease(key string, val []byte, ttl time.Duration, keepAlive bool) (err error)

ttl in seconds