shard

Documentation

Index

• func IDs(shards []shard.Shard) []uint32
• func NewShards(ids []uint32, state shard.State) []shard.Shard
• func ShardsRange(from, to uint32, s shard.State) []shard.Shard
• type ShardSet
  • func NewShardSet(shards []shard.Shard) ShardSet

Functions

func IDs

func IDs(shards []shard.Shard) []uint32

IDs returns a new slice of shard IDs for a set of shards

func NewShards

func NewShards(ids []uint32, state shard.State) []shard.Shard

NewShards returns a new slice of shards with a specified state

func ShardsRange

func ShardsRange(from, to uint32, s shard.State) []shard.Shard

ShardsRange returns a slice of shards for all ids between [from, to], with shard state `s`.

Types

type ShardSet

type ShardSet interface {
	// All returns a slice to the shards in this set
	All() []shard.Shard

	// AllIDs returns a slice to the shard IDs in this set
	AllIDs() []uint32
}

ShardSet contains a sharding function and a set of shards, this interface allows for potentially out of order shard sets

func NewShardSet

func NewShardSet(shards []shard.Shard) ShardSet

NewShardSet creates a new sharding scheme with a set of shards