File tree Expand file tree Collapse file tree 1 file changed +13
-5
lines changed Expand file tree Collapse file tree 1 file changed +13
-5
lines changed Original file line number Diff line number Diff line change @@ -113,6 +113,14 @@ config :flume,
113113 dequeue_lock_poll_interval: 500
114114```
115115
116+ Import flume config in ` config/config.exs ` as given below:
117+
118+ ``` elixir
119+ .. .
120+ import_config " #{ Mix .env ()} .exs"
121+ + import_config " flume.exs"
122+ ```
123+
116124### Pipelines
117125
118126Each pipeline is a GenStage pipeline having these parameters -
@@ -212,10 +220,11 @@ Flume supports rate-limiting for each configured pipeline.
212220
213221Rate-Limiting has two key parameters -
214222
215- * `rate_limit_scale` - Time scale in `milliseconds` for the pipeline
216- * `rate_limit_count` - Total number of jobs to be processed within the time scale
217- * `rate_limit_key`(optional) - Using this option, rate limit can be set across pipelines.
218- When this option is not set, rate limit will be maintained for a pipeline.
223+ - `rate_limit_scale` - Time scale in `milliseconds` for the pipeline
224+ - `rate_limit_count` - Total number of jobs to be processed within the time scale
225+ - `rate_limit_key`(optional) - Using this option, rate limit can be set across pipelines.
226+
227+ **Note**: When this option is not set, rate limit will be maintained for a pipeline.
219228
220229```elixir
221230rate_limit_count = 1000
@@ -262,7 +271,6 @@ Flume supports batch-processing for each configured pipeline.
262271It groups individual jobs by the configured `batch_size` option and
263272each worker process will receive a group of jobs.
264273
265-
266274```elixir
267275config :flume,
268276 pipelines: [
You can’t perform that action at this time.
0 commit comments