class Mosquito::Api::Executor

Overview

An interface for an executor.

This is used to inspect the state of an executor. For more information about executors, see Mosquito::Runners::Executor.

mosquito/api/executor.cr

#current_job : String | Nil
The current job being executed by the executor.
#current_job_queue : String | Nil
The queue which housed the current job being executed.
#heartbeat : Time | Nil
The last heartbeat time, or nil if none exists.
#instance_id : String

def self.new(instance_id : String) #

Creates an executor inspector. The metadata is readonly and can be used to inspect the state of the executor.

see #current_job, #current_job_queue

def current_job : String | Nil #

The current job being executed by the executor.

When the executor is idle, this will be nil.

def current_job_queue : String | Nil #

The queue which housed the current job being executed.

When the executor is idle, this will be nil.

def heartbeat : Time | Nil #

The last heartbeat time, or nil if none exists.

def instance_id : String #