stores

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

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

type Closable interface {
	Close() error
}

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

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

type Index interface {
	sync.Locker
	String() string
	Write(key, value interface{}) error
	KeyPrefixer(key, value interface{}) (hash string)
	Delete(key, value interface{}) error
	Read(index string) (backend.Iterator, error)
	Values(key string) ([]string, error)
	Keys() ([]string, error)
	Compare(key interface{}, valBefore, valAfter interface{}) (bool, error)
	KeyIndexed(index string, key interface{}) (bool, error)
	Backend() backend.Backend
	Close() error
}

type IndexBuilder interface {
	Name() string
	Build(store ReadOnlyStore, backend backend.Builder, keyEncoder encoding.Encoder) (Index, error)
}

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

type IndexedStoreBuilder func(name string, keyEncoder, valEncoder encoding.Encoder, indexes []IndexBuilder, options ...Option) (IndexedStore, error)

type Iterator interface {
	SeekToFirst()
	Next()
	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 Option func(config *StoreOptions)

type ReadOnlyStore interface {
	Name() string
	KeyEncoder() encoding.Encoder
	ValEncoder() encoding.Encoder
	Get(ctx context.Context, key interface{}) (value interface{}, err error)
	Iterator(ctx context.Context) (Iterator, error)
	PrefixedIterator(ctx context.Context, keyPrefix interface{}, prefixEncoder encoding.Encoder) (Iterator, error)
	String() string
	Close() error
}

type RecordVersionExtractor func(ctx context.Context, key, value interface{}) (version int64, err error)

type RecordVersionWriter func(ctx context.Context, version int64, vIn interface{}) (vOut interface{}, err error)

type Registry interface {
	Register(store ReadOnlyStore) error
	RegisterDynamic(name string, lister StateStoresLister) error
	Create(name string, keyEncoder, valEncoder encoding.Encoder, options ...Option) (Store, error)
	CreateOrReturn(name string, keyEncoder encoding.Encoder, valEncoder encoding.Encoder, options ...Option) (Store, error)
	NewIndexedStore(name string, keyEncoder, valEncoder encoding.Encoder, indexes []IndexBuilder, options ...Option) IndexedStore
	NewBuilder(name string, keyEncoder, valEncoder encoding.Encoder, options ...Option) StoreBuilder
	Store(name string) (ReadOnlyStore, error)
	Builder(name string) (StoreBuilder, error)
	Index(name string) (Index, error)
	Stores() []ReadOnlyStore
	StartWebServer()
	Builders() []StoreBuilder
	Indexes() []Index
}

type RegistryConfig struct {
	Host        string
	HttpEnabled bool

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

type StateStoresLister func() []ReadOnlyStore

type Store interface {
	Backend() backend.Backend
	Set(ctx context.Context, key, value interface{}, expiry time.Duration) error
	Delete(ctx context.Context, key interface{}) error
	Flush() error
	Cache() StoreCache
	ReadOnlyStore
}

type StoreBuilder interface {
	Name() string
	Build(name string, options ...Option) (Store, error)
}

type StoreCache interface {
	Get(ctx context.Context, key interface{}) (value interface{}, err error)
	Iterator(ctx context.Context) (Iterator, error)
	PrefixedIterator(ctx context.Context, keyPrefix interface{}, prefixEncoder encoding.Encoder) (Iterator, error)
	Set(ctx context.Context, key, value interface{}, expiry time.Duration) error
	Delete(ctx context.Context, key interface{}) error
	Flush() error
	Close() error
	Reset()
	Backend() backend.Cache
}

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