consul

Documentation

Index

• func KvPairsToKvBytes(kvp api.KVPairs) (stores.KVBytes, error)
• func New(cfg *config.Config, cn ConsulKVIFace) stores.IFace
• func NewDefault(cfg *config.Config) (stores.IFace, error)
• type ConsulKVIFace
• type MockConsul
  • func NewMockConsul(key string, kvb stores.KVBytes, err error) (mc *MockConsul)
  • func (mc *MockConsul) Delete(key string, w *api.WriteOptions) (*api.WriteMeta, error)
  • func (mc *MockConsul) Get(key string, qo *api.QueryOptions) (*api.KVPair, *api.QueryMeta, error)
  • func (mc *MockConsul) List(prefix string, qo *api.QueryOptions) (api.KVPairs, *api.QueryMeta, error)
  • func (mc *MockConsul) Put(p *api.KVPair, qo *api.WriteOptions) (*api.WriteMeta, error)
• type Store
  • func (s *Store) Close()
  • func (cs *Store) Delete(key string) error
  • func (cs *Store) Get(key string) (*stores.KVByte, error)
  • func (cs *Store) List(prefix string) (stores.KVBytes, error)
  • func (cs *Store) Register(cb func(kvb stores.KVBytes))
  • func (cs *Store) Set(key string, bts []byte) error
  • func (cs *Store) Updated(kvs interface{})
  • func (cs *Store) Watch() error

Functions

func KvPairsToKvBytes

func KvPairsToKvBytes(kvp api.KVPairs) (stores.KVBytes, error)

func New

func New(cfg *config.Config, cn ConsulKVIFace) stores.IFace

func NewDefault

func NewDefault(cfg *config.Config) (stores.IFace, error)

Types

type ConsulKVIFace

type ConsulKVIFace interface {
	List(prefix string, q *api.QueryOptions) (api.KVPairs, *api.QueryMeta, error)
	Get(key string, q *api.QueryOptions) (*api.KVPair, *api.QueryMeta, error)
	Put(p *api.KVPair, q *api.WriteOptions) (*api.WriteMeta, error)
	Delete(key string, w *api.WriteOptions) (*api.WriteMeta, error)
}

type MockConsul

type MockConsul struct {
	Item  *stores.KVByte
	Items stores.KVBytes
	Err   error
}

func NewMockConsul

func NewMockConsul(key string, kvb stores.KVBytes, err error) (mc *MockConsul)

func (*MockConsul) Delete

func (mc *MockConsul) Delete(key string, w *api.WriteOptions) (*api.WriteMeta, error)

func (*MockConsul) Get

func (mc *MockConsul) Get(key string, qo *api.QueryOptions) (*api.KVPair, *api.QueryMeta, error)

func (*MockConsul) List

func (mc *MockConsul) List(prefix string, qo *api.QueryOptions) (api.KVPairs, *api.QueryMeta, error)

func (*MockConsul) Put

func (mc *MockConsul) Put(p *api.KVPair, qo *api.WriteOptions) (*api.WriteMeta, error)

type Store

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

func (*Store) Close

func (s *Store) Close()

func (*Store) Delete

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

func (*Store) Get

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

func (*Store) List

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

func (*Store) Register

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

func (*Store) Set

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

func (*Store) Updated

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

func (*Store) Watch

func (cs *Store) Watch() error