Documentation
¶
Index ¶
- Variables
- type Consistent
- func (c *Consistent) Add(elt string)
- func (c *Consistent) Get(name string) (string, error)
- func (c *Consistent) GetN(name string, n int) ([]string, error)
- func (c *Consistent) GetTwo(name string) (string, string, error)
- func (c *Consistent) Members() []string
- func (c *Consistent) Remove(elt string)
- func (c *Consistent) Set(elts []string)
- type ConsistentHashNodeRing
Constants ¶
This section is empty.
Variables ¶
var ErrEmptyCircle = errors.New("empty circle")
ErrEmptyCircle is the error returned when trying to get an element when nothing has been added to hash.
Functions ¶
This section is empty.
Types ¶
type Consistent ¶
type Consistent struct {
NumberOfReplicas int
sync.RWMutex
// contains filtered or unexported fields
}
Consistent holds the information about the members of the consistent hash circle.
func NewConsistent ¶
func NewConsistent() *Consistent
New creates a new Consistent object with a default setting of 20 replicas for each entry.
To change the number of replicas, set NumberOfReplicas before adding entries.
func (*Consistent) Add ¶
func (c *Consistent) Add(elt string)
Add inserts a string element in the consistent hash.
func (*Consistent) Get ¶
func (c *Consistent) Get(name string) (string, error)
Get returns an element close to where name hashes to in the circle.
func (*Consistent) GetN ¶
func (c *Consistent) GetN(name string, n int) ([]string, error)
GetN returns the N closest distinct elements to the name input in the circle.
func (*Consistent) GetTwo ¶
func (c *Consistent) GetTwo(name string) (string, string, error)
GetTwo returns the two closest distinct elements to the name input in the circle.
func (*Consistent) Members ¶
func (c *Consistent) Members() []string
func (*Consistent) Remove ¶
func (c *Consistent) Remove(elt string)
Remove removes an element from the hash.
func (*Consistent) Set ¶
func (c *Consistent) Set(elts []string)
Set sets all the elements in the hash. If there are existing elements not
type ConsistentHashNodeRing ¶
type ConsistentHashNodeRing struct {
// contains filtered or unexported fields
}
一致性哈希环,用于管理服务器节点.
func NewConsistentHashNodesRing ¶
func NewConsistentHashNodesRing(numberOfReplicas int32, nodes []string) *ConsistentHashNodeRing
func (*ConsistentHashNodeRing) GetNode ¶
func (u *ConsistentHashNodeRing) GetNode(pk string) (string, error)
根据pk,获取node节点. hash(pk) -> node
func (*ConsistentHashNodeRing) SetNodes ¶
func (u *ConsistentHashNodeRing) SetNodes(nodes []string)
func (*ConsistentHashNodeRing) SetNumberOfReplicas ¶
func (u *ConsistentHashNodeRing) SetNumberOfReplicas(num int32)
Source Files