gabsurd/sql

Code generated by parrot. DO NOT EDIT.

Types

AwaitEvent

pub type AwaitEvent {
  AwaitEvent(should_suspend: Bool, payload: String)
}

Constructors

AwaitEvent(should_suspend: Bool, payload: String)

CancelTask

</>

pub type CancelTask {
  CancelTask(col_0: String)
}

Constructors

```
CancelTask(col_0: String)
```

ClaimTask

</>

pub type ClaimTask {
  ClaimTask(
    run_id: BitArray,
    task_id: BitArray,
    attempt: Int,
    task_name: String,
    params: String,
    retry_strategy: String,
    max_attempts: Int,
    headers: String,
    wake_event: String,
    event_payload: String,
  )
}

Constructors

ClaimTask(
  run_id: BitArray,
  task_id: BitArray,
  attempt: Int,
  task_name: String,
  params: String,
  retry_strategy: String,
  max_attempts: Int,
  headers: String,
  wake_event: String,
  event_payload: String,
)

CleanupAllQueues

</>

pub type CleanupAllQueues {
  CleanupAllQueues(
    queue_name: String,
    tasks_deleted: Int,
    events_deleted: Int,
  )
}

Constructors

CleanupAllQueues(
  queue_name: String,
  tasks_deleted: Int,
  events_deleted: Int,
)

CleanupEvents

</>

pub type CleanupEvents {
  CleanupEvents(cleanup_events: Int)
}

Constructors

```
CleanupEvents(cleanup_events: Int)
```

CleanupTasks

</>

pub type CleanupTasks {
  CleanupTasks(cleanup_tasks: Int)
}

Constructors

```
CleanupTasks(cleanup_tasks: Int)
```

CompleteRun

</>

pub type CompleteRun {
  CompleteRun(col_0: String)
}

Constructors

```
CompleteRun(col_0: String)
```

CreateQueue

</>

pub type CreateQueue {
  CreateQueue(col_0: String)
}

Constructors

```
CreateQueue(col_0: String)
```

CreateQueueWithMode

</>

pub type CreateQueueWithMode {
  CreateQueueWithMode(col_0: String)
}

Constructors

```
CreateQueueWithMode(col_0: String)
```

DropQueue

</>

pub type DropQueue {
  DropQueue(col_0: String)
}

Constructors

```
DropQueue(col_0: String)
```

EmitEvent

</>

pub type EmitEvent {
  EmitEvent(col_0: String)
}

Constructors

```
EmitEvent(col_0: String)
```

ExtendClaim

</>

pub type ExtendClaim {
  ExtendClaim(col_0: String)
}

Constructors

```
ExtendClaim(col_0: String)
```

FailRun

</>

pub type FailRun {
  FailRun(col_0: String)
}

Constructors

```
FailRun(col_0: String)
```

FailRunWithRetry

</>

pub type FailRunWithRetry {
  FailRunWithRetry(col_0: String)
}

Constructors

```
FailRunWithRetry(col_0: String)
```

GetQueuePolicy

</>

pub type GetQueuePolicy {
  GetQueuePolicy(
    queue_name: String,
    storage_mode: String,
    default_partition: String,
    partition_lookahead: String,
    partition_lookback: String,
    cleanup_ttl: String,
    cleanup_limit: Int,
    detach_mode: String,
    detach_min_age: String,
  )
}

Constructors

GetQueuePolicy(
  queue_name: String,
  storage_mode: String,
  default_partition: String,
  partition_lookahead: String,
  partition_lookback: String,
  cleanup_ttl: String,
  cleanup_limit: Int,
  detach_mode: String,
  detach_min_age: String,
)

GetSchemaVersion

</>

pub type GetSchemaVersion {
  GetSchemaVersion(get_schema_version: String)
}

Constructors

GetSchemaVersion(get_schema_version: String)

GetTaskCheckpointState

</>

pub type GetTaskCheckpointState {
  GetTaskCheckpointState(
    checkpoint_name: String,
    state: String,
    status: String,
    owner_run_id: BitArray,
    updated_at: timestamp.Timestamp,
  )
}

Constructors

GetTaskCheckpointState(
  checkpoint_name: String,
  state: String,
  status: String,
  owner_run_id: BitArray,
  updated_at: timestamp.Timestamp,
)

GetTaskCheckpointStates

</>

pub type GetTaskCheckpointStates {
  GetTaskCheckpointStates(
    checkpoint_name: String,
    state: String,
    status: String,
    owner_run_id: BitArray,
    updated_at: timestamp.Timestamp,
  )
}

Constructors

GetTaskCheckpointStates(
  checkpoint_name: String,
  state: String,
  status: String,
  owner_run_id: BitArray,
  updated_at: timestamp.Timestamp,
)

GetTaskResult

</>

pub type GetTaskResult {
  GetTaskResult(
    task_id: BitArray,
    state: String,
    result: String,
    failure_reason: String,
  )
}

Constructors

GetTaskResult(
  task_id: BitArray,
  state: String,
  result: String,
  failure_reason: String,
)

ListQueues

</>

pub type ListQueues {
  ListQueues(queue_name: String)
}

Constructors

```
ListQueues(queue_name: String)
```

RetryTask

</>

pub type RetryTask {
  RetryTask(
    task_id: BitArray,
    run_id: BitArray,
    attempt: Int,
    created: Bool,
  )
}

Constructors

RetryTask(
  task_id: BitArray,
  run_id: BitArray,
  attempt: Int,
  created: Bool,
)

ScheduleRun

</>

pub type ScheduleRun {
  ScheduleRun(col_0: String)
}

Constructors

```
ScheduleRun(col_0: String)
```

SetQueuePolicy

</>

pub type SetQueuePolicy {
  SetQueuePolicy(col_0: String)
}

Constructors

```
SetQueuePolicy(col_0: String)
```

SetTaskCheckpointState

</>

pub type SetTaskCheckpointState {
  SetTaskCheckpointState(col_0: String)
}

Constructors

```
SetTaskCheckpointState(col_0: String)
```

SpawnTask

</>

pub type SpawnTask {
  SpawnTask(
    task_id: BitArray,
    run_id: BitArray,
    attempt: Int,
    created: Bool,
  )
}

Constructors

SpawnTask(
  task_id: BitArray,
  run_id: BitArray,
  attempt: Int,
  created: Bool,
)

Values

await_event

</>

pub fn await_event(
  p_queue_name p_queue_name: String,
  p_task_id p_task_id: BitArray,
  p_run_id p_run_id: BitArray,
  p_step_name p_step_name: String,
  p_event_name p_event_name: String,
  p_timeout p_timeout: Int,
) -> #(String, List(dev.Param), decode.Decoder(AwaitEvent))

await_event_decoder

</>

pub fn await_event_decoder() -> decode.Decoder(AwaitEvent)

cancel_task

</>

pub fn cancel_task(
  p_queue_name p_queue_name: String,
  p_task_id p_task_id: BitArray,
) -> #(String, List(dev.Param))

cancel_task_decoder

</>

pub fn cancel_task_decoder() -> decode.Decoder(CancelTask)

claim_task

</>

pub fn claim_task(
  p_queue_name p_queue_name: String,
  p_worker_id p_worker_id: String,
  p_claim_timeout p_claim_timeout: Int,
  p_qty p_qty: Int,
) -> #(String, List(dev.Param), decode.Decoder(ClaimTask))

claim_task_decoder

</>

pub fn claim_task_decoder() -> decode.Decoder(ClaimTask)

cleanup_all_queues

</>

pub fn cleanup_all_queues(
  p_queue_name p_queue_name: String,
) -> #(String, List(dev.Param), decode.Decoder(CleanupAllQueues))

cleanup_all_queues_decoder

</>

pub fn cleanup_all_queues_decoder() -> decode.Decoder(
  CleanupAllQueues,
)

cleanup_events

</>

pub fn cleanup_events(
  p_queue_name p_queue_name: String,
  p_ttl_seconds p_ttl_seconds: Int,
  p_limit p_limit: Int,
) -> #(String, List(dev.Param), decode.Decoder(CleanupEvents))

cleanup_events_decoder

</>

pub fn cleanup_events_decoder() -> decode.Decoder(CleanupEvents)

cleanup_tasks

</>

pub fn cleanup_tasks(
  p_queue_name p_queue_name: String,
  p_ttl_seconds p_ttl_seconds: Int,
  p_limit p_limit: Int,
) -> #(String, List(dev.Param), decode.Decoder(CleanupTasks))

cleanup_tasks_decoder

</>

pub fn cleanup_tasks_decoder() -> decode.Decoder(CleanupTasks)

complete_run

</>

pub fn complete_run(
  p_queue_name p_queue_name: String,
  p_run_id p_run_id: BitArray,
  p_state p_state: String,
) -> #(String, List(dev.Param))

complete_run_decoder

</>

pub fn complete_run_decoder() -> decode.Decoder(CompleteRun)

create_queue

</>

pub fn create_queue(
  p_queue_name p_queue_name: String,
) -> #(String, List(dev.Param))

create_queue_decoder

</>

pub fn create_queue_decoder() -> decode.Decoder(CreateQueue)

create_queue_with_mode

</>

pub fn create_queue_with_mode(
  p_queue_name p_queue_name: String,
  p_storage_mode p_storage_mode: String,
) -> #(String, List(dev.Param))

create_queue_with_mode_decoder

</>

pub fn create_queue_with_mode_decoder() -> decode.Decoder(
  CreateQueueWithMode,
)

drop_queue

</>

pub fn drop_queue(
  p_queue_name p_queue_name: String,
) -> #(String, List(dev.Param))

drop_queue_decoder

</>

pub fn drop_queue_decoder() -> decode.Decoder(DropQueue)

emit_event

</>

pub fn emit_event(
  p_queue_name p_queue_name: String,
  p_event_name p_event_name: String,
  p_payload p_payload: String,
) -> #(String, List(dev.Param))

emit_event_decoder

</>

pub fn emit_event_decoder() -> decode.Decoder(EmitEvent)

extend_claim

</>

pub fn extend_claim(
  p_queue_name p_queue_name: String,
  p_run_id p_run_id: BitArray,
  p_extend_by p_extend_by: Int,
) -> #(String, List(dev.Param))

extend_claim_decoder

</>

pub fn extend_claim_decoder() -> decode.Decoder(ExtendClaim)

fail_run

</>

pub fn fail_run(
  p_queue_name p_queue_name: String,
  p_run_id p_run_id: BitArray,
  p_reason p_reason: String,
) -> #(String, List(dev.Param))

fail_run_decoder

</>

pub fn fail_run_decoder() -> decode.Decoder(FailRun)

fail_run_with_retry

</>

pub fn fail_run_with_retry(
  p_queue_name p_queue_name: String,
  p_run_id p_run_id: BitArray,
  p_reason p_reason: String,
  p_retry_at p_retry_at: timestamp.Timestamp,
) -> #(String, List(dev.Param))

fail_run_with_retry_decoder

</>

pub fn fail_run_with_retry_decoder() -> decode.Decoder(
  FailRunWithRetry,
)

get_queue_policy

</>

pub fn get_queue_policy(
  p_queue_name p_queue_name: String,
) -> #(String, List(dev.Param), decode.Decoder(GetQueuePolicy))

get_queue_policy_decoder

</>

pub fn get_queue_policy_decoder() -> decode.Decoder(
  GetQueuePolicy,
)

get_schema_version

</>

pub fn get_schema_version() -> #(
  String,
  List(a),
  decode.Decoder(GetSchemaVersion),
)

get_schema_version_decoder

</>

pub fn get_schema_version_decoder() -> decode.Decoder(
  GetSchemaVersion,
)

get_task_checkpoint_state

</>

pub fn get_task_checkpoint_state(
  p_queue_name p_queue_name: String,
  p_task_id p_task_id: BitArray,
  p_step_name p_step_name: String,
  p_include_pending p_include_pending: Bool,
) -> #(
  String,
  List(dev.Param),
  decode.Decoder(GetTaskCheckpointState),
)

get_task_checkpoint_state_decoder

</>

pub fn get_task_checkpoint_state_decoder() -> decode.Decoder(
  GetTaskCheckpointState,
)

get_task_checkpoint_states

</>

pub fn get_task_checkpoint_states(
  p_queue_name p_queue_name: String,
  p_task_id p_task_id: BitArray,
  p_run_id p_run_id: BitArray,
) -> #(
  String,
  List(dev.Param),
  decode.Decoder(GetTaskCheckpointStates),
)

get_task_checkpoint_states_decoder

</>

pub fn get_task_checkpoint_states_decoder() -> decode.Decoder(
  GetTaskCheckpointStates,
)

get_task_result

</>

pub fn get_task_result(
  p_queue_name p_queue_name: String,
  p_task_id p_task_id: BitArray,
) -> #(String, List(dev.Param), decode.Decoder(GetTaskResult))

get_task_result_decoder

</>

pub fn get_task_result_decoder() -> decode.Decoder(GetTaskResult)

list_queues

</>

pub fn list_queues() -> #(
  String,
  List(a),
  decode.Decoder(ListQueues),
)

list_queues_decoder

</>

pub fn list_queues_decoder() -> decode.Decoder(ListQueues)

retry_task

</>

pub fn retry_task(
  p_queue_name p_queue_name: String,
  p_task_id p_task_id: BitArray,
  p_options p_options: String,
) -> #(String, List(dev.Param), decode.Decoder(RetryTask))

retry_task_decoder

</>

pub fn retry_task_decoder() -> decode.Decoder(RetryTask)

schedule_run

</>

pub fn schedule_run(
  p_queue_name p_queue_name: String,
  p_run_id p_run_id: BitArray,
  p_wake_at p_wake_at: timestamp.Timestamp,
) -> #(String, List(dev.Param))

schedule_run_decoder

</>

pub fn schedule_run_decoder() -> decode.Decoder(ScheduleRun)

set_queue_policy

</>

pub fn set_queue_policy(
  p_queue_name p_queue_name: String,
  p_policy p_policy: String,
) -> #(String, List(dev.Param))

set_queue_policy_decoder

</>

pub fn set_queue_policy_decoder() -> decode.Decoder(
  SetQueuePolicy,
)

set_task_checkpoint_state

</>

pub fn set_task_checkpoint_state(
  p_queue_name p_queue_name: String,
  p_task_id p_task_id: BitArray,
  p_step_name p_step_name: String,
  p_state p_state: String,
  p_owner_run p_owner_run: BitArray,
  p_extend_claim_by p_extend_claim_by: Int,
) -> #(String, List(dev.Param))

set_task_checkpoint_state_decoder

</>

pub fn set_task_checkpoint_state_decoder() -> decode.Decoder(
  SetTaskCheckpointState,
)

spawn_task

</>

pub fn spawn_task(
  p_queue_name p_queue_name: String,
  p_task_name p_task_name: String,
  p_params p_params: String,
  p_options p_options: String,
) -> #(String, List(dev.Param), decode.Decoder(SpawnTask))

spawn_task_decoder

</>

pub fn spawn_task_decoder() -> decode.Decoder(SpawnTask)