weighted

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.

This section is empty.

func Init() error

Init registers the weighted balancer with the balancer registry.

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

Balancer selects an endpoint based on weighted random selection.

func NewBalancer(endpoints []*target.Endpoint) (*Balancer, error)

NewBalancer creates a new weighted balancer with the given endpoints.

func (b *Balancer) Select(_ context.Context, _ *app.RequestContext) (*target.Endpoint, error)

Select picks an endpoint using weighted random selection, skipping unhealthy endpoints.