NYSETL.Engines.E1.Broadway behaviour (nys_etl v0.1.0) View Source
Reads an ECLRS file and processes it with high concurrency.
Link to this section Summary
Functions
Callback implementation for Broadway.handle_batch/4.
Callback implementation for Broadway.handle_failed/2.
Callback implementation for Broadway.handle_message/3.
Link to this section Callbacks
Specs
process_name(Broadway.name(), base_name :: String.t()) :: Broadway.name()
Link to this section Functions
Callback implementation for Broadway.handle_batch/4.
Callback implementation for Broadway.handle_failed/2.
Callback implementation for Broadway.handle_message/3.