endpoints

Documentation

Index

• type Manager
  • func NewManager(mgr ctrl.Manager) (*Manager, error)
  • func (r *Manager) AwaitHostAddress(ctx context.Context, service, portName string) (string, error)
  • func (r *Manager) GetAllHosts(service, portName 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

	EndpointSizeCallback func(deploymentName string, size int)

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

func NewManager

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

func (*Manager) AwaitHostAddress

func (r *Manager) AwaitHostAddress(ctx context.Context, service, portName string) (string, error)

AwaitHostAddress returns the host address with the lowest number of in-flight requests. It will block until the host address becomes available or the context times out.

It returns a string in the format "host:port" or error on timeout

func (*Manager) GetAllHosts

func (r *Manager) GetAllHosts(service, portName string) []string

GetAllHosts retrieves the list of all hosts for a given service and port.

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