informers

Documentation

Index

• func NewFilteredEventsInformer(ctx context.Context, sender, receiver cloudevents.Client, ...) informers.GenericInformer
• type Event
• type EventListWatcher
  • func NewEventListWatcher(ctx context.Context, source, namespace string, ...) *EventListWatcher
  • func (e *EventListWatcher) List(options metav1.ListOptions) (runtime.Object, error)
  • func (e *EventListWatcher) Watch(options metav1.ListOptions) (watch.Interface, error)
• type EventSharedInformerFactory
  • func NewEventsSharedInformerFactory(ctx context.Context, sender, receiver cloudevents.Client, ...) EventSharedInformerFactory
  • func NewFilteredEventSharedInformerFactory(ctx context.Context, sender, receiver cloudevents.Client, ...) EventSharedInformerFactory
• type ListWatchEvent
  • func (l *ListWatchEvent) ToCloudEvent() cloudevents.Event

Functions

func NewFilteredEventsInformer

func NewFilteredEventsInformer(
	ctx context.Context,
	sender, receiver cloudevents.Client,
	gvr schema.GroupVersionResource,
	namespace string,
	resyncPeriod time.Duration,
	indexers cache.Indexers,
	tweakListOptions dynamicinformer.TweakListOptionsFunc) informers.GenericInformer

Types

type Event

type Event interface {
	ToCloudEvent() cloudevents.Event
}

type EventListWatcher

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

func NewEventListWatcher

func NewEventListWatcher(ctx context.Context, source, namespace string, sender, receiver cloudevents.Client, gvr schema.GroupVersionResource) *EventListWatcher

func (*EventListWatcher) List

func (e *EventListWatcher) List(options metav1.ListOptions) (runtime.Object, error)

func (*EventListWatcher) Watch

func (e *EventListWatcher) Watch(options metav1.ListOptions) (watch.Interface, error)

type EventSharedInformerFactory

type EventSharedInformerFactory interface {
	Start()
	ForResource(gvr schema.GroupVersionResource) informers.GenericInformer
	WaitForCacheSync(stopCh <-chan struct{}) map[schema.GroupVersionResource]bool
}

func NewEventsSharedInformerFactory

func NewEventsSharedInformerFactory(ctx context.Context, sender, receiver cloudevents.Client, defaultResync time.Duration) EventSharedInformerFactory

func NewFilteredEventSharedInformerFactory

func NewFilteredEventSharedInformerFactory(ctx context.Context, sender, receiver cloudevents.Client, defaultResync time.Duration, namespace string, tweakListOptions dynamicinformer.TweakListOptionsFunc) EventSharedInformerFactory

NewFilteredDynamicSharedInformerFactory constructs a new instance of dynamicSharedInformerFactory. Listers obtained via this factory will be subject to the same filters as specified here.

type ListWatchEvent

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

func (*ListWatchEvent) ToCloudEvent

func (l *ListWatchEvent) ToCloudEvent() cloudevents.Event