k8s

Documentation

Index

• 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
  • 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{})

Functions

func DeleteConfigFromConfigmap

func DeleteConfigFromConfigmap(cs kubernetes.Interface) (bool, error)

func IsGatewayClassValid

func IsGatewayClassValid(key string, gatewayClass *gatewayv1.GatewayClass) bool

func IsGatewayUpdated

func IsGatewayUpdated(oldGateway, newGateway *gatewayv1.Gateway) bool

func IsHTTPRouteUpdated

func IsHTTPRouteUpdated(oldHTTPRoute, newHTTPRoute *gatewayv1.HTTPRoute) bool

func IsHTTPRouteValid

func IsHTTPRouteValid(key string, obj *gatewayv1.HTTPRoute) bool

func IsValidGateway

func IsValidGateway(key string, gateway *gatewayv1.Gateway) bool

func SetDeleteSyncChannel

func SetDeleteSyncChannel()

func SyncFromFastRetryLayer

func SyncFromFastRetryLayer(key interface{}, wg *sync.WaitGroup) error

func SyncFromIngestionLayer

func SyncFromIngestionLayer(key interface{}, wg *sync.WaitGroup) error

func SyncFromNodesLayer

func SyncFromNodesLayer(key interface{}, wg *sync.WaitGroup) error

func SyncFromSlowRetryLayer

func SyncFromSlowRetryLayer(key interface{}, wg *sync.WaitGroup) error

func SyncFromStatusQueue

func SyncFromStatusQueue(key interface{}, wg *sync.WaitGroup) error

Types

type GatewayController

type GatewayController struct {
	DisableSync bool
	// contains filtered or unexported fields
}

func SharedGatewayController

func SharedGatewayController() *GatewayController

func (*GatewayController) DeleteModels

func (c *GatewayController) DeleteModels()

DeleteModels : Delete models and add the model name in the queue. The rest layer would pick up the model key and delete the objects in Avi

func (*GatewayController) FullSync

func (c *GatewayController) FullSync()

func (*GatewayController) FullSyncK8s

func (c *GatewayController) FullSyncK8s(sync bool) error

func (*GatewayController) HandleConfigMap

func (c *GatewayController) HandleConfigMap(k8sinfo k8s.K8sinformers, ctrlCh chan struct{}, stopCh <-chan struct{}, quickSyncCh chan struct{}) error

HandleConfigMap : initialise the controller, start informer for configmap and wait for the ako configmap to be created. When the configmap is created, enable sync for other k8s objects. When the configmap is disabled, disable sync.

func (*GatewayController) InitController

func (c *GatewayController) InitController(informers k8s.K8sinformers, registeredInformers []string, ctrlCh <-chan struct{}, stopCh <-chan struct{}, quickSyncCh chan struct{}, waitGroupMap ...map[string]*sync.WaitGroup)

func (*GatewayController) InitGatewayAPIInformers

func (c *GatewayController) InitGatewayAPIInformers(cs gatewayclientset.Interface)

func (*GatewayController) RefreshAuthToken

func (c *GatewayController) RefreshAuthToken()

func (*GatewayController) SetupEventHandlers

func (c *GatewayController) SetupEventHandlers(k8sinfo k8s.K8sinformers)

func (*GatewayController) SetupGatewayApiEventHandlers

func (c *GatewayController) SetupGatewayApiEventHandlers(numWorkers uint32)

func (*GatewayController) Start

func (c *GatewayController) Start(stopCh <-chan struct{})