hashring

package
v0.7.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 19, 2022 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type HashRing 

type HashRing struct {
	VRing           *rbtree.Rbtree
	NRing           *rbtree.Rbtree
	Nodes           *sync.Map // map(NodeID => *Node)
	NodeStatus      *sync.Map // map(NodeID => status)
	NodeCount       uint32
	NodeOkCount     uint32
	NumberOfVirtual uint32
	sync.Mutex
}

HashRing

func New 

func New(numOfVNode uint32) *HashRing

NewHashRing

func (*HashRing) AddNode 

func (r *HashRing) AddNode(node *Node)

AddNode

func (*HashRing) CalcIndex 

func (r *HashRing) CalcIndex(key string) uint32

CalcIndex

func (*HashRing) GetNode 

func (r *HashRing) GetNode(key string) (uint32, string)

GetNode @params key

func (*HashRing) GetNodeByIndex 

func (r *HashRing) GetNodeByIndex(keyIndex uint32) (uint32, string)

GetNodeByIndex @params keyIndex

func (*HashRing) GetNodeExcludedNodeIDs 

func (r *HashRing) GetNodeExcludedNodeIDs(key string, NodeIDs []string) (uint32, string)

GetNodeMissNodeID get node excluded given NodeIDs @params key

func (*HashRing) GetNodeUpDownNodes 

func (r *HashRing) GetNodeUpDownNodes(NodeID string) (string, string)

GetNodeUpDownNodes get upstream of downstream of node @params

func (*HashRing) IsOnline 

func (r *HashRing) IsOnline(ID string) bool

func (*HashRing) Node 

func (r *HashRing) Node(ID string) *Node

func (*HashRing) PrintNodes 

func (r *HashRing) PrintNodes()

PrintNodes print all non-virtual nodes

func (*HashRing) RandomGetNodes 

func (r *HashRing) RandomGetNodes(num int) []*Node

func (*HashRing) RemoveNode 

func (r *HashRing) RemoveNode(nodeID string) bool

RemoveNode

func (*HashRing) SetOffline 

func (r *HashRing) SetOffline(ID string)

func (*HashRing) SetOnline 

func (r *HashRing) SetOnline(ID string)

func (*HashRing) TraversalNRing 

func (r *HashRing) TraversalNRing()

TraversalNRing traverse non-virtual rbtree

func (*HashRing) TraversalVRing 

func (r *HashRing) TraversalVRing()

TraversalVRing traverse virtual rbtree

type Node 

type Node struct {
	ID   string
	Host string
	Rest string
	Data *sync.Map
}

Node

func (*Node) Less 

func (n *Node) Less(than rbtree.Item) bool

Less of rbtree

type VNode 

type VNode struct {
	Index  uint32 // index, crc32 of hashkey
	NodeID string
}

VNode virtual node

func (*VNode) Less 

func (vn *VNode) Less(than rbtree.Item) bool

Less of rbtree

type VWeightedNode added in v0.5.0 

type VWeightedNode struct {
	Index  uint32 // index, crc32 of hashkey
	NodeID string
}

VWeightedNode virtual node

func (*VWeightedNode) Less added in v0.5.0 

func (vwn *VWeightedNode) Less(than rbtree.Item) bool

Less of rbtree

type WeightedHashRing added in v0.5.0 

type WeightedHashRing struct {
	VRing           *rbtree.Rbtree
	NRing           *rbtree.Rbtree
	Nodes           *sync.Map // map(NodeID => *WeightedNode)
	NodeStatus      *sync.Map // map(NodeID => status)
	NodeCount       uint32
	NodeOkCount     uint32
	NumberOfVirtual uint32
	sync.Mutex
}

HashRing

func NewWeightedHashRing added in v0.5.0 

func NewWeightedHashRing() *WeightedHashRing

NewHashRing

func (*WeightedHashRing) AddNode added in v0.5.0 

func (r *WeightedHashRing) AddNode(node *WeightedNode)

AddNode

func (*WeightedHashRing) CalcIndex added in v0.5.0 

func (r *WeightedHashRing) CalcIndex(key string) uint32

CalcIndex

func (*WeightedHashRing) GetNode added in v0.5.0 

func (r *WeightedHashRing) GetNode(key string) (uint32, string)

GetNode @params key

func (*WeightedHashRing) GetNodeByIndex added in v0.5.0 

func (r *WeightedHashRing) GetNodeByIndex(keyIndex uint32) (uint32, string)

GetNodeByIndex @params keyIndex

func (*WeightedHashRing) GetNodeExcludedNodeIDs added in v0.5.0 

func (r *WeightedHashRing) GetNodeExcludedNodeIDs(key string, NodeIDs []string) (uint32, string)

GetNodeMissNodeID get node excluded given NodeIDs @params key

func (*WeightedHashRing) GetNodeUpDownNodes added in v0.5.0 

func (r *WeightedHashRing) GetNodeUpDownNodes(NodeID string) (string, string)

GetNodeUpDownNodes get upstream of downstream of node @params

func (*WeightedHashRing) IsOnline added in v0.5.0 

func (r *WeightedHashRing) IsOnline(ID string) bool

func (*WeightedHashRing) Node added in v0.5.0 

func (r *WeightedHashRing) Node(ID string) *WeightedNode

func (*WeightedHashRing) PrintNodes added in v0.5.0 

func (r *WeightedHashRing) PrintNodes()

PrintNodes print all non-virtual nodes

func (*WeightedHashRing) RandomGetNodes added in v0.5.0 

func (r *WeightedHashRing) RandomGetNodes(num int) []*WeightedNode

func (*WeightedHashRing) RemoveNode added in v0.5.0 

func (r *WeightedHashRing) RemoveNode(nodeID string) bool

RemoveNode

func (*WeightedHashRing) SetOffline added in v0.5.0 

func (r *WeightedHashRing) SetOffline(ID string)

func (*WeightedHashRing) SetOnline added in v0.5.0 

func (r *WeightedHashRing) SetOnline(ID string)

func (*WeightedHashRing) TraversalNRing added in v0.5.0 

func (r *WeightedHashRing) TraversalNRing()

TraversalNRing traverse non-virtual rbtree

func (*WeightedHashRing) TraversalVRing added in v0.5.0 

func (r *WeightedHashRing) TraversalVRing()

TraversalVRing traverse virtual rbtree

type WeightedNode added in v0.5.0 

type WeightedNode struct {
	ID   string
	Host string
	Rest string
	Tier uint32
	Data *sync.Map
}

Node

func (*WeightedNode) Less added in v0.5.0 

func (n *WeightedNode) Less(than rbtree.Item) bool

Less of rbtree

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.