_remote_music_queue

Module Contents

Functions

declare_dlx(b)

dispatch(→ None)

transmute_youtube_query(...)

transmute_youtube_playlist() → None)

transmute_youtube() → None)

transmute_spotify() → None)

Attributes

tracer_provider

broker

plq

dlx

dlq

dispatcher_queue

server_publisher

provider_exch

youtube_playlist_queue

youtube_playlist_publisher

youtube_query_queue

youtube_queue

spotify_queue

spotify_publisher

hub_exch

hub_queue

_remote_music_queue.tracer_provider
_remote_music_queue.broker
_remote_music_queue.plq
_remote_music_queue.dlx
_remote_music_queue.dlq
async _remote_music_queue.declare_dlx(b: faststream.rabbit.RabbitBroker)
_remote_music_queue.dispatcher_queue
_remote_music_queue.server_publisher
_remote_music_queue.provider_exch
_remote_music_queue.youtube_playlist_queue
_remote_music_queue.youtube_playlist_publisher
_remote_music_queue.youtube_query_queue
_remote_music_queue.youtube_queue
_remote_music_queue.spotify_queue
_remote_music_queue.spotify_publisher
_remote_music_queue.hub_exch
_remote_music_queue.hub_queue
async _remote_music_queue.dispatch(logger: faststream.Logger, request: pipo.player.music_queue.models.MusicRequest) → None
async _remote_music_queue.transmute_youtube_query(request: pipo.player.music_queue.models.ProviderOperation, logger: faststream.Logger) → pipo.player.music_queue.models.ProviderOperation
async _remote_music_queue.transmute_youtube_playlist(request: pipo.player.music_queue.models.ProviderOperation, logger: faststream.Logger, correlation_id: str = Context('message.correlation_id')) → None
async _remote_music_queue.transmute_youtube(request: pipo.player.music_queue.models.ProviderOperation, logger: faststream.Logger, correlation_id: str = Context('message.correlation_id')) → None
async _remote_music_queue.transmute_spotify(request: pipo.player.music_queue.models.ProviderOperation, logger: faststream.Logger, correlation_id: str = Context('message.correlation_id')) → None