NYSETL.Engines.E3.Broadway behaviour (nys_etl v0.1.0) View Source

Link to this section Summary

Callbacks

process_name(name, base_name)

Functions

ack(atom, successful, failed)

handle_message(_, message, _)

Callback implementation for Broadway.handle_message/3.

process_name(broadway_name, base_name)

start_link(_)

transform(data, _)

Link to this section Callbacks

process_name(name, base_name)

Specs

process_name(Broadway.name(), base_name :: String.t()) :: Broadway.name()

Link to this section Functions

ack(atom, successful, failed)

handle_message(_, message, _)

Callback implementation for Broadway.handle_message/3.

process_name(broadway_name, base_name)

start_link(_)

transform(data, _)