storemonotree

Documentation

Index

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

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 New

type New func(
	upstream store.Store,
) (
	tree *Tree,
	err error,
)

type Tree

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

func (*Tree) Delete

func (t *Tree) Delete(
	keys []store.Key,
) (
	err error,
)

func (*Tree) Exists

func (t *Tree) Exists(
	key store.Key,
) (
	exists bool,
	err error,
)

func (*Tree) ID

func (t *Tree) ID() (store.ID, error)

func (*Tree) IterAllKeys

func (t *Tree) IterAllKeys(
	fn func(store.Key) error,
) (
	err error,
)

func (*Tree) IterKeys

func (t *Tree) IterKeys(
	ns key.Namespace,
	fn func(store.Key) error,
) (
	err error,
)

func (*Tree) Name

func (t *Tree) Name() string

func (*Tree) Read

func (t *Tree) Read(
	key store.Key,
	fn func(sb.Stream) error,
) (
	err error,
)

func (*Tree) Write

func (t *Tree) Write(
	ns key.Namespace,
	stream sb.Stream,
	options ...store.WriteOption,
) (
	res store.WriteResult,
	err error,
)