utils

Oct 25, 2024

Changes in this version

+ func IsUnsupportedNetworkTierError(err error) bool

+ type UnsupportedNetworkTierError struct

+ func NewUnsupportedNetworkTierErr(resourceInErr, networkTier string) *UnsupportedNetworkTierError

+ func (e *UnsupportedNetworkTierError) Error() string

Aug 14, 2024

Changes in this version

+ func MinMaxPortRange[T api_v1.ServicePort | string](svcPorts []T) string

Jun 12, 2024

Changes in this version

+ const LabelNodeSubnet

+ func GetDomainFromGABasePath(basePath string) string

+ func GetNodeNames(nodes []*api_v1.Node) []string

Apr 11, 2024

Changes in this version

type ServicePort

+ func (sp *ServicePort) NEGName() string

Sep 25, 2024

Changes in this version

+ func IsMemberAlreadyExistsError(err error) bool

Feb 12, 2024

Changes in this version

+ func EqualCloudResourceIDs(a, b *cloud.ResourceID) bool

Nov 29, 2023

Changes in this version

+ func IsGCEL7XLBRegionalIngress(ing *networkingv1.Ingress) bool

type ServicePort

+ L7XLBRegionalEnabled bool

Aug 19, 2023

Changes in this version

+ const DualStackSubnetStackType

+ func IsUnsupportedFeatureError(err error, featureName string) bool

+ func SubnetHasIPv6Range(cloud *gce.Cloud, subnetName, ipv6AccessType string) (bool, error)

+ type UserError struct

+ func NewUserError(err error) *UserError

+ func (e *UserError) Error() string

Jul 6, 2023

Changes in this version

+ func IsGCEServerError(err error) bool

+ func IsK8sServerError(err error) bool

+ func IsQuotaExceededError(err error) bool

type ServicePort

+ THCConfiguration THCConfiguration

+ type THCConfiguration struct

+ THCEvents THCEvents

+ THCOptInOnSvc bool

+ type THCEvents struct

+ BackendConfigOverridesTHC bool

+ THCAnnotationWithoutFlag bool

+ THCAnnotationWithoutNEG bool

+ THCConfigured bool

Apr 17, 2023

Changes in this version

+ func DeepCopyComputeHealthCheck(src *compute.HealthCheck) *compute.HealthCheck

Feb 10, 2023

Changes in this version

+ func AddIPToLBStatus(status *api_v1.LoadBalancerStatus, ips ...string) *api_v1.LoadBalancerStatus

+ func IPv4ServiceSourceRanges(service *v1.Service) ([]string, error)

+ func IPv6ServiceSourceRanges(service *v1.Service) ([]string, error)

+ func IsInvalidLoadBalancerSourceRangesAnnotationError(err error) bool

+ func IsInvalidLoadBalancerSourceRangesSpecError(err error) bool

+ func IsSubnetworkMissingIPv6GCEError(err error) bool

+ func MakeL4IPv6ForwardingRuleDescription(service *api_v1.Service) (string, error)

+ func NeedsIPv4(service *v1.Service) bool

+ func NeedsIPv6(service *v1.Service) bool

+ type InvalidLoadBalancerSourceRangesAnnotationError struct

+ LoadBalancerSourceRangesAnnotation string

+ ParseErr error

+ func NewInvalidLoadBalancerSourceRangesAnnotationError(serviceLoadBalancerSourceRangesAnnotation string, err error) *InvalidLoadBalancerSourceRangesAnnotationError

+ func (e *InvalidLoadBalancerSourceRangesAnnotationError) Error() string

+ type InvalidLoadBalancerSourceRangesSpecError struct

+ LoadBalancerSourceRangesSpec []string

+ ParseErr error

+ func NewInvalidSpecLoadBalancerSourceRangesError(specLoadBalancerSourceRanges []string, err error) *InvalidLoadBalancerSourceRangesSpecError

+ func (e *InvalidLoadBalancerSourceRangesSpecError) Error() string

Feb 13, 2023

Changes in this version

+ func IsIPConfigurationError(err error) bool

+ type IPConfigurationError struct

+ func NewIPConfigurationError(ip, reason string) *IPConfigurationError

+ func (e *IPConfigurationError) Error() string

Oct 15, 2022

Changes in this version

+ func GetNodePorts(svcPorts []api_v1.ServicePort) []int64

+ func GetPorts(svcPorts []api_v1.ServicePort) []string

+ func GetProtocol(svcPorts []api_v1.ServicePort) api_v1.Protocol

+ func GetServicePortRanges(svcPorts []api_v1.ServicePort) []string

Aug 8, 2022

Changes in this version

+ func GetServiceNodePort(service *api_v1.Service) int64

+ func IsLoadBalancerServiceType(service *api_v1.Service) bool

Jun 2, 2022

Changes in this version

+ func IsNetworkTierError(err error) bool

+ func IsNetworkTierMismatchGCEError(err error) bool

+ func IsUserError(err error) bool

+ func MakeL4LBFirewallDescription(svcName, ip string, version meta.Version, shared bool) (string, error)

+ type NetworkTierError struct

+ func NewNetworkTierErr(resourceInErr, desired, received string) *NetworkTierError

+ func (e *NetworkTierError) Error() string

Mar 21, 2022

Changes in this version

+ func HasL4NetLBFinalizerV2(svc *api_v1.Service) bool

Jan 8, 2022

Changes in this version

+ const L4LBSharedResourcesDesc

+ func GetNetworkTier(service *api_v1.Service) (cloud.NetworkTier, bool)

+ func IsL4NetLBService(svc *api_v1.Service) bool

+ func IsLegacyL4NetLBService(svc *api_v1.Service) bool

+ func MakeL4LBServiceDescription(svcName, ip string, version meta.Version, shared bool, lbType L4LBType) (string, error)

+ func MinMaxPortRangeAndProtocol(svcPorts []api_v1.ServicePort) (portRange, protocol string)

+ type L4LBResourceDescription struct

+ APIVersion meta.Version

+ ResourceDescription string

+ ServiceIP string

+ ServiceName string

+ func (d *L4LBResourceDescription) Marshal() (string, error)

+ func (d *L4LBResourceDescription) Unmarshal(desc string) error

+ type L4LBType int

+ const ILB

+ const XLB

+ func (lbType L4LBType) ToString() string

type ServicePort

+ L4RBSEnabled bool

Nov 23, 2021

Changes in this version

+ const GKECurrentOperationLabel

+ const NodeDrain

Sep 24, 2021

Changes in this version

+ var AllNodesPredicate = func(node *api_v1.Node) bool

+ var CandidateNodesPredicate = func(node *api_v1.Node) bool

+ var CandidateNodesPredicateIncludeUnreadyExcludeUpgradingNodes = func(node *api_v1.Node) bool

type ServicePort

+ CapacityScaler *float64

+ MaxRatePerEndpoint *float64

+ PortName string

Sep 8, 2021

Changes in this version

type NodeConditionPredicate

+ func NodeConditionPredicateIncludeUnreadyExcludeUpgradingNodes() NodeConditionPredicate

Aug 13, 2021

Changes in this version

+ const GKECurrentOperationAnnotation

+ const GKEUpgradeOperation

type NodeConditionPredicate

+ func NodeConditionPredicateIncludeUnreadyNodes() NodeConditionPredicate

Jul 1, 2021

Changes in this version

+ func GetBasePath(cloud *gce.Cloud) string

Sep 16, 2021

Changes in this version

+ func IsSubsettingL4ILBService(svc *api_v1.Service) bool

+ func LegacyForwardingRuleName(svc *api_v1.Service) string

May 14, 2021

Changes in this version

+ func GetErrorType(err error) string

Apr 13, 2021

Changes in this version

+ const L4ILBSharedResourcesDesc

type L4ILBResourceDescription

+ ResourceDescription string

type PeriodicTaskQueue

+ func (t *PeriodicTaskQueue) Len() int

+ func (t *PeriodicTaskQueue) NumRequeues(obj interface{}) int

+ type PeriodicTaskQueueWithMultipleWorkers struct

+ func NewPeriodicTaskQueueWithMultipleWorkers(name, resource string, numWorkers int, syncFn func(string) error) *PeriodicTaskQueueWithMultipleWorkers

+ func (t *PeriodicTaskQueueWithMultipleWorkers) Enqueue(objs ...interface{})

+ func (t *PeriodicTaskQueueWithMultipleWorkers) Len() int

+ func (t *PeriodicTaskQueueWithMultipleWorkers) NumRequeues(obj interface{}) int

+ func (t *PeriodicTaskQueueWithMultipleWorkers) Run()

+ func (t *PeriodicTaskQueueWithMultipleWorkers) Shutdown()

type TaskQueue

+ Len func() int

+ NumRequeues func(obj interface{}) int

Oct 23, 2020

Changes in this version

+ func VerifyDescription(expectDesc NegDescription, descString, negName, zone string) (bool, error)

Aug 6, 2020

Changes in this version

+ const LabelAlphaNodeRoleExcludeBalancer

+ const LegacyNodeRoleBehaviorFeature

+ const ServiceNodeExclusionFeature

+ func BetaToAlphaHealthCheck(hc *computebeta.HealthCheck) (*computealpha.HealthCheck, error)

+ func ListWithPredicate(nodeLister listers.NodeLister, predicate NodeConditionPredicate) ([]*api_v1.Node, error)

+ func MergePatchBytes(old, cur interface{}) ([]byte, error)

+ func ToBetaHealthCheck(hc *computealpha.HealthCheck) (*computebeta.HealthCheck, error)

+ func ToV1HealthCheck(hc *computealpha.HealthCheck) (*compute.HealthCheck, error)

+ func V1ToAlphaHealthCheck(hc *compute.HealthCheck) (*computealpha.HealthCheck, error)

+ type NegDescription struct

+ ClusterUID string

+ Namespace string

+ Port string

+ ServiceName string

+ func NegDescriptionFromString(descString string) (*NegDescription, error)

+ func (desc NegDescription) String() string

+ type NodeConditionPredicate func(node *api_v1.Node) bool

Oct 14, 2020

Changes in this version

type FrontendGCAlgorithm

+ const CleanupV2FrontendResourcesScopeChange

Aug 31, 2020

Changes in this version

+ func NewInt64Pointer(i int64) *int64

May 27, 2020

Changes in this version

type ServicePort

+ VMIPNEGEnabled bool

Mar 9, 2020

Changes in this version

+ const L4ILBServiceDescKey

+ func EqualStringSets(x, y []string) bool

+ func GetNodePrimaryIP(inputNode *api_v1.Node) string

+ func GetPortRanges(ports []int) (ranges []string)

+ func GetPortsAndProtocol(svcPorts []api_v1.ServicePort) (ports []string, portRanges []string, protocol api_v1.Protocol)

+ func IsLegacyL4ILBService(svc *api_v1.Service) bool

+ func MakeL4ILBServiceDescription(svcName, ip string, version meta.Version) (string, error)

+ func NewStringPointer(s string) *string

+ func NumEndpoints(ep *api_v1.Endpoints) (result int)

+ func PatchService(c corev1.CoreV1Interface, oldSvc, newSvc *v1.Service) (*v1.Service, error)

+ func TranslateAffinityType(affinityType string) string

+ type L4ILBResourceDescription struct

+ APIVersion meta.Version

+ ServiceIP string

+ ServiceName string

+ func (d *L4ILBResourceDescription) Marshal() (string, error)

+ func (d *L4ILBResourceDescription) Unmarshal(desc string) error

type ServicePort

+ PrimaryIPNEGEnabled bool

Nov 18, 2019

Changes in this version

+ func GetAPIVersionFromServicePort(sp *ServicePort) meta.Version

+ func HasVIP(ing *v1beta1.Ingress) bool

+ type FrontendGCAlgorithm int

+ const CleanupV1FrontendResources

+ const CleanupV2FrontendResources

+ const NoCleanUpNeeded

type ServicePort

+ BackendNamer namer.BackendNamer

+ func (sp ServicePort) IGName() string

Sep 26, 2019

Changes in this version

+ const ToBeDeletedTaint

+ func IsGCEL7ILBIngress(ing *v1beta1.Ingress) bool

+ func NeedsCleanup(ing *v1beta1.Ingress) bool

type Namer

+ func (n *Namer) NEGWithSubset(namespace, name, subset string, port int32) string

type ServicePort

+ L7ILBEnabled bool

Feb 27, 2019

Changes in this version

+ const FinalizerKey

+ func AddFinalizer(ing *extensions.Ingress, ingClient client.IngressInterface) error

+ func RemoveFinalizer(ing *extensions.Ingress, ingClient client.IngressInterface) error

type NameComponents

+ LbName string

type Namer

+ func (n *Namer) LoadBalancerFromLbName(lbName string) string

Nov 1, 2018

Changes in this version

+ const FinalizerKeySuffix

+ func HasFinalizer(m meta_v1.ObjectMeta, key string) bool

+ func IsDeletionCandidate(m meta_v1.ObjectMeta, key string) bool

+ func JoinErrs(errs []error) error

+ func NeedToAddFinalizer(m meta_v1.ObjectMeta, key string) bool

+ func ServiceKeyFunc(namespace, name string) string

+ func SplitAnnotation(annotation string) []string

+ func StrategicMergePatchBytes(old, cur, refStruct interface{}) ([]byte, error)

+ func TrimFieldsEvenly(max int, fields ...string) []string

type PeriodicTaskQueue

+ func NewPeriodicTaskQueueWithLimiter(resource string, syncFn func(string) error, rl workqueue.RateLimiter) *PeriodicTaskQueue

Aug 31, 2018

Changes in this version

+ func IngressKeyFunc(ing *extensions.Ingress) string

+ func IsGLBCIngress(ing *extensions.Ingress) bool

+ func TraverseIngressBackends(ing *extensions.Ingress, process func(id ServicePortID) bool)

Aug 16, 2018

Changes in this version

+ const LabelNodeRoleExcludeBalancer

+ const LabelNodeRoleMaster

+ var KeyFunc = cache.DeletionHandlingMetaNamespaceKeyFunc

+ func GetNodeConditionPredicate() listers.NodeConditionPredicate

+ func GetReadyNodeNames(lister listers.NodeLister) ([]string, error)

+ func IsGCEIngress(ing *extensions.Ingress) bool

+ func IsGCEMultiClusterIngress(ing *extensions.Ingress) bool

+ func NewNamespaceIndexer() cache.Indexers

+ type HostRule struct

+ Hostname string

+ Paths []PathRule

+ type Joiner struct

+ func NewJoiner(ingLister StoreToIngressLister, svcLister cache.Indexer, ...) *Joiner

+ func (j *Joiner) IngressesForBackendConfig(beConfig *backendconfigv1beta1.BackendConfig) (ingList []*extensions.Ingress)

+ func (j *Joiner) IngressesForService(svc *api_v1.Service) (ingList []*extensions.Ingress)

type ServicePort

+ func NewServicePortWithID(svcName, svcNamespace string, port intstr.IntOrString) ServicePort

+ type StoreToIngressLister struct

+ func (s *StoreToIngressLister) GetServiceIngress(svc *api_v1.Service, systemDefaultBackend ServicePortID) (ings []extensions.Ingress, err error)

+ func (s *StoreToIngressLister) ListAll() (ing extensions.IngressList, err error)

+ func (s *StoreToIngressLister) ListGCEIngresses() (ing extensions.IngressList, err error)

Jul 19, 2018

Changes in this version

type ServicePortID

+ func (id ServicePortID) String() string

Jul 9, 2018

Changes in this version

+ func EqualMapping(a, b *GCEURLMap) bool

+ func EqualResourceIDs(a, b string) bool

+ func EqualResourcePaths(a, b string) bool

+ func IGLinks(igs []*compute.InstanceGroup) (igLinks []string)

+ func KeyName(url string) (string, error)

+ func PrettyJson(data interface{}) (string, error)

+ func RelativeResourceName(url string) (string, error)

+ func ResourcePath(url string) (string, error)

+ func ToNamespacedName(s string) (r types.NamespacedName, err error)

+ type Description struct

+ ServiceName string

+ ServicePort string

+ XFeatures []string

+ func DescriptionFromString(descString string) *Description

+ func (desc *Description) String() string

type GCEURLMap

+ DefaultBackend *ServicePort

+ HostRules map[string][]PathRule

+ func NewGCEURLMap() *GCEURLMap

+ func (g *GCEURLMap) AllServicePorts() (svcPorts []ServicePort)

+ func (g *GCEURLMap) HostExists(hostname string) bool

+ func (g *GCEURLMap) PathExists(hostname, path string) (bool, ServicePort)

+ func (g *GCEURLMap) PutPathRulesForHost(hostname string, pathRules []PathRule)

type Namer

+ func (n *Namer) IGBackend(port int64) string

+ func (n *Namer) IGBackendPort(beName string) (string, error)

+ type PathRule struct

+ Backend ServicePort

+ Path string

+ type ServicePort struct

+ BackendConfig *backendconfigv1beta1.BackendConfig

+ ID ServicePortID

+ NEGEnabled bool

+ NodePort int64

+ Port int32

+ Protocol annotations.AppProtocol

+ TargetPort string

+ func (sp ServicePort) BackendName(namer *Namer) string

+ func (sp ServicePort) GetDescription() Description

+ type ServicePortID struct

+ Port intstr.IntOrString

+ Service types.NamespacedName

+ func BackendToServicePortID(be extensions.IngressBackend, namespace string) ServicePortID

+ type TimeTracker struct

+ func NewTimeTracker() TimeTracker

+ func (t *TimeTracker) Get() time.Time

+ func (t *TimeTracker) Set(timestamp time.Time)

+ func (t *TimeTracker) Track() time.Time

Apr 11, 2018

Changes in this version

type Namer

+ func (n *Namer) IsCertUsedForLB(lbName, resourceName string) bool

+ func (n *Namer) IsLegacySSLCert(lbName string, resourceName string) bool

+ func (n *Namer) SSLCertName(lbName string, secretHash string) string

Mar 16, 2018

Changes in this version

+ const Add

+ const AddInstances

+ const Create

+ const DefaultBackendKey

+ const Delete

+ const Get

+ const Remove

+ const RemoveInstances

+ const Sync

+ const Update

+ func CompareLinks(l1, l2 string) bool

+ func FakeGoogleAPIForbiddenErr() *googleapi.Error

+ func FakeGoogleAPINotFoundErr() *googleapi.Error

+ func IgnoreHTTPNotFound(err error) error

+ func IsForbiddenError(err error) bool

+ func IsHTTPErrorCode(err error, code int) bool

+ func IsInUsedByError(err error) bool

+ func IsNotFoundError(err error) bool

+ func NodeIsReady(node *v1.Node) bool

+ type FakeIngressRuleValueMap map[string]string

+ type GCEURLMap map[string]map[string]*compute.BackendService

+ func (g GCEURLMap) GetDefaultBackend() *compute.BackendService

+ func (g GCEURLMap) PutDefaultBackend(d *compute.BackendService)

+ func (g GCEURLMap) String() string

+ type NameComponents struct

+ ClusterName string

+ Metadata string

+ Resource string

+ type Namer struct

+ func NewNamer(clusterName, firewallName string) *Namer

+ func NewNamerWithPrefix(prefix, clusterName, firewallName string) *Namer

+ func (n *Namer) Backend(port int64) string

+ func (n *Namer) BackendPort(beName string) (string, error)

+ func (n *Namer) Firewall() string

+ func (n *Namer) FirewallRule() string

+ func (n *Namer) ForwardingRule(lbName string, protocol NamerProtocol) string

+ func (n *Namer) InstanceGroup() string

+ func (n *Namer) IsNEG(name string) bool

+ func (n *Namer) IsSSLCert(name string) bool

+ func (n *Namer) LoadBalancer(key string) string

+ func (n *Namer) NEG(namespace, name, port string) string

+ func (n *Namer) NameBelongsToCluster(name string) bool

+ func (n *Namer) NamedPort(port int64) string

+ func (n *Namer) ParseName(name string) *NameComponents

+ func (n *Namer) SSLCert(lbName string, isPrimary bool) string

+ func (n *Namer) SetFirewall(name string)

+ func (n *Namer) SetUID(name string)

+ func (n *Namer) TargetProxy(lbName string, protocol NamerProtocol) string

+ func (n *Namer) UID() string

+ func (n *Namer) UrlMap(lbName string) string

+ type NamerProtocol string

+ const HTTPProtocol

+ const HTTPSProtocol

+ type PeriodicTaskQueue struct

+ func NewPeriodicTaskQueue(resource string, syncFn func(string) error) *PeriodicTaskQueue

+ func (t *PeriodicTaskQueue) Enqueue(obj interface{})

+ func (t *PeriodicTaskQueue) Run(period time.Duration, stopCh <-chan struct{})

+ func (t *PeriodicTaskQueue) Shutdown()

+ type TaskQueue interface

+ Enqueue func(obj interface{})

+ Run func(period time.Duration, stopCh <-chan struct{})

+ Shutdown func()