storenssharded

Documentation

Index

• func TestStore(t *testing.T, testStore store.TestStore, scope dscope.Scope, wg *pr2.WaitGroup)
• type Def
  • func (_ Def) New() New
• type Key
• type New
• type Store
  • func (s *Store) Delete(keys []Key) error
  • func (s *Store) Exists(key Key) (bool, error)
  • func (s *Store) ID() (StoreID, error)
  • func (s *Store) IterAllKeys(fn func(Key) error) (err error)
  • func (s *Store) IterKeys(ns key.Namespace, fn func(Key) error) error
  • func (s *Store) Name() string
  • func (s *Store) Read(key Key, fn func(sb.Stream) error) error
  • func (s *Store) Write(ns key.Namespace, stream sb.Stream, options ...WriteOption) (WriteResult, error)
• type StoreID
• type WriteOption
• type WriteResult

Functions

func TestStore

func TestStore(
	t *testing.T,
	testStore store.TestStore,
	scope dscope.Scope,
	wg *pr2.WaitGroup,
)

Types

type Def

type Def struct{}

func (Def) New

func (_ Def) New() New

type Key

type Key = store.Key

type New

type New func(
	shards map[key.Namespace]store.Store,
	def store.Store,
) (*Store, error)

type Store

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

func (*Store) Delete

func (s *Store) Delete(keys []Key) error

func (*Store) Exists

func (s *Store) Exists(key Key) (bool, error)

func (*Store) ID

func (s *Store) ID() (StoreID, error)

func (*Store) IterAllKeys

func (s *Store) IterAllKeys(fn func(Key) error) (err error)

func (*Store) IterKeys

func (s *Store) IterKeys(ns key.Namespace, fn func(Key) error) error

func (*Store) Name

func (s *Store) Name() string

func (*Store) Read

func (s *Store) Read(key Key, fn func(sb.Stream) error) error

func (*Store) Write

func (s *Store) Write(ns key.Namespace, stream sb.Stream, options ...WriteOption) (WriteResult, error)

type StoreID

type StoreID = store.ID

type WriteOption

type WriteOption = store.WriteOption

type WriteResult

type WriteResult = store.WriteResult