Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ParallelTask ¶
type ParallelTask struct {
// contains filtered or unexported fields
}
func NewParallelTask ¶
func NewParallelTask(ctx context.Context, entrySuccessQuorum, entryFailureQuorum int, cancelOtherGoroutine bool) *ParallelTask
func (*ParallelTask) Goroutine ¶
func (et *ParallelTask) Goroutine(f func(ctx context.Context) error)
func (*ParallelTask) Wait ¶
func (et *ParallelTask) Wait() error
Click to show internal directories.
Click to hide internal directories.