Broadway.update_rate_limiting
You're seeing just the function
update_rate_limiting
, go back to Broadway module for more information.
Specs
update_rate_limiting(server :: atom(), opts :: Keyword.t()) :: :ok | {:error, :rate_limiting_not_enabled}
Updates the producer rate limiting of the given pipeline at runtime.
Supports the following options (see the :rate_limiting
options in the module
documentation for more information):
:allowed_messages
:interval
Returns an {:error, reason}
tuple if the given broadway
pipeline doesn't
have rate limiting enabled.
Examples
Broadway.update_rate_limiting(broadway, allowed_messages: 100)