gaato/discord/queue - mooncakes.io

README
U
AllowedMentionType
U
AllowedMentions
U
AllowedMentionsError
U
App
U
AppConfigError
U
AppCtx
U
Arg
U
Args
U
AudioSource
U
Bot
U
BotError
U
BotSession
U
CheckCtx
U
Client
U
Command
U
CommandCheck
U
CommandReply
U
CommandScope
U
ComponentDeferredCtx
U
ComponentHandler
U
ComponentImmediateCtx
U
ComponentReply
U
ComponentRoute
U
CooldownBucket
U
CustomIdCodec
U
CustomIdError
U
DeferredCtx
U
ErrorPolicy
U
Event
U
EventType
U
Events
U
FailureCtx
U
FailureOrigin
U
FileUpload
U
GatewayCapabilities
U
GatewayCtx
U
HandlerError
U
ImmediateCtx
U
InitialResponse
U
Intents
U
InteractionEndpoint
U
InteractionHandler
U
InteractionHttpBody
U
InteractionHttpRequest
U
InteractionHttpResponse
U
InteractionOutcome
U
InteractionVerifier
U
InteractionVerifierError
U
InteractionsServer
U
Modal
U
ModalDeferredCtx
U
ModalField
U
ModalFields
U
ModalHandle
U
ModalImmediateCtx
U
ModalSubmitHandler
U
OggOpusError
U
OggOpusSource
U
OggOpusWriter
U
ShardConfig
U
SlashChild
U
SuggestCtx
U
VoiceConnection
U
VoiceConnectionState
U
VoiceError
U
VoiceEvent
U
VoiceReceiveStream
U
VoiceTelemetry
U
WaitFrom
V
API_VERSION
V
SILENCE_FRAME
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/queue does not have a README file

IdentifyQueue

pub(open) trait IdentifyQueue {
  async fn wait_for_identify(Self, shard_id : Int) -> Unit
}

Serializes shard Identify calls per Discord's max_concurrency buckets. One queue instance must be shared by every shard of a bot; cross-process deployments can substitute their own implementation.

InMemoryQueue

source

pub struct InMemoryQueue {
  // private fields
}

In-process identify queue: shard_id % max_concurrency buckets, at most one Identify per bucket per spacing_ms (default 5 seconds plus margin).

impl IdentifyQueue for InMemoryQueue

InMemoryQueue::InMemoryQueue

source

fn InMemoryQueue::InMemoryQueue(max_concurrency? : Int, spacing_ms? : Int) -> InMemoryQueue

Create a queue with max_concurrency identify buckets (the value Discord reports in GET /gateway/bot), spacing identifies within each bucket by spacing_ms.

InMemoryQueue::wait_for_identify

source

async fn InMemoryQueue::wait_for_identify(self : InMemoryQueue, shard_id : Int) -> Unit

Source Files

queue.mbt

Site source Report issue Packages Build queue Skills Statistics

#IdentifyQueue

#InMemoryQueue

#InMemoryQueue::InMemoryQueue

#InMemoryQueue::wait_for_identify

Source Files

IdentifyQueue

InMemoryQueue

InMemoryQueue::InMemoryQueue

InMemoryQueue::wait_for_identify