View Source EchoPubSub.Producer.Delivery (EchoPubSub v0.2.0)

Sends a registered node what it still needs, in a task. The node's cursor moves to the batch's target only when its worker acks, so a failed batch is resent.

Summary

Functions

abort(state, node)

Drops a task that died without a verdict; the cursor stays, so a retry resends.

finish(state, node, target, verdict)

Applies the task's verdict, then flushes again if writes piled up behind the batch.

running?(state, node)

Whether a batch to node is in flight.

start(state, pid, node)

Starts a delivery task to pid unless node is caught up. Only registered nodes get here.

Functions

abort(state, node)

@spec abort(EchoPubSub.Producer.State.t(), node()) :: EchoPubSub.Producer.State.t()

Drops a task that died without a verdict; the cursor stays, so a retry resends.

finish(state, node, target, verdict)

@spec finish(
  EchoPubSub.Producer.State.t(),
  node(),
  EchoPubSub.Producer.State.cursor(),
  EchoPubSub.Producer.Remote.verdict()
) :: EchoPubSub.Producer.State.t()

Applies the task's verdict, then flushes again if writes piled up behind the batch.

running?(state, node)

@spec running?(EchoPubSub.Producer.State.t(), node()) :: boolean()

Whether a batch to node is in flight.

start(state, pid, node)

@spec start(EchoPubSub.Producer.State.t(), pid(), node()) ::
  EchoPubSub.Producer.State.t()

Starts a delivery task to pid unless node is caught up. Only registered nodes get here.