sharded

Documentation

Index

• Variables
• func NewShardIDProvider(numOfShards int32) (*shardIDProvider, error)
• func NewShardedPersister(path string, persisterCreator types.PersisterCreator, ...) (*shardedPersister, error)

Variables

var ErrInvalidNumberOfShards = errors.New("the number of shards must be greater than zero")

ErrInvalidNumberOfShards signals that an invalid number of shards was passed to the sharding registry

var ErrInvalidPath = errors.New("invalid path")

ErrInvalidPath signals that an invalid path has been provided

var ErrNilIDProvider = errors.New("nil id provider")

ErrNilIDProvider signals that a nil id provider was provided

var ErrNilPersisterCreator = errors.New("nil persister creator")

ErrNilPersisterCreator signals that a nil persister creator was provided

Functions

func NewShardIDProvider

func NewShardIDProvider(numOfShards int32) (*shardIDProvider, error)

NewShardIDProvider will create a new shard ID provider component

func NewShardedPersister

func NewShardedPersister(path string, persisterCreator types.PersisterCreator, idProvider types.ShardIDProvider) (*shardedPersister, error)

NewShardedPersister will created a new sharded persister