package
0.0.5-beta
Repository: https://github.com/holdstation-hub/pipeline.git
Documentation: pkg.go.dev
# Functions
AllEqual returns true iff all the provided elements are equal to each other.
ContextFromChan creates a context that finishes when the provided channel receives or is closed.
ContextWithDeadlineFn returns a copy of the parent context with the deadline modified by deadlineFn.
No description provided by the author
JustError takes a tuple and returns the last entry, the error.
NewDependentAwaiter creates a new DependentAwaiter.
NewSleeperTask takes a worker and returns a SleeperTask.
SleeperFuncTask returns a Worker to execute the given work function.
ToDecimal converts an input to a decimal.
WaitGroupChan creates a channel that closes when the provided sync.WaitGroup is done.
WithJitter adds +/- 10% to a duration.
WrapIfError decorates an error with the given message.
# Structs
SleeperTask represents a task that waits in the background to process some work.
# Interfaces
DependentAwaiter contains Dependent funcs.
Worker is a simple interface that represents some work to do repeatedly.