memory

Documentation

Index

• func DiscoverPartitions(ctx context.Context, options *store.StoreOptions) ([]partition.ID, error)
• func NewMemoryStore(ctx context.Context, partitionID partition.ID, options *store.StoreOptions) (store.Store, error)
• func SetDiscoverer(d func(*store.StoreOptions) ([]partition.ID, error))

Functions

func DiscoverPartitions

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

DiscoverPartitions discovers the in-memory partitions. This is very useful during testing.

func NewMemoryStore

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

NewMemoryStore returns new memory store

func SetDiscoverer

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

SetDiscoverer sets the function that returns the initial list of partitions Only for testing purposes