Mosql.ChangeStreamProducer (mosql v0.1.0)
Link to this section Summary
Functions
Invoked once by Broadway during Broadway.start_link/2. see more here https://hexdocs.pm/broadway/Broadway.Producer.html#c:prepare_for_start/2
Link to this section Functions
Link to this function
prepare_for_start(module, broadway_opts)
Invoked once by Broadway during Broadway.start_link/2. see more here https://hexdocs.pm/broadway/Broadway.Producer.html#c:prepare_for_start/2
@broadway_opts [ hibernate_after: 15000, context: :context_not_set, resubscribe_interval: 100, max_seconds: 5, max_restarts: 3, shutdown: 30000, name: MS.Pipeline, producer: [
hibernate_after: 15000,
transformer: nil,
concurrency: 1,
module:
{MS.BroadwayMongo.Producer, <producer_opts>}
], processors: [default: [hibernate_after: 15000, max_demand: 10, concurrency: 1]], batchers: [
default: [hibernate_after: 15000, batch_timeout: 1000, concurrency: 1, batch_size: 1]
] ]