All Classes and Interfaces
Class
Description
A causal past carried at the edge of the pipeline: a session token held by a client, or
the recorded past stored beside a projected row.
The outcome of one coverage check.
A causal frontier: per channel, the highest position known to be a cause.
The wire representation of a causal frontier.
Signals metadata that was present and could not be trusted.
A typed topic a process receives from or sends to.
Where a process begins reading a channel it has no committed position for.
A channel, named by topic identity rather than topic name.
The delivery decision, as a pure function.
One unsatisfied cause.
Every cause is satisfied.
At least one cause is outstanding.
Per-channel view of how far delivery has settled.
The outcome of one decision.
A message the engine has established as deliverable, with its causes decoded.
One message, established as causally deliverable and handed to application logic.
Everything one step changes: the messages it sends and the state it writes.
Accumulates sends and writes.
One message to send.
One change to application state.
Application logic for one channel of one process.
One message header.
What a host learned of channel identity when a process initialised: which channels' topics
no longer exist, and which exist again under a new identity.
The one spelling of Kafka's topic-name rule.
Reads ordering state without an engine.
The byte-level key-value store holding a process's ordering state.
Receives one entry during a prefix scan.
A running set of processes, each executing under causal delivery order.
Broker connection, application identity and the tuning Parsley leaves open.
Accumulates configuration, rejecting anything that would weaken the guarantee.
Thrown where the delivery guarantee cannot be upheld.
Why delivery stopped.
Owns the Kafka Streams application behind each running process.
One process: the channels it receives, the channels it sends on, and the stores it owns.
Accumulates the channels and stores of one process.
A received channel and the logic that handles it.
The protocol, driven by a host.
What became of a message the host fed in.
The state of one process at a moment in time.
Lifecycle state of a process.
A message as the host fed it to the engine, before its causes were read.
Read access to the stores a process declared.
A typed key-value store a process reads and writes.
The delivery state of one task of a process: what it holds, what each hold is waiting for,
and how much causal metadata it carries.
One cause a held message is waiting for.
One channel with held messages.