View Source EchoPubSub.Producer.Remote (EchoPubSub v0.2.2)

Calls the producer's tasks make to remote workers. Every failure (timeout, dead worker, nodedown, injected fault, non-:ok reply) becomes an error result, so a task never crashes.

Summary

Types

batch()

registration()

verdict()

Functions

deliver(pid, arg, timeout)

Sends a batch, or {:expired, node()} for a node too far behind, and returns the verdict the producer folds into its state.

probe(pid, timeout)

Pings the worker to learn whether it answers again. A worker older than :ping replies {:error, :bad_message}, which still proves it is alive.

register(pid, message, timeout)

Sends {:register, node, missed_writes?} or {:resume, node} to the worker.

Types

batch()

@type batch() :: {:expired, pos_integer()} | {:messages, [term()]}

registration()

@type registration() :: {:register, node(), boolean()} | {:resume, node()}

verdict()

@type verdict() ::
  :ok | {:expired, pos_integer()} | :expired_failed | {:failed, pos_integer()}

Functions

deliver(pid, arg, timeout)

@spec deliver(pid(), batch(), timeout()) :: verdict()

Sends a batch, or {:expired, node()} for a node too far behind, and returns the verdict the producer folds into its state.

probe(pid, timeout)

@spec probe(pid(), timeout()) :: :ok | :error

Pings the worker to learn whether it answers again. A worker older than :ping replies {:error, :bad_message}, which still proves it is alive.

register(pid, message, timeout)

@spec register(pid(), registration(), timeout()) :: :ok | :error

Sends {:register, node, missed_writes?} or {:resume, node} to the worker.