broker

Documentation

Index

• type MockBroker
  • func (mb *MockBroker) Delete(key string, opts ...datasync.DelOption) (found bool, err error)
  • func (mb *MockBroker) GetValue(key string, val proto.Message) (found bool, rev int64, err error)
  • func (mb *MockBroker) Keys() []string
  • func (mb *MockBroker) ListKeys(prefix string) (keyval.ProtoKeyIterator, error)
  • func (mb *MockBroker) ListValues(key string) (keyval.ProtoKeyValIterator, error)
  • func (mb *MockBroker) NewTxn() keyval.ProtoTxn
  • func (mb *MockBroker) Put(key string, data proto.Message, opts ...datasync.PutOption) error

Types

type MockBroker

type MockBroker struct {
	Data map[string]proto.Message
}

func (*MockBroker) Delete

func (mb *MockBroker) Delete(key string, opts ...datasync.DelOption) (found bool, err error)

func (*MockBroker) GetValue

func (mb *MockBroker) GetValue(key string, val proto.Message) (found bool, rev int64, err error)

func (*MockBroker) Keys

func (mb *MockBroker) Keys() []string

func (*MockBroker) ListKeys

func (mb *MockBroker) ListKeys(prefix string) (keyval.ProtoKeyIterator, error)

func (*MockBroker) ListValues

func (mb *MockBroker) ListValues(key string) (keyval.ProtoKeyValIterator, error)

func (*MockBroker) NewTxn

func (mb *MockBroker) NewTxn() keyval.ProtoTxn

func (*MockBroker) Put

func (mb *MockBroker) Put(key string, data proto.Message, opts ...datasync.PutOption) error