pub fn cancel(
  handle: aion_client.WorkflowHandle,
  reason: String,
) -> Result(Nil, error.Error)

pub fn describe(
  handle: aion_client.WorkflowHandle,
) -> Result(aion_client.WorkflowDescription, error.Error)

pub fn new(
  client: aion_client.Client,
  workflow_id: String,
  run_id: String,
) -> aion_client.WorkflowHandle

pub fn query(
  handle: aion_client.WorkflowHandle,
  query_name: String,
  args: args,
  encoder: fn(args) -> json.Json,
  decoder: decode.Decoder(result),
) -> Result(result, error.Error)

pub fn query_payload(
  handle: aion_client.WorkflowHandle,
  query_name: String,
  args: payload.Payload,
) -> Result(payload.Payload, error.Error)

pub fn query_raw(
  handle: aion_client.WorkflowHandle,
  query_name: String,
  args: payload.Payload,
  decoder: decode.Decoder(result),
) -> Result(result, error.Error)

pub fn run_id(handle: aion_client.WorkflowHandle) -> String

pub fn signal(
  handle: aion_client.WorkflowHandle,
  signal_name: String,
  input: input,
  encoder: fn(input) -> json.Json,
) -> Result(Nil, error.Error)

pub fn signal_raw(
  handle: aion_client.WorkflowHandle,
  signal_name: String,
  input: payload.Payload,
) -> Result(Nil, error.Error)

pub fn subscribe(
  handle: aion_client.WorkflowHandle,
  decoder: decode.Decoder(event),
) -> stream.EventStream(event)

pub fn target_run(
  run_id: option.Option(String),
  handle: aion_client.WorkflowHandle,
) -> aion_client.WorkflowHandle

pub fn with_run_id(
  handle: aion_client.WorkflowHandle,
  run_id: String,
) -> aion_client.WorkflowHandle

pub fn workflow_id(handle: aion_client.WorkflowHandle) -> String