status

Documentation

Index

• Constants
• 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
• type StatusPublisher
  • func NewStatusPublisher() StatusPublisher
• type UpdateCRDStatusOptions
• type UpdateGWStatusConditionOptions
• type UpdateOptions
• type UpdateSvcApiGWStatusConditionOptions

Constants

const GatewayObjectDeletionStatus = "AviGatewayObjectDeletionStatus"

const ObjectDeletionStatus = "AviObjectDeletionStatus"

Functions

func CheckNPLSvcAnnotation

func CheckNPLSvcAnnotation(key, namespace, name string) bool

func DeleteSvcApiStatus

func DeleteSvcApiStatus(key string, svcMetadataObj lib.ServiceMetadataObj) error

func HostRuleEventBroadcast

func HostRuleEventBroadcast(vsName string, vsCacheMetadataOld, vsMetadataNew lib.CRDMetadata)

HostRuleEventBroadcast is responsible from broadcasting HostRule specific events when the VS Cache is Added/Updated/Deleted.

func HttpRuleEventBroadcast

func HttpRuleEventBroadcast(poolName string, poolCacheMetadataOld, vsMetadataNew lib.CRDMetadata)

HttpRuleEventBroadcast is responsible from broadcasting HttpRule specific events when the Pool Cache is Added/Updated/Deleted.

func InitializeGatewayConditions

func InitializeGatewayConditions(gwStatus *advl4v1alpha1pre1.GatewayStatus, gwSpec *advl4v1alpha1pre1.GatewaySpec, gwReady bool)

func InitializeSvcApiGatewayConditions

func InitializeSvcApiGatewayConditions(gwStatus *svcapiv1alpha1.GatewayStatus, gwSpec *svcapiv1alpha1.GatewaySpec, gwReady bool)

func L4RuleEventBroadcast

func L4RuleEventBroadcast(vsName string, vsCacheMetadataOld, vsMetadataNew lib.CRDMetadata)

L4RuleEventBroadcast is responsible from broadcasting L4Rule specific events when the VS Cache is Added/Updated/Deleted.

func L7RuleEventBroadcast

func L7RuleEventBroadcast(vsName string, vsCacheMetadataOld, vsMetadataNew lib.CRDMetadata)

L7RuleEventBroadcast is responsible from broadcasting L7Rule specific events when the VS Cache is Added/Updated/Deleted.

func ParseOptionsFromMetadata

func ParseOptionsFromMetadata(options []UpdateOptions, bulk bool) ([]string, map[string]UpdateOptions)

func PublishToStatusQueue

func PublishToStatusQueue(key string, statusOption StatusOptions)

func ResetStatefulSetStatus

func ResetStatefulSetStatus()

ResetStatefulSetStatus removes the condition set by AKO from AKO statefulset

func SSORuleEventBroadcast

func SSORuleEventBroadcast(vsName string, vsCacheMetadataOld, vsMetadataNew lib.CRDMetadata)

SSORuleEventBroadcast is responsible for broadcasting SSORule specific events when the VS Cache is Added/Updated/Deleted.

func UpdateAviInfraSettingStatus

func UpdateAviInfraSettingStatus(key string, infraSetting *akov1beta1.AviInfraSetting, updateStatus UpdateCRDStatusOptions, retryNum ...int)

UpdateAviInfraSettingStatus AviInfraSetting status updates

func UpdateGatewayStatusGWCondition

func UpdateGatewayStatusGWCondition(key string, gwStatus *advl4v1alpha1pre1.GatewayStatus, updateStatus *UpdateGWStatusConditionOptions)

supported GatewayConditionTypes InvalidListeners, InvalidAddress, *Serviceable

func UpdateGatewayStatusListenerConditions

func UpdateGatewayStatusListenerConditions(key string, gwStatus *advl4v1alpha1pre1.GatewayStatus, portString string, updateStatus *UpdateGWStatusConditionOptions)

supported ListenerConditionType PortConflict, InvalidRoutes, UnsupportedProtocol, *Serviceable pass portString as empty string for updating status in all ports

func UpdateGatewayStatusObject

func UpdateGatewayStatusObject(key string, gw *advl4v1alpha1pre1.Gateway, updateStatus *advl4v1alpha1pre1.GatewayStatus, retryNum ...int)

func UpdateHTTPRuleStatus

func UpdateHTTPRuleStatus(key string, rr *akov1beta1.HTTPRule, updateStatus UpdateCRDStatusOptions, retryNum ...int)

UpdateHTTPRuleStatus HttpRule status updates

func UpdateHostRuleStatus

func UpdateHostRuleStatus(key string, hr *akov1beta1.HostRule, updateStatus UpdateCRDStatusOptions, retryNum ...int)

UpdateHostRuleStatus HostRule status updates

func UpdateL4RuleStatus

func UpdateL4RuleStatus(key string, l4Rule *akov1alpha2.L4Rule, updateStatus UpdateCRDStatusOptions, retryNum ...int)

UpdateL4RuleStatus updates the L4Rule status

func UpdateL7RuleStatus

func UpdateL7RuleStatus(key string, l7Rule *akov1alpha2.L7Rule, updateStatus UpdateCRDStatusOptions, retryNum ...int)

UpdateL7RuleStatus updates the L7Rule status

func UpdateMultiClusterIngressAnnotations

func UpdateMultiClusterIngressAnnotations(mci *akov1alpha1.MultiClusterIngress, vsAnnotations map[string]string, key string) error

func UpdateMultiClusterIngressStatus

func UpdateMultiClusterIngressStatus(key string, mci *akov1alpha1.MultiClusterIngress, status *akov1alpha1.MultiClusterIngressStatus, retryNum ...int)

UpdateMultiClusterIngressStatus updates MultiClusterIngress' status

func UpdateRouteStatusWithErrMsg

func UpdateRouteStatusWithErrMsg(key, routeName, namespace, msg string, retryNum ...int)

func UpdateSSORuleStatus

func UpdateSSORuleStatus(key string, sr *akov1alpha2.SSORule, updateStatus UpdateCRDStatusOptions, retryNum ...int)

UpdateSSORuleStatus SSORule status updates

func UpdateSvcApiGatewayStatusGWCondition

func UpdateSvcApiGatewayStatusGWCondition(key string, gwStatus *svcapiv1alpha1.GatewayStatus, updateStatus *UpdateSvcApiGWStatusConditionOptions)

supported GatewayConditionTypes InvalidListeners, InvalidAddress, *Serviceable

func UpdateSvcApiGatewayStatusListenerConditions

func UpdateSvcApiGatewayStatusListenerConditions(key string, gwStatus *svcapiv1alpha1.GatewayStatus, portString string, updateStatus *UpdateSvcApiGWStatusConditionOptions)

supported ListenerConditionType PortConflict, InvalidRoutes, UnsupportedProtocol, *Serviceable pass portString as empty string for updating status in all ports

func UpdateSvcApiGatewayStatusObject

func UpdateSvcApiGatewayStatusObject(key string, gw *svcapiv1alpha1.Gateway, updateStatus *svcapiv1alpha1.GatewayStatus, retryNum ...int)

Types

type StatusOptions

type StatusOptions struct {
	ObjType   string
	Op        string
	IsVSDel   bool
	ObjName   string
	Namespace string
	Key       string
	Options   *UpdateOptions
}

type StatusPublisher

type StatusPublisher interface {
	DequeueStatus(objIntf interface{}) error

	UpdateL4LBStatus(options []UpdateOptions, bulk bool)
	DeleteL4LBStatus(svc_mdata_obj lib.ServiceMetadataObj, vsName, key string) error

	UpdateIngressStatus(options []UpdateOptions, bulk bool)
	DeleteIngressStatus(options []UpdateOptions, isVSDelete bool, key string) error

	UpdateRouteStatus(options []UpdateOptions, bulk bool)
	DeleteRouteStatus(options []UpdateOptions, isVSDelete bool, key string) error

	UpdateRouteIngressStatus(options []UpdateOptions, bulk bool)
	DeleteRouteIngressStatus(options []UpdateOptions, isVSDelete bool, key string) error

	UpdateGatewayStatusAddress(options []UpdateOptions, bulk bool)
	DeleteGatewayStatusAddress(svcMetadataObj lib.ServiceMetadataObj, key string) error

	UpdateSvcApiGatewayStatusAddress(options []UpdateOptions, bulk bool)
	DeleteSvcApiGatewayStatusAddress(key string, svcMetadataObj lib.ServiceMetadataObj) error

	UpdateNPLAnnotation(key, namespace, name string)
	DeleteNPLAnnotation(key, namespace, name string)

	UpdateMultiClusterIngressStatusAndAnnotation(key string, option *UpdateOptions)
	DeleteMultiClusterIngressStatusAndAnnotation(key string, option *UpdateOptions)

	AddStatefulSetAnnotation(statusName string, reason string)
	ResetStatefulSetAnnotation(statusName string)
}

func NewStatusPublisher

func NewStatusPublisher() StatusPublisher

type UpdateCRDStatusOptions

type UpdateCRDStatusOptions struct {
	Status string
	Error  string
}

UpdateCRDStatusOptions CRD Status Update Options

type UpdateGWStatusConditionOptions

type UpdateGWStatusConditionOptions struct {
	Type    string               // to be casted to the appropriate conditionType
	Status  core.ConditionStatus // True/False/Unknown
	Message string               // extended condition message
	Reason  string               // reason for transition
}

type UpdateOptions

type UpdateOptions struct {
	// IngSvc format: namespace/name, not supposed to be provided by the caller
	IngSvc             string
	Vip                []string
	ServiceMetadata    lib.ServiceMetadataObj
	Key                string
	VirtualServiceUUID string
	VSName             string
}

type UpdateSvcApiGWStatusConditionOptions

type UpdateSvcApiGWStatusConditionOptions struct {
	Type    string                 // to be casted to the appropriate conditionType
	Status  metav1.ConditionStatus // True/False/Unknown
	Message string                 // extended condition message
	Reason  string                 // reason for transition
}