utils

Documentation

Index

• Constants
• func CompareLinks(l1, l2 string) bool
• func IsHTTPErrorCode(err error, code int) bool
• type FakeIngressRuleValueMap
• type GCEURLMap
  • func (g GCEURLMap) GetDefaultBackend() *compute.BackendService
  • func (g GCEURLMap) PutDefaultBackend(d *compute.BackendService)
  • func (g GCEURLMap) String() string
• type Namer
  • func (n *Namer) BeName(port int64) string
  • func (n *Namer) BePort(beName string) (string, error)
  • func (n *Namer) IGName() string
  • func (n *Namer) LBName(key string) string
  • func (n *Namer) NameBelongsToCluster(name string) bool
  • func (n *Namer) Truncate(key string) string

Constants

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 recrod 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

	// DefaultBackendKey is the key used to transmit the defaultBackend through
	// a urlmap. It's not a valid subdomain, and it is a catch all path.
	// TODO: Find a better way to transmit this, once we've decided on default
	// backend semantics (i.e do we want a default per host, per lb etc).
	DefaultBackendKey = "DefaultBackend"

	// K8sAnnotationPrefix is the prefix used in annotations used to record
	// debug information in the Ingress annotations.
	K8sAnnotationPrefix = "ingress.kubernetes.io"
)

Functions

func CompareLinks

func CompareLinks(l1, l2 string) bool

CompareLinks returns true if the 2 self links are equal.

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.

Types

type FakeIngressRuleValueMap

type FakeIngressRuleValueMap map[string]string

FakeIngressRuleValueMap is a convenience type used by multiple submodules that share the same testing methods.

type GCEURLMap

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

GCEURLMap is a nested map of hostname->path regex->backend

func (GCEURLMap) GetDefaultBackend

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

GetDefaultBackend performs a destructive read and returns the default backend of the urlmap.

func (GCEURLMap) PutDefaultBackend

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

PutDefaultBackend performs a destructive write replacing the default backend of the url map with the given backend.

func (GCEURLMap) String

func (g GCEURLMap) String() string

String implements the string interface for the GCEURLMap.

type Namer

type Namer struct {
	ClusterName string
}

Namer handles centralized naming for the cluster.

func (*Namer) BeName

func (n *Namer) BeName(port int64) string

BeName constructs the name for a backend.

func (*Namer) BePort

func (n *Namer) BePort(beName string) (string, error)

BePort retrieves the port from the given backend name.

func (*Namer) IGName

func (n *Namer) IGName() string

IGName constructs the name for an Instance Group.

func (*Namer) LBName

func (n *Namer) LBName(key string) string

LBName constructs a loadbalancer name from the given key. The key is usually the namespace/name of a Kubernetes Ingress.

func (*Namer) NameBelongsToCluster

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

NameBelongsToCluster checks if a given name is tagged with this cluster's UID.

func (*Namer) Truncate

func (n *Namer) Truncate(key string) string

Truncate truncates the given key to a GCE length limit.