Documentation ¶
Index ¶
- func AllMetadata() (results []plugins.Metadata)
- func ExporterMetadata() (results []plugins.Metadata)
- func HandlePanic(logger *log.Logger)
- func ImporterMetadata() (results []plugins.Metadata)
- func ProcessorMetadata() (results []plugins.Metadata)
- type ErrOverrideConflict
- type Pipeline
- type PluginLogFormatter
- type Status
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AllMetadata ¶
AllMetadata gets a slice with metadata from all registered plugins.
func ExporterMetadata ¶
ExporterMetadata gets a slice with metadata for all importers.Exporter plugins.
func HandlePanic ¶
HandlePanic function to log panics in a common way
func ImporterMetadata ¶
ImporterMetadata gets a slice with metadata for all importers.Importer plugins.
func ProcessorMetadata ¶
ProcessorMetadata gets a slice with metadata for all importers.Processor plugins.
Types ¶
type ErrOverrideConflict ¶ added in v1.1.0
type ErrOverrideConflict struct {
// contains filtered or unexported fields
}
ErrOverrideConflict is used when there are two different round overrides detected.
func (ErrOverrideConflict) Error ¶ added in v1.1.0
func (e ErrOverrideConflict) Error() string
Error implements the error interface.
type Pipeline ¶
type Pipeline interface { Init() error Start() Stop() Error() error Wait() Status() (Status, error) }
Pipeline is a struct that orchestrates the entire sequence of events, taking in importers, processors and exporters and generating the result
type PluginLogFormatter ¶
type PluginLogFormatter struct { Formatter *log.JSONFormatter Type string Name string }
PluginLogFormatter formats the log message with special conduit tags