statestore

Documentation

Index

• type Option
  • func WithBulkDeleteError(err error) Option
  • func WithBulkGetError(err error) Option
  • func WithBulkSetError(err error) Option
  • func WithDeleteError(err error) Option
  • func WithGetError(err error) Option
  • func WithQueryError(err error) Option
  • func WithSetError(err error) Option
  • func WithSocket(socket *socket.Socket) Option
  • func WithStateStore(store state.Store) Option
• type StateStore
  • func New(t *testing.T, fopts ...Option) *StateStore
  • func (s *StateStore) Cleanup(t *testing.T)
  • func (s *StateStore) Run(t *testing.T, ctx context.Context)
  • func (s *StateStore) SocketName() string

Types

type Option

type Option func(*options)

Option is a function that configures the process.

func WithBulkDeleteError

func WithBulkDeleteError(err error) Option

func WithBulkGetError

func WithBulkGetError(err error) Option

func WithBulkSetError

func WithBulkSetError(err error) Option

func WithDeleteError

func WithDeleteError(err error) Option

func WithGetError

func WithGetError(err error) Option

func WithQueryError

func WithQueryError(err error) Option

func WithSetError

func WithSetError(err error) Option

func WithSocket

func WithSocket(socket *socket.Socket) Option

func WithStateStore

func WithStateStore(store state.Store) Option

type StateStore

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

StateStore is a pluggable state store component for Dapr.

func New

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

func (*StateStore) Cleanup

func (s *StateStore) Cleanup(t *testing.T)

func (*StateStore) Run

func (s *StateStore) Run(t *testing.T, ctx context.Context)

func (*StateStore) SocketName

func (s *StateStore) SocketName() string