endpoint

Documentation

Index

• func MatchingEndpoints(epMap map[string]wapi.DependantSelectors) predicate.Predicate
• func ReadyEndpoints(logger logr.Logger) predicate.Predicate
• type Reconciler
  • func (r *Reconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *Reconciler) SetupWithManager(mgr ctrl.Manager) error

Functions

func MatchingEndpoints

func MatchingEndpoints(epMap map[string]wapi.DependantSelectors) predicate.Predicate

MatchingEndpoints is a predicate to allow events for only configured endpoints

func ReadyEndpoints

func ReadyEndpoints(logger logr.Logger) predicate.Predicate

ReadyEndpoints is a predicate to allow events for only ready endpoints. Endpoint is considered ready when there is at least a single endpoint subset that has at least one IP address assigned.

Types

type Reconciler

type Reconciler struct {
	client.Client
	SeedClient              kubernetes.Interface
	WeederConfig            *wapi.Config
	WeederMgr               weeder.Manager
	MaxConcurrentReconciles int
}

Reconciler EndpointReconciler reconciles an Endpoints object

func (*Reconciler) Reconcile

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

Reconcile listens to create/update events for `Endpoints` resources and manages weeder which shoot the dependent pods of the configured services, if necessary

func (*Reconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.