kube

Documentation

Index

• func NewPDB(workload *unstructured.Unstructured, ls *metav1.LabelSelector, ...) *policyv1.PodDisruptionBudget
• type Clients
  • func (c *Clients) GetClientset() kubernetes.Interface
  • func (c *Clients) GetNamespacedPDBs(ns string) (map[string][]policyv1.PodDisruptionBudget, error)
  • func (c *Clients) GetNamespacedPods(ns, podName string) (map[string][]corev1.Pod, error)
  • func (c *Clients) GetPodParent(podName, ns string) (metav1.Object, error)
  • func (c *Clients) NewBuilder() *resource.Builder
• type Interface
  • func New(conf genericclioptions.RESTClientGetter) (Interface, error)

Functions

func NewPDB

func NewPDB(workload *unstructured.Unstructured, ls *metav1.LabelSelector, minAvail, maxUnavail *intstr.IntOrString) *policyv1.PodDisruptionBudget

Types

type Clients

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

func (*Clients) GetClientset

func (c *Clients) GetClientset() kubernetes.Interface

func (*Clients) GetNamespacedPDBs

func (c *Clients) GetNamespacedPDBs(ns string) (map[string][]policyv1.PodDisruptionBudget, error)

func (*Clients) GetNamespacedPods

func (c *Clients) GetNamespacedPods(ns, podName string) (map[string][]corev1.Pod, error)

func (*Clients) GetPodParent

func (c *Clients) GetPodParent(podName, ns string) (metav1.Object, error)

func (*Clients) NewBuilder

func (c *Clients) NewBuilder() *resource.Builder

type Interface

type Interface interface {
	GetClientset() kubernetes.Interface
	NewBuilder() *resource.Builder

	GetPodParent(string, string) (metav1.Object, error)
	GetNamespacedPods(string, string) (map[string][]corev1.Pod, error)
	GetNamespacedPDBs(string) (map[string][]policyv1.PodDisruptionBudget, error)
}

func New

func New(conf genericclioptions.RESTClientGetter) (Interface, error)