modelresolver

Documentation

Index

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

Types

type Manager

type Manager struct {
	client.Client

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

func NewManager

func NewManager(mgr ctrl.Manager) (*Manager, error)

func (*Manager) AwaitBestAddress

func (r *Manager) AwaitBestAddress(ctx context.Context, model 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 (*Manager) GetAllAddresses

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

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

func (*Manager) Reconcile

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

func (*Manager) SetupWithManager

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