Versions in this module Expand all Collapse all v0 v0.1.0 Mar 7, 2024 Changes in this version + const GatewayObjectDeletionStatus + const ObjectDeletionStatus + func CheckNPLSvcAnnotation(key, namespace, name string) bool + func DeleteSvcApiStatus(key string, svcMetadataObj lib.ServiceMetadataObj) error + func HostRuleEventBroadcast(vsName string, vsCacheMetadataOld, vsMetadataNew lib.CRDMetadata) + func HttpRuleEventBroadcast(poolName string, poolCacheMetadataOld, vsMetadataNew lib.CRDMetadata) + func InitializeGatewayConditions(gwStatus *advl4v1alpha1pre1.GatewayStatus, ...) + func InitializeSvcApiGatewayConditions(gwStatus *svcapiv1alpha1.GatewayStatus, gwSpec *svcapiv1alpha1.GatewaySpec, ...) + func L4RuleEventBroadcast(vsName string, vsCacheMetadataOld, vsMetadataNew lib.CRDMetadata) + func L7RuleEventBroadcast(vsName string, vsCacheMetadataOld, vsMetadataNew lib.CRDMetadata) + func ParseOptionsFromMetadata(options []UpdateOptions, bulk bool) ([]string, map[string]UpdateOptions) + func PublishToStatusQueue(key string, statusOption StatusOptions) + func ResetStatefulSetStatus() + func SSORuleEventBroadcast(vsName string, vsCacheMetadataOld, vsMetadataNew lib.CRDMetadata) + func UpdateAviInfraSettingStatus(key string, infraSetting *akov1beta1.AviInfraSetting, ...) + func UpdateGatewayStatusGWCondition(key string, gwStatus *advl4v1alpha1pre1.GatewayStatus, ...) + func UpdateGatewayStatusListenerConditions(key string, gwStatus *advl4v1alpha1pre1.GatewayStatus, portString string, ...) + func UpdateGatewayStatusObject(key string, gw *advl4v1alpha1pre1.Gateway, ...) + func UpdateHTTPRuleStatus(key string, rr *akov1beta1.HTTPRule, updateStatus UpdateCRDStatusOptions, ...) + func UpdateHostRuleStatus(key string, hr *akov1beta1.HostRule, updateStatus UpdateCRDStatusOptions, ...) + func UpdateL4RuleStatus(key string, l4Rule *akov1alpha2.L4Rule, updateStatus UpdateCRDStatusOptions, ...) + func UpdateL7RuleStatus(key string, l7Rule *akov1alpha2.L7Rule, updateStatus UpdateCRDStatusOptions, ...) + func UpdateMultiClusterIngressAnnotations(mci *akov1alpha1.MultiClusterIngress, vsAnnotations map[string]string, ...) error + func UpdateMultiClusterIngressStatus(key string, mci *akov1alpha1.MultiClusterIngress, ...) + func UpdateRouteStatusWithErrMsg(key, routeName, namespace, msg string, retryNum ...int) + func UpdateSSORuleStatus(key string, sr *akov1alpha2.SSORule, updateStatus UpdateCRDStatusOptions, ...) + func UpdateSvcApiGatewayStatusGWCondition(key string, gwStatus *svcapiv1alpha1.GatewayStatus, ...) + func UpdateSvcApiGatewayStatusListenerConditions(key string, gwStatus *svcapiv1alpha1.GatewayStatus, portString string, ...) + func UpdateSvcApiGatewayStatusObject(key string, gw *svcapiv1alpha1.Gateway, ...) + type StatusOptions struct + IsVSDel bool + Key string + Namespace string + ObjName string + ObjType string + Op string + Options *UpdateOptions + type StatusPublisher interface + AddStatefulSetAnnotation func(statusName string, reason string) + DeleteGatewayStatusAddress func(svcMetadataObj lib.ServiceMetadataObj, key string) error + DeleteIngressStatus func(options []UpdateOptions, isVSDelete bool, key string) error + DeleteL4LBStatus func(svc_mdata_obj lib.ServiceMetadataObj, vsName, key string) error + DeleteMultiClusterIngressStatusAndAnnotation func(key string, option *UpdateOptions) + DeleteNPLAnnotation func(key, namespace, name string) + DeleteRouteIngressStatus func(options []UpdateOptions, isVSDelete bool, key string) error + DeleteRouteStatus func(options []UpdateOptions, isVSDelete bool, key string) error + DeleteSvcApiGatewayStatusAddress func(key string, svcMetadataObj lib.ServiceMetadataObj) error + DequeueStatus func(objIntf interface{}) error + ResetStatefulSetAnnotation func(statusName string) + UpdateGatewayStatusAddress func(options []UpdateOptions, bulk bool) + UpdateIngressStatus func(options []UpdateOptions, bulk bool) + UpdateL4LBStatus func(options []UpdateOptions, bulk bool) + UpdateMultiClusterIngressStatusAndAnnotation func(key string, option *UpdateOptions) + UpdateNPLAnnotation func(key, namespace, name string) + UpdateRouteIngressStatus func(options []UpdateOptions, bulk bool) + UpdateRouteStatus func(options []UpdateOptions, bulk bool) + UpdateSvcApiGatewayStatusAddress func(options []UpdateOptions, bulk bool) + func NewStatusPublisher() StatusPublisher + type UpdateCRDStatusOptions struct + Error string + Status string + type UpdateGWStatusConditionOptions struct + Message string + Reason string + Status core.ConditionStatus + Type string + type UpdateOptions struct + IngSvc string + Key string + ServiceMetadata lib.ServiceMetadataObj + VSName string + Vip []string + VirtualServiceUUID string + type UpdateSvcApiGWStatusConditionOptions struct + Message string + Reason string + Status metav1.ConditionStatus + Type string