target

package

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

Details

This section is empty.

This section is empty.

func EndpointHash(endpoints []*Endpoint) string

EndpointHash returns a deterministic hash of the given endpoints.

type Endpoint struct {
	Address string
	Weight  uint32
	Tags    map[string]string
	State   *State
}

Endpoint represents an upstream endpoint address with weight and state.

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

State tracks the health of an endpoint with failure counting and timeout.

func NewState(maxFails uint, failTimeout time.Duration) *State

NewState creates a new State with the given max failures and fail timeout.

func (s *State) IsAvailable() bool

IsAvailable returns true if the endpoint is healthy and accepting requests.

func (s *State) RecordFailure()

RecordFailure increments the failure count, resetting if past the fail timeout.

type Target struct {
	Name      string
	Weight    uint32
	Tags      map[string]string
	Endpoints map[string]*Endpoint
}

Target groups endpoints under a logical name with weight and tags.