kubernetes

Documentation

Index

• func CreateEventRecorder(kubeClient clientset.Interface) kube_record.EventRecorder
• func GetReadinessState(node *apiv1.Node) (isNodeReady bool, lastTransitionTime time.Time, err error)
• func IsNodeReadyAndSchedulable(node *apiv1.Node) bool
• type AllNodeLister
  • func (allNodeLister *AllNodeLister) List() ([]*apiv1.Node, error)
• type DaemonSetLister
  • func NewDaemonSetLister(kubeClient client.Interface, stopchannel <-chan struct{}) DaemonSetLister
• type DaemonSetListerImpl
  • func (lister *DaemonSetListerImpl) List() ([]*extensionsv1.DaemonSet, error)
• type ListerRegistry
  • func NewListerRegistry(allNode NodeLister, readyNode NodeLister, scheduledPod PodLister, ...) ListerRegistry
  • func NewListerRegistryWithDefaultListers(kubeClient client.Interface, stopChannel <-chan struct{}) ListerRegistry
• type NodeLister
  • func NewAllNodeLister(kubeClient client.Interface, stopchannel <-chan struct{}) NodeLister
  • func NewReadyNodeLister(kubeClient client.Interface, stopChannel <-chan struct{}) NodeLister
• type PodDisruptionBudgetLister
  • func NewPodDisruptionBudgetLister(kubeClient client.Interface, stopchannel <-chan struct{}) PodDisruptionBudgetLister
• type PodDisruptionBudgetListerImpl
  • func (lister *PodDisruptionBudgetListerImpl) List() ([]*policyv1.PodDisruptionBudget, error)
• type PodLister
  • func NewScheduledPodLister(kubeClient client.Interface, stopchannel <-chan struct{}) PodLister
  • func NewUnschedulablePodInNamespaceLister(kubeClient client.Interface, namespace string, stopchannel <-chan struct{}) PodLister
  • func NewUnschedulablePodLister(kubeClient client.Interface, stopchannel <-chan struct{}) PodLister
• type ReadyNodeLister
  • func (readyNodeLister *ReadyNodeLister) List() ([]*apiv1.Node, error)
• type ScheduledPodLister
  • func (lister *ScheduledPodLister) List() ([]*apiv1.Pod, error)
• type UnschedulablePodLister
  • func (unschedulablePodLister *UnschedulablePodLister) List() ([]*apiv1.Pod, error)

Functions

func CreateEventRecorder

func CreateEventRecorder(kubeClient clientset.Interface) kube_record.EventRecorder

CreateEventRecorder creates an event recorder to send custom events to Kubernetes to be recorded for targeted Kubernetes objects

func GetReadinessState

func GetReadinessState(node *apiv1.Node) (isNodeReady bool, lastTransitionTime time.Time, err error)

GetReadinessState gets readiness state for the node

func IsNodeReadyAndSchedulable

func IsNodeReadyAndSchedulable(node *apiv1.Node) bool

IsNodeReadyAndSchedulable returns true if the node is ready and schedulable.

Types

type AllNodeLister

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

AllNodeLister lists all nodes

func (*AllNodeLister) List

func (allNodeLister *AllNodeLister) List() ([]*apiv1.Node, error)

List returns all nodes

type DaemonSetLister

type DaemonSetLister interface {
	List() ([]*extensionsv1.DaemonSet, error)
}

DaemonSetLister lists daemonsets.

func NewDaemonSetLister

func NewDaemonSetLister(kubeClient client.Interface, stopchannel <-chan struct{}) DaemonSetLister

NewDaemonSetLister builds a daemonset lister.

type DaemonSetListerImpl

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

DaemonSetListerImpl lists all daemonsets.

func (*DaemonSetListerImpl) List

func (lister *DaemonSetListerImpl) List() ([]*extensionsv1.DaemonSet, error)

List returns all daemon sets

type ListerRegistry

type ListerRegistry interface {
	AllNodeLister() NodeLister
	ReadyNodeLister() NodeLister
	ScheduledPodLister() PodLister
	UnschedulablePodLister() PodLister
	PodDisruptionBudgetLister() PodDisruptionBudgetLister
	DaemonSetLister() DaemonSetLister
}

ListerRegistry is a registry providing various listers to list pods or nodes matching conditions

func NewListerRegistry

func NewListerRegistry(allNode NodeLister, readyNode NodeLister, scheduledPod PodLister,
	unschedulablePod PodLister, podDisruptionBudgetLister PodDisruptionBudgetLister,
	daemonSetLister DaemonSetLister) ListerRegistry

NewListerRegistry returns a registry providing various listers to list pods or nodes matching conditions

func NewListerRegistryWithDefaultListers

func NewListerRegistryWithDefaultListers(kubeClient client.Interface, stopChannel <-chan struct{}) ListerRegistry

NewListerRegistryWithDefaultListers returns a registry filled with listers of the default implementations

type NodeLister

type NodeLister interface {
	List() ([]*apiv1.Node, error)
}

NodeLister lists nodes.

func NewAllNodeLister

func NewAllNodeLister(kubeClient client.Interface, stopchannel <-chan struct{}) NodeLister

NewAllNodeLister builds a node lister that returns all nodes (ready and unready)

func NewReadyNodeLister

func NewReadyNodeLister(kubeClient client.Interface, stopChannel <-chan struct{}) NodeLister

NewReadyNodeLister builds a node lister.

type PodDisruptionBudgetLister

type PodDisruptionBudgetLister interface {
	List() ([]*policyv1.PodDisruptionBudget, error)
}

PodDisruptionBudgetLister lists pod disruption budgets.

func NewPodDisruptionBudgetLister

func NewPodDisruptionBudgetLister(kubeClient client.Interface, stopchannel <-chan struct{}) PodDisruptionBudgetLister

NewPodDisruptionBudgetLister builds a pod disruption budget lister.

type PodDisruptionBudgetListerImpl

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

PodDisruptionBudgetListerImpl lists pod disruption budgets

func (*PodDisruptionBudgetListerImpl) List

func (lister *PodDisruptionBudgetListerImpl) List() ([]*policyv1.PodDisruptionBudget, error)

List returns all pdbs

type PodLister

type PodLister interface {
	List() ([]*apiv1.Pod, error)
}

PodLister lists pods.

func NewScheduledPodLister

func NewScheduledPodLister(kubeClient client.Interface, stopchannel <-chan struct{}) PodLister

NewScheduledPodLister builds ScheduledPodLister

func NewUnschedulablePodInNamespaceLister

func NewUnschedulablePodInNamespaceLister(kubeClient client.Interface, namespace string, stopchannel <-chan struct{}) PodLister

NewUnschedulablePodInNamespaceLister returns a lister providing pods that failed to be scheduled in the given namespace.

func NewUnschedulablePodLister

func NewUnschedulablePodLister(kubeClient client.Interface, stopchannel <-chan struct{}) PodLister

NewUnschedulablePodLister returns a lister providing pods that failed to be scheduled.

type ReadyNodeLister

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

ReadyNodeLister lists ready nodes.

func (*ReadyNodeLister) List

func (readyNodeLister *ReadyNodeLister) List() ([]*apiv1.Node, error)

List returns ready nodes.

type ScheduledPodLister

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

ScheduledPodLister lists scheduled pods.

func (*ScheduledPodLister) List

func (lister *ScheduledPodLister) List() ([]*apiv1.Pod, error)

List returns all scheduled pods.

type UnschedulablePodLister

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

UnschedulablePodLister lists unscheduled pods

func (*UnschedulablePodLister) List

func (unschedulablePodLister *UnschedulablePodLister) List() ([]*apiv1.Pod, error)

List returns all unscheduled pods.