You're seeing just the function update_rate_limiting, go back to Broadway module for more information.
Link to this function

update_rate_limiting(broadway, opts)

View Source (since 0.6.0)


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.


Broadway.update_rate_limiting(broadway, allowed_messages: 100)