processor

type Processor interface {
	// Run performs the prediction routine.
	Run(ctx context.Context)

	Register(processConfig *processortypes.ProcessConfig) *errortypes.CustomError

	Cancel(processKey *processortypes.ProcessKey) *errortypes.CustomError

	QueryProcessedValues(taskKey *processortypes.ProcessKey) (float64, error)
}