pipeline

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

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

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

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

type PipelineGroupMock struct {
	AddMessageInvoked bool
	StartInvoked      bool
	CloseInvoked      bool

	AssertAddMessage func(data entities.PipelineEvent)
	CloseErr         error

	Messages []entities.PipelineEvent
}