dropeventemitter

Documentation

Index

• type DropEventEmitter
  • func NewDropEventEmitter(interval time.Duration, reasons []string, k8s client.Clientset, ...) *DropEventEmitter
  • func (e *DropEventEmitter) ProcessFlow(ctx context.Context, flow *flowpb.Flow) error
• type FakeRecorder
  • func NewFakeRecorder(bufferSize int) *FakeRecorder
  • func (f *FakeRecorder) AnnotatedEventf(object runtime.Object, annotations map[string]string, ...)
  • func (f *FakeRecorder) Event(object runtime.Object, eventtype, reason, message string)
  • func (f *FakeRecorder) Eventf(object runtime.Object, eventtype, reason, messageFmt string, ...)
  • func (f *FakeRecorder) WithLogger(logger klog.Logger) record.EventRecorderLogger

Types

type DropEventEmitter

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

func NewDropEventEmitter

func NewDropEventEmitter(interval time.Duration, reasons []string, k8s client.Clientset, watcher watchers.CacheAccessK8SWatcher) *DropEventEmitter

func (*DropEventEmitter) ProcessFlow

func (e *DropEventEmitter) ProcessFlow(ctx context.Context, flow *flowpb.Flow) error

type FakeRecorder

type FakeRecorder struct {
	Events chan string

	IncludeObject bool
}

FakeRecorder is used as a fake during tests. It is thread safe. It is usable when created manually and not by NewFakeRecorder, however all events may be thrown away in this case.

func NewFakeRecorder

func NewFakeRecorder(bufferSize int) *FakeRecorder

NewFakeRecorder creates new fake event recorder with event channel with buffer of given size.

func (*FakeRecorder) AnnotatedEventf

func (f *FakeRecorder) AnnotatedEventf(object runtime.Object, annotations map[string]string, eventtype, reason, messageFmt string, args ...interface{})

func (*FakeRecorder) Event

func (f *FakeRecorder) Event(object runtime.Object, eventtype, reason, message string)

func (*FakeRecorder) Eventf

func (f *FakeRecorder) Eventf(object runtime.Object, eventtype, reason, messageFmt string, args ...interface{})

func (*FakeRecorder) WithLogger

func (f *FakeRecorder) WithLogger(logger klog.Logger) record.EventRecorderLogger