FerricStore.Flow (ferricstore_sdk v0.6.2)

Copy Markdown View Source

High-level FerricFlow command helpers.

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

Summary

Functions

by_correlation(client, id, opts \\ [])
by_parent(client, id, opts \\ [])
by_root(client, id, opts \\ [])
cancel(client, id, opts)
cancel_payload(id, opts)
claim_due(client, type, opts)
claim_due_payload(type, opts)
complete(client, id, opts)
complete_many(client, jobs, opts \\ [])
complete_many_payload(jobs, opts \\ [])
complete_payload(id, opts)
create(client, id, opts)
create_many(client, items, opts)
create_many_payload(items, opts)
create_payload(id, opts)
enqueue(client, id, opts)
explain(client, query, params \\ %{}, opts \\ [])
explain_analyze(client, query, params \\ %{}, opts \\ [])
fail(client, id, opts)
fail_payload(id, opts)
failures(client, type, opts \\ [])
get(client, id, opts \\ [])
get_payload(id, opts \\ [])
history(client, id, opts \\ [])
history_payload(id, opts \\ [])
list(client, opts \\ [])
policy_get(client, type, opts \\ [])

Returns the typed policy snapshot and its monotonic generation.

policy_get_payload(type, opts \\ [])
policy_set(client, type, opts \\ [])

Deep-patches a Flow type policy and returns its typed snapshot.

policy_set_payload(type, opts)
query(client, query, params \\ %{}, opts \\ [])
query_indexes(client, index_id \\ nil, opts \\ [])
retry(client, id, opts)
retry_payload(id, opts)
search(client, opts \\ [])
signal(client, id, opts)
signal_payload(id, opts)
stuck(client, type, opts \\ [])
terminals(client, type, opts \\ [])
transition(client, id, opts)
transition_payload(id, opts)
value_mget(client, refs, opts \\ [])
value_put(client, value, opts \\ [])

Functions

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

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

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

cancel(client, id, opts)

cancel_payload(id, opts)

claim_due(client, type, opts)

claim_due_payload(type, opts)

complete(client, id, opts)

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

complete_many_payload(jobs, opts \\ [])

complete_payload(id, opts)

create(client, id, opts)

create_many(client, items, opts)

create_many_payload(items, opts)

create_payload(id, opts)

enqueue(client, id, opts)

explain(client, query, params \\ %{}, opts \\ [])

explain_analyze(client, query, params \\ %{}, opts \\ [])

fail(client, id, opts)

fail_payload(id, opts)

failures(client, type, opts \\ [])

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

get_payload(id, opts \\ [])

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

history_payload(id, opts \\ [])

list(client, opts \\ [])

policy_get(client, type, opts \\ [])

@spec policy_get(pid(), binary(), keyword()) ::
  FerricStore.Flow.PolicySnapshot.t() | {:error, FerricStore.Error.t()}

Returns the typed policy snapshot and its monotonic generation.

policy_get_payload(type, opts \\ [])

policy_set(client, type, opts \\ [])

@spec policy_set(pid(), binary(), keyword()) ::
  FerricStore.Flow.PolicySnapshot.t()
  | {:error,
     FerricStore.Error.t() | FerricStore.Flow.StalePolicyGenerationError.t()}

Deep-patches a Flow type policy and returns its typed snapshot.

Pass replace: true for full replacement. Pass expected_generation from a prior FerricStore.Flow.PolicySnapshot for compare-and-swap. CAS mutations are never retried automatically.

policy_set_payload(type, opts)

query(client, query, params \\ %{}, opts \\ [])

query_indexes(client, index_id \\ nil, opts \\ [])

retry(client, id, opts)

retry_payload(id, opts)

search(client, opts \\ [])

signal(client, id, opts)

signal_payload(id, opts)

stuck(client, type, opts \\ [])

terminals(client, type, opts \\ [])

transition(client, id, opts)

transition_payload(id, opts)

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

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