sharder

Documentation

Index

• Constants
• func Hash(key []byte) (uint32, error)
• type ShardType
• type Sharder
  • func NewSharder(cluster cluster.Cluster) *Sharder
  • func (s *Sharder) CalculateShard(shardType ShardType, key []byte) (uint64, error)
  • func (s *Sharder) CalculateShardWithShardIDs(shardType ShardType, key []byte, shardIDs []uint64) (uint64, error)
  • func (s *Sharder) Start() error
  • func (s *Sharder) Stop() error

Constants

const (
	ShardTypeHash = iota + 1
	ShardTypeRange
)

Functions

func Hash

func Hash(key []byte) (uint32, error)

Types

type ShardType

type ShardType int

type Sharder

type Sharder struct {
	// contains filtered or unexported fields
}

func NewSharder

func NewSharder(cluster cluster.Cluster) *Sharder

func (*Sharder) CalculateShard

func (s *Sharder) CalculateShard(shardType ShardType, key []byte) (uint64, error)

func (*Sharder) CalculateShardWithShardIDs

func (s *Sharder) CalculateShardWithShardIDs(shardType ShardType, key []byte, shardIDs []uint64) (uint64, error)

func (*Sharder) Start

func (s *Sharder) Start() error

func (*Sharder) Stop

func (s *Sharder) Stop() error