watcher

Documentation

Index

• type Options
• type Watcher
  • func NewWatcher(clientset *kubernetes.Clientset, c collector.Collector, log logrus.FieldLogger, ...) *Watcher
  • func (w *Watcher) Watch(ctx context.Context, podWatcher watch.Interface, eventWatcher watch.Interface)

Types

type Options

type Options struct {
	LabelSelector  labels.Selector
	Namespaces     []string
	ResourceNames  []string
	ContainerNames []string
	RunningOnly    bool
	OneShot        bool
	DumpMetadata   bool
	DumpEvents     bool
}

type Watcher

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

func NewWatcher

func NewWatcher(
	clientset *kubernetes.Clientset,
	c collector.Collector,
	log logrus.FieldLogger,
	initialPods []corev1.Pod,
	initialEvents []corev1.Event,
	opt Options,
) *Watcher

func (*Watcher) Watch

func (w *Watcher) Watch(ctx context.Context, podWatcher watch.Interface, eventWatcher watch.Interface)