stores

package

Go to main page

Versions in this module

v2

v2.0.1

Aug 9, 2023

Changes in this version

type IdxBuilder

+ func (idb *IdxBuilder) Name() string

type Index

+ Backend func() backend.Backend

type IndexBuilder

+ Name func() string

type IndexedStore

+ RebuildIndexes func() error

v2.0.0

Jun 23, 2023

Changes in this version

+ func DeleteIndexes(ctx context.Context, store IndexedStore, key interface{}) error

+ func MakeEndpoints(host string, registry Registry, logger log.Logger)

+ func UpdateIndexes(ctx context.Context, store IndexedStore, key, val interface{}) error

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

+ type Cache struct

+ func (c *Cache) Backend() backend.Cache

+ func (c *Cache) Close() error

+ func (c *Cache) Delete(ctx context.Context, key interface{}) error

+ func (c *Cache) Flush() error

+ func (c *Cache) Get(ctx context.Context, key interface{}) (value interface{}, err error)

+ func (c *Cache) Iterator(ctx context.Context) (Iterator, error)

+ func (c *Cache) PrefixedIterator(ctx context.Context, keyPrefix interface{}, prefixEncoder encoding.Encoder) (Iterator, error)

+ func (c *Cache) Reset()

+ func (c *Cache) Set(ctx context.Context, key, value interface{}, expiry time.Duration) error

+ type Closable interface

+ Close func() error

+ type Err struct

+ Err string

+ type IdxBuilder struct

+ func NewIndex(name string, mapper KeyMapper) *IdxBuilder

+ func (idb *IdxBuilder) Build(store ReadOnlyStore, backend backend.Builder, keyEncoder encoding.Encoder) (Index, error)

+ type Index interface

+ Close func() error

+ Compare func(key interface{}, valBefore, valAfter interface{}) (bool, error)

+ Delete func(key, value interface{}) error

+ KeyIndexed func(index string, key interface{}) (bool, error)

+ KeyPrefixer func(key, value interface{}) (hash string)

+ Keys func() ([]string, error)

+ Read func(index string) (backend.Iterator, error)

+ String func() string

+ Values func(key string) ([]string, error)

+ Write func(key, value interface{}) error

+ type IndexBuilder interface

+ Build func(store ReadOnlyStore, backend backend.Builder, keyEncoder encoding.Encoder) (Index, error)

+ type IndexedStore interface

+ GetIndex func(ctx context.Context, name string) (Index, error)

+ GetIndexedRecords func(ctx context.Context, indexName, key string) (Iterator, error)

+ Indexes func() []Index

+ func NewIndexedStore(name string, keyEncoder, valEncoder encoding.Encoder, indexes []IndexBuilder, ...) (IndexedStore, error)

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

+ type Iterator interface

+ Close func()

+ Error func() error

+ Key func() (interface{}, error)

+ Next func()

+ SeekToFirst func()

+ Valid func() bool

+ Value func() (interface{}, error)

+ func NewIterator(backendItr backend.Iterator, keyEnc, valEnc encoding.Encoder) Iterator

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

+ type Meta struct

+ func NewMata(c sarama.Client, group string) *Meta

+ func (m *Meta) GetMeta(tp string) string

+ func (m *Meta) Refresh()

+ type Option func(config *StoreOptions)

+ func Buffered(size int) Option

+ func Compacated() Option

+ func WithBackend(backend backend.Backend) Option

+ func WithBackendBuilder(builder backend.Builder) Option

+ func WithCachingEnabled() Option

+ func WithVersionExtractor(etc RecordVersionExtractor) Option

+ func WithVersionWriter(wr RecordVersionWriter) Option

+ type ReadOnlyStore interface

+ Close func() error

+ Get func(ctx context.Context, key interface{}) (value interface{}, err error)

+ Iterator func(ctx context.Context) (Iterator, error)

+ KeyEncoder func() encoding.Encoder

+ Name func() string

+ PrefixedIterator func(ctx context.Context, keyPrefix interface{}, prefixEncoder encoding.Encoder) (Iterator, error)

+ String func() string

+ ValEncoder func() encoding.Encoder

+ 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

+ Builder func(name string) (StoreBuilder, error)

+ Builders func() []StoreBuilder

+ Create func(name string, keyEncoder, valEncoder encoding.Encoder, options ...Option) (Store, error)

+ CreateOrReturn func(name string, keyEncoder encoding.Encoder, valEncoder encoding.Encoder, ...) (Store, error)

+ Index func(name string) (Index, error)

+ Indexes func() []Index

+ NewBuilder func(name string, keyEncoder, valEncoder encoding.Encoder, options ...Option) StoreBuilder

+ NewIndexedStore func(name string, keyEncoder, valEncoder encoding.Encoder, indexes []IndexBuilder, ...) IndexedStore

+ Register func(store ReadOnlyStore) error

+ RegisterDynamic func(name string, lister StateStoresLister) error

+ StartWebServer func()

+ Store func(name string) (ReadOnlyStore, error)

+ Stores func() []ReadOnlyStore

+ func NewRegistry(config *RegistryConfig) Registry

+ type RegistryConfig struct

+ Host string

+ HttpEnabled bool

+ IndexedStoreBuilder IndexedStoreBuilder

+ Logger log.Logger

+ MetricsReporter metrics.Reporter

+ StoreBuilder Builder

+ type StateStoresLister func() []ReadOnlyStore

+ type Store interface

+ Backend func() backend.Backend

+ Cache func() StoreCache

+ Delete func(ctx context.Context, key interface{}) error

+ Flush func() error

+ Set func(ctx context.Context, key, value interface{}, expiry time.Duration) error

+ func NewStore(name string, keyEncoder encoding.Encoder, valEncoder encoding.Encoder, ...) (Store, error)

+ type StoreBuilder interface

+ Build func(name string, options ...Option) (Store, error)

+ Name func() string

+ func NewDefaultStoreBuilder(name string, keyEncoder encoding.Encoder, valEncoder encoding.Encoder, ...) StoreBuilder

+ type StoreCache interface

+ Backend func() backend.Cache

+ Close func() error

+ Delete func(ctx context.Context, key interface{}) error

+ Flush func() error

+ Get func(ctx context.Context, key interface{}) (value interface{}, err error)

+ Iterator func(ctx context.Context) (Iterator, error)

+ PrefixedIterator func(ctx context.Context, keyPrefix interface{}, prefixEncoder encoding.Encoder) (Iterator, error)

+ Reset func()

+ Set func(ctx context.Context, key, value interface{}, expiry time.Duration) error

+ type StoreOptions struct

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL