concurrency

type BaseExecutorCallbackInput struct {
	// The name of the executor
	ExecutorName string
}

type ContinuousBatchInput[OutputType any] executorInput[time.Time, OutputType, []OutputType, ProcessingFuncWithoutInputWithOutput[OutputType]]

type ContinuousFinalInput executorInput[time.Time, any, any, ProcessingFuncWithoutInputWithoutOutput]

type ContinuousInput[OutputType any] executorInput[time.Time, OutputType, OutputType, ProcessingFuncWithoutInputWithOutput[OutputType]]

type ContinuousRebatchInput[OutputType any] executorInput[time.Time, []OutputType, []OutputType, ProcessingFuncWithoutInputWithOutput[[]OutputType]]

type ContinuousUnbatchInput[OutputChanType any] executorInput[time.Time, []OutputChanType, OutputChanType, ProcessingFuncWithoutInputWithOutput[[]OutputChanType]]

type EmptyInputChannelCallbackInput struct {
	*RoutineFunctionMetadata
	// The duration since the last input was received
	TimeSinceLastInput time.Duration
}

type ExecutorBatchInput[InputType any, OutputType any] executorInput[InputType, OutputType, []OutputType, ProcessingFuncWithInputWithOutput[InputType, OutputType]]

type ExecutorContextDoneCallbackInput struct {
	*BaseExecutorCallbackInput
	// The context cancellation error (may wrap other info)
	Err stackerr.Error
}

type ExecutorErrorCallbackInput struct {
	*BaseExecutorCallbackInput
	// The error that caused one or more of the routines to fail
	Err stackerr.Error
}

type ExecutorFinalInput[InputType any] executorInput[InputType, any, any, ProcessingFuncWithInputWithoutOutput[InputType]]

type ExecutorInput[InputType any, OutputType any] executorInput[InputType, OutputType, OutputType, ProcessingFuncWithInputWithOutput[InputType, OutputType]]

type ExecutorOutput[OutputChanType any] struct {

	// The name of the executor
	Name string

	// The status tracker for the routines.
	RoutineStatusTracker *RoutineStatusTracker

	// The channel that the outputs are written to
	OutputChan <-chan OutputChanType
	// contains filtered or unexported fields
}

type ExecutorRebatchInput[InputType any, OutputType any] executorInput[InputType, []OutputType, []OutputType, ProcessingFuncWithInputWithOutput[InputType, []OutputType]]

type ExecutorSuccessCallbackInput struct {
	*BaseExecutorCallbackInput
}

type ExecutorUnbatchInput[InputType any, OutputChanType any] executorInput[InputType, []OutputChanType, OutputChanType, ProcessingFuncWithInputWithOutput[InputType, []OutputChanType]]

type FullOutputChannelCallbackInput struct {
	*RoutineFunctionMetadata
	// The duration since the last output was stored
	TimeSinceLastOutput time.Duration
	// The output index, specific to the corresponding input
	// (i.e. resets at 0 for each input)
	OutputIndex uint64
}

type ProcessingFuncTypes[InputType any, OutputType any] interface {
	ProcessingFuncWithInputWithOutput[InputType, OutputType] | ProcessingFuncWithInputWithoutOutput[InputType] | ProcessingFuncWithoutInputWithOutput[OutputType] | ProcessingFuncWithoutInputWithoutOutput
}

type ProcessingFuncWithInputWithOutput[InputType any, OutputType any] func(ctx context.Context, input InputType, metadata *RoutineFunctionMetadata) (output OutputType, err stackerr.Error)

type ProcessingFuncWithInputWithoutOutput[InputType any] func(ctx context.Context, input InputType, metadata *RoutineFunctionMetadata) (err stackerr.Error)

type ProcessingFuncWithoutInputWithOutput[OutputType any] func(ctx context.Context, metadata *RoutineFunctionMetadata) (output OutputType, err stackerr.Error)

type ProcessingFuncWithoutInputWithoutOutput func(ctx context.Context, metadata *RoutineFunctionMetadata) (err stackerr.Error)

type RoutineContextDoneCallbackInput struct {
	*RoutineFunctionMetadata
	// The error that killed the context
	Err stackerr.Error
}

type RoutineErrorCallbackInput struct {
	*RoutineFunctionMetadata
	// The error that was returned by the function
	Err stackerr.Error
}

type RoutineFunctionMetadata struct {
	// The name of the executor
	ExecutorName string
	// The index of the routine (will be in [0-concurrency))
	RoutineIndex uint
	// The index of the input (the input value is the Nth value
	// from the input channel)
	ExecutorInputIndex uint64
	// The index of the input for this routine
	RoutineInputIndex uint64
	// The status tracker for this executor
	RoutineStatusTracker *RoutineStatusTracker
	// The status trackers for all executors in this chain (by map)
	RoutineStatusTrackersMap map[string]*RoutineStatusTracker
	// The status trackers for all executors in this chain (by slice, in order of chaining)
	RoutineStatusTrackersSlice []*RoutineStatusTracker
}

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

type RoutineSuccessCallbackInput struct {
	*RoutineFunctionMetadata
}