podlocality

Documentation

Index

• Constants
• func Add(mgr manager.Manager) error
• type PodLocalityReconciler
  • func (r *PodLocalityReconciler) Reconcile(request reconcile.Request) (reconcile.Result, error)

Constants

const (

	// NodeRegionLabel is the well-known label for kubernetes node region
	NodeRegionLabel = "failure-domain.beta.kubernetes.io/region"
	// NodeZoneLabel is the well-known label for kubernetes node zone
	NodeZoneLabel = "failure-domain.beta.kubernetes.io/zone"
	// NodeRegionLabelGA is the well-known label for kubernetes node region in ga
	NodeRegionLabelGA = "topology.kubernetes.io/region"
	// NodeZoneLabelGA is the well-known label for kubernetes node zone in ga
	NodeZoneLabelGA = "topology.kubernetes.io/zone"
	// IstioSubzoneLabel is custom subzone label for locality-based routing in Kubernetes see: https://github.com/istio/istio/issues/19114
	IstioSubzoneLabel = "topology.istio.io/subzone"
	// IstioSidecarStatusAnnotation is the annotation Istio adds to the pod when the sidecar is injected
	IstioSidecarStatusAnnotation = "sidecar.istio.io/status"
)

Functions

func Add

func Add(mgr manager.Manager) error

Add creates a new PodLocality Controller and adds it to the Manager. The Manager will set fields on the Controller and Start it when the Manager is Started.

Types

type PodLocalityReconciler

type PodLocalityReconciler struct {
	// This client, initialized using mgr.Client() above, is a split client
	// that reads objects from the cache and writes to the apiserver
	common.ControllerResources
}

PodLocalityReconciler copies the node's region/zone labels to the pod after it's scheduled to a node

func (*PodLocalityReconciler) Reconcile

func (r *PodLocalityReconciler) Reconcile(request reconcile.Request) (reconcile.Result, error)

The Controller will requeue the Request to be processed again if the returned error is non-nil or Result.Requeue is true, otherwise upon completion it will remove the work from the queue.