cslb

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

type HashFunc func(interface{}) (uint64, error)

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

type LoadBalancerOption struct {
	// LoadBalancer will keep MaxNodeCount nodes in Next() result set
	// Please notice that refresh or exile will change the result set
	// Number of connections might be greater than this value, if any pre-connected node has been excluded in newer
	// result set, but no new connection will be established to these nodes
	MaxNodeCount int

	// Cache TTL
	TTL time.Duration

	// Refresh when healthy node ratio is below MinHealthyNodeRatio
	MinHealthyNodeRatio float64

	// Node will be exiled if (failed / total) > MaxNodeFailedRatio
	MaxNodeFailedRatio float64

	// At least MinSampleSize times a node has been returned through Next(), this node can be count for exile.
	MinSampleSize int
}

type Metrics struct {
	MinSampleSize int
	// contains filtered or unexported fields
}

type Node interface {
	fmt.Stringer
}

type Service interface {
	// Nodes returns a new slice of available node
	Nodes() []Node
	// Refresh updates nodes
	Refresh()
	// NodeFailedCallbackFunc returns a callback function which will be triggered in another go routine when certain
	// node exiled by LoadBalancer
	NodeFailedCallbackFunc() func(node Node)
}

type Strategy interface {
	// SetNodes update saved nodes
	SetNodes(nodes []Node)
	// Next returns a node address
	Next() (Node, error)
	// NextFor returns a node address assigned to request
	NextFor(interface{}) (Node, error)
}