sinks

Documentation

Overview

type EventHandler interface {
	OnAdd(event corev1.Event)
	OnUpdate(old, new corev1.Event)
	OnDelete(event corev1.Event)
}

Index

• type ElasticsearchSink
  • func (e *ElasticsearchSink) CreateIndex(name string) error
  • func (e *ElasticsearchSink) Index(date time.Time) string
  • func (e *ElasticsearchSink) OnAdd(event *corev1.Event)
  • func (e *ElasticsearchSink) OnDelete(event *corev1.Event)
  • func (e *ElasticsearchSink) OnUpdate(old, new *corev1.Event)
  • func (e *ElasticsearchSink) Run(stopCh <-chan struct{})
• type FileSink
  • func (f FileSink) OnAdd(event *corev1.Event)
  • func (f FileSink) OnDelete(event *corev1.Event)
  • func (f FileSink) OnUpdate(old, new *corev1.Event)
  • func (f FileSink) Run(stopCh <-chan struct{})
• type Sink
  • func NewEventSinkManager(u flags.Uri) (Sink, error)

Types

type ElasticsearchSink

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

func (*ElasticsearchSink) CreateIndex

func (e *ElasticsearchSink) CreateIndex(name string) error

func (*ElasticsearchSink) Index

func (e *ElasticsearchSink) Index(date time.Time) string

func (*ElasticsearchSink) OnAdd

func (e *ElasticsearchSink) OnAdd(event *corev1.Event)

func (*ElasticsearchSink) OnDelete

func (e *ElasticsearchSink) OnDelete(event *corev1.Event)

func (*ElasticsearchSink) OnUpdate

func (e *ElasticsearchSink) OnUpdate(old, new *corev1.Event)

func (*ElasticsearchSink) Run

func (e *ElasticsearchSink) Run(stopCh <-chan struct{})

type FileSink

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

func (FileSink) OnAdd

func (f FileSink) OnAdd(event *corev1.Event)

func (FileSink) OnDelete

func (f FileSink) OnDelete(event *corev1.Event)

func (FileSink) OnUpdate

func (f FileSink) OnUpdate(old, new *corev1.Event)

func (FileSink) Run

func (f FileSink) Run(stopCh <-chan struct{})

type Sink

type Sink interface {
	events.EventHandler

	Run(stopCh <-chan struct{})
}

func NewEventSinkManager

func NewEventSinkManager(u flags.Uri) (Sink, error)