Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Pipeline ¶
type Pipeline struct {
// contains filtered or unexported fields
}
func CompilePipeline ¶
func (*Pipeline) Execute ¶
func (p *Pipeline) Execute(ctx context.Context, params PipelineParameters) <-chan PipelineStepResult
func (*Pipeline) GetStepNames ¶ added in v0.5.0
type PipelineParameters ¶
type PipelineParameters struct {
ConfigSource config.ConfigSource
EventsRepo events.Repository
Logger *zap.Logger
}
type PipelineStepResult ¶
type PipelineStepResult struct {
Events []events.EventWithExtractedFields
}
Source Files
Click to show internal directories.
Click to hide internal directories.