gaato/discord/cooldown - mooncakes.io

README
U
AllowedMentionType
U
AllowedMentions
U
AllowedMentionsError
U
App
U
AppBuilder
U
AppConfigError
U
AppCtx
U
AppWarning
U
ApplicationRef
U
Arg
U
Args
U
Bot
U
BotBuilder
U
BotConfigError
U
BotError
U
BotSession
U
CacheLimit
U
CacheLimits
U
CacheResources
U
ChannelRef
U
CheckCtx
U
Client
U
Command
U
CommandCheck
U
CommandPlan
U
CommandReply
U
CommandScope
U
ComponentCtx
U
ComponentDeferredCtx
U
ComponentHandler
U
ComponentImmediateCtx
U
ComponentReply
U
ComponentRoute
U
CooldownBucket
U
CooldownOutage
U
CustomIdCodec
U
CustomIdError
U
DeferredCtx
U
DiscordHttpError
U
ErrorPolicy
U
Event
U
EventMiddleware
U
EventType
U
Events
U
FailureCtx
U
FailureOrigin
U
FileUpload
U
GatewayCapabilities
U
GatewayCtx
U
GuildInvocation
U
GuildRef
U
HandlerError
U
HandlerIntake
U
ImmediateCtx
U
InMemoryCache
U
InitialResponse
U
Intents
U
InteractionCtx
U
InteractionEndpoint
U
InteractionHandler
U
InteractionHttpBody
U
InteractionHttpRequest
U
InteractionHttpResponse
U
InteractionOutcome
U
InteractionTarget
U
InteractionVerifier
U
InteractionVerifierError
U
InteractionsServer
U
InvocationScope
U
MemberRef
U
MessageRef
U
MessageUpdate
U
Modal
U
ModalDeferredCtx
U
ModalField
U
ModalFields
U
ModalHandle
U
ModalImmediateCtx
U
ModalOrigin
U
ModalReply
U
ModalShowError
U
ModalSubmitHandler
U
PendingEvent
U
ResponseState
U
RestAccess
U
ServerConfigError
U
ShardConfig
U
SlashChild
U
SuggestCtx
U
SyncReport
U
TargetUser
U
UserRef
U
WaitFrom
V
API_VERSION
V
action_row
V
arg_attachment
V
arg_bool
V
arg_channel
V
arg_int
V
arg_int32
V
arg_mentionable
V
arg_number
V
arg_role
V
arg_string
V
arg_user
V
button
V
channel_select
V
component_route
V
container
V
dm_only
V
file_field
V
file_upload
V
guild_only
V
int_choice
V
label
V
link_button
V
media_gallery
V
media_item
V
mentionable_select
V
message_command
V
modal
V
number_choice
V
required_permissions
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_select
V
subcommand
V
subcommand_group
V
text_display
V
text_field
V
text_input
V
thumbnail
V
user_command
V
user_select
V
verify_signature

gaato/discord/cooldown does not have a README file

CooldownStore

pub(open) trait CooldownStore {
  async fn try_acquire(Self, key : String, window_ms~ : Int64) -> CooldownDecision
}

Storage for command cooldown windows. Implementations own their clock.

CooldownDecision

source

pub(all) enum CooldownDecision {
  Acquired
  Active(retry_after_ms~ : Int64)
  Unavailable(reason~ : String)
} derive(Eq, @moonbitlang/core/debug.Debug
Debug)

The result of attempting to start a cooldown window.

InMemoryCooldownStore

source

pub struct InMemoryCooldownStore {
  // private fields
}

In-process fixed windows. Expired keys are swept each time the map has doubled since the last sweep, so memory follows the live windows however long or short they are, and at least once a minute, so a burst's expired keys do not stay once traffic returns to a few keys.

impl CooldownStore for InMemoryCooldownStore

InMemoryCooldownStore::InMemoryCooldownStore

source

fn InMemoryCooldownStore::InMemoryCooldownStore(now? : () -> Int64) -> InMemoryCooldownStore

Create an empty store, optionally supplying a clock for deterministic tests.

async test {
  let store = @cooldown.InMemoryCooldownStore(now=() => 1_000L)
  assert_eq(store.try_acquire("1:ping|global", window_ms=10_000L), Acquired)
  assert_eq(
    store.try_acquire("1:ping|global", window_ms=10_000L),
    Active(retry_after_ms=10_000L),
  )
}

InMemoryCooldownStore::try_acquire

source

async fn InMemoryCooldownStore::try_acquire(self : InMemoryCooldownStore, key : String, window_ms~ : Int64) -> CooldownDecision

Source Files

cooldown.mbt

Site source Report issue Packages Build queue Skills Statistics

#CooldownStore

#CooldownDecision

#InMemoryCooldownStore

#InMemoryCooldownStore::InMemoryCooldownStore

#InMemoryCooldownStore::try_acquire

Source Files

CooldownStore

CooldownDecision

InMemoryCooldownStore

InMemoryCooldownStore::InMemoryCooldownStore

InMemoryCooldownStore::try_acquire