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
- type DaemonSetLister
- type DaemonSetListerImpl
- type ListerRegistry
- type NodeLister
- type NotReadyNodeLister
- type PodDisruptionBudgetLister
- type PodDisruptionBudgetListerImpl
- 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
- type ScheduledPodLister
- type UnschedulablePodLister
Constants ¶
This section is empty.
Variables ¶
This section is empty.
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 ¶
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
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
NotReadyNodeLister() 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, notReadyNode 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 ¶
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 NewNotReadyNodeLister ¶
func NewNotReadyNodeLister(kubeClient client.Interface, stopChannel <-chan struct{}) NodeLister
NewReadyNodeLister builds a node lister.
func NewReadyNodeLister ¶
func NewReadyNodeLister(kubeClient client.Interface, stopChannel <-chan struct{}) NodeLister
NewReadyNodeLister builds a node lister.
type NotReadyNodeLister ¶
type NotReadyNodeLister struct {
// contains filtered or unexported fields
}
NotReadyNodeLister lists ready nodes.
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 ¶
PodLister lists pods.
func NewScheduledPodLister ¶
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 ¶
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.
type ScheduledPodLister ¶
type ScheduledPodLister struct {
// contains filtered or unexported fields
}
ScheduledPodLister lists scheduled pods.
type UnschedulablePodLister ¶
type UnschedulablePodLister struct {
// contains filtered or unexported fields
}
UnschedulablePodLister lists unscheduled pods
Source Files