informer

Documentation

Index

• func NewEventListerWatcher(client kubernetes.Interface, namespace string, ...) cache.ListerWatcher
• func NewInstrumentedEventInformer(client kubernetes.Interface, namespace string, metrics *ListWatchMetrics, ...) cache.SharedIndexInformer
• func NewInstrumentedListerWatcher(lw cache.ListerWatcher, metrics *ListWatchMetrics) cache.ListerWatcher
• type InstrumentedListerWatcher
  • func (i *InstrumentedListerWatcher) List(options metav1.ListOptions) (runtime.Object, error)
  • func (i *InstrumentedListerWatcher) Watch(options metav1.ListOptions) (watch.Interface, error)
• type ListWatchMetrics
  • func NewListWatchMetrics(registry *prometheus.Registry) *ListWatchMetrics

Functions

func NewEventListerWatcher

func NewEventListerWatcher(client kubernetes.Interface, namespace string, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.ListerWatcher

NewEventListerWatcher constructs a new lister watcher for Event type.

func NewInstrumentedEventInformer

func NewInstrumentedEventInformer(client kubernetes.Interface, namespace string, metrics *ListWatchMetrics, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer

NewInstrumentedEventInformer constructs a new informer for Event type with instrumented list watch.

func NewInstrumentedListerWatcher

func NewInstrumentedListerWatcher(lw cache.ListerWatcher, metrics *ListWatchMetrics) cache.ListerWatcher

NewInstrumentedListerWatcher returns a new InstrumentedListerWatcher.

Types

type InstrumentedListerWatcher

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

InstrumentedListerWatcher provides the list/watch metrics with a cache ListerWatcher obj and the related resource.

func (*InstrumentedListerWatcher) List

func (i *InstrumentedListerWatcher) List(options metav1.ListOptions) (runtime.Object, error)

List is a wrapper func around the cache.ListerWatcher.List func. It increases the success/error counters based on the outcome of the List operation it instruments.

func (*InstrumentedListerWatcher) Watch

func (i *InstrumentedListerWatcher) Watch(options metav1.ListOptions) (watch.Interface, error)

Watch is a wrapper func around the cache.ListerWatcher.Watch func. It increases the success/error counters based on the outcome of the Watch operation it instruments.

type ListWatchMetrics

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

ListWatchMetrics stores the pointers of list/watch counter metrics.

func NewListWatchMetrics

func NewListWatchMetrics(registry *prometheus.Registry) *ListWatchMetrics

NewListWatchMetrics takes in a prometheus registry and initializes and registers list and watch metrics.