chash1

Documentation

Index

• Constants
• func GetRandom() string
• type Consistent
  • func NewConsistent() *Consistent
  • func (c *Consistent) Add(node *Node) bool
  • func (c *Consistent) Get(key string) Node
  • func (c *Consistent) Remove(node *Node)
• type HashRing
  • func (c HashRing) Len() int
  • func (c HashRing) Less(i, j int) bool
  • func (c HashRing) Swap(i, j int)
• type Node
  • func NewNode(id int, rstr string, weight int) *Node

Constants

const DEFAULT_REPLICAS = 10000

Functions

func GetRandom

func GetRandom() string

产生一个随机字符串

Types

type Consistent

type Consistent struct {
	Nodes map[uint32]Node

	Resources map[int]bool

	sync.RWMutex
	// contains filtered or unexported fields
}

func NewConsistent

func NewConsistent() *Consistent

func (*Consistent) Add

func (c *Consistent) Add(node *Node) bool

func (*Consistent) Get

func (c *Consistent) Get(key string) Node

数据分配，根据key计算出的hash值确定 这个key由哪个节点承载

func (*Consistent) Remove

func (c *Consistent) Remove(node *Node)

type HashRing

type HashRing []uint32

func (HashRing) Len

func (c HashRing) Len() int

func (HashRing) Less

func (c HashRing) Less(i, j int) bool

func (HashRing) Swap

func (c HashRing) Swap(i, j int)

type Node

type Node struct {
	Id        int
	Randomstr string
	// Ip       string
	// Port     int
	// HostName string
	Weight int
}

func NewNode

func NewNode(id int, rstr string, weight int) *Node

NewNode 节点信息，IP地址 还有一个权重值