Documentation
¶
Index ¶
- func NewExecutor(log *zap.Logger, qs query.QueryService, as influxdb.AuthorizationService, ...) (*Executor, *ExecutorMetrics)
- func NewRunCollector(ex *Executor) prometheus.Collector
- type Executor
- func (e *Executor) Cancel(ctx context.Context, runID influxdb.ID) error
- func (e *Executor) Execute(ctx context.Context, id scheduler.ID, scheduledFor time.Time, runAt time.Time) error
- func (e *Executor) ManualRun(ctx context.Context, id influxdb.ID, runID influxdb.ID) (Promise, error)
- func (e *Executor) PromiseQueueUsage() float64
- func (e *Executor) PromisedExecute(ctx context.Context, id scheduler.ID, scheduledFor time.Time, runAt time.Time) (Promise, error)
- func (e *Executor) ResumeCurrentRun(ctx context.Context, id influxdb.ID, runID influxdb.ID) (Promise, error)
- func (e *Executor) RunsActive() int
- func (e *Executor) SetLimitFunc(l LimitFunc)
- func (e *Executor) WorkersBusy() float64
- type ExecutorMetrics
- func (em *ExecutorMetrics) FinishRun(task *influxdb.Task, status backend.RunStatus, runDuration time.Duration)
- func (em *ExecutorMetrics) LogError(taskType string, err error)
- func (em *ExecutorMetrics) LogUnrecoverableError(taskID influxdb.ID, err error)
- func (em *ExecutorMetrics) PrometheusCollectors() []prometheus.Collector
- func (em *ExecutorMetrics) StartRun(task *influxdb.Task, queueDelta time.Duration, runLatency time.Duration)
- type LimitFunc
- type Promise
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewExecutor ¶
func NewExecutor(log *zap.Logger, qs query.QueryService, as influxdb.AuthorizationService, ts influxdb.TaskService, tcs backend.TaskControlService) (*Executor, *ExecutorMetrics)
NewExecutor creates a new task executor
func NewRunCollector ¶
func NewRunCollector(ex *Executor) prometheus.Collector
NewRunCollector returns a collector which exports influxdb process metrics.
Types ¶
type Executor ¶
type Executor struct {
// contains filtered or unexported fields
}
Executor it a task specific executor that works with the new scheduler system.
func (*Executor) Execute ¶
func (e *Executor) Execute(ctx context.Context, id scheduler.ID, scheduledFor time.Time, runAt time.Time) error
Execute is a executor to satisfy the needs of tasks
func (*Executor) PromiseQueueUsage ¶
PromiseQueueUsage returns the percent of the Promise Queue that is currently filled
func (*Executor) PromisedExecute ¶
func (e *Executor) PromisedExecute(ctx context.Context, id scheduler.ID, scheduledFor time.Time, runAt time.Time) (Promise, error)
PromisedExecute begins execution for the tasks id with a specific scheduledFor time. When we execute we will first build a run for the scheduledFor time, We then want to add to the queue anything that was manually queued to run. If the queue is full the call to execute should hang and apply back pressure to the caller We then start a worker to work the newly queued jobs.
func (*Executor) ResumeCurrentRun ¶
func (*Executor) RunsActive ¶
RunsActive returns the current number of workers, which is equivalent to the number of runs actively running
func (*Executor) SetLimitFunc ¶
SetLimitFunc sets the limit func for this task executor
func (*Executor) WorkersBusy ¶
WorkersBusy returns the percent of total workers that are busy
type ExecutorMetrics ¶
type ExecutorMetrics struct {
// contains filtered or unexported fields
}
func NewExecutorMetrics ¶
func NewExecutorMetrics(ex *Executor) *ExecutorMetrics
func (*ExecutorMetrics) FinishRun ¶
func (em *ExecutorMetrics) FinishRun(task *influxdb.Task, status backend.RunStatus, runDuration time.Duration)
FinishRun adjusts the metrics to indicate a run is no longer in progress for the given task ID.
func (*ExecutorMetrics) LogError ¶
func (em *ExecutorMetrics) LogError(taskType string, err error)
LogError increments the count of errors by error code.
func (*ExecutorMetrics) LogUnrecoverableError ¶
func (em *ExecutorMetrics) LogUnrecoverableError(taskID influxdb.ID, err error)
LogUnrecoverableError increments the count of unrecoverable errors, which require admin intervention to resolve or deactivate This count is separate from the errors count so that the errors metric can be used to identify only internal, rather than user errors and so that unrecoverable errors can be quickly identified for deactivation
func (*ExecutorMetrics) PrometheusCollectors ¶
func (em *ExecutorMetrics) PrometheusCollectors() []prometheus.Collector
PrometheusCollectors satisfies the prom.PrometheusCollector interface.
type LimitFunc ¶
LimitFunc is a function the executor will use to
func ConcurrencyLimit ¶
ConcurrencyLimit creates a concurrency limit func that uses the executor to determine if the task has exceeded the concurrency limit.
func MultiLimit ¶
MultiLimit allows us to create a single limit func that applies more then one limit.
Source Files