topology.ex

      processors: [
        # valid options are: [:concurrency, :min_demand, :max_demand, :partition_by, :spawn_opt, :hibernate_after]
        default: [concurrency: 6, partition_by: &partition/1]
      ],
      batchers: [
        # valid options are: [:concurrency, :batch_size, :max_demand, :batch_timeout, :partition_by, :spawn_opt, :hibernate_after]
        pickup: [
          concurrency: 1,
          batch_size: 5,
          batch_timeout: 2_000
        ],
        dropoff: [
          concurrency: 1,
          batch_size: 5,
          batch_timeout: 2_000
        ],
        enroute: [
          concurrency: 4,
          batch_size: 25,
          batch_timeout: 2_000
        ]
      ]