k8sagent

Documentation

Overview

Package k8sagent contains machinery for getting pod data from the Kubernetes API.

Index

• type PodWatcher
• type PodWatcherImpl
  • func NewPodWatcher(namespace string, labelSelector string, fieldSelector string, ...) *PodWatcherImpl
  • func (w *PodWatcherImpl) DeletedPods() chan types.UID
  • func (w *PodWatcherImpl) Get(uid types.UID) (*v1.Pod, bool)
  • func (w *PodWatcherImpl) Pods() chan *v1.Pod

Types

type PodWatcher

type PodWatcher interface {
	Get(types.UID) (*v1.Pod, bool)
	Pods() chan *v1.Pod
	DeletedPods() chan types.UID
}

type PodWatcherImpl

type PodWatcherImpl struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewPodWatcher

func NewPodWatcher(namespace string, labelSelector string, fieldSelector string, client corev1.PodsGetter) *PodWatcherImpl

func (*PodWatcherImpl) DeletedPods

func (w *PodWatcherImpl) DeletedPods() chan types.UID

func (*PodWatcherImpl) Get

func (w *PodWatcherImpl) Get(uid types.UID) (*v1.Pod, bool)

func (*PodWatcherImpl) Pods

func (w *PodWatcherImpl) Pods() chan *v1.Pod