stores

Documentation

Index

• type IFace
• type KVByte
  • func (kv *KVByte) String() string
• type KVBytes
• type MockRepo
  • func (mr *MockRepo) Clone() error
  • func (mr *MockRepo) Commit(bts []byte, msg string) error
  • func (mr *MockRepo) Create() error
  • func (mr *MockRepo) CurrentSHA() (string, error)
  • func (mr *MockRepo) Enabled() bool
  • func (mr *MockRepo) Exists() bool
  • func (mr *MockRepo) Init()
  • func (mr *MockRepo) Pull() error
  • func (mr *MockRepo) Push() error
• type MockStore
  • func NewMockStore(ft *models.Feature, err error) (ms *MockStore)
  • func (ms *MockStore) Close()
  • func (ms *MockStore) Delete(key string) error
  • func (ms *MockStore) Get(key string) (*KVByte, error)
  • func (ms *MockStore) List(prefix string) (KVBytes, error)
  • func (ms *MockStore) Put(key string, bts []byte) error
  • func (ms *MockStore) Register(func(kvb KVBytes))
  • func (ms *MockStore) Set(key string, bts []byte) error
  • func (ms *MockStore) Updated(kvs interface{})
  • func (ms *MockStore) Watch() error

Types

type IFace

type IFace interface {
	List(prefix string) (KVBytes, error)
	Get(key string) (*KVByte, error)
	Delete(key string) error
	Set(key string, bts []byte) error
	Register(func(kvb KVBytes))
	Watch() error
	Updated(kvs interface{})
	Close()
}

type KVByte

type KVByte struct {
	Key   string
	Bytes []byte
}

func (*KVByte) String

func (kv *KVByte) String() string

type KVBytes

type KVBytes []*KVByte

type MockRepo

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

func (*MockRepo) Clone

func (mr *MockRepo) Clone() error

func (*MockRepo) Commit

func (mr *MockRepo) Commit(bts []byte, msg string) error

func (*MockRepo) Create

func (mr *MockRepo) Create() error

func (*MockRepo) CurrentSHA

func (mr *MockRepo) CurrentSHA() (string, error)

func (*MockRepo) Enabled

func (mr *MockRepo) Enabled() bool

func (*MockRepo) Exists

func (mr *MockRepo) Exists() bool

func (*MockRepo) Init

func (mr *MockRepo) Init()

func (*MockRepo) Pull

func (mr *MockRepo) Pull() error

func (*MockRepo) Push

func (mr *MockRepo) Push() error

type MockStore

type MockStore struct {
	Item  *KVByte
	Items KVBytes
	Err   error
}

func NewMockStore

func NewMockStore(ft *models.Feature, err error) (ms *MockStore)

func (*MockStore) Close

func (ms *MockStore) Close()

func (*MockStore) Delete

func (ms *MockStore) Delete(key string) error

func (*MockStore) Get

func (ms *MockStore) Get(key string) (*KVByte, error)

func (*MockStore) List

func (ms *MockStore) List(prefix string) (KVBytes, error)

func (*MockStore) Put

func (ms *MockStore) Put(key string, bts []byte) error

func (*MockStore) Register

func (ms *MockStore) Register(func(kvb KVBytes))

func (*MockStore) Set

func (ms *MockStore) Set(key string, bts []byte) error

func (*MockStore) Updated

func (ms *MockStore) Updated(kvs interface{})

func (*MockStore) Watch

func (ms *MockStore) Watch() error