ConcurrencyLimit creates a concurrency limit func that uses the executor to determine if the task has exceeded the concurrency limit.

MultiLimit allows us to create a single limit func that applies more then one limit.

NewASTCompiler parses a Flux query string into an AST representation.

NewExecutor creates a new task executor.

NewRunCollector returns a collector which exports influxdb process metrics.

WithMaxWorkers specifies the number of workers used by the Executor.

WithNonSystemCompilerBuilder is an Executor option that configures a CompilerBuilderFunc to be used when compiling queries for non-System Tasks (Checks and Notifications).

WithSystemCompilerBuilder is an Executor option that configures a CompilerBuilderFunc to be used when compiling queries for System Tasks.

CompilerBuilderTimestamps contains timestamps which should be provided along with a Task query.

Executor it a task specific executor that works with the new scheduler system.

CompilerBuilderFunc is a function that yields a new flux.Compiler.

LimitFunc is a function the executor will use to.