NewRuntimeCtxWithSubmitTime creates a RuntimeContext with a given submit-time.

NewTaskCommitter returns a TaskCommitter.

NewTaskRunner creates a new TaskRunner instance.

ToRuntimeCtx tries to convert a plain context.Context to RuntimeContext.

RuntimeContext is used to store information related to the Runtime.

TaskCommitter is used to implement two-phase task dispatching.

TaskRunner receives RunnableContainer in a FIFO way, and runs them in independent background goroutines.

WrappedTaskAdder is an interface used to abstract a TaskRunner.

Re-export types for public use.

Re-export types for public use.