Versions in this module Expand all Collapse all v0 v0.1.0 Mar 7, 2024 Changes in this version + const ADMIN_NS + const ADVANCED_L4 + const AKO_DEFAULT_NS + const AVIAPI_CONNECTED + const AVIAPI_DISCONNECTED + const AVIAPI_INITIATING + const AVI_DEFAULT_SCTP_HM + const AVI_DEFAULT_TCP_HM + const AVI_DEFAULT_UDP_HM + const AuthTokenExpiry + const ConfigMapInformer + const CreateEv + const DEFAULT_FILE_SUFFIX + const DEFAULT_L4_APP_PROFILE + const DEFAULT_L4_SSL_APP_PROFILE + const DEFAULT_L7_APP_PROFILE + const DEFAULT_L7_SECURE_APP_PROFILE + const DEFAULT_SHARD_VS_PREFIX + const DEFAULT_TCP_NW_PROFILE + const DebugLevel + const DeleteEv + const ENV_CTRL_AUTHTOKEN + const ENV_CTRL_CADATA + const ENV_CTRL_IPADDRESS + const ENV_CTRL_PASSWORD + const ENV_CTRL_USERNAME + const EndpointInformer + const Endpoints + const ErrorLevel + const FULL_SYNC_INTERVAL + const GlobalVRF + const GraphLayer + const HTTP + const HTTPRoute + const HTTPS + const HTTP_DS_SCRIPT + const HTTP_DS_SCRIPT_MODIFIED + const HeaderAuthority + const HeaderMethod + const HeaderScheme + const INFORMERS_ADVANCED_L4 + const INFORMERS_AKO_CLIENT + const INFORMERS_INSTANTIATE_ONCE + const INFORMERS_NAMESPACE + const INFORMERS_OPENSHIFT_CLIENT + const InfoLevel + const Ingress + const IngressClass + const IngressClassInformer + const IngressInformer + const K8S_ETIMEDOUT + const K8S_TLS_SECRET_ALT_CERT + const K8S_TLS_SECRET_ALT_KEY + const K8S_TLS_SECRET_CERT + const K8S_TLS_SECRET_KEY + const K8S_UNAUTHORIZED + const L4LBService + const L7_PG_PREFIX + const LeastConnection + const LoadBalancer + const MCI_ENABLED + const MIXED_NET_PROFILE + const MaxAviVersion + const MultiClusterIngressInformer + const NSInformer + const Namespace + const NamespaceNetworkInfo + const NodeInformer + const NodeObj + const NumWorkersGraph + const NumWorkersIngestion + const OSHIFT_K8S_CLOUD_CONNECTOR + const ObjectIngestionLayer + const OshiftRoute + const POD_NAMESPACE + const PassthroughConnection + const PatchAddOp + const PatchDeleteOp + const PatchReplaceOp + const Pod + const PodInformer + const RandomConnection + const RefreshAuthTokenInterval + const RefreshAuthTokenPeriod + const RoundRobinConnection + const RouteInformer + const SCTP + const SERVICES_API + const SYSTEM_SCTP_PROXY + const SYSTEM_UDP_FAST_PATH + const Secret + const SecretInformer + const Service + const ServiceImportInformer + const ServiceInformer + const StatusQueue + const TCP + const TCP_NW_FAST_PATH + const TLS + const TLS_PASSTHROUGH + const UDP + const USE_DEFAULT_SECRETS_ONLY + const UpdateEv + const VCF_CLUSTER + const VMWARE_SYSTEM_AKO + const VRF_CONTEXT + const VS_DATASCRIPT_EVT_HTTP_REQ + const VS_TYPE_NORMAL + const VS_TYPE_VH_CHILD + const VS_TYPE_VH_ENHANCED + const VS_TYPE_VH_PARENT + const WarnLevel + var AddToScheme = localSchemeBuilder.AddToScheme + var CloudName string + var Codecs = serializer.NewCodecFactory(EventScheme) + var CtrlVersion string + var EventScheme = runtime.NewScheme() + var InformerDefaultResync = 12 * time.Hour + var LogLevelMap = map[string]zapcore.Level + var ParameterCodec = runtime.NewParameterCodec(EventScheme) + var VipNetworkList []akov1beta1.AviInfraSettingVipNetwork + func AddNamespaceToFilter(namespace string) + func AviModelToUrl(model string) string + func AviUrlToObjType(aviurl string) (string, error) + func Bkt(key string, num_workers uint32) uint32 + func CheckIfNamespaceAccepted(namespace string, opts ...interface{}) bool + func ContainsDuplicate(arr interface{}) bool + func CreateAuthTokenWithRetry(c *clients.AviClient, retryCount int) (interface{}, error) + func CrudHashKey(obj_type string, obj interface{}) string + func DeepCopy(a, b interface{}) + func DeleteAuthTokenWithRetry(c *clients.AviClient, tokenID string, retryCount int) error + func DeleteNamespaceFromFilter(namespace string) + func ExtractNamespaceObjectName(key string) (string, string) + func FindAndRemove(arr []string, item string) (bool, []string) + func GetAKONamespace() string + func GetAdvancedL4() bool + func GetAuthTokenMapWithRetry(c *clients.AviClient, tokens map[string]interface{}, retryCount int, ...) error + func GetAuthTokenWithRetry(c *clients.AviClient, retryCount int, nextPage ...string) (interface{}, error) + func GetAuthtokenFromCache() (string, error) + func GetCloudRef(tenant string) string + func GetHTTPTransportWithCert(rootPEMCerts string) (*http.Transport, bool) + func GetNSFilter(obj *K8ValidNamespaces) (string, string) + func GetTokenFromRestObj(robj interface{}, ctrlAuthToken string) (oldTokenID string, refresh bool, err error) + func GetVipNetworkList() []akov1beta1.AviInfraSettingVipNetwork + func HasElem(s interface{}, elem interface{}) bool + func Hash(s string) uint32 + func InitializeNSSync(labelKey, labelVal string) + func IsMultiClusterIngressEnabled() bool + func IsNSPresent(namespace string, obj *K8ValidNamespaces) bool + func IsSecretsHandlingRestrictedToAKONS() bool + func IsServiceNSValid(namespace string) bool + func IsSvcHttp(svc_name string, port int32) bool + func IsV4(addr string) bool + func IsVCFCluster() bool + func LogApi(next http.Handler) http.Handler + func ObjKey(obj interface{}) string + func RandomSeq(n int) string + func Remove(arr []string, item string) []string + func Respond(w http.ResponseWriter, data interface{}) + func SetCloudName(cloudName string) + func SetVipNetworkList(vipNetworks []akov1beta1.AviInfraSettingVipNetwork) + func SetupSignalHandler() (stopCh <-chan struct{}) + func String(s *string) string + func Stringify(serialize interface{}) string + type AviCache struct + func NewAviCache() *AviCache + func (c *AviCache) AviCacheAdd(k interface{}, val interface{}) + func (c *AviCache) AviCacheDelete(k interface{}) + func (c *AviCache) AviCacheGet(k interface{}) (interface{}, bool) + func (c *AviCache) AviCacheGetKeyByUuid(uuid string) (interface{}, bool) + type AviCloudPropertyCache struct + NSIpam string + NSIpamDNS string + Name string + VType string + type AviHTTPCache struct + CloudConfigCksum string + Name string + Tenant string + Uuid string + type AviHostPathPortPoolPG struct + Host string + Path string + Pool string + PoolGroup string + Port uint32 + type AviHttpPolicySetMeta struct + CloudConfigCksum string + HppMap []AviHostPathPortPoolPG + Name string + Tenant string + type AviLogger struct + var AviLog AviLogger + func (AviLogger) Init(info logr.RuntimeInfo) + func (aviLogger *AviLogger) Debug(args ...interface{}) + func (aviLogger *AviLogger) Debugf(template string, args ...interface{}) + func (aviLogger *AviLogger) Errorf(template string, args ...interface{}) + func (aviLogger *AviLogger) Fatal(args ...interface{}) + func (aviLogger *AviLogger) Fatalf(template string, args ...interface{}) + func (aviLogger *AviLogger) Infof(template string, args ...interface{}) + func (aviLogger *AviLogger) SetLevel(l string) + func (aviLogger *AviLogger) Warn(args ...interface{}) + func (aviLogger *AviLogger) Warnf(template string, args ...interface{}) + func (aviLogger AviLogger) Enabled(level int) bool + func (aviLogger AviLogger) Error(err error, msg string, args ...interface{}) + func (aviLogger AviLogger) Info(level int, msg string, args ...interface{}) + func (aviLogger AviLogger) V(level int) logr.LogSink + func (aviLogger AviLogger) WithName(name string) logr.LogSink + func (aviLogger AviLogger) WithValues(keysAndValues ...interface{}) logr.LogSink + type AviMultiCache struct + func NewAviMultiCache() *AviMultiCache + func (c *AviMultiCache) AviMultiCacheAdd(k interface{}, val interface{}) + func (c *AviMultiCache) AviMultiCacheDeleteKey(k interface{}) + func (c *AviMultiCache) AviMultiCacheDeleteVal(k interface{}, dval interface{}) + func (c *AviMultiCache) AviMultiCacheGetKey(k interface{}) (map[interface{}]bool, bool) + func (c *AviMultiCache) AviMultiCacheLookup(k interface{}, lval interface{}) bool + type AviObjectMarkers struct + GatewayName string + Host []string + InfrasettingName string + IngressName []string + Namespace string + Path []string + Port string + Protocol string + ServiceName string + type AviPGCache struct + CloudConfigCksum string + Name string + ServiceMetadata ServiceMetadataObj + Tenant string + Uuid string + type AviPkiProfileCache struct + Name string + Tenant string + Uuid string + type AviPoolCache struct + CloudConfigCksum string + LbAlgorithm string + Name string + ServiceMetadata ServiceMetadataObj + Tenant string + Uuid string + type AviPoolMetaServer struct + Ip avimodels.IPAddr + ServerNode string + type AviPortProtocol struct + Port int32 + Protocol string + type AviPortStrProtocol struct + Port string + Protocol string + type AviRestClientPool struct + AviClient map[string][]*clients.AviClient + var AviClientInstance *AviRestClientPool + func NewAviRestClientPool(num uint32, ...) (*AviRestClientPool, string, error) + func (p *AviRestClientPool) AviRestOperate(c *clients.AviClient, rest_ops []*RestOp) error + type AviRestObjMacro struct + Data interface{} + ModelName string + type AviSSLCache struct + Name string + Tenant string + Uuid string + type AviVsCache struct + CloudConfigCksum string + HTTPKeyCollection []NamespaceName + Name string + PGKeyCollection []NamespaceName + PoolKeyCollection []NamespaceName + SNIChildCollection []string + SSLKeyCertCollection []NamespaceName + ServiceMetadata ServiceMetadataObj + Tenant string + Uuid string + Vip []*avimodels.Vip + type CtrlPropCache struct + func SharedCtrlProp() *CtrlPropCache + func (o *CtrlPropCache) GetAllCtrlProp() map[string]string + func (o *CtrlPropCache) PopulateCtrlProp(cp map[string]string) + type EvType string + type EventRecorder struct + Enabled bool + Fake bool + Recorder record.EventRecorder + func NewEventRecorder(id string, kubeClient kubernetes.Interface, fake bool) *EventRecorder + func (e *EventRecorder) Event(object runtime.Object, eventtype, reason, messageFmt string) + func (e *EventRecorder) Eventf(object runtime.Object, eventtype, reason, messageFmt string, ...) + type FullSyncThread struct + Interval time.Duration + QuickSyncChan chan struct{} + QuickSyncFunction func(bool) error + ShutdownChan chan string + Stopped bool + SyncFunction func() + func NewFullSyncThread(interval time.Duration) *FullSyncThread + func (w *FullSyncThread) QuickSync() + func (w *FullSyncThread) Run() + func (w *FullSyncThread) Shutdown() + type Informers struct + ConfigMapInformer coreinformers.ConfigMapInformer + EpInformer coreinformers.EndpointsInformer + IngressClassInformer netinformers.IngressClassInformer + IngressInformer netinformers.IngressInformer + IngressVersion string + MultiClusterIngressInformer akoinformers.MultiClusterIngressInformer + NSInformer coreinformers.NamespaceInformer + NodeInformer coreinformers.NodeInformer + OshiftClient oshiftclientset.Interface + PodInformer coreinformers.PodInformer + RouteInformer oshiftinformers.RouteInformer + SecretInformer coreinformers.SecretInformer + ServiceImportInformer akoinformers.ServiceImportInformer + ServiceInformer coreinformers.ServiceInformer + func GetInformers() *Informers + func NewInformers(kubeClient KubeClientIntf, registeredInformers []string, ...) *Informers + type K8NamespaceList struct + type K8ValidNamespaces struct + EnableMigration bool + func GetGlobalNSFilter() *K8ValidNamespaces + type K8sAviPoolGroupMeta struct + CloudConfigCksum string + Members []*avimodels.PoolGroupMember + Name string + ServiceMetadata ServiceMetadataObj + Tenant string + type K8sAviPoolMeta struct + CloudConfigCksum string + Name string + Port int32 + Protocol string + Servers []AviPoolMetaServer + ServiceMetadata ServiceMetadataObj + Tenant string + type K8sAviVsMeta struct + ApplicationProfile string + CloudConfigCksum string + DefaultPool string + DefaultPoolGroup string + EastWest bool + Name string + NetworkProfile string + PoolGroupMap map[AviPortProtocol]string + PortProto []AviPortProtocol + ServiceMetadata ServiceMetadataObj + Tenant string + type KubeClientIntf struct + ClientSet kubernetes.Interface + type LeaderElector interface + Run func(ctx context.Context, wg *sync.WaitGroup) chan struct{} + func NewLeaderElector(clientset kubernetes.Interface, ...) (LeaderElector, error) + type NamespaceFilter struct + type NamespaceName struct + Name string + Namespace string + func RemoveNamespaceName(s []NamespaceName, r NamespaceName) []NamespaceName + type RestMethod string + const RestDelete + const RestGet + const RestPatch + const RestPost + const RestPut + type RestOp struct + Err error + Message string + Method RestMethod + Model string + Obj interface{} + ObjName string + PatchOp string + Path string + Response interface{} + Tenant string + Version string + type ServiceMetadataObj struct + CrudHashKey string + type SkipSyncError struct + Msg string + func (e *SkipSyncError) Error() string + type Version struct + func NewVersion(version string) (*Version, error) + func (v *Version) Compare(v1 *Version) int + type WebSyncError struct + Err error + Operation string + func (e *WebSyncError) Error() string + func (e *WebSyncError) GetWebAPIError() error + type WorkQueueWrapper struct + func SharedWorkQueue(queueParams ...*WorkerQueue) *WorkQueueWrapper + func (w *WorkQueueWrapper) GetQueueByName(queueName string) *WorkerQueue + type WorkerQueue struct + NumWorkers uint32 + SlowSyncTime int + SyncFunc func(interface{}, *sync.WaitGroup) error + Workqueue []workqueue.RateLimitingInterface + WorkqueueName string + func NewWorkQueue(num_workers uint32, workerQueueName string, slowSyncTime ...int) *WorkerQueue + func (c *WorkerQueue) Run(stopCh <-chan struct{}, wg *sync.WaitGroup) error + func (c *WorkerQueue) StopWorkers(stopCh <-chan struct{})
Go to main page