leastconn

Documentation

Overview

Package leastconn provides a balancer based on the least connections.

Index

• Variables
• type Balancer
  • func NewBalancer(policy string, getconcurrency func(loadbalancer.Endpoint) int) *Balancer
  • func (b *Balancer) Forward(c context.Context, r any, eps *loadbalancer.Static) (any, error)
  • func (b *Balancer) Policy() string
• type Concurrenter

Variables

var GetConcurrency func(loadbalancer.Endpoint) int = func(e loadbalancer.Endpoint) int {
	if c, ok := e.(Concurrenter); ok {
		return c.Concurrent()
	}
	return 0
}

GetConcurrency is the default function to get the concurrency number of the endpoint.

For the default implementation, check whether the endpoint has implemented the interface Concurrenter and call it. Or, return 0.

Types

type Balancer

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

Balancer implements the balancer based on the least number of the connection.

func NewBalancer

func NewBalancer(policy string, getconcurrency func(loadbalancer.Endpoint) int) *Balancer

NewBalancer returns a new balancer based on the random with the policy name.

If policy is empty, use "leastconn" instead. If getconcurrency is nil, use GetConcurrency instead.

func (*Balancer) Forward

func (b *Balancer) Forward(c context.Context, r any, eps *loadbalancer.Static) (any, error)

Forward forwards the request to one of the backend endpoints.

func (*Balancer) Policy

func (b *Balancer) Policy() string

Policy returns the policy of the balancer.

type Concurrenter

type Concurrenter interface {
	Concurrent() int
}

Concurrenter is used to return the concurrent number of an endpoint.