module Workr::Services::JobDataService

Extended Modules

Defined in:

services/job_data_service.cr

Instance Method Summary

Instance Method Detail

def create_execution(job_name) #

[View source]
def finish_execution(job_name, job_execution_id, exit_code) #

[View source]
def get_all_executions(job_name) #

[View source]
def get_execution(job_name : String, job_execution_id : UInt32) #

[View source]
def get_execution_output(job_name, job_execution_id) #

[View source]
def get_job(job_name) #

[View source]
def subscribe_execution_output(job_name, job_execution_id, &subscriber : Bytes -> Nil) #

[View source]
def write_execution_output(job_name : String, job_execution_id : UInt32, &) #

[View source]