store

type Builder func(name string, keyEncoder encoding.Builder, valEncoder encoding.Builder, options ...Options) (Store, error)

type Err struct {
	Err string `json:"error"`
}

type Iterator interface {
	SeekToFirst()
	SeekToLast()
	Seek(key interface{}) error
	Next()
	Prev()
	Close()
	Key() (interface{}, error)
	Value() (interface{}, error)
	Valid() bool
	Error() error
}

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

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

type Options func(config *storeOptions)

type RecoverableStore interface {
	Store
	Recover(ctx context.Context) error
}

type Registry interface {
	Register(store Store)
	New(name string, keyEncoder encoding.Builder, valEncoder encoding.Builder, options ...Options) Store
	Store(name string) Store
	List() []string
}

type RegistryConfig struct {
	Host string

	StoreBuilder      Builder
	StateStoreBuilder StateStoreBuilder
	Logger            log.Logger
	MetricsReporter   metrics.Reporter
	// contains filtered or unexported fields
}

type StateStore interface {
	Name() string
	Set(key interface{}, value interface{}) error
	Get(key interface{}) (value interface{}, err error)
	GetAll() ([]*data.Record, error)
}

type StateStoreBuilder func(name string, keyEncoder encoding.Builder, valEncoder encoding.Builder, options ...Options) StateStore

type Store interface {
	Name() string
	Backend() backend.Backend
	KeyEncoder() encoding.Encoder
	ValEncoder() encoding.Encoder
	Set(ctx context.Context, key interface{}, value interface{}, expiry time.Duration) error
	Get(ctx context.Context, key interface{}) (value interface{}, err error)
	GetRange(ctx context.Context, fromKey interface{}, toKey interface{}) (map[interface{}]interface{}, error)
	GetAll(ctx context.Context) (Iterator, error)
	Delete(ctx context.Context, key interface{}) error
	String() string
}