Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ConcurrentCall ¶
type SequenceCall[T any] func(context.Context, chan T) chan T
type ConcurrentTask ¶
type ConcurrentTask struct { Name string Call ConcurrentCall }
type Pipeline ¶
type Pipeline[T any] struct { StartCall StartCall[T] SequenceTasks []SequenceTask[T] ConcurrentTasks []ConcurrentTask }
func NewPipeline ¶
func NewPipeline[T any]( sc StartCall[T], seqt []SequenceTask[T], conct []ConcurrentTask) *Pipeline[T]
type SequenceHandler ¶
type SequenceTask ¶
type SequenceTask[T any] struct { Name string Capacity uint32 Call SequenceHandler[T] }
Click to show internal directories.
Click to hide internal directories.