Autonomic.Store.Postgres (Autonomic Postgres v0.1.0)

Copy Markdown View Source

PostgreSQL-backed durable authority store with one lock order: episode -> effect -> lease.

Summary

Functions

abort_effect(effect_id, reason)
begin_effect_commit(effect_id, required_decisions)
checkpoint(id)
claim_episode(episode_id, owner_node, ttl_ms)
complete_effect(effect_id, outcome, details \\ %{})
create_episode(attrs)
effect_decisions(effect_id, revision \\ nil)
fetch_episode(id)
latest_stable_checkpoint(episode_id)
list_effects(episode_id, states \\ nil)
mark_committing(effect_id)
mark_effect_evaluating(effect_id)
mark_effect_ready(effect_id)
pending_reconciliation()
prepare_effect(effect)
prepare_existing_effect(effect_id)
put_checkpoint(checkpoint)
reconcile_effect(effect_id, outcome, details \\ %{})
record_effect_decision(effect_id, decision)
record_observation(frame)
record_recovery(attrs)
renew_episode_owner(episode_id, token, ttl_ms)
revoke_lease(id, reason)
set_episode_domain(episode_id, domain)
set_episode_state(episode_id, state, metadata \\ %{})
update_effect_revision(effect_id, attrs)
update_trajectory(episode_id, homeostatic_state)

Functions

abort_effect(effect_id, reason)

begin_effect_commit(effect_id, required_decisions)

checkpoint(id)

claim_episode(episode_id, owner_node, ttl_ms)

complete_effect(effect_id, outcome, details \\ %{})

create_episode(attrs)

effect_decisions(effect_id, revision \\ nil)

fetch_episode(id)

latest_stable_checkpoint(episode_id)

list_effects(episode_id, states \\ nil)

mark_committing(effect_id)

mark_effect_evaluating(effect_id)

mark_effect_ready(effect_id)

pending_reconciliation()

prepare_effect(effect)

prepare_existing_effect(effect_id)

put_checkpoint(checkpoint)

reconcile_effect(effect_id, outcome, details \\ %{})

record_effect_decision(effect_id, decision)

record_observation(frame)

record_recovery(attrs)

renew_episode_owner(episode_id, token, ttl_ms)

revoke_lease(id, reason)

set_episode_domain(episode_id, domain)

set_episode_state(episode_id, state, metadata \\ %{})

update_effect_revision(effect_id, attrs)

update_trajectory(episode_id, homeostatic_state)