sharding

Documentation

Index

• type ShardManager
  • func NewShardManager(shardID, totalShards int) *ShardManager
  • func (s *ShardManager) IsResponsibleFor(key string) bool

Types

type ShardManager

type ShardManager struct {
	ShardID     int
	TotalShards int
}

ShardManager determines if the current manager instance is responsible for a given resource

func NewShardManager

func NewShardManager(shardID, totalShards int) *ShardManager

NewShardManager creates a new ShardManager

func (*ShardManager) IsResponsibleFor

func (s *ShardManager) IsResponsibleFor(key string) bool

IsResponsibleFor returns true if the current shard is responsible for the given key