mooncakes.io

README
U
AllowedMentionType
U
AllowedMentions
U
AllowedMentionsError
U
App
U
AppConfigError
U
AppCtx
U
ApplicationEmojiRef
U
ApplicationRef
U
Arg
U
Args
U
ArgsDecodeError
U
AudioSource
U
AutoModerationRuleRef
U
AutocompleteCtx
U
Bot
U
BotError
U
ChannelRef
U
CheckCtx
U
Client
U
Command
U
CommandCheck
U
CommandCtx
U
CommandModel
U
CommandOptions
U
CommandReply
U
CommandSpec
U
CommandSync
U
ComponentCtx
U
ComponentDeferredCtx
U
ComponentHandler
U
ComponentImmediateCtx
U
ComponentReply
U
ComponentWaiter
U
CooldownBucket
U
Coordinator
U
CoordinatorError
U
DeferredCtx
U
EmojiRef
U
EntitlementRef
U
ErrorPolicy
U
Event
U
EventType
U
Events
U
FailureCtx
U
FailureOrigin
U
FailureRaw
U
FileUpload
U
Framework
U
GatewayCtx
U
GlobalCommandRef
U
GuildCommandRef
U
GuildInvocation
U
GuildRef
U
HandlerError
U
ImmediateCtx
U
InitialResponse
U
Intents
U
InteractionContextError
U
InteractionEndpoint
U
InteractionHandler
U
InteractionOutcome
U
InteractionVerifier
U
InteractionVerifierError
U
InteractionsServer
U
InviteRef
U
InvocationScope
U
MemberRef
U
MessageRef
U
Modal
U
ModalCtx
U
ModalDeferredCtx
U
ModalField
U
ModalFields
U
ModalHandle
U
ModalImmediateCtx
U
ModalOrigin
U
ModalSubmitHandler
U
OggOpusError
U
OggOpusSource
U
OggOpusWriter
U
Paginator
U
RegisteredCommand
U
RemoteIdentifyQueue
U
RemoteRateLimiter
U
ResponsePhase
U
RoleRef
U
ScheduledEventRef
U
Shard
U
ShardConfig
U
ShardEvent
U
SkuRef
U
SlashChild
U
SoundboardSoundRef
U
Spawner
U
StickerRef
U
SuggestCtx
U
TargetUser
U
TelemetryEvent
U
TemplateRef
U
UserRef
U
VoiceConnection
U
VoiceConnectionState
U
VoiceError
U
VoiceEvent
U
VoiceReceiveStream
U
VoiceTelemetry
U
WebhookMessageRef
U
WebhookRef
U
WebhookTokenRef
V
API_VERSION
V
SILENCE_FRAME
V
action_row
V
arg_attachment
V
arg_bool
V
arg_channel
V
arg_int
V
arg_mentionable
V
arg_number
V
arg_role
V
arg_string
V
arg_user
V
attachment_option
V
boolean_option
V
button
V
channel_option
V
channel_select
V
container
V
dm_only
V
guild_only
V
int_choice
V
integer_option
V
label
V
link_button
V
media_gallery
V
media_item
V
mentionable_option
V
mentionable_select
V
message_command
V
modal
V
number_choice
V
number_option
V
required_permissions
V
role_option
V
role_select
V
section
V
select_field
V
select_option
V
separator
V
serve_interactions
V
slash
V
slash_group
V
string_choice
V
string_option
V
string_select
V
sub_command
V
sub_command_group
V
subcommand
V
subcommand_group
V
text_display
V
text_field
V
text_input
V
thumbnail
V
user_command
V
user_option
V
user_select
V
verify_signature

gaato/discord/ratelimit does not have a README file

RateLimiter

pub(open) trait RateLimiter {
  async fn acquire(Self, bucket_key : String, global_exempt~ : Bool) -> Unit
  async fn release(Self, bucket_key : String, status~ : Int, headers~ : Map[String, String]) -> Unit
}

REST rate limiting strategy.

The design is requester-driven: acquire blocks (asynchronously) in the calling task until the request may proceed, and release must be called exactly once per successful acquire, with the response's rate-limit headers when available. There is no background actor task, so a cancelled caller cleans up naturally.

Implementations other than InMemoryRateLimiter (e.g. a cross-process store) can be plugged into the HTTP client via this trait.

InMemoryRateLimiter

source

pub struct InMemoryRateLimiter {
  global_limit : Int
  global_window_start : Int64
  global_count : Int
  global_blocked_until : Int64
  // private fields
}

In-process RateLimiter: per-bucket accounting learned from response headers plus a global sliding-window limit (default 50 requests/second).

impl RateLimiter for InMemoryRateLimiter

async fn acquire(self : InMemoryRateLimiter, bucket_key : String, global_exempt~ : Bool) -> Unit

source

Wait for bucket capacity — and the global window unless global_exempt — before the request is sent.

async fn release(self : InMemoryRateLimiter, bucket_key : String, status~ : Int, headers~ : Map[String, String]) -> Unit

source

Feed the response's x-ratelimit-* headers back into the bucket accounting.

InMemoryRateLimiter::InMemoryRateLimiter

source

fn InMemoryRateLimiter::InMemoryRateLimiter(global_limit? : Int) -> InMemoryRateLimiter

Create a limiter with empty bucket accounting and a global window of global_limit requests per second.

Source Files

ratelimit.mbt

README
U
AllowedMentionType
U
AllowedMentions
U
AllowedMentionsError
U
App
U
AppConfigError
U
AppCtx
U
ApplicationEmojiRef
U
ApplicationRef
U
Arg
U
Args
U
ArgsDecodeError
U
AudioSource
U
AutoModerationRuleRef
U
AutocompleteCtx
U
Bot
U
BotError
U
ChannelRef
U
CheckCtx
U
Client
U
Command
U
CommandCheck
U
CommandCtx
U
CommandModel
U
CommandOptions
U
CommandReply
U
CommandSpec
U
CommandSync
U
ComponentCtx
U
ComponentDeferredCtx
U
ComponentHandler
U
ComponentImmediateCtx
U
ComponentReply
U
ComponentWaiter
U
CooldownBucket
U
Coordinator
U
CoordinatorError
U
DeferredCtx
U
EmojiRef
U
EntitlementRef
U
ErrorPolicy
U
Event
U
EventType
U
Events
U
FailureCtx
U
FailureOrigin
U
FailureRaw
U
FileUpload
U
Framework
U
GatewayCtx
U
GlobalCommandRef
U
GuildCommandRef
U
GuildInvocation
U
GuildRef
U
HandlerError
U
ImmediateCtx
U
InitialResponse
U
Intents
U
InteractionContextError
U
InteractionEndpoint
U
InteractionHandler
U
InteractionOutcome
U
InteractionVerifier
U
InteractionVerifierError
U
InteractionsServer
U
InviteRef
U
InvocationScope
U
MemberRef
U
MessageRef
U
Modal
U
ModalCtx
U
ModalDeferredCtx
U
ModalField
U
ModalFields
U
ModalHandle
U
ModalImmediateCtx
U
ModalOrigin
U
ModalSubmitHandler
U
OggOpusError
U
OggOpusSource
U
OggOpusWriter
U
Paginator
U
RegisteredCommand
U
RemoteIdentifyQueue
U
RemoteRateLimiter
U
ResponsePhase
U
RoleRef
U
ScheduledEventRef
U
Shard
U
ShardConfig
U
ShardEvent
U
SkuRef
U
SlashChild
U
SoundboardSoundRef
U
Spawner
U
StickerRef
U
SuggestCtx
U
TargetUser
U
TelemetryEvent
U
TemplateRef
U
UserRef
U
VoiceConnection
U
VoiceConnectionState
U
VoiceError
U
VoiceEvent
U
VoiceReceiveStream
U
VoiceTelemetry
U
WebhookMessageRef
U
WebhookRef
U
WebhookTokenRef
V
API_VERSION
V
SILENCE_FRAME
V
action_row
V
arg_attachment
V
arg_bool
V
arg_channel
V
arg_int
V
arg_mentionable
V
arg_number
V
arg_role
V
arg_string
V
arg_user
V
attachment_option
V
boolean_option
V
button
V
channel_option
V
channel_select
V
container
V
dm_only
V
guild_only
V
int_choice
V
integer_option
V
label
V
link_button
V
media_gallery
V
media_item
V
mentionable_option
V
mentionable_select
V
message_command
V
modal
V
number_choice
V
number_option
V
required_permissions
V
role_option
V
role_select
V
section
V
select_field
V
select_option
V
separator
V
serve_interactions
V
slash
V
slash_group
V
string_choice
V
string_option
V
string_select
V
sub_command
V
sub_command_group
V
subcommand
V
subcommand_group
V
text_display
V
text_field
V
text_input
V
thumbnail
V
user_command
V
user_option
V
user_select
V
verify_signature

Site source Report issue Packages Build queue Skills Statistics

#RateLimiter

#InMemoryRateLimiter

#InMemoryRateLimiter::InMemoryRateLimiter

Source Files

RateLimiter

InMemoryRateLimiter

InMemoryRateLimiter::InMemoryRateLimiter