picker

Documentation

Overview

Package picker gets list of healthy nodes and pick one of them randomly based on weight

Index

• type Node
• type RandomWeighted
  • func NewRandomWeighted(nodes config.NodesMap, refresh, timeout time.Duration, failBackURL string) *RandomWeighted
  • func (w *RandomWeighted) Nodes() map[string][]Node
  • func (w *RandomWeighted) Pick(svc, resource string) (resURL string, node Node, err error)
  • func (w *RandomWeighted) Status() (ok bool, failed []string)

Types

type Node

type Node struct {
	config.Node
	// contains filtered or unexported fields
}

Node has a part from config and alive + changed for status monitoring

type RandomWeighted

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

RandomWeighted implements picker with the random, weighted selection

func NewRandomWeighted

func NewRandomWeighted(nodes config.NodesMap, refresh, timeout time.Duration, failBackURL string) *RandomWeighted

NewRandomWeighted makes new picker. Activate alive update thread

func (*RandomWeighted) Nodes

func (w *RandomWeighted) Nodes() map[string][]Node

Nodes return list of all current nodes

func (*RandomWeighted) Pick

func (w *RandomWeighted) Pick(svc, resource string) (resURL string, node Node, err error)

Pick random node with weights

func (*RandomWeighted) Status

func (w *RandomWeighted) Status() (ok bool, failed []string)

Status return status of all nodes, true if all nodes are alive, false if at least one is dead and return list of dead nodes