balance

type Algorithm interface {
	EndpointSet
	// Get returns the Service Endpoint to use for the next request.
	//
	// Get is called when wanting to send a request to a Service. It returns the
	// Endpoint that request should be directed to. When used with an affinity load
	// balancing scheme, the affinity key needs to be given as argument to this
	// function.
	//
	// When used with an affinity load balancing scheme, Get will panic if no key
	// or more than one key is given. The variadic form is only used for
	// aesthetics, ie. being able to use Get() which non-affinity load balancers.
	//
	// Get may return nil when the load balancer is not aware of any
	// Endpoint.
	Get(key ...string) Endpoint
	// Put releases the Endpoint when it has finished processing the request.
	Put(endpoint Endpoint)
}

type Consistent struct {
	sync.Mutex
	// contains filtered or unexported fields
}

type ConsistentConfig struct {
	// Name used for metrics and reporting
	Name string

	// Hash is the hashing function used for hash Endpoints and keys onto the hash
	// ring. You may want to use an interesting hash function like xxHash.
	// Defaults to CRC32.
	Hash Hash

	// ReplicationCount controls the number of virtual nodes to add to the hash
	// ring for each Endpoint.
	// Defaults to 128.
	ReplicationCount int

	// LoadFactor controls the maximum load of any endpoint. The load is defined as
	// the number of requests currently being handled by an endpoint. When set to a
	// value > 1.0, Consistent implements the bounded loads variant of consistent
	// hashing and ensures no endpoint has a load > LoadFactor * averageLoad.
	//
	// See https://arxiv.org/abs/1608.01350 for details about consistent hashing
	// with bounded loads.
	LoadFactor float64
}

type Endpoint interface {
	Key() string
}

type EndpointSet interface {
	AddEndpoints(...Endpoint)
	RemoveEndpoints(...Endpoint)
}

type EndpointWatcher struct {
	Client   client.Interface
	Service  Service
	Receiver EndpointSet
	// contains filtered or unexported fields
}

type Fallback string

type Hash func(data []byte) uint32

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

type LoadBalancerOptions struct {
	// Fallback defines the strategy to adopt when the load balancer had no
	// endpoint. If not specified, defaults to FallbackService.
	Fallback Fallback
}

type Service struct {
	Namespace, Name, Port string
}