AllowedFields checks that only allowed fields are used in the configuration.

Cap returns the capacity of this default pool.

Free returns the available goroutines to work.

MutuallyExclusiveRequiredFields checks that only one of the given fields is used at the same time.

NewConditional returns a constructor suitable for registering when conditionals as a plugin.

NewConditionList takes a slice of Config objects and turns them into real Condition objects.

NewConditionRule returns a processor that will execute the provided processor if the condition is true.

NewPipeline creates new DAG.

NewFilterConditional returns a constructor suitable for registering when conditionals as a plugin.

NewFilterConditionList takes a slice of Config objects and turns them into real Condition objects.

NewFilterConditionRule returns a processor that will execute the provided processor if the condition is true.

NewIfElseThenFilter construct a new IfThenElseFilter.

NewIfElseThenProcessor construct a new IfThenElseProcessor.

NewPool generates an instance of ants pool.

NewPoolWithFunc generates an instance of ants pool with a specific function.

Reboot reboots the default pool.

Release Closes the default pool.

ReleaseContext could be called concurrently Doesn't handle context lifecycle, only recycle the resources Mark the context as released, quit the pipeline loop automatically.

RequireFields checks that the required fields are present in the configuration.

Running returns the number of the currently running goroutines.

Submit submits a task to pool.

WithExpiryDuration sets up the interval time of cleaning up goroutines.

WithLogger sets up a customized logger.

WithMaxBlockingTasks sets up the maximum number of goroutines that are blocked when it reaches the capacity of pool.

WithNonblocking indicates that pool will return nil when there is no available workers.

WithOptions accepts the whole options config.

WithPanicHandler sets up panic handler.

WithPreAlloc indicates whether it should malloc for workers.

CLOSED represents that the pool is closed.

DefaultAntsPoolSize is the default capacity for a default goroutine pool.

DefaultCleanIntervalTime is the interval time to clean up goroutines.

OPENED represents that the pool is opened.

ErrInvalidPoolExpiry will be returned when setting a negative number as the periodic duration to purge goroutines.

ErrInvalidPreAllocSize will be returned when trying to set up a negative capacity under PreAlloc mode.

ErrLackPoolFunc will be returned when invokers don't provide function for pool.

ErrPoolClosed will be returned when submitting task to a closed pool.

ErrPoolOverload will be returned when the pool is full and no workers available.

ErrTimeout will be returned after the operations timed out.

Dag represents directed acyclic graph.

IfThenElseFilter executes one set of processors (then) if the condition is true and another set of processors (else) if the condition is false.

IfThenElseProcessor executes one set of processors (then) if the condition is true and another set of processors (else) if the condition is false.

Job - Each job consists of one or more tasks Each Job can runs tasks in order(Sequential) or unordered.

Options contains all options which will be applied when instantiating an ants pool.

Pool accepts the tasks from client, it limits the total of goroutines to a given number by recycling goroutines.

PoolWithFunc accepts the tasks from client, it limits the total of goroutines to a given number by recycling goroutines.

WhenFilter is a tuple of condition plus a Processor.

WhenProcessor is a tuple of condition plus a Processor.

Logger is used for logging formatted messages.

Option represents the optional function.