kubernetes

Documentation

Index

• Constants
• func Client() (*kubernetes.Clientset, error)
• func DeploymentsIndexInformer(client kubernetes.Interface, namespace string, fieldSelector fields.Selector, ...) cache.SharedIndexInformer
• func EndpointsIndexInformer(client kubernetes.Interface, namespace string, fieldSelector fields.Selector, ...) cache.SharedIndexInformer
• func GetMinReplicas(annotations map[string]string, defaultVal int32) int32
• func NodesIndexInformer(client kubernetes.Interface, namespace string, fieldSelector fields.Selector, ...) cache.SharedIndexInformer
• func PodIsEligibleForProxyInjection(annotations map[string]string) bool
• func PodsIndexInformer(client kubernetes.Interface, namespace string, fieldSelector fields.Selector, ...) cache.SharedIndexInformer
• func ServiceIsEligibleForEndpointsManagement(annotations map[string]string) bool
• func ServicesIndexInformer(client kubernetes.Interface, namespace string, fieldSelector fields.Selector, ...) cache.SharedIndexInformer
• func StatefulSetsIndexInformer(client kubernetes.Interface, namespace string, fieldSelector fields.Selector, ...) cache.SharedIndexInformer
• func WorkloadIsEligibleForAutoScaling(annotations map[string]string) bool
• type PatchOperation

Constants

const (
	IgnoredPathsAnnotationName         = "osiris.dm.gg/ignoredPaths"
	MetricsCollectorAnnotationName     = "osiris.dm.gg/metricsCollector"
	MetricsCheckIntervalAnnotationName = "osiris.dm.gg/metricsCheckInterval"
)

Functions

func Client

func Client() (*kubernetes.Clientset, error)

Client returns a new Kubernetes client

func DeploymentsIndexInformer

func DeploymentsIndexInformer(
	client kubernetes.Interface,
	namespace string,
	fieldSelector fields.Selector,
	labelSelector labels.Selector,
	resyncPeriod time.Duration,
) cache.SharedIndexInformer

func EndpointsIndexInformer

func EndpointsIndexInformer(
	client kubernetes.Interface,
	namespace string,
	fieldSelector fields.Selector,
	labelSelector labels.Selector,
	resyncPeriod time.Duration,
) cache.SharedIndexInformer

func GetMinReplicas

func GetMinReplicas(annotations map[string]string, defaultVal int32) int32

GetMinReplicas gets the minimum number of replicas required for scale up from the annotations. If it fails to do so, it returns the default value instead.

func NodesIndexInformer

func NodesIndexInformer(
	client kubernetes.Interface,
	namespace string,
	fieldSelector fields.Selector,
	labelSelector labels.Selector,
	resyncPeriod time.Duration,
) cache.SharedIndexInformer

func PodIsEligibleForProxyInjection

func PodIsEligibleForProxyInjection(annotations map[string]string) bool

PodIsEligibleForProxyInjection checks the annotations to see if the pod is eligible for proxy injection or not.

func PodsIndexInformer

func PodsIndexInformer(
	client kubernetes.Interface,
	namespace string,
	fieldSelector fields.Selector,
	labelSelector labels.Selector,
	resyncPeriod time.Duration,
) cache.SharedIndexInformer

func ServiceIsEligibleForEndpointsManagement

func ServiceIsEligibleForEndpointsManagement(annotations map[string]string) bool

ServiceIsEligibleForEndpointsManagement checks the annotations to see if the service is eligible for management of its endpoints by osiris or not.

func ServicesIndexInformer

func ServicesIndexInformer(
	client kubernetes.Interface,
	namespace string,
	fieldSelector fields.Selector,
	labelSelector labels.Selector,
	resyncPeriod time.Duration,
) cache.SharedIndexInformer

func StatefulSetsIndexInformer

func StatefulSetsIndexInformer(
	client kubernetes.Interface,
	namespace string,
	fieldSelector fields.Selector,
	labelSelector labels.Selector,
	resyncPeriod time.Duration,
) cache.SharedIndexInformer

func WorkloadIsEligibleForAutoScaling

func WorkloadIsEligibleForAutoScaling(annotations map[string]string) bool

WorkloadIsEligibleForAutoScaling checks the annotations to see if the workload (deployment or statefulset) is eligible for auto-scaling with osiris or not.

Types

type PatchOperation

type PatchOperation struct {
	Op    string      `json:"op"`
	Path  string      `json:"path"`
	Value interface{} `json:"value,omitempty"`
}

PatchOperation represents a discreet change to be applied to a Kubernetes resource