Versions in this module Expand all Collapse all v1 v1.8.8 Jun 18, 2024 Changes in this version + const CommonSuccessMessage + const Component + const ConditionType + const MessageResourceFailed + const MessageResourceSynced + const ResourceSyncAborted + const ResourceSynced + func CompareNetworkingV1LBEqual(lb1 []networkingv1.IngressLoadBalancerIngress, ...) bool + func CompareNetworkingV1beta1LBEqual(lb1 []networkingv1beta1.IngressLoadBalancerIngress, ...) bool + func CoreV1ToGatewayV1beta1Addr(lbips []corev1.LoadBalancerIngress) []gatewayv1beta1.GatewayStatusAddress + func CoreV1ToNetworkV1LB(lbips []corev1.LoadBalancerIngress) []networkingv1.IngressLoadBalancerIngress + func CoreV1ToNetworkV1beta1LB(lbips []corev1.LoadBalancerIngress) []networkingv1beta1.IngressLoadBalancerIngress + func DiffGlobalRules(olds, news []*apisixv1.GlobalRule) (added, updated, deleted []*apisixv1.GlobalRule) + func DiffPluginConfigs(olds, news []*apisixv1.PluginConfig) (added, updated, deleted []*apisixv1.PluginConfig) + func DiffPluginMetadatas(olds, news []*apisixv1.PluginMetadata) (added, updated, deleted []*apisixv1.PluginMetadata) + func DiffRoutes(olds, news []*apisixv1.Route) (added, updated, deleted []*apisixv1.Route) + func DiffSSL(olds, news []*apisixv1.Ssl) (added, updated, deleted []*apisixv1.Ssl) + func DiffStreamRoutes(olds, news []*apisixv1.StreamRoute) (added, updated, deleted []*apisixv1.StreamRoute) + func DiffUpstreams(olds, news []*apisixv1.Upstream) (added, updated, deleted []*apisixv1.Upstream) + func Difference(a, b []string) []string + func Equal(a, b []string) bool + func IngressLBStatusIPs(ingressPublishService string, ingressStatusAddress []string, ...) ([]corev1.LoadBalancerIngress, error) + func IngressPublishAddresses(ingressPublishService string, ingressStatusAddress []string, ...) ([]string, error) + func InsertKeyInMap(key string, value interface{}, dest map[string]interface{}) + func IsHostnameMatch(listener, route string) bool + func MatchCRDsIngressClass(resourceIngressClassName string, configIngressClass string) bool + func MatchHostDef(host string) bool + func PtrOf[T any](v T) *T + func RecorderEvent(recorder record.EventRecorder, object runtime.Object, eventtype, reason string, ...) + func RecorderEventS(recorder record.EventRecorder, object runtime.Object, eventtype, reason string, ...) + func ReverseString(s string) string + func SchemeToPort(schema string) int + func SyncManifests(ctx context.Context, apisix apisix.APISIX, clusterName string, ...) error + func TruncateString(s string, max int) string + func VerifyConditions(conditions *[]metav1.Condition, newCondition metav1.Condition) bool + func VerifyGeneration(conditions *[]metav1.Condition, newCondition metav1.Condition) bool + type Manifest struct + GlobalRules []*apisixv1.GlobalRule + PluginConfigs []*apisixv1.PluginConfig + PluginMetadatas []*apisixv1.PluginMetadata + Routes []*apisixv1.Route + SSLs []*apisixv1.Ssl + StreamRoutes []*apisixv1.StreamRoute + Upstreams []*apisixv1.Upstream + func (m *Manifest) Diff(om *Manifest) (added, updated, deleted *Manifest) + type ParallelExecutor struct + func (exec *ParallelExecutor) Add(handler func()) + func (exec *ParallelExecutor) AddE(handler func() error) + func (exec *ParallelExecutor) Errors() []error + func (exec *ParallelExecutor) Wait() v1.8.5 Jun 12, 2024