loadbalancer

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

type Factory interface {
	CreateStrategy(input StrategyInput) (Strategy, error)
}

type HealthStatus struct {
	Healthy    bool
	LastCheck  time.Time
	LastError  error
	Failures   int
	ActiveConn int32
}

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

type Pool struct {
	ID              string
	Registries      []*registry.Registry
	Weights         map[ids.RegistryID]int
	Algorithm       string
	EmbeddingConfig *registry.EmbeddingConfig
}

type Strategy interface {
	Next(req *infracontext.RequestContext, exclude map[ids.RegistryID]struct{}) *registry.Registry
	Name() string
}

type StrategyInput struct {
	Algorithm       string
	Registries      []*registry.Registry
	Weights         map[ids.RegistryID]int
	EmbeddingConfig *embedding.Config
}