common

Documentation

Overview

GetWindowsNodes returns Windows nodes, optionally filtering the list of nodes with the given filter functions.

Index

• Constants
• func GetExpectedTyphaScale(nodes int) int
• func HasWindowsNodes(c client.Client) (bool, error)
• func MapExistsOrInitialize(m map[string]string) map[string]string
• func MergeMaps(current, desired map[string]string) map[string]string
• func MergeOwnerReferences(desired, current []metav1.OwnerReference) []metav1.OwnerReference
• func OperatorNamespace() string
• func OperatorServiceAccount() string
• func WindowsEnabled(installation operatorv1.InstallationSpec) bool
• type VersionInfo
  • func GetKubernetesVersion(clientset kubernetes.Interface) (*VersionInfo, error)
  • func (v *VersionInfo) ProvidesCertV1API() bool

Constants

const (
	CalicoNamespace               = "calico-system"
	TyphaDeploymentName           = "calico-typha"
	NodeDaemonSetName             = "calico-node"
	KubeControllersDeploymentName = "calico-kube-controllers"
	WindowsDaemonSetName          = "calico-node-windows"

	// Monitor + Prometheus related const
	TigeraPrometheusNamespace = "tigera-prometheus"

	// ComplianceFeature name
	ComplianceFeature = "compliance-reports"
	// ThreatDefenseFeature feature name
	ThreatDefenseFeature = "threat-defense"
	// ExportLogsFeature to 3rd party systems feature name
	ExportLogsFeature = "export-logs"
	// TiersFeature enables creation/update of Tiers
	TiersFeature = "tiers"
	// EgressAccessControl enables creation/update of NetworkPolicy with Domains
	EgressAccessControlFeature = "egress-access-control"
	// PolicyRecommendation feature name
	PolicyRecommendationFeature = "policy-recommendation"
	// MultipleOwnersLabel used to indicate multiple owner references.
	// If the render code places this label on an object, the object mergeState machinery will merge owner
	// references with any that already exist on the object rather than replace the owner references. Further
	// the controller in the owner reference will not be set.
	MultipleOwnersLabel = "operator.tigera.io/multipleOwners"
)

const (
	CalicoWindowsUpgradeResourceName = "calico-windows-upgrade"
)

Functions

func GetExpectedTyphaScale

func GetExpectedTyphaScale(nodes int) int

GetExpectedTyphaScale will return the number of Typhas needed for the number of nodes.

Nodes Replicas

  1-2              1
  3-4              2
 <200              3
 >400              4
 >600              5
 >800              6
>1000              7
...
>2000             12
...
>3600             20

func HasWindowsNodes

func HasWindowsNodes(c client.Client) (bool, error)

func MapExistsOrInitialize

func MapExistsOrInitialize(m map[string]string) map[string]string

MapExistsOrInitialize returns the given map if non-nil or returns an empty map.

func MergeMaps

func MergeMaps(current, desired map[string]string) map[string]string

MergeMaps merges current and desired maps. If both current and desired maps contain the same key, the desired map's value is used. MergeMaps does not copy hash.operator.tigera.io annotations from the current map, since those are managed by the operator.

func MergeOwnerReferences

func MergeOwnerReferences(desired, current []metav1.OwnerReference) []metav1.OwnerReference

MergeOwnerReferences merges desired and current owner references, removing the duplicates.

func OperatorNamespace

func OperatorNamespace() string

OperatorNamespace returns the namespace the operator is running in. The value returned is based on the following priority (these are evaluated at startup):

If the OPERATOR_NAMESPACE environment variable is non-empty then that is return.
If the file /var/run/secrets/kubernetes.io/serviceaccount/namespace is non-empty
then the contents is returned.
The default "tigera-operator" is returned.

func OperatorServiceAccount

func OperatorServiceAccount() string

OperatorServiceAccount returns the ServiceAccount name the operator is running in. The value returned is based on the following priority (these are evaluated at startup):

If the OPERATOR_SERVICEACCOUNT environment variable is non-empty then that is return.
If the file /var/run/secrets/kubernetes.io/serviceaccount/namespace is non-empty
then the contents is returned.
The default "tigera-operator" is returned.

func WindowsEnabled

func WindowsEnabled(installation operatorv1.InstallationSpec) bool

WindowsEnabled returns true if the given Installation enables Windows, false otherwise.

Types

type VersionInfo

type VersionInfo struct {
	Major int
	Minor int
}

VersionInfo contains information about the version of Kubernetes API the cluster is using Major and Minor fields map to the v<Major>.<Minor>+ part of the version string

func GetKubernetesVersion

func GetKubernetesVersion(clientset kubernetes.Interface) (*VersionInfo, error)

func (*VersionInfo) ProvidesCertV1API

func (v *VersionInfo) ProvidesCertV1API() bool

ProvidesCertV1API returns if k8s.io/api/certificates/v1 is supported given the current k8s version