store

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

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

type Index interface {
	String() string
	Write(key, value interface{}) error
	WriteHash(hash, key interface{}) error
	Hash(key, val interface{}) (hash interface{})
	Delete(key, value interface{}) error
	Read(index interface{}) ([]interface{}, error)
	Keys() []interface{}
	Values() map[interface{}][]interface{}
	ValueIndexed(index, value interface{}) (bool, error)
}

type IndexedStore interface {
	Store
	GetIndex(ctx context.Context, name string) (Index, error)
	Indexes() []Index
	GetIndexedRecords(ctx context.Context, index string, key interface{}) ([]interface{}, error)
}

type IndexedStoreBuilder func(name string, keyEncoder, valEncoder encoding.Builder, indexes []Index, options ...Options) (IndexedStore, error)

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

type KeyMapper func(key, val interface{}) (idx string)

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

type MockRecord 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, valEncoder encoding.Builder, options ...Options) Store
	NewIndexedStore(name string, keyEncoder, valEncoder encoding.Builder, indexes []Index, options ...Options) IndexedStore
	Store(name string) (Store, error)
	Index(name string) (Index, error)
	Stores() []Store
	Indexes() []Index
}

type RegistryConfig struct {
	Host        string
	HttpEnabled bool

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

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

type StateStoreBuilder func(name string, keyEncoder, 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, value interface{}, expiry time.Duration) error
	Get(ctx context.Context, key interface{}) (value interface{}, err error)
	GetRange(ctx context.Context, fromKey, toKey interface{}) (map[interface{}]interface{}, error)
	GetAll(ctx context.Context) (Iterator, error)
	Delete(ctx context.Context, key interface{}) error
	String() string
}