loadbalancer

Documentation

Index

• func NewRandomLoadBalancer(endpoints []*envoy_config_endpoint_v3.Endpoint) *randomLoadBalancer
• func NewWeightedLeastLoadBalancer(endpoints []*envoy_config_endpoint_v3.Endpoint, ...) *weightedLeastRequestLoadBalancer
• func NewWeightedRoundRobinLoadBalancer(endpoints []*envoy_config_endpoint_v3.Endpoint, ...) *weightedRoundRobinLoadBalancer
• type LoadBalancer

Functions

func NewRandomLoadBalancer

func NewRandomLoadBalancer(endpoints []*envoy_config_endpoint_v3.Endpoint) *randomLoadBalancer

func NewWeightedLeastLoadBalancer

func NewWeightedLeastLoadBalancer(
	endpoints []*envoy_config_endpoint_v3.Endpoint,
	endpointsLoad map[string]float64,
	endpointsStats *endpoint.EndpointsStats,
	choiceCount uint32,
	endpointWeightsAreEqual bool) *weightedLeastRequestLoadBalancer

func NewWeightedRoundRobinLoadBalancer

func NewWeightedRoundRobinLoadBalancer(
	endpoints []*envoy_config_endpoint_v3.Endpoint,
	endpointsLoad map[string]float64,
	endpointsStats *endpoint.EndpointsStats) *weightedRoundRobinLoadBalancer

Types

type LoadBalancer

type LoadBalancer interface {
	// NextEndpoint returns the next endpoint address according to the load balancing algorithm implemented
	// by the load balancer
	NextEndpoint() net.Addr
}