utils

package
v1.8.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 18, 2019 License: Apache-2.0 Imports: 26 Imported by: 68

Documentation

Overview

Package utils contains shared data structures and functions.

Index

Constants

View Source 
const (
	// Add used to record additions in a sync pool.
	Add = iota
	// Remove used to record removals from a sync pool.
	Remove
	// Sync used to record syncs of a sync pool.
	Sync
	// Get used to record Get from a sync pool.
	Get
	// Create used to record creations in a sync pool.
	Create
	// Update used to record updates in a sync pool.
	Update
	// Delete used to record deltions from a sync pool.
	Delete
	// AddInstances used to record a call to AddInstances.
	AddInstances
	// RemoveInstances used to record a call to RemoveInstances.
	RemoveInstances
	// LabelNodeRoleMaster specifies that a node is a master
	// This is a duplicate definition of the constant in:
	// kubernetes/kubernetes/pkg/controller/service/service_controller.go
	LabelNodeRoleMaster = "node-role.kubernetes.io/master"
	// LabelNodeRoleExcludeBalancer specifies that a node should be excluded from load-balancing
	// This is a duplicate definition of the constant in:
	// kubernetes/kubernetes/pkg/controller/service/service_controller.go
	// This label is feature-gated in kubernetes/kubernetes but we do not have feature gates
	// This will need to be updated after the end of the alpha
	LabelNodeRoleExcludeBalancer = "alpha.service-controller.kubernetes.io/exclude-balancer"
	// ToBeDeletedTaint is the taint that the autoscaler adds when a node is scheduled to be deleted
	// https://github.com/kubernetes/autoscaler/blob/cluster-autoscaler-0.5.2/cluster-autoscaler/utils/deletetaint/delete.go#L33
	ToBeDeletedTaint = "ToBeDeletedByClusterAutoscaler"
)

Variables

View Source 
var (
	KeyFunc = cache.DeletionHandlingMetaNamespaceKeyFunc
)

Functions

func EqualMapping added in v1.2.2 

func EqualMapping(a, b *GCEURLMap) bool

EqualMapping returns true if both maps point to the same ServicePortIDs. ServicePort settings are *not* included in this comparison.

func EqualResourceIDs added in v1.2.2 

func EqualResourceIDs(a, b string) bool

EqualResourceIDs returns true if a and b have equal ResourceIDs which entail the project, location, resource type, and resource name.

func EqualResourcePaths added in v1.2.2 

func EqualResourcePaths(a, b string) bool

EqualResourcePaths returns true if a and b have equal ResourcePaths. Resource paths entail the location, resource type, and resource name.

func FakeGoogleAPIForbiddenErr 

func FakeGoogleAPIForbiddenErr() *googleapi.Error

FakeGoogleAPIForbiddenErr creates a Forbidden error with type googleapi.Error

func FakeGoogleAPINotFoundErr 

func FakeGoogleAPINotFoundErr() *googleapi.Error

FakeGoogleAPINotFoundErr creates a NotFound error with type googleapi.Error

func GetAPIVersionFromServicePort added in v1.8.0 

func GetAPIVersionFromServicePort(sp *ServicePort) meta.Version

GetAPIVersionFromServicePort returns the compute API version to be used for creating NEGs associated with the given ServicePort.

func GetNodeConditionPredicate added in v1.3.0 

func GetNodeConditionPredicate() listers.NodeConditionPredicate

This is a duplicate definition of the function in: kubernetes/kubernetes/pkg/controller/service/service_controller.go

func GetReadyNodeNames added in v1.3.0 

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

GetReadyNodeNames returns names of schedulable, ready nodes from the node lister It also filters out masters and nodes excluded from load-balancing TODO(rramkumar): Add a test for this.

func HasVIP added in v1.8.0 

func HasVIP(ing *v1beta1.Ingress) bool

HasVIP returns true if given ingress has a vip. 

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

IGLinks returns a list of links extracted from the passed in list of compute.InstanceGroup's.

func IgnoreHTTPNotFound 

func IgnoreHTTPNotFound(err error) error

IgnoreHTTPNotFound returns the passed err if it's not a GoogleAPI error with a NotFound status code.

func IsForbiddenError 

func IsForbiddenError(err error) bool

IsForbiddenError returns true if the operation was forbidden

func IsGCEIngress added in v1.3.0 

func IsGCEIngress(ing *v1beta1.Ingress) bool

IsGCEIngress returns true if the Ingress matches the class managed by this controller.

func IsGCEL7ILBIngress added in v1.7.0 

func IsGCEL7ILBIngress(ing *v1beta1.Ingress) bool

IsGCEL7ILBIngress returns true if the given Ingress has ingress.class annotation set to "gce-l7-ilb"

func IsGCEMultiClusterIngress added in v1.3.0 

func IsGCEMultiClusterIngress(ing *v1beta1.Ingress) bool

IsGCEMultiClusterIngress returns true if the given Ingress has ingress.class annotation set to "gce-multi-cluster".

func IsGLBCIngress added in v1.3.2 

func IsGLBCIngress(ing *v1beta1.Ingress) bool

IsGLBCIngress returns true if the given Ingress should be processed by GLBC

func IsHTTPErrorCode 

func IsHTTPErrorCode(err error, code int) bool

IsHTTPErrorCode checks if the given error matches the given HTTP Error code. For this to work the error must be a googleapi Error.

func IsInUsedByError 

func IsInUsedByError(err error) bool

IsInUsedByError returns true if the resource is being used by another GCP resource

func IsNotFoundError 

func IsNotFoundError(err error) bool

IsNotFoundError returns true if the resource does not exist

func JoinErrs added in v1.4.0 

func JoinErrs(errs []error) error

JoinErrs returns an aggregated error based on the passed in list of errors.

func KeyName added in v1.2.2 

func KeyName(url string) (string, error)

KeyName returns the name portion from a full or partial GCP resource URL. Example: 

Input:  https://googleapis.com/v1/compute/projects/my-project/global/backendServices/my-backend
Output: my-backend

func NeedsCleanup added in v1.7.0 

func NeedsCleanup(ing *v1beta1.Ingress) bool

NeedsCleanup returns true if the ingress needs to have its associated resources deleted.

func NewNamespaceIndexer added in v1.3.0 

func NewNamespaceIndexer() cache.Indexers

NewNamespaceIndexer returns a new Indexer for use by SharedIndexInformers

func NodeIsReady 

func NodeIsReady(node *api_v1.Node) bool

NodeIsReady returns true if a node contains at least one condition of type "Ready"

func PrettyJson added in v1.2.2 

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

PrettyJson marshals an object in a human-friendly format.

func RelativeResourceName added in v1.2.2 

func RelativeResourceName(url string) (string, error)

RelativeResourceName returns the project, location, resource, and name from a full/partial GCP resource URL. This removes the endpoint prefix and version. Example: 

Input:  https://googleapis.com/v1/compute/projects/my-project/global/backendServices/my-backend
Output: projects/my-project/global/backendServices/my-backend

func ResourcePath added in v1.2.2 

func ResourcePath(url string) (string, error)

ResourcePath returns the location, resource and name portion from a full or partial GCP resource URL. This removes the endpoint prefix, version, and project. Example: 

Input:  https://googleapis.com/v1/compute/projects/my-project/global/backendServices/my-backend
Output: global/backendServices/my-backend

func ServiceKeyFunc added in v1.4.0 

func ServiceKeyFunc(namespace, name string) string

func SplitAnnotation added in v1.4.0 

func SplitAnnotation(annotation string) []string

SplitAnnotation splits annotation by separator and trims whitespace from each resulting token

func StrategicMergePatchBytes added in v1.4.0 

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

StrategicMergePatchBytes returns a patch between the old and new object using a strategic merge patch. Note: refStruct is a empty struct of the type which the patch is being generated for.

func ToNamespacedName added in v1.2.2 

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

ToNamespacedName returns a types.NamespacedName struct parsed from namespace/name.

func TraverseIngressBackends added in v1.3.2 

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

TraverseIngressBackends traverse thru all backends specified in the input ingress and call process If process return true, then return and stop traversing the backends

Types

type Description added in v1.2.2 

type Description struct {
	ServiceName string   `json:"kubernetes.io/service-name"`
	ServicePort string   `json:"kubernetes.io/service-port"`
	XFeatures   []string `json:"x-features,omitempty"`
}

Description stores the description for a BackendService.

func DescriptionFromString added in v1.2.2 

func DescriptionFromString(descString string) *Description

DescriptionFromString gets a Description from string,

func (Description) String added in v1.2.2 

func (desc Description) String() string

String returns the string representation of a Description.

type FrontendGCAlgorithm added in v1.8.0 

type FrontendGCAlgorithm int

FrontendGCAlgorithm species GC algorithm used for ingress frontend resources. 

const (
	// NoCleanUpNeeded specifies that frontend resources need not be deleted.
	NoCleanUpNeeded FrontendGCAlgorithm = iota
	// CleanupV1FrontendResources specifies that frontend resources for ingresses
	// that use v1 naming scheme need to be deleted.
	CleanupV1FrontendResources
	// CleanupV2FrontendResources specifies that frontend resources for ingresses
	// that use v2 naming scheme need to be deleted.
	CleanupV2FrontendResources
)

type GCEURLMap 

type GCEURLMap struct {
	DefaultBackend *ServicePort
	// HostRules is an ordered list of hostnames, path rule tuples.
	HostRules []HostRule
	// contains filtered or unexported fields
}

GCEURLMap is a simplified representation of a UrlMap somewhere in the middle of a compute.UrlMap and rules in an Ingress spec. This representation maintains three invariants/rules:

  1. All hostnames are unique
  2. All paths for a specific host are unique.
  3. Adding paths for a hostname replaces existing for that host.

func NewGCEURLMap added in v1.2.2 

func NewGCEURLMap() *GCEURLMap

NewGCEURLMap returns an empty GCEURLMap

func (*GCEURLMap) AllServicePorts added in v1.2.2 

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

AllServicePorts return a list of all ServicePorts contained in the GCEURLMap.

func (*GCEURLMap) HostExists added in v1.2.2 

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

HostExists returns true if the given hostname is specified in the GCEURLMap.

func (*GCEURLMap) PathExists added in v1.2.2 

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

PathExists returns true if the given path exists for the given hostname. It will also return the backend associated with that path.

func (*GCEURLMap) PutPathRulesForHost added in v1.2.2 

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

PutPathRulesForHost adds path rules for a single hostname. This function ensures the invariants of the GCEURLMap are maintained. It will log if an invariant violation was found and reconciled. TODO(rramkumar): Surface an error instead of logging.

func (*GCEURLMap) String 

func (g *GCEURLMap) String() string

String dumps a readable version of the GCEURLMap.

type HostRule added in v1.3.0 

type HostRule struct {
	Hostname string
	Paths    []PathRule
}

HostRule encapsulates the Hostname and its list of PathRules.

type PathRule added in v1.2.2 

type PathRule struct {
	Path    string
	Backend ServicePort
}

PathRule encapsulates the information for a single path -> backend mapping.

type PeriodicTaskQueue 

type PeriodicTaskQueue struct {
	// contains filtered or unexported fields
}

PeriodicTaskQueue invokes the given sync function for every work item inserted. If the sync() function results in an error, the item is put on the work queue after a rate-limit.

func NewPeriodicTaskQueue 

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

NewPeriodicTaskQueue creates a new task queue with the default rate limiter.

func NewPeriodicTaskQueueWithLimiter added in v1.4.0 

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

NewPeriodicTaskQueueWithLimiter creates a new task queue with the given sync function and rate limiter. The sync function is called for every element inserted into the queue.

func (*PeriodicTaskQueue) Enqueue 

func (t *PeriodicTaskQueue) Enqueue(objs ...interface{})

Enqueue one or more keys to the work queue.

func (*PeriodicTaskQueue) Run 

func (t *PeriodicTaskQueue) Run()

Run the task queue. This will block until the Shutdown() has been called.

func (*PeriodicTaskQueue) Shutdown 

func (t *PeriodicTaskQueue) Shutdown()

Shutdown shuts down the work queue and waits for the worker to ACK

type ServicePort added in v1.2.2 

type ServicePort struct {
	// Ingress backend-specified service name and port
	ID ServicePortID

	NodePort int64
	// Numerical port of the Service, retrieved from the Service
	Port          int32
	Protocol      annotations.AppProtocol
	TargetPort    string
	NEGEnabled    bool
	L7ILBEnabled  bool
	BackendConfig *backendconfigv1beta1.BackendConfig
	BackendNamer  namer.BackendNamer
}

ServicePort maintains configuration for a single backend.

func NewServicePortWithID added in v1.3.0 

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

NewServicePortWithID returns a ServicePort with only ID.

func (ServicePort) BackendName added in v1.2.2 

func (sp ServicePort) BackendName() string

BackendName returns the name of the backend which would be used for this ServicePort.

func (ServicePort) GetDescription added in v1.2.2 

func (sp ServicePort) GetDescription() Description

GetDescription returns a Description for this ServicePort.

func (ServicePort) IGName added in v1.8.0 

func (sp ServicePort) IGName() string

IGName returns the name of the instance group which would be used for this ServicePort.

type ServicePortID added in v1.2.2 

type ServicePortID struct {
	Service types.NamespacedName
	Port    intstr.IntOrString
}

ServicePortID contains the Service and Port fields.

func BackendToServicePortID added in v1.2.2 

func BackendToServicePortID(be v1beta1.IngressBackend, namespace string) ServicePortID

BackendToServicePortID creates a ServicePortID from a given IngressBackend and namespace.

func (ServicePortID) String added in v1.2.3 

func (id ServicePortID) String() string

type TaskQueue 

type TaskQueue interface {
	Run()
	Enqueue(objs ...interface{})
	Shutdown()
}

TaskQueue is a rate limited operation queue.

type TimeTracker added in v1.2.2 

type TimeTracker struct {
	// contains filtered or unexported fields
}

func NewTimeTracker added in v1.2.2 

func NewTimeTracker() TimeTracker

func (*TimeTracker) Get added in v1.2.2 

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

Get returns previous recorded time

func (*TimeTracker) Set added in v1.2.2 

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

Set records input timestamp

func (*TimeTracker) Track added in v1.2.2 

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

Track records the current time and returns it

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.