cluster

Documentation

Index

• type ConsistentRing
  • func (r *ConsistentRing) BuildRing(shards []Shard) *HashRing
• type HashFunc
• type HashRing
  • func (r *HashRing) Get(key []byte) (*Shard, func() *Shard)
• type NodeReader
• type RingBuilder
• type Shard

Types

type ConsistentRing

type ConsistentRing struct {
	Hashfunc HashFunc
	Nreplica int
}

Consistent HashRing implementation

func (*ConsistentRing) BuildRing

func (r *ConsistentRing) BuildRing(shards []Shard) *HashRing

Build a consistent HashRing with given shard information

type HashFunc

type HashFunc func([]byte) uint32

type HashRing

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

HashRing object for a clustered connector

func (*HashRing) Get

func (r *HashRing) Get(key []byte) (*Shard, func() *Shard)

Return a shard for a given key with the iterator closure function which could be used by failover logic.

type NodeReader

type NodeReader interface {
	ReadNodes() []Shard
}

type RingBuilder

type RingBuilder interface {
	BuildRing([]Shard) *HashRing
}

type Shard

type Shard struct {
	Name string
	Addr string
}