dht

Documentation

Index

• func HashKey(key string) int
• type HashRing
  • func NewHashRing() *HashRing
  • func (h *HashRing) AddNode(nodes ...*Node)
  • func (h *HashRing) GetNodeForKey(key string) (*Node, error)
  • func (h *HashRing) GetNodes() map[int]*Node
  • func (h *HashRing) NodeExists(key string) bool
  • func (h *HashRing) RemoveNode(nodes ...*Node)
• type Node
  • func NewNode(addr net.Addr) *Node

Functions

func HashKey

func HashKey(key string) int

Types

type HashRing

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

func NewHashRing

func NewHashRing() *HashRing

NewHashRing creates empty HashRing

func (*HashRing) AddNode

func (h *HashRing) AddNode(nodes ...*Node)

AddNode adds node to Hash Ring

func (*HashRing) GetNodeForKey

func (h *HashRing) GetNodeForKey(key string) (*Node, error)

GetNodeForKey returns Node corresponding to given key. Error can occur if Node is not found

func (*HashRing) GetNodes

func (h *HashRing) GetNodes() map[int]*Node

func (*HashRing) NodeExists

func (h *HashRing) NodeExists(key string) bool

NodeExists returns true if node exists in hash ring, false otherwise

func (*HashRing) RemoveNode

func (h *HashRing) RemoveNode(nodes ...*Node)

type Node

type Node struct {
	Addr  net.Addr
	Alive bool
}

func NewNode

func NewNode(addr net.Addr) *Node