ewma

Documentation

Overview

Package ewma (Exponentially-Weighted Moving Average) maintain a moving average of each replica’s round-trip time, weighted by the number of outstanding requests, and distribute traffic to replicas where that cost function is smallest.

Index

• type Builder
  • func (b *Builder) Build(n registry.Node) registry.WeightedNode
• type Node
  • func (n *Node) Pick() registry.DoneFunc
  • func (n *Node) PickElapsed() time.Duration
  • func (n *Node) Raw() registry.Node
  • func (n *Node) Weight() (weight float64)

Types

type Builder

type Builder struct {
	ErrHandler func(err error) (isErr bool)
}

Builder is ewma node builder.

func (*Builder) Build

func (b *Builder) Build(n registry.Node) registry.WeightedNode

Build create a weighted node.

type Node

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

Node is endpoint instance

func (*Node) Pick

func (n *Node) Pick() registry.DoneFunc

Pick pick a node.

func (*Node) PickElapsed

func (n *Node) PickElapsed() time.Duration

func (*Node) Raw

func (n *Node) Raw() registry.Node

func (*Node) Weight

func (n *Node) Weight() (weight float64)

Weight is node effective weight.