ElasticsearchElixirBulkProcessor.Bulk.Retry (Elasticsearch Elixir Bulk Processor v0.1.8)
Link to this section Summary
Link to this section Functions
Link to this function
default()
Link to this function
policy()
Reads the application variable retry_function
and uses as the result as the retyr policy.
ElixirRetry is used for retrying. The default policy is:
constant_backoff(100) |> Stream.take(5)
Examples
iex> use Retry ...> Application.put_env(:elasticsearch_elixir_bulk_processor, :retry_function, fn -> ...> constant_backoff(100) |> Stream.take(2) ...> end) ...> ElasticsearchElixirBulkProcessor.Bulk.Retry.policy() |> Enum.to_list() 'dd'
iex> use Retry ...> Application.put_env(:elasticsearch_elixir_bulk_processor, :retry_function, nil) ...> ElasticsearchElixirBulkProcessor.Bulk.Retry.policy() |> Enum.to_list() 'ddddd'