store

type Store interface {
	// Read returns upto N(size) messages from the persisted store, it also returns
	// a boolean flag to indicate if the end of file has been reached.
	Read(size int64) ([]*isb.ReadMessage, bool, error)
	// Write writes message to persistence store
	Write(msg *isb.ReadMessage) error
	// Close closes store
	Close() error
	// GC does garbage collection and deletes all the messages that are persisted
	GC() error
}

type StoreProvider interface {
	// CreateStore returns a new store instance.
	CreateStore(context.Context, partition.ID) (Store, error)
	// DiscoverPartitions discovers all the managed partitions.
	DiscoverPartitions(context.Context) ([]partition.ID, error)
}