controller

Documentation

Index

• type AppGwIngressController
  • func NewAppGwIngressController(azClient azure.AzClient, appGwIdentifier appgw.Identifier, ...) *AppGwIngressController
  • func (c AppGwIngressController) GetAppGw() (*n.ApplicationGateway, *appgw.ConfigBuilderContext, error)
  • func (c *AppGwIngressController) Liveness() bool
  • func (c AppGwIngressController) MutateAllIngress(appGw *n.ApplicationGateway, cbCtx *appgw.ConfigBuilderContext) error
  • func (c AppGwIngressController) MutateAppGateway(event events.Event, appGw *n.ApplicationGateway, ...) error
  • func (c *AppGwIngressController) ProcessEvent(event events.Event) error
  • func (c *AppGwIngressController) PruneIngress(appGw *n.ApplicationGateway, cbCtx *appgw.ConfigBuilderContext) []*networking.Ingress
  • func (c *AppGwIngressController) Readiness() bool
  • func (c AppGwIngressController) ResetAllIngress(appGw *n.ApplicationGateway, cbCtx *appgw.ConfigBuilderContext)
  • func (c AppGwIngressController) ShouldProcess(event events.Event) (bool, *string)
  • func (c *AppGwIngressController) Start(envVariables environment.EnvVariables) error
  • func (c *AppGwIngressController) Stop()

Types

type AppGwIngressController

type AppGwIngressController struct {
	MetricStore metricstore.MetricStore
	// contains filtered or unexported fields
}

AppGwIngressController configures the application gateway based on the ingress rules defined.

func NewAppGwIngressController

func NewAppGwIngressController(azClient azure.AzClient, appGwIdentifier appgw.Identifier, k8sContext *k8scontext.Context, recorder record.EventRecorder, metricStore metricstore.MetricStore, agicPod *v1.Pod, hostedOnUnderlay bool) *AppGwIngressController

NewAppGwIngressController constructs a controller object.

func (AppGwIngressController) GetAppGw

func (c AppGwIngressController) GetAppGw() (*n.ApplicationGateway, *appgw.ConfigBuilderContext, error)

GetAppGw gets App Gateway config.

func (*AppGwIngressController) Liveness

func (c *AppGwIngressController) Liveness() bool

Liveness fulfills the health.HealthProbe interface; It is evaluated when K8s liveness-checks the AGIC pod.

func (AppGwIngressController) MutateAllIngress

func (c AppGwIngressController) MutateAllIngress(appGw *n.ApplicationGateway, cbCtx *appgw.ConfigBuilderContext) error

MutateAllIngress applies changes to ingress status object in kubernetes

func (AppGwIngressController) MutateAppGateway

func (c AppGwIngressController) MutateAppGateway(event events.Event, appGw *n.ApplicationGateway, cbCtx *appgw.ConfigBuilderContext) error

MutateAppGateway applies App Gateway config.

func (*AppGwIngressController) ProcessEvent

func (c *AppGwIngressController) ProcessEvent(event events.Event) error

ProcessEvent is the handler for K8 cluster events which are listened by informers.

func (*AppGwIngressController) PruneIngress

func (c *AppGwIngressController) PruneIngress(appGw *n.ApplicationGateway, cbCtx *appgw.ConfigBuilderContext) []*networking.Ingress

PruneIngress filters ingress list based on filter functions and returns a filtered ingress list

func (*AppGwIngressController) Readiness

func (c *AppGwIngressController) Readiness() bool

Readiness fulfills the health.HealthProbe interface; It is evaluated when K8s readiness-checks the AGIC pod.

func (AppGwIngressController) ResetAllIngress

func (c AppGwIngressController) ResetAllIngress(appGw *n.ApplicationGateway, cbCtx *appgw.ConfigBuilderContext)

ResetAllIngress resets the ingress status object in kubernetes

func (AppGwIngressController) ShouldProcess

func (c AppGwIngressController) ShouldProcess(event events.Event) (bool, *string)

ShouldProcess determines whether to process an event.

func (*AppGwIngressController) Start

func (c *AppGwIngressController) Start(envVariables environment.EnvVariables) error

Start function runs the k8scontext and continues to listen to the event channel and enqueue events before stopChannel is closed

func (*AppGwIngressController) Stop

func (c *AppGwIngressController) Stop()

Stop function terminates the k8scontext and signal the stopchannel