Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/Desiders/ytdl_tg_bot
/ functions
Functions
727 in github.com/Desiders/ytdl_tg_bot
⨍
Functions
727
◇
Types & classes
375
↓ 1 callers
Method
send_audio_group
( &self, SendMediaGroupRequest { chat_id, reply_to_message_id,
bot/src/services/messenger/telegram.rs:457
↓ 1 callers
Method
send_photo_by_id
(&self, request: SendMediaByIdRequest<'_>)
bot/src/services/messenger/telegram.rs:346
↓ 1 callers
Method
send_photo_group
(&self, request: SendMediaGroupRequest)
bot/src/services/messenger/telegram.rs:486
↓ 1 callers
Method
send_unknown_locale
(&self, input: LangInput<'_>, current: Locale, val: &str)
bot/src/interactors/lang.rs:106
↓ 1 callers
Method
send_video_by_id
(&self, request: SendMediaByIdRequest<'_>)
bot/src/services/messenger/telegram.rs:299
↓ 1 callers
Method
send_video_group
(&self, request: SendMediaGroupRequest)
bot/src/services/messenger/telegram.rs:433
↓ 1 callers
Function
set_my_commands
(bot: Bot)
bot/src/utils/startup.rs:35
↓ 1 callers
Function
shutdown_signal
()
downloader/src/main.rs:112
↓ 1 callers
Function
spawn_pool
Ensures the consumer group exists and spawns `workers` worker tasks. Returns their join handles so the caller can await graceful drain after cancellin
bot/src/worker.rs:45
↓ 1 callers
Method
stats
Stream length split into still-waiting vs delivered-but-unacked (in flight), plus the dead-letter backlog. `XLEN` counts both undelivered and in-fligh
bot/src/services/queue.rs:180
↓ 1 callers
Function
stream_direct_audio
( url: &Url, media: &Media, direct_url: &Url, effective_max_file_size: u64, tx: UnboundedS
downloader/src/grpc/downloader.rs:709
↓ 1 callers
Function
stream_direct_video
( url: &Url, media: &Media, format: &MediaFormat, direct_url: &Url, effective_max_file_siz
downloader/src/grpc/downloader.rs:768
↓ 1 callers
Function
stream_download
( request: DownloadRequest, yt_dlp_cfg: Arc<YtDlpConfig>, gallery_dl_cfg: Arc<GalleryDlConfig>,
downloader/src/grpc/downloader.rs:335
↓ 1 callers
Function
stream_media
( format_id: &str, max_filesize: u64, info_file_path: &Path, yt_dlp_cfg: &YtDlpConfig, pot
downloader/src/services/ytdl.rs:471
↓ 1 callers
Function
stream_media_file
(media_file_path: &std::path::Path, tx: &UnboundedSender<Result<DownloadChunk, Status>>)
downloader/src/grpc/downloader.rs:1193
↓ 1 callers
Function
stream_photo_download
( request: DownloadRequest, url: Url, effective_max_file_size: u64, gallery_dl_cfg: Arc<Galler
downloader/src/grpc/downloader.rs:645
↓ 1 callers
Function
stream_piped_download
( url: &Url, format_id: &str, raw_info_json: &str, media: &Media, format: &MediaFormat,
downloader/src/grpc/downloader.rs:518
↓ 1 callers
Method
sync_cycle
(&mut self)
cookie_assignment/src/service.rs:35
↓ 1 callers
Function
synthesize_photo
Builds a single-photo playlist for a snapsave image: the direct CDN URL is fetched as-is at download time (`direct` marker), with the original post UR
downloader/src/grpc/downloader.rs:1003
↓ 1 callers
Method
templates
(&self)
downloader/src/services/ytdl.rs:33
↓ 1 callers
Function
tg_messenger_registry
(bot: Bot, api_server: APIServer, cfg_registry: Registry)
bot/src/di_container.rs:58
↓ 1 callers
Method
to_download_sections_string
(&self)
downloader/src/entities/sections.rs:60
↓ 1 callers
Method
to_download_sections_string
(&self)
bot/src/entities/sections.rs:62
↓ 1 callers
Method
to_range_string
(&self)
downloader/src/entities/range.rs:43
↓ 1 callers
Method
toggle
(self)
bot/src/locale.rs:31
↓ 1 callers
Method
transcode_to_wav
(&self, input: &Path, wav: &Path)
downloader/src/services/songrec.rs:91
↓ 1 callers
Method
update
( &self, ChatConfigUpdate { tg_id, cmd_random_enabled, lin
bot/src/database/repos/chat_config.rs:62
↓ 1 callers
Method
upload_audio
(&self, request: UploadAudioRequest<'_>)
bot/src/services/messenger/telegram.rs:181
↓ 1 callers
Method
upload_photo
(&self, request: UploadPhotoRequest<'_>)
bot/src/services/messenger/telegram.rs:230
↓ 1 callers
Method
upload_photo_url
(&self, request: UploadPhotoUrlRequest<'_>)
bot/src/services/messenger/telegram.rs:268
↓ 1 callers
Method
upload_video
(&self, request: UploadVideoRequest<'_>)
bot/src/services/messenger/telegram.rs:132
↓ 1 callers
Method
upsert_cookie
(&self, cookie_id: &str, domain: &str, data: &str)
downloader/src/entities/cookies.rs:40
↓ 1 callers
Method
with_language
(mut self, language: String)
bot/src/entities/chat_config.rs:68
↓ 1 callers
Method
with_link_is_visible
(mut self, link_is_visible: bool)
bot/src/entities/chat_config.rs:63
↓ 1 callers
Method
with_progress_reuse
(mut self, progress_message_id: i64, base_text: Option<String>)
bot/src/entities/download_job.rs:76
↓ 1 callers
Function
worker_loop
(consumer: String, container: Container, queue: Arc<RedisJobQueue>, shutdown: CancellationToken)
bot/src/worker.rs:70
Function
accepts_modern_image_formats
()
downloader/src/services/gallery_dl.rs:506
Function
active_livestream_when_is_live_flag_is_true
()
downloader/src/entities/media.rs:345
Function
active_livestream_when_live_status_is_live
()
downloader/src/entities/media.rs:350
Function
active_livestream_when_live_status_is_upcoming
()
downloader/src/entities/media.rs:355
Function
add_exclude_domain
( message: Message, Extension(chat_cfg): Extension<ChatConfig>, Extension(chat_cfg_domains): Exten
bot/src/handlers/config.rs:55
Function
allows_non_live_playlist
()
downloader/src/grpc/downloader.rs:1438
Function
appends_extension_when_name_has_no_extension
()
bot/src/utils/fs.rs:97
Function
appends_last_extension_when_name_has_no_extension
()
bot/src/utils/fs.rs:55
Function
applies_first_matching_rule
()
downloader/src/services/domain_replacer.rs:131
Method
aspect_ratio_kind
(&self)
bot/src/entities/media.rs:38
Function
audio_only_builds_formats_correctly_without_heights
()
downloader/src/services/ytdl.rs:663
Function
audio_only_includes_language_if_provided
()
downloader/src/services/ytdl.rs:676
Function
audio_only_multiple_languages_are_handled_correctly
()
downloader/src/services/ytdl.rs:691
Method
call
(&mut self, request: Request<()>)
downloader/src/grpc/auth.rs:22
Method
call
(&mut self, mut request: Request, next: Next)
bot/src/middlewares/remove_tracking_params.rs:17
Method
call
(&mut self, mut request: Request)
bot/src/middlewares/create_chat.rs:25
Method
call
(&mut self, request: Request, next: Next)
bot/src/middlewares/reaction.rs:21
Function
change_link_visibility
( message: Message, Extension(chat_cfg): Extension<ChatConfig>, Inject(interactor): Inject<config:
bot/src/handlers/config.rs:15
Function
change_link_visibility_private_only
( message: Message, Extension(chat_cfg): Extension<ChatConfig>, Inject(messenger): Inject<Messenge
bot/src/handlers/config.rs:32
Function
classify_download_error
(err: &DownloadErrorKind)
downloader_client/src/download.rs:93
Function
classify_get_media_info_error
(err: &GetMediaInfoErrorKind)
downloader_client/src/media_info.rs:36
Function
classify_recognize_song_error
(err: &RecognizeSongErrorKind)
downloader_client/src/recognize.rs:55
Function
classify_resolve_source_error
(err: &ResolveSourceErrorKind)
downloader_client/src/resolve.rs:74
Function
command_parts_default_to_python_module_launcher
()
downloader/src/config.rs:262
Function
command_parts_use_explicit_command_when_present
()
downloader/src/config.rs:249
Function
compare_nodes
(left: &NodeSnapshot<'_>, right: &NodeSnapshot<'_>)
downloader_client/src/selection.rs:15
Method
compare_workers
( worker_assignments: &WorkerAssignments<'_>, left: &AssignmentNodeHandle, right: &Ass
cookie_assignment/src/service.rs:314
Method
cookie_domains
(cookies: &[CookieRecord])
cookie_assignment/src/service.rs:281
Method
count_by_period
(conn: &Conn, since: Option<OffsetDateTime>)
bot/src/database/readers/downloaded_media.rs:119
Method
default
()
downloader/src/config.rs:137
Method
default
()
downloader/src/entities/range.rs:49
Method
default
()
bot/src/database/factories.rs:125
Method
default
()
bot/src/entities/range.rs:62
Function
default_db_acquire_timeout_secs
()
bot/src/config.rs:97
Function
default_db_connect_timeout_secs
()
bot/src/config.rs:101
Function
default_db_max_connections
()
bot/src/config.rs:93
Function
defaults_to_jpg_when_extension_is_missing
()
downloader/src/services/gallery_dl.rs:488
Function
detects_retryable_authentication_error
()
downloader/src/services/ytdl.rs:720
Function
detects_retryable_geo_restricted_error
()
downloader/src/services/ytdl.rs:730
Function
detects_spotify_platforms
()
downloader_client/src/resolve.rs:88
Function
does_not_replace_for_media_type_without_rules
()
downloader/src/services/domain_replacer.rs:106
Method
down
(&self, manager: &SchemaManager)
migration/src/m20260210_174551_add_downloaded_media_sections.rs:38
Method
down
(&self, manager: &SchemaManager)
migration/src/m20220101_000001_create_table.rs:57
Method
down
(&self, manager: &SchemaManager)
migration/src/m20260228_070901_add_chat_config_link_is_visible.rs:21
Method
down
(&self, manager: &SchemaManager)
migration/src/m20251113_100712_remove_chat_from_downloaded_media.rs:21
Method
down
(&self, manager: &SchemaManager)
migration/src/m20260301_120000_add_chat_config_language.rs:21
Method
down
(&self, manager: &SchemaManager)
migration/src/m20260123_213835_add_downloaded_media_language.rs:36
Method
down
(&self, manager: &SchemaManager)
migration/src/m20260217_205206_add_chat_config_exclude_domains.rs:42
Method
down
(&self, manager: &SchemaManager)
migration/src/m20260112_142259_chat_config.rs:36
Method
down
(&self, manager: &SchemaManager)
migration/src/m20260427_120000_add_chat_type_to_chats.rs:30
Method
down
(&self, _manager: &SchemaManager)
migration/src/m20260501_000000_add_photo_media_type.rs:15
Function
download
( message: Message, params: Params, Extension(url): Extension<Url>, Extension(chat_cfg): Exten
bot/src/handlers/audio.rs:18
Function
download
( message: Message, params: Params, Extension(url): Extension<Url>, Extension(chat_cfg): Exten
bot/src/handlers/video.rs:18
Function
download
( message: Message, params: Params, Extension(url): Extension<Url>, Extension(chat_cfg): Exten
bot/src/handlers/photo.rs:18
Function
download_audio
( params: Params, url_option: Option<Extension<Url>>, Extension(chat_cfg): Extension<ChatConfig>,
bot/src/handlers/chosen_inline.rs:84
Function
download_auto
( params: Params, url_option: Option<Extension<Url>>, Extension(chat_cfg): Extension<ChatConfig>,
bot/src/handlers/chosen_inline.rs:18
Function
download_auto
( message: Message, params: Params, Extension(url): Extension<Url>, Extension(chat_cfg): Exten
bot/src/handlers/video.rs:48
Function
download_auto_quiet
( message: Message, params: Params, Extension(url): Extension<Url>, Extension(chat_cfg): Exten
bot/src/handlers/video.rs:78
Function
download_error_status
(err: ytdl::DownloadErrorKind)
downloader/src/grpc/downloader.rs:1104
Function
download_media
( search: &str, raw_info: &RawPhotoInfo, max_filesize: u64, output_dir_path: &Path, galler
downloader/src/services/gallery_dl.rs:293
Function
download_media
Starts media download on a routed downloader node. The node streams `Progress` chunks while the download runs and only sends `Meta` once the download
downloader_client/src/download.rs:56
Function
download_video
( params: Params, url_option: Option<Extension<Url>>, Extension(chat_cfg): Extension<ChatConfig>,
bot/src/handlers/chosen_inline.rs:51
Method
drop
(&mut self)
downloader/src/grpc/downloader.rs:330
Function
drops_video_file_events
()
downloader/src/services/gallery_dl.rs:471
← previous
next →
301–400 of 727, ranked by callers