hashring

Documentation

Index

• type HashRing
  • func New() *HashRing
  • func (r *HashRing) AddNode(id string, node *Node)
  • func (r *HashRing) IsOnline(ID string) bool
  • func (r *HashRing) Node(ID string) *Node
  • func (r *HashRing) NodeCount() uint32
  • func (r *HashRing) NodeOkCount() uint32
  • func (r *HashRing) RandomNode(seed string) (string, *Node)
  • func (r *HashRing) RandomNodeExcludedIDs(excludedIDs []string, seed string) (string, *Node)
  • func (r *HashRing) RandomNodes(num int, seed string) []*Node
  • func (r *HashRing) RemoveNode(ID string)
  • func (r *HashRing) SetOffline(ID string)
  • func (r *HashRing) SetOnline(ID string)
  • func (r *HashRing) String() string
  • func (r *HashRing) UpdateNodeDiskUsage(ID string, diskSize, freeDisk uint64)
• type Node
  • func (n *Node) GetID() string
  • func (n *Node) IsOnline() bool
  • func (n *Node) SetDiskUsage(diskSize, freeDisk uint64)
  • func (n *Node) SetID(ID string)
  • func (n *Node) String() string

Types

type HashRing

type HashRing struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func New

func New() *HashRing

func (*HashRing) AddNode

func (r *HashRing) AddNode(id string, node *Node)

func (*HashRing) IsOnline

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

func (*HashRing) Node

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

func (*HashRing) NodeCount

func (r *HashRing) NodeCount() uint32

func (*HashRing) NodeOkCount

func (r *HashRing) NodeOkCount() uint32

func (*HashRing) RandomNode

func (r *HashRing) RandomNode(seed string) (string, *Node)

RandomNode uses the given seed to select a random online node If the seed is empty, it will use a cryptographically secure random seed

func (*HashRing) RandomNodeExcludedIDs

func (r *HashRing) RandomNodeExcludedIDs(excludedIDs []string, seed string) (string, *Node)

RandomNodeExcludedIDs uses the given seed to select a random online node, while excluding specified nodes If the seed is empty, it will use a cryptographically secure random seed

func (*HashRing) RandomNodes

func (r *HashRing) RandomNodes(num int, seed string) []*Node

RandomNodes return random nodes from the hashring If the seed is empty, it will use a cryptographically secure random seed

func (*HashRing) RemoveNode

func (r *HashRing) RemoveNode(ID string)

func (*HashRing) SetOffline

func (r *HashRing) SetOffline(ID string)

func (*HashRing) SetOnline

func (r *HashRing) SetOnline(ID string)

func (*HashRing) String

func (r *HashRing) String() string

func (*HashRing) UpdateNodeDiskUsage

func (r *HashRing) UpdateNodeDiskUsage(ID string, diskSize, freeDisk uint64)

type Node

type Node struct {
	Host      string
	Rest      string
	Data      *sync.Map
	DiskUsage float64
	Weight    float64
	// contains filtered or unexported fields
}

func (*Node) GetID

func (n *Node) GetID() string

func (*Node) IsOnline

func (n *Node) IsOnline() bool

func (*Node) SetDiskUsage

func (n *Node) SetDiskUsage(diskSize, freeDisk uint64)

func (*Node) SetID

func (n *Node) SetID(ID string)

SetID will only set the ID if it's missing

func (*Node) String

func (n *Node) String() string