SuperWorker.Supervisor.Chain.Messaging (SuperWorker v0.3.6)

View Source

Handles message passing and data flow within a worker chain.

This module is responsible for sending data to the correct worker(s) based on the chain's configuration (e.g., send type, order) and invoking the finished callback when data completes its journey through the chain.

Summary

Functions

new_data(chain, msg)

Injects new data into the beginning of the chain.

send_next(chain, order, msg)

Sends data to the next worker(s) in the chain based on the current order.

Functions

new_data(chain, msg)

@spec new_data(SuperWorker.Supervisor.Chain.t(), SuperWorker.Supervisor.Message.t()) ::
  :ok

Injects new data into the beginning of the chain.

send_next(chain, order, msg)

@spec send_next(
  SuperWorker.Supervisor.Chain.t(),
  non_neg_integer(),
  SuperWorker.Supervisor.Message.t()
) ::
  {:ok, atom()} | {:error, atom()}

Sends data to the next worker(s) in the chain based on the current order.