exporter

Documentation

Index

• type ClusterEventExporter
  • func NewClusterEventExporter(eventInformer informerv1.EventInformer, w sinks.Writer) *ClusterEventExporter
  • func NewUnsunkClusterEventExporter(eventInformer informerv1.EventInformer) *ClusterEventExporter
  • func (c *ClusterEventExporter) AddSink(name string, w sinks.Writer)
  • func (c *ClusterEventExporter) DeleteSink(name string)
  • func (c *ClusterEventExporter) Run(stopCh <-chan struct{}) error
• type Exporter

Types

type ClusterEventExporter

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

ClusterEventExporter is the main event exporter.

func NewClusterEventExporter

func NewClusterEventExporter(eventInformer informerv1.EventInformer, w sinks.Writer) *ClusterEventExporter

NewClusterEventExporter creates a new event exporter with a sink.

func NewUnsunkClusterEventExporter

func NewUnsunkClusterEventExporter(eventInformer informerv1.EventInformer) *ClusterEventExporter

NewUnsunkClusterEventExporter creates a new event exporter. Sinks must be added manually by calling AddSink.

func (*ClusterEventExporter) AddSink

func (c *ClusterEventExporter) AddSink(name string, w sinks.Writer)

AddSink adds an event sink to the exporter.

func (*ClusterEventExporter) DeleteSink

func (c *ClusterEventExporter) DeleteSink(name string)

DeleteSink removes an event sink by name from the exporter.

func (*ClusterEventExporter) Run

func (c *ClusterEventExporter) Run(stopCh <-chan struct{}) error

Run waits for the initial cache sync to complete and blocks until the main exporter loop returns, i.e., when the stopCh closes.

type Exporter

type Exporter interface {
	Run(<-chan struct{}) error
}