loadbalancer

Documentation

Index

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

Types

type LoadBalancer

type LoadBalancer struct {
	client.Client

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

func New

func New(mgr ctrl.Manager) (*LoadBalancer, error)

func (*LoadBalancer) AwaitBestAddress

func (r *LoadBalancer) AwaitBestAddress(ctx context.Context, req *apiutils.Request) (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 (*LoadBalancer) GetAllAddresses

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

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

func (*LoadBalancer) GetSelfIPs

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

func (*LoadBalancer) Reconcile

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

func (*LoadBalancer) SetupWithManager

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