mockstorage

Documentation

Index

• type MockStore
  • func (s *MockStore) Batch(operations []storage.Operation) error
  • func (s *MockStore) Close() error
  • func (s *MockStore) Delete(k string) error
  • func (s *MockStore) Flush() error
  • func (s *MockStore) Get(k string) ([]byte, error)
  • func (s *MockStore) GetBulk(k ...string) ([][]byte, error)
  • func (s *MockStore) GetTags(key string) ([]storage.Tag, error)
  • func (s *MockStore) Put(k string, v []byte, _ ...storage.Tag) error
  • func (s *MockStore) PutBulk(keys []string, values [][]byte) error
  • func (s *MockStore) Query(expression string, options ...storage.QueryOption) (storage.Iterator, error)
• type Provider
  • func NewMockStoreProvider() *Provider
  • func (p *Provider) Close() error
  • func (p *Provider) GetOpenStores() []storage.Store
  • func (p *Provider) GetStoreConfig(name string) (storage.StoreConfiguration, error)
  • func (p *Provider) OpenStore(name string) (storage.Store, error)
  • func (p *Provider) SetStoreConfig(name string, config storage.StoreConfiguration) error

Types

type MockStore

type MockStore struct {
	Store map[string][]byte

	ErrPut error
	ErrGet error
	// contains filtered or unexported fields
}

MockStore represents a mock store.

func (*MockStore) Batch

func (s *MockStore) Batch(operations []storage.Operation) error

Batch performs multiple Put and/or Delete operations in order.

func (*MockStore) Close

func (s *MockStore) Close() error

Close closes this store object, freeing resources.

func (*MockStore) Delete

func (s *MockStore) Delete(k string) error

Delete is currently unimplemented.

func (*MockStore) Flush

func (s *MockStore) Flush() error

Flush forces any queued up Put and/or Delete operations to execute.

func (*MockStore) Get

func (s *MockStore) Get(k string) ([]byte, error)

Get fetches the value associated with the given key.

func (*MockStore) GetBulk

func (s *MockStore) GetBulk(k ...string) ([][]byte, error)

GetBulk mock is not implemented.

func (*MockStore) GetTags

func (s *MockStore) GetTags(key string) ([]storage.Tag, error)

GetTags fetches all tags associated with the given key.

func (*MockStore) Put

func (s *MockStore) Put(k string, v []byte, _ ...storage.Tag) error

Put stores the key-value pair.

func (*MockStore) PutBulk

func (s *MockStore) PutBulk(keys []string, values [][]byte) error

PutBulk mock not implemented.

func (*MockStore) Query

func (s *MockStore) Query(expression string, options ...storage.QueryOption) (storage.Iterator, error)

Query returns all data that satisfies the expression. Expression format: TagName:TagValue.

type Provider

type Provider struct {
	Stores             map[string]storage.Store
	Store              *MockStore
	ErrOpenStoreHandle error
	FailNameSpace      string
}

Provider mock store provider.

func NewMockStoreProvider

func NewMockStoreProvider() *Provider

NewMockStoreProvider new store provider instance.

func (*Provider) Close

func (p *Provider) Close() error

Close closes all stores created under this store provider.

func (*Provider) GetOpenStores

func (p *Provider) GetOpenStores() []storage.Store

GetOpenStores returns all currently open stores.

func (*Provider) GetStoreConfig

func (p *Provider) GetStoreConfig(name string) (storage.StoreConfiguration, error)

GetStoreConfig gets the current store configuration.

func (*Provider) OpenStore

func (p *Provider) OpenStore(name string) (storage.Store, error)

OpenStore opens and returns a store for given name space.

func (*Provider) SetStoreConfig

func (p *Provider) SetStoreConfig(name string, config storage.StoreConfiguration) error

SetStoreConfig sets the configuration on a store.