balancer

package

v0.11.0 Latest Latest Go to latest Published: Jul 5, 2026 License: Apache-2.0 Imports: 6 Imported by: 0

Details

This section is empty.

View Source

var (
	// ErrNotAvailable is returned when no upstream endpoint is available.
	ErrNotAvailable = errors.New("no available upstream at the moment")
)

func Register(names []string, h CreateBalancerHandler) error

Register registers a balancer handler under the given names.

type Balancer interface {
	Select(ctx context.Context, hzCtx *app.RequestContext) (*target.Endpoint, error)
}

Balancer selects an endpoint from available upstream targets.

type CreateBalancerHandler func(endpoints []*target.Endpoint, params any) (Balancer, error)

CreateBalancerHandler is a function that creates a Balancer from endpoints and params.

func Factory(name string) CreateBalancerHandler

Factory returns the registered balancer handler for the given name.