memory

Nov 29, 2022

Changes in this version

+ func NewMemoryStores(opts ...Option) store.StoreProvider

+ type Option func(stores *memoryStores)

+ func WithDiscoverer(f func(ctx context.Context) ([]partition.ID, error)) Option

+ func WithStoreSize(size int64) Option

Oct 27, 2022

Changes in this version

+ func DiscoverPartitions(ctx context.Context, options *store.StoreOptions) ([]partition.ID, error)

+ func SetDiscoverer(d func(*store.StoreOptions) ([]partition.ID, error))

Sep 20, 2022

Changes in this version

+ func NewMemoryStore(ctx context.Context, partitionID string, options *store.StoreOptions) (store.Store, error)