output

Documentation

Index

• type BrokerWriter
  • func NewBrokerWriter(br broker.Handler) *BrokerWriter
  • func (s *BrokerWriter) Write(obj model.KubernetesResource, evtype broker.EventType, ...) error
• type CompositeWriter
  • func NewCompositeWriter(writer ...Writer) *CompositeWriter
  • func (w *CompositeWriter) Write(obj model.KubernetesResource, evtype broker.EventType, ...) error
• type FileWriter
  • func NewFileWriter(fw file.Writer) *FileWriter
  • func (s *FileWriter) Write(obj model.KubernetesResource, evtype broker.EventType, ...) error
• type InMemoryDeduplicatorStreamingWriter
  • func NewInMemoryDeduplicatorStreamingWriter(realWriter Writer) *InMemoryDeduplicatorStreamingWriter
  • func (w *InMemoryDeduplicatorStreamingWriter) Write(obj model.KubernetesResource, evtype broker.EventType, ...) error
• type InMemoryDeduplicatorWriter
  • func NewInMemoryDeduplicatorWriter(realWritter Writer) *InMemoryDeduplicatorWriter
  • func (w *InMemoryDeduplicatorWriter) Flush() error
  • func (w *InMemoryDeduplicatorWriter) Write(obj model.KubernetesResource, evtype broker.EventType, ...) error
• type Processor
  • func NewProcessor() *Processor
  • func (p *Processor) SetOutput(output Writer)
  • func (p *Processor) Write(obj model.KubernetesResource, evtype broker.EventType, ...) error
• type Writer

Types

type BrokerWriter

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

func NewBrokerWriter

func NewBrokerWriter(br broker.Handler) *BrokerWriter

func (*BrokerWriter) Write

func (s *BrokerWriter) Write(
	obj model.KubernetesResource,
	evtype broker.EventType,
	config config.PipelineConfig,
) error

type CompositeWriter

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

a wrapper which allows to have multiple writers under one entity

func NewCompositeWriter

func NewCompositeWriter(writer ...Writer) *CompositeWriter

func (*CompositeWriter) Write

func (w *CompositeWriter) Write(
	obj model.KubernetesResource,
	evtype broker.EventType,
	config config.PipelineConfig,
) error

type FileWriter

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

func NewFileWriter

func NewFileWriter(fw file.Writer) *FileWriter

func (*FileWriter) Write

func (s *FileWriter) Write(
	obj model.KubernetesResource,
	evtype broker.EventType,
	config config.PipelineConfig,
) error

type InMemoryDeduplicatorStreamingWriter

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

InMemoryDeduplicatorStreamingWriter writes each unique resource once immediately upon first seeing it

func NewInMemoryDeduplicatorStreamingWriter

func NewInMemoryDeduplicatorStreamingWriter(realWriter Writer) *InMemoryDeduplicatorStreamingWriter

NewInMemoryDeduplicatorStreamingWriter creates a deduplicator that writes immediately and filters repeats

func (*InMemoryDeduplicatorStreamingWriter) Write

func (w *InMemoryDeduplicatorStreamingWriter) Write(
	obj model.KubernetesResource,
	evtype broker.EventType,
	cfg config.PipelineConfig,
) error

type InMemoryDeduplicatorWriter

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

instead of direct write to output destination InMemoryDeduplicatorWriter collects data in memory identifying entity by metadata.uid and write to output only on program exit

func NewInMemoryDeduplicatorWriter

func NewInMemoryDeduplicatorWriter(realWritter Writer) *InMemoryDeduplicatorWriter

func (*InMemoryDeduplicatorWriter) Flush

func (w *InMemoryDeduplicatorWriter) Flush() error

func (*InMemoryDeduplicatorWriter) Write

func (w *InMemoryDeduplicatorWriter) Write(
	obj model.KubernetesResource,
	evtype broker.EventType,
	config config.PipelineConfig,
) error

type Processor

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

func NewProcessor

func NewProcessor() *Processor

func (*Processor) SetOutput

func (p *Processor) SetOutput(output Writer)

func (*Processor) Write

func (p *Processor) Write(
	obj model.KubernetesResource,
	evtype broker.EventType,
	config config.PipelineConfig,
) error

type Writer

type Writer interface {
	Write(
		obj model.KubernetesResource,
		evtype broker.EventType,
		config config.PipelineConfig,
	) error
}