Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
var ( // ErrCacheSyncFailed is returned by a lister when we fail to synchronize its internal cache. ErrCacheSyncFailed = errors.New("cache sync failed") )
Functions ¶
func NewKubernetesNodeLister ¶
func NewKubernetesNodeLister(client kubernetes.Interface) *kubernetesNodeLister
NewKubernetesNodeLister returns a NodeLister that provides simplified listing of nodes via the underlying client-go SharedInformer APIs
func NewKubernetesPodLister ¶
func NewKubernetesPodLister(client kubernetes.Interface) *kubernetesPodLister
NewKubernetesPodLister returns a PodLister that provides simplified listing of pods via the underlying client-go SharedInformer APIs.
Types ¶
type FakeNodeLister ¶
FakeNodeLister provides a mock NodeLister implementation.
func (*FakeNodeLister) Run ¶
func (l *FakeNodeLister) Run(stopCh <-chan struct{}) error
Run mimics the run loop of a concrete NodeLister.
type FakePodLister ¶
FakePodLister provides a mock PodLister implementation.
func (*FakePodLister) Run ¶
func (l *FakePodLister) Run(stopCh <-chan struct{}) error
Run mimics the run loop of a concrete PodLister.
type NodeLister ¶
type NodeLister interface {
List(selector labels.Selector) (ret []*core_v1.Node, err error)
Run(stopCh <-chan struct{}) error
}
NodeLister lists nodes in a kubernetes cluster. The canonical implementation uses the kubernetes informer mechanism, which is expected to be started via a call to the Run method. Prior to this, a concrete implementation will generally not succesfully return nodes.
type PodLister ¶
type PodLister interface {
List(selector labels.Selector) ([]*core_v1.Pod, error)
Run(stopCh <-chan struct{}) error
}
PodLister lists pods in a kubernetes cluster. The canonical implementation uses the kubernetes informer mechanism, which is expected to be started via a call to the Run method. Prior to this, a concrete implementation will generally not succesfully return pods.
Source Files