Documentation
¶
Index ¶
- Constants
- Variables
- func ConfigureSeGroup(client *clients.AviClient, seGroup *models.ServiceEngineGroup, segExists bool) bool
- func PopulateControllerProperties(cs kubernetes.Interface) error
- type AviControllerInfra
- func (a *AviControllerInfra) AnnotateSystemNamespace(seGroup string, cloudName string, retries ...int) bool
- func (a *AviControllerInfra) DeriveCloudNameAndSEGroupTmpl(tz string) (error, string, string)
- func (a *AviControllerInfra) InitInfraController()
- func (a *AviControllerInfra) SetupSEGroup(tz string) bool
- func (a *AviControllerInfra) VerifyAviControllerLicense() error
- type VCFK8sController
- func (c *VCFK8sController) AddAvailabilityZoneCREventHandler(stopCh <-chan struct{})
- func (c *VCFK8sController) AddConfigMapEventHandler(stopCh <-chan struct{}, startSyncCh chan struct{})
- func (c *VCFK8sController) AddNamespaceEventHandler(stopCh <-chan struct{})
- func (c *VCFK8sController) AddNetworkInfoEventHandler(stopCh <-chan struct{})
- func (c *VCFK8sController) AddSecretEventHandler(stopCh <-chan struct{})
- func (c *VCFK8sController) HandleVCF(stopCh <-chan struct{}, ctrlCh chan struct{}, skipAviClient ...bool) string
- func (c *VCFK8sController) InitFullSyncWorker() *utils.FullSyncThread
- func (c *VCFK8sController) InitNetworkingHandler()
- func (c *VCFK8sController) Sync()
- func (c *VCFK8sController) ValidBootStrapData() bool
- func (c *VCFK8sController) ValidBootstrapSecretData(controllerIP, secretName, secretNamespace string) bool
Constants ¶
View Source
const ( AVI_ENTERPRISE = "ENTERPRISE" VSphereClusterIDLabelKey = "vSphereClusterID" )
Variables ¶
View Source
var WorkloadNamespaceCount int = 0
Functions ¶
func ConfigureSeGroup ¶
func ConfigureSeGroup(client *clients.AviClient, seGroup *models.ServiceEngineGroup, segExists bool) bool
ConfigureSeGroup creates the SE group with the supplied properties, alters just the SE group name and the markers.
func PopulateControllerProperties ¶
func PopulateControllerProperties(cs kubernetes.Interface) error
Types ¶
type AviControllerInfra ¶
type AviControllerInfra struct {
AviRestClient *clients.AviClient
// contains filtered or unexported fields
}
func NewAviControllerInfra ¶
func NewAviControllerInfra(cs kubernetes.Interface) *AviControllerInfra
func (*AviControllerInfra) AnnotateSystemNamespace ¶
func (a *AviControllerInfra) AnnotateSystemNamespace(seGroup string, cloudName string, retries ...int) bool
func (*AviControllerInfra) DeriveCloudNameAndSEGroupTmpl ¶
func (a *AviControllerInfra) DeriveCloudNameAndSEGroupTmpl(tz string) (error, string, string)
func (*AviControllerInfra) InitInfraController ¶
func (a *AviControllerInfra) InitInfraController()
func (*AviControllerInfra) SetupSEGroup ¶
func (a *AviControllerInfra) SetupSEGroup(tz string) bool
func (*AviControllerInfra) VerifyAviControllerLicense ¶
func (a *AviControllerInfra) VerifyAviControllerLicense() error
type VCFK8sController ¶
type VCFK8sController struct {
//workqueue []workqueue.RateLimitingInterface
DisableSync bool
NetHandler avirest.NetworkingHandler
// contains filtered or unexported fields
}
func SharedVCFK8sController ¶
func SharedVCFK8sController() *VCFK8sController
func (*VCFK8sController) AddAvailabilityZoneCREventHandler ¶
func (c *VCFK8sController) AddAvailabilityZoneCREventHandler(stopCh <-chan struct{})
func (*VCFK8sController) AddConfigMapEventHandler ¶
func (c *VCFK8sController) AddConfigMapEventHandler(stopCh <-chan struct{}, startSyncCh chan struct{})
func (*VCFK8sController) AddNamespaceEventHandler ¶
func (c *VCFK8sController) AddNamespaceEventHandler(stopCh <-chan struct{})
func (*VCFK8sController) AddNetworkInfoEventHandler ¶
func (c *VCFK8sController) AddNetworkInfoEventHandler(stopCh <-chan struct{})
func (*VCFK8sController) AddSecretEventHandler ¶
func (c *VCFK8sController) AddSecretEventHandler(stopCh <-chan struct{})
func (*VCFK8sController) HandleVCF ¶
func (c *VCFK8sController) HandleVCF(stopCh <-chan struct{}, ctrlCh chan struct{}, skipAviClient ...bool) string
HandleVCF checks if avi secret used by AKO is already present. If found, then it would try to connect to AVI Controller. If there is any failure, we would look at Bootstrap CR used by NCP to communicate with AKO. If Bootstrap CR is not found, AKO would wait for it to be created. If the authtoken from Bootstrap CR can be used to connect to the AVI Controller, then avi-secret would be created with that token.
func (*VCFK8sController) InitFullSyncWorker ¶
func (c *VCFK8sController) InitFullSyncWorker() *utils.FullSyncThread
func (*VCFK8sController) InitNetworkingHandler ¶
func (c *VCFK8sController) InitNetworkingHandler()
func (*VCFK8sController) Sync ¶
func (c *VCFK8sController) Sync()
func (*VCFK8sController) ValidBootStrapData ¶
func (c *VCFK8sController) ValidBootStrapData() bool
func (*VCFK8sController) ValidBootstrapSecretData ¶
func (c *VCFK8sController) ValidBootstrapSecretData(controllerIP, secretName, secretNamespace string) bool
Source Files
Click to show internal directories.
Click to hide internal directories.