inmemory

Documentation

Index

• func New(t *testing.T, fopts ...Option) state.Store
• func NewQuerier(t *testing.T, fopts ...Option) state.Store
• func NewTransactionalMultiMaxSize(t *testing.T, fopts ...Option) state.Store
• type Option
  • func WithFeatures(features ...state.Feature) Option
  • func WithQueryFn(fn func(context.Context, *state.QueryRequest) (*state.QueryResponse, error)) Option
  • func WithTransactionalStoreMultiMaxSizeFn(fn func() int) Option
• type Wrapped
  • func (w *Wrapped) Close() error
  • func (w *Wrapped) Features() []state.Feature
  • func (w *Wrapped) Init(ctx context.Context, metadata state.Metadata) error
• type WrappedQuerier
  • func (w *WrappedQuerier) Query(ctx context.Context, req *state.QueryRequest) (*state.QueryResponse, error)
• type WrappedTransactionalMultiMaxSize
  • func (w *WrappedTransactionalMultiMaxSize) MultiMaxSize() int

Functions

func New

func New(t *testing.T, fopts ...Option) state.Store

func NewQuerier

func NewQuerier(t *testing.T, fopts ...Option) state.Store

func NewTransactionalMultiMaxSize

func NewTransactionalMultiMaxSize(t *testing.T, fopts ...Option) state.Store

Types

type Option

type Option func(*options)

Option is a function that configures the process.

func WithFeatures

func WithFeatures(features ...state.Feature) Option

func WithQueryFn

func WithQueryFn(fn func(context.Context, *state.QueryRequest) (*state.QueryResponse, error)) Option

func WithTransactionalStoreMultiMaxSizeFn

func WithTransactionalStoreMultiMaxSizeFn(fn func() int) Option

type Wrapped

type Wrapped struct {
	state.Store
	// contains filtered or unexported fields
}

Wrapped is a wrapper around inmemory state store to ensure that Init and Close are called only once.

func (*Wrapped) Close

func (w *Wrapped) Close() error

func (*Wrapped) Features

func (w *Wrapped) Features() []state.Feature

func (*Wrapped) Init

func (w *Wrapped) Init(ctx context.Context, metadata state.Metadata) error

type WrappedQuerier

type WrappedQuerier struct {
	*Wrapped
	// contains filtered or unexported fields
}

func (*WrappedQuerier) Query

func (w *WrappedQuerier) Query(ctx context.Context, req *state.QueryRequest) (*state.QueryResponse, error)

type WrappedTransactionalMultiMaxSize

type WrappedTransactionalMultiMaxSize struct {
	*Wrapped
	state.TransactionalStore
	// contains filtered or unexported fields
}

func (*WrappedTransactionalMultiMaxSize) MultiMaxSize

func (w *WrappedTransactionalMultiMaxSize) MultiMaxSize() int