etcd

Documentation

Index

• Variables
• func DefaultStore(cfg *config.Config) (client.KeysAPI, error)
• func FlattenToKVBytes(n *client.Node, nodes stores.KVBytes) stores.KVBytes
• func New(cfg *config.Config) stores.IFace
• type Store
  • func (s *Store) Close()
  • func (s *Store) Delete(key string) error
  • func (s *Store) Get(key string) (*stores.KVByte, error)
  • func (s *Store) Init()
  • func (s *Store) List(prefix string) (stores.KVBytes, error)
  • func (s *Store) Register(cb func(kvb stores.KVBytes))
  • func (s *Store) Set(key string, bts []byte) error
  • func (s *Store) Updated(kvs interface{})
  • func (s *Store) Watch() error

Variables

var (
	DefaultEndpoints = []string{"http://127.0.0.1:2379"}
	ReconnectTime    = 2 * time.Second
)

Functions

func DefaultStore

func DefaultStore(cfg *config.Config) (client.KeysAPI, error)

func FlattenToKVBytes

func FlattenToKVBytes(n *client.Node, nodes stores.KVBytes) stores.KVBytes

func New

func New(cfg *config.Config) stores.IFace

Types

type Store

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

func (*Store) Close

func (s *Store) Close()

func (*Store) Delete

func (s *Store) Delete(key string) error

func (*Store) Get

func (s *Store) Get(key string) (*stores.KVByte, error)

func (*Store) Init

func (s *Store) Init()

Init etcd watches do not fire an initial event. This method triggers a write to the file systems of the entire keyspace.

func (*Store) List

func (s *Store) List(prefix string) (stores.KVBytes, error)

func (*Store) Register

func (s *Store) Register(cb func(kvb stores.KVBytes))

func (*Store) Set

func (s *Store) Set(key string, bts []byte) error

func (*Store) Updated

func (s *Store) Updated(kvs interface{})

func (*Store) Watch

func (s *Store) Watch() error