Versions in this module Expand all Collapse all v0 v0.1.0 Mar 7, 2024 Changes in this version + func DeleteConfigFromConfigmap(cs kubernetes.Interface) (bool, error) + func IsGatewayClassValid(key string, gatewayClass *gatewayv1.GatewayClass) bool + func IsGatewayUpdated(oldGateway, newGateway *gatewayv1.Gateway) bool + func IsHTTPRouteUpdated(oldHTTPRoute, newHTTPRoute *gatewayv1.HTTPRoute) bool + func IsHTTPRouteValid(key string, obj *gatewayv1.HTTPRoute) bool + func IsValidGateway(key string, gateway *gatewayv1.Gateway) bool + func SetDeleteSyncChannel() + func SyncFromFastRetryLayer(key interface{}, wg *sync.WaitGroup) error + func SyncFromIngestionLayer(key interface{}, wg *sync.WaitGroup) error + func SyncFromNodesLayer(key interface{}, wg *sync.WaitGroup) error + func SyncFromSlowRetryLayer(key interface{}, wg *sync.WaitGroup) error + func SyncFromStatusQueue(key interface{}, wg *sync.WaitGroup) error + type GatewayController struct + DisableSync bool + func SharedGatewayController() *GatewayController + func (c *GatewayController) DeleteModels() + func (c *GatewayController) FullSync() + func (c *GatewayController) FullSyncK8s(sync bool) error + func (c *GatewayController) HandleConfigMap(k8sinfo k8s.K8sinformers, ctrlCh chan struct{}, stopCh <-chan struct{}, ...) error + func (c *GatewayController) InitController(informers k8s.K8sinformers, registeredInformers []string, ...) + func (c *GatewayController) InitGatewayAPIInformers(cs gatewayclientset.Interface) + func (c *GatewayController) RefreshAuthToken() + func (c *GatewayController) SetupEventHandlers(k8sinfo k8s.K8sinformers) + func (c *GatewayController) SetupGatewayApiEventHandlers(numWorkers uint32) + func (c *GatewayController) Start(stopCh <-chan struct{})
Go to main page