ingestion

Documentation

Index

• Constants
• Variables
• func ConfigureSeGroup(client *clients.AviClient, seGroup *models.ServiceEngineGroup, segExists bool) bool
• func PopulateControllerProperties(cs kubernetes.Interface) error
• type AviControllerInfra
  • func NewAviControllerInfra(cs kubernetes.Interface) *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 SharedVCFK8sController() *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

const (
	AVI_ENTERPRISE           = "ENTERPRISE"
	VSphereClusterIDLabelKey = "vSphereClusterID"
)

Variables

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