m25

-record(queue, {
    name :: binary(),
    max_concurrency :: integer(),
    input_to_json :: fun((any()) -> gleam@json:json()),
    input_decoder :: gleam@dynamic@decode:decoder(any()),
    output_to_json :: fun((any()) -> gleam@json:json()),
    output_decoder :: gleam@dynamic@decode:decoder(any()),
    error_to_json :: fun((any()) -> gleam@json:json()),
    error_decoder :: gleam@dynamic@decode:decoder(any()),
    handler_function :: fun((any()) -> {ok, any()} | {error, any()}),
    default_job_timeout :: gleam@time@duration:duration(),
    poll_interval :: integer(),
    heartbeat_interval :: integer(),
    allowed_heartbeat_misses :: integer(),
    executor_init_timeout :: integer(),
    reserved_timeout :: integer()
}).