FerricStore.Flow (ferricstore_sdk v0.1.0)

High-level FerricFlow command helpers.

Functions build the same native command arguments as the Python SDK while keeping defaults simple: create returns an ack, claim returns compact jobs with attributes, and terminal commands return an ack unless return_record: true.

Summary

Functions

cancel(client, id, opts)

cancel_args(id, opts)

claim_due(client, type, opts)

claim_due_args(type, opts)

claim_due_payload(type, opts)

complete(client, id, opts)

complete_args(id, opts)

complete_many(client, jobs, opts \\ [])

complete_many_payload(jobs, opts \\ [])

complete_payload(id, opts)

create(client, id, opts)

create_args(id, opts)

create_many(client, items, opts)

create_many_payload(items, opts)

create_payload(id, opts)

enqueue(client, id, opts)

fail(client, id, opts)

fail_args(id, opts)

get(client, id, opts \\ [])

history(client, id, opts \\ [])

list(client, opts \\ [])

retry(client, id, opts)

retry_args(id, opts)

signal(client, id, opts)

transition(client, id, opts)

transition_args(id, opts)

value_mget(client, refs, opts \\ [])

value_put(client, value, opts \\ [])

Functions

cancel(client, id, opts)

cancel_args(id, opts)

claim_due(client, type, opts)

claim_due_args(type, opts)

claim_due_payload(type, opts)

complete(client, id, opts)

complete_args(id, opts)

complete_many(client, jobs, opts \\ [])

complete_many_payload(jobs, opts \\ [])

complete_payload(id, opts)

create(client, id, opts)

create_args(id, opts)

create_many(client, items, opts)

create_many_payload(items, opts)

create_payload(id, opts)

enqueue(client, id, opts)

fail(client, id, opts)

fail_args(id, opts)

get(client, id, opts \\ [])

history(client, id, opts \\ [])

list(client, opts \\ [])

retry(client, id, opts)

retry_args(id, opts)

signal(client, id, opts)

transition(client, id, opts)

transition_args(id, opts)

value_mget(client, refs, opts \\ [])

value_put(client, value, opts \\ [])