Capstan.CheckpointStore.InMemory (Capstan v0.1.0)

Copy Markdown View Source

A process-lifetime Capstan.CheckpointStore reference implementation.

Backed by an Agent holding one pipeline's gtid_set string (nil until first written). It is durable only for the life of the process — a restart loses the checkpoint — so it is intended for tests and ephemeral pipelines, never as a production durable store.

Summary

Functions

Start a fresh store (the checkpoint begins nil).

Functions

start_link(opts \\ [])

@spec start_link(keyword()) :: Agent.on_start()

Start a fresh store (the checkpoint begins nil).