Versions in this module Expand all Collapse all v0 v0.1.0 Mar 7, 2024 Changes in this version + const BOOT_UP_AS_FOLLOWER + const BOOT_UP_AS_LEADER + const FOLLOWER + const FOLLOWER_TO_LEADER + const LEADER + const LOST_LEADERSHIP + const UNKNOWN + func AddGatewaysFromNSToIngestionQueue(numWorkers uint32, c *AviController, namespace string, msg string) + func AddGatewaysFromNSToIngestionQueueWCP(numWorkers uint32, c *AviController, namespace string, msg string) + func AddIngressFromNSToIngestionQueue(numWorkers uint32, c *AviController, namespace string, msg string) + func AddMultiClusterIngressFromNSToIngestionQueue(numWorkers uint32, c *AviController, namespace string, msg string) + func AddNamespaceAnnotationEventHandler(numWorkers uint32, c *AviController) cache.ResourceEventHandler + func AddNamespaceEventHandler(numWorkers uint32, c *AviController) cache.ResourceEventHandler + func AddPodEventHandler(numWorkers uint32, c *AviController) cache.ResourceEventHandler + func AddRouteEventHandler(numWorkers uint32, c *AviController) cache.ResourceEventHandler + func AddRoutesFromNSToIngestionQueue(numWorkers uint32, c *AviController, namespace string, msg string) + func AddServiceImportsFromNSToIngestionQueue(numWorkers uint32, c *AviController, namespace string, msg string) + func AddServicesFromNSToIngestionQueue(numWorkers uint32, c *AviController, namespace string, msg string) + func DeleteAviObjects(parentVSKeys []avicache.NamespaceName, avi_obj_cache *avicache.AviObjCache, ...) + func DeleteConfigFromConfigmap(cs kubernetes.Interface) (bool, error) + func DeleteNPLAnnotations() + func GetSEGManagementNetwork(name, tenant string) string + func InformerStatusUpdatesForGateway(key string, gateway *advl4v1alpha1pre1.Gateway) + func InformerStatusUpdatesForSvcApiGateway(key string, gateway *servicesapi.Gateway) + func NewAdvL4Informers(cs advl4crd.Interface) + func NewCRDInformers() + func NewInfraSettingCRDInformer() + func NewIstioCRDInformers(cs istiocrd.Interface) + func NewSvcApiInformers(cs svccrd.Interface) + func PopulateCache(tenant string) error + func PopulateControllerProperties(cs kubernetes.Interface) error + func PopulateNodeCache(cs *kubernetes.Clientset) + func SetAviInfrasettingNodeNetworks(name, segMgmtNetwork, infraSEGName string, ...) + func SetAviInfrasettingVIPNetworks(name, segMgmtNetwork, infraSEGName string, ...) + 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 AviController struct + DisableSync bool + State *State + func SharedAviController() *AviController + func (c *AviController) AddBootupNSEventHandler(stopCh <-chan struct{}, startSyncCh chan struct{}) + func (c *AviController) CleanupStaleVSes() + func (c *AviController) DeleteModels() + func (c *AviController) FullSync() + func (c *AviController) FullSyncK8s(sync bool) error + func (c *AviController) GetValidator() Validator + func (c *AviController) HandleConfigMap(k8sinfo K8sinformers, ctrlCh chan struct{}, stopCh <-chan struct{}, ...) error + func (c *AviController) InitController(informers K8sinformers, registeredInformers []string, ctrlCh <-chan struct{}, ...) + func (c *AviController) InitVCFHandlers(kubeClient kubernetes.Interface, ctrlCh <-chan struct{}, ...) + func (c *AviController) InitializeNamespaceSync() + func (c *AviController) IstioBootstrap() + func (c *AviController) NewFSM() *FSM + func (c *AviController) NoOperation() + func (c *AviController) OnLostLeadership() + func (c *AviController) OnNewLeader() + func (c *AviController) OnNewLeaderDuringBootup() + func (c *AviController) OnStartedLeading() + func (c *AviController) OnStartedLeadingAfterFailover() + func (c *AviController) OnStartedLeadingDuringBootup() + func (c *AviController) OnStoppedLeading() + func (c *AviController) RefreshAuthToken() + func (c *AviController) Run(stopCh <-chan struct{}) error + func (c *AviController) SetSEGroupCloudNameFromNSAnnotations() bool + func (c *AviController) SetupAKOCRDEventHandlers(numWorkers uint32) + func (c *AviController) SetupAdvL4EventHandlers(numWorkers uint32) + func (c *AviController) SetupEventHandlers(k8sinfo K8sinformers) + func (c *AviController) SetupIstioCRDEventHandlers(numWorkers uint32) + func (c *AviController) SetupMultiClusterIngressEventHandlers(numWorkers uint32) + func (c *AviController) SetupNamespaceEventHandler(numWorkers uint32) + func (c *AviController) SetupServiceImportEventHandlers(numWorkers uint32) + func (c *AviController) SetupSvcApiEventHandlers(numWorkers uint32) + func (c *AviController) Start(stopCh <-chan struct{}) + func (c *AviController) SyncCRDObjects() + func (c *AviController) TransitionToFollower() + func (c *AviController) TransitionToLeader() + func (c *AviController) ValidAviSecret() bool + type Event struct + Handler func() + Name string + Transition func() + func (e *Event) Handle() + type FSM struct + Event map[string]*Event + type K8sinformers struct + Cs kubernetes.Interface + DynamicClient dynamic.Interface + OshiftClient oshiftclient.Interface + type State struct + type Validator interface + ValidateAviInfraSetting func(key string, infraSetting *akov1beta1.AviInfraSetting) error + ValidateHTTPRuleObj func(key string, httprule *akov1beta1.HTTPRule) error + ValidateHostRuleObj func(key string, hostrule *akov1beta1.HostRule) error + ValidateL4RuleObj func(key string, l4Rule *akov1alpha2.L4Rule) error + ValidateL7RuleObj func(key string, l7Rule *akov1alpha2.L7Rule) error + ValidateMultiClusterIngressObj func(key string, multiClusterIngress *akov1alpha1.MultiClusterIngress) error + ValidateSSORuleObj func(key string, ssoRule *akov1alpha2.SSORule) error + ValidateServiceImportObj func(key string, serviceImport *akov1alpha1.ServiceImport) error + func NewValidator() Validator
Go to main page