pipeline

package

v0.3.0-rc.0 Latest Latest Go to latest Published: May 29, 2025 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation ¶

This section is empty.

View Source

var (
	ErrWriterNotDefined = errors.New("writer not defined")
)

This section is empty.

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

func NewGroup(logger *logrus.Logger, pipelines ...IPipeline) *Group

func (pg *Group) AddMessage(event entities.PipelineEvent)

func (pg *Group) Start(ctx context.Context)

type IPipeline interface {
	AddMessage(data entities.PipelineEvent)
	Start(ctx context.Context) error
}

func New(logger *logrus.Logger, p *processors.Processors, sinks sinks.Sink[entities.PipelineEvent]) (IPipeline, error)

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

func (p Pipeline) AddMessage(data entities.PipelineEvent)

func (p Pipeline) Start(ctx context.Context) error