pipeline

package

v0.3.0-rc.1 Latest Latest Go to latest Published: Jul 1, 2025 License: Apache-2.0 Imports: 10 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 (pg *Group) AddMessage(event entities.PipelineEvent)

func (pg *Group) Close() error

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

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

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

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

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

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

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

func (p Pipeline) Close() error

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