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 NewPipeline ¶
func NewPipeline(source *Source, sinker *Sinker, steps []PipelineStep) Pipeline
func (*Pipeline) Execute ¶
func (p *Pipeline) Execute() (PipelineCtx, error)
type PipelineCtx ¶
type PipelineStep ¶
type PipelineStep interface {
Execute(ctx PipelineCtx) (PipelineCtx, error)
}
type ReadFunc ¶
type ReadFunc = func(ctx PipelineCtx) (PipelineCtx, error)
type SinkFunc ¶
type SinkFunc = func(PipelineCtx) (PipelineCtx, error)
type Sinker ¶
type Sinker struct {
// contains filtered or unexported fields
}
func (*Sinker) Execute ¶
func (s *Sinker) Execute(ctx PipelineCtx) (PipelineCtx, error)
Click to show internal directories.
Click to hide internal directories.