Documentation
¶
Index ¶
- type 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()
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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
Source Files