View Source AntikytheraCore.AsyncJob.RateLimit (antikythera v0.5.1)

Summary

Functions

Link to this function

check_for_command(queue_name)

View Source
@spec check_for_command(atom()) :: :ok | {:error, pos_integer()}
Link to this function

check_with_retry_for_query(queue_name, f, attempts \\ 0)

View Source
@spec check_with_retry_for_query(
  atom(),
  (() -> a),
  non_neg_integer()
) :: a
when a: any()
Link to this function

milliseconds_per_token()

View Source