endpoints

Documentation

Index

• type Resolver
  • func NewResolver(mgr ctrl.Manager) (*Resolver, error)
  • func (r *Resolver) AwaitBestAddress(ctx context.Context, model, adapter string) (string, func(), error)
  • func (r *Resolver) GetAllAddresses(model string) []string
  • func (r *Resolver) GetSelfIPs() []string
  • func (r *Resolver) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *Resolver) SetupWithManager(mgr ctrl.Manager) error

Types

type Resolver

type Resolver struct {
	client.Client

	ExcludePods map[string]struct{}
	// contains filtered or unexported fields
}

func NewResolver

func NewResolver(mgr ctrl.Manager) (*Resolver, error)

func (*Resolver) AwaitBestAddress

func (r *Resolver) AwaitBestAddress(ctx context.Context, model, adapter string) (string, func(), error)

AwaitBestAddress returns the "IP:Port" with the lowest number of in-flight requests. It will block until an endpoint becomes available or the context times out. It returns a function that should be called when the request is complete to decrement the in-flight count.

func (*Resolver) GetAllAddresses

func (r *Resolver) GetAllAddresses(model string) []string

GetAllHosts retrieves the list of all hosts for a given model.

func (*Resolver) GetSelfIPs

func (r *Resolver) GetSelfIPs() []string

func (*Resolver) Reconcile

func (r *Resolver) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*Resolver) SetupWithManager

func (r *Resolver) SetupWithManager(mgr ctrl.Manager) error