TLX.Extractor.Broadway (TLX v0.5.2)

Extracts pipeline topology from Broadway modules via source AST.

Parses the Broadway.start_link/2 call in start_link/1 to extract producer, processor, and batcher configuration. Also detects handle_message/3 and handle_batch/4 callback clauses.

Usage

{:ok, result} = TLX.Extractor.Broadway.extract_from_source(source)

result.producers    #=> [%{module: Broadway.DummyProducer}]
result.processors   #=> [%{name: :default, concurrency: 2}]
result.batchers     #=> [%{name: :sqs, concurrency: 1, batch_size: 10}]

Summary

Functions

extract_from_file(path)

Extract Broadway pipeline topology from a source file.

extract_from_source(source)

Extract Broadway pipeline topology from an Elixir source string.

Functions

extract_from_file(path)

Extract Broadway pipeline topology from a source file.

extract_from_source(source)

Extract Broadway pipeline topology from an Elixir source string.