ingress

Documentation

Index

• func NewConcurrencyWatchdog(manager ctrl.Manager, conf *config.Config, target ListWatchdogTargets) error
• func NewIngressClassReconciler(manager ctrl.Manager, resources []client.Object, name string) error
• func NewIngressControllerReconciler(manager ctrl.Manager, resources []client.Object, name string) error
• func NginxScrapeFn(ctx context.Context, client rest.Interface, pod *corev1.Pod) (float64, error)
• type ConcurrencyWatchdog
  • func (c *ConcurrencyWatchdog) NeedLeaderElection() bool
  • func (c *ConcurrencyWatchdog) Start(ctx context.Context) error
• type ListWatchdogTargets
  • func GetListNginxWatchdogTargets(cl client.Client, defaultNicControllerClass string) ListWatchdogTargets
• type ScrapeFn
• type WatchdogTarget

Functions

func NewConcurrencyWatchdog

func NewConcurrencyWatchdog(manager ctrl.Manager, conf *config.Config, target ListWatchdogTargets) error

func NewIngressClassReconciler

func NewIngressClassReconciler(manager ctrl.Manager, resources []client.Object, name string) error

NewIngressClassReconciler creates a reconciler that manages ingress class resources

func NewIngressControllerReconciler

func NewIngressControllerReconciler(manager ctrl.Manager, resources []client.Object, name string) error

NewIngressControllerReconciler creates a reconciler that manages ingress controller resources

func NginxScrapeFn

func NginxScrapeFn(ctx context.Context, client rest.Interface, pod *corev1.Pod) (float64, error)

NginxScrapeFn is the scrape function for Nginx

Types

type ConcurrencyWatchdog

type ConcurrencyWatchdog struct {
	// contains filtered or unexported fields
}

ConcurrencyWatchdog evicts ingress controller pods that have too many active connections relative to others. This helps redistribute long-running connections when the ingress controller scales up.

func (*ConcurrencyWatchdog) NeedLeaderElection

func (c *ConcurrencyWatchdog) NeedLeaderElection() bool

func (*ConcurrencyWatchdog) Start

func (c *ConcurrencyWatchdog) Start(ctx context.Context) error

type ListWatchdogTargets

type ListWatchdogTargets func() ([]WatchdogTarget, error)

func GetListNginxWatchdogTargets

func GetListNginxWatchdogTargets(cl client.Client, defaultNicControllerClass string) ListWatchdogTargets

type ScrapeFn

type ScrapeFn func(ctx context.Context, client rest.Interface, pod *corev1.Pod) (float64, error)

ScrapeFn returns the connection count for the given pod

type WatchdogTarget

type WatchdogTarget struct {
	ScrapeFn  ScrapeFn
	PodLabels map[string]string
}

WatchdogTarget refers to a target the concurrency watchdog should track