Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( // ErrFatal is returned when a fatal error occurs and we want to exit. ErrFatal = errors.New("fatal error") // ErrEvent is returned when something went wrong with a specific event. ErrEvent = errors.New("event error") // ErrNotFound is returned when a postprocessing is not found in the store. ErrNotFound = errors.New("postprocessing not found") )
Functions ¶
This section is empty.
Types ¶
type PostprocessingService ¶
type PostprocessingService struct {
// contains filtered or unexported fields
}
PostprocessingService is an instance of the service handling postprocessing of files
func NewPostprocessingService ¶
func NewPostprocessingService(ctx context.Context, stream events.Stream, logger log.Logger, sto store.Store, tp trace.TracerProvider, c config.Postprocessing) (*PostprocessingService, error)
NewPostprocessingService returns a new instance of a postprocessing service
func (*PostprocessingService) Run ¶
func (pps *PostprocessingService) Run() error
Run to fulfil Runner interface
Source Files
Click to show internal directories.
Click to hide internal directories.