MCPcopy Index your code

hub / github.com/ermak-dev/cloudpub / functions

Functions376 in github.com/ermak-dev/cloudpub

⨍ Functions 376◇ Types & classes 91
↓ 172 callersMethodclone
(&self)
common/src/fair_channel.rs:147
↓ 50 callersMethodsend
Send a value, waiting if the channel is full
common/src/fair_channel.rs:158
↓ 33 callersMethodread
(reader: &mut T, hdr_len: u8)
common/src/protocol.rs:424
↓ 30 callersMethodinsert
Inserts a new item into the queue, ensuring spatial distancing between items of the same group. Returns true if inserted successfully, false if group
common/src/fair_channel.rs:60
↓ 30 callersMethodlen
(&self)
common/src/lease.rs:198
↓ 24 callersMethodwrite
(&self, writer: &mut T)
common/src/protocol.rs:385
↓ 21 callersMethodis_empty
(&self)
common/src/lease.rs:202
↓ 20 callersMethodget_mut
(&mut self)
common/src/transport/tcp.rs:43
↓ 16 callersFunctionget_cache_dir
(subdir: &str)
client/src/shell.rs:490
↓ 14 callersMethodport
(&self)
client/src/plugins/plugin_trait.rs:178
↓ 13 callersMethoditer
(&self)
common/src/lease.rs:186
↓ 11 callersMethodget
(&self, key: &str)
client/src/i18n.rs:42
↓ 11 callersMethodparse
(&self)
client/src/commands.rs:144
↓ 9 callersMethodget_ref
(&self)
common/src/transport/tcp.rs:39
↓ 8 callersMethodplist_path
(&self)
client/src/service/macos.rs:19
↓ 8 callersMethodrecv
Receive a value, waiting if the channel is empty
common/src/fair_channel.rs:232
↓ 8 callersMethodstatus
(&self)
client/src/service/linux.rs:101
↓ 8 callersMethodwait_for_event
Ожидает наступления определенного события с таймаутом. Этот метод блокируется до получения целевого события или истечения таймаута. Он используется в
sdk/rust/src/connection.rs:274
↓ 7 callersMethodacquire_lease
(&self, guid: String)
common/src/lease.rs:81
↓ 7 callersMethodspawn
( plugin: Arc<dyn Plugin>, mut endpoint: ServerEndpoint, config: Arc<RwLock<ClientConf
client/src/plugins/plugin_trait.rs:48
↓ 6 callersFunctioncreatePacket
(type, queueLane, outputArea)
docs/ru/static/js/fair-queue-animation.js:116
↓ 5 callersMethodapply
(&self, conn: &Stream)
common/src/transport/mod.rs:225
↓ 5 callersMethodbuild
Создает и устанавливает соединение с сервером CloudPub. Этот метод: 1. Проверяет конфигурацию 2. Инициализирует логирование 3. Загружает или создает
sdk/rust/src/builder.rs:437
↓ 5 callersFunctiondownload
( message: &str, config: Arc<RwLock<ClientConfig>>, url: &str, path: &Path, command_rx: &m
client/src/shell.rs:329
↓ 5 callersMethodls
Получить список всех зарегистрированных сервисов Возвращает: list[ServerEndpoint]: Список зарегистрированных конечных точек Исключения: CloudPubErro
sdk/python/src/lib.rs:792
↓ 5 callersMethodresolve
(&mut self)
common/src/transport/mod.rs:51
↓ 5 callersFunctionrun_script
( script_name: &str, script_template: &str, replacements: Vec<(&str, String)>, is_service: boo
client/src/upgrade/mod.rs:375
↓ 5 callersMethodstatus
(&self)
client/src/service/macos.rs:99
↓ 4 callersFunctionexecute
( command: PathBuf, args: Vec<String>, chdir: Option<PathBuf>, envs: HashMap<String, String>,
client/src/shell.rs:115
↓ 4 callersFunctionget_version_number
(version: &str)
common/src/utils.rs:113
↓ 4 callersMethodgroup_id
(&self)
common/src/fair_channel.rs:323
↓ 4 callersFunctioninit
(args: &Cli)
client/src/base.rs:120
↓ 4 callersMethodload
(cfg_name: &str, user_dir: bool, readonly: bool)
client/src/config.rs:206
↓ 4 callersMethodls
Выводит список всех зарегистрированных сервисов. Возвращает список всех сервисов, в данный момент зарегистрированных на сервере, включая их статус, U
sdk/rust/src/connection.rs:646
↓ 4 callersMethodpublish
( &self, protocol: Protocol, address: String, name: Option<String>, au
sdk/python/src/lib.rs:690
↓ 4 callersMethodsave
(&self)
client/src/config.rs:194
↓ 4 callersMethodservice_file_path
(&self)
client/src/service/linux.rs:19
↓ 4 callersMethodtry_send
Try to send a value without waiting
common/src/fair_channel.rs:185
↓ 3 callersMethodas_raw_fd
(conn: &Self::Stream)
common/src/transport/tcp.rs:147
↓ 3 callersMethodas_url
(&self)
common/src/protocol.rs:217
↓ 3 callersMethodcopy_config_to_system
Copy the provided config to the system location
client/src/service/mod.rs:102
↓ 3 callersFunctionfair_channel
Creates a new fair channel with the specified max group size
common/src/fair_channel.rs:290
↓ 3 callersFunctionfind_free_tcp_port
()
common/src/utils.rs:72
↓ 3 callersMethodget
(&self, protocol: Protocol)
client/src/plugins/registry.rs:37
↓ 3 callersFunctionhost_port_pair
(s: &str)
common/src/utils.rs:29
↓ 3 callersMethodinto_stream
(self)
common/src/transport/tcp.rs:47
↓ 3 callersMethodlocal_addr
(&self)
common/src/unix_tcp/stream.rs:50
↓ 3 callersMethodpassword
Устанавливает только пароль. Должен использоваться в сочетании с `email()`. Это полезно, когда учетные данные получаются отдельно. # Аргументы `pas
sdk/rust/src/builder.rs:289
↓ 3 callersMethodpop
(&mut self)
common/src/fair_channel.rs:90
↓ 3 callersFunctionprocess_certificate
( cert_der: CertificateDer<'a>, cert_type: &str, )
common/src/transport/rustls.rs:48
↓ 3 callersMethodregister
(&mut self, protocol: Protocol, plugin: Arc<dyn Plugin>)
client/src/plugins/registry.rs:33
↓ 3 callersFunctionsend_progress
( message: &str, template: &str, total: u64, current: u64, progress_tx: &mpsc::Sender<Mess
client/src/shell.rs:98
↓ 3 callersMethodstart
(&self)
client/src/service/linux.rs:85
↓ 3 callersMethodunpublish
Отменить публикацию (отменить регистрацию) сервиса по GUID Аргументы: guid: GUID сервиса для отмены публикации Исключения: CloudPubError: Если отмен
sdk/python/src/lib.rs:775
↓ 3 callersFunctionunzip
( message: &str, zip_file_path: &Path, extract_dir: &Path, skip: usize, result_tx: &mpsc::
client/src/shell.rs:261
↓ 3 callersMethodvalidate
(&self)
client/src/config.rs:227
↓ 2 callersFunctionbuild_proxy_v2_header
Builds a PROXY protocol v2 header for TCP connections # Arguments `client_addr` - The original client's socket address `server_addr` - The server's s
common/src/proxy_protocol.rs:35
↓ 2 callersMethodcan_insert
Check if a value can be inserted without exceeding group limits
common/src/fair_channel.rs:37
↓ 2 callersFunctioncheck_enviroment
(config: Arc<RwLock<ClientConfig>>)
client/src/plugins/onec/mod.rs:39
↓ 2 callersMethodconfig_path
Устанавливает путь к файлу конфигурации. По умолчанию SDK ищет файл конфигурации в стандартном системном расположении. Используйте этот метод для ука
sdk/rust/src/builder.rs:117
↓ 2 callersMethodconnect
(named_socket_addr: &NamedSocketAddr)
common/src/unix_tcp/stream.rs:40
↓ 2 callersMethodcredentials
Устанавливает email и пароль для аутентификации. Используйте этот метод для аутентификации на основе учетных данных. Это взаимоисключающе с аутентифи
sdk/rust/src/builder.rs:227
↓ 2 callersMethodcredentials
(&self)
common/src/protocol.rs:202
↓ 2 callersMethoddefault_port
(&self)
common/src/protocol.rs:82
↓ 2 callersMethoddrop_lease
(&self, guid: &str)
common/src/lease.rs:116
↓ 2 callersMethodget
(&self, key: &str)
client/src/config.rs:218
↓ 2 callersMethodget_all_options
(&self)
client/src/config.rs:223
↓ 2 callersMethodget_tcpstream
(&self)
common/src/transport/websocket.rs:51
↓ 2 callersFunctioninitQueue
(container, type)
docs/ru/static/js/fair-queue-animation.js:26
↓ 2 callersFunctioninit_log
( level: &str, log_file: &Path, stderr: bool, max_size: usize, max_files: usize, )
common/src/logging.rs:10
↓ 2 callersFunctionload_roots
(config: &TlsConfig)
common/src/transport/rustls.rs:118
↓ 2 callersMethodlog_level
Устанавливает уровень логирования для SDK. # Аргументы `level` - Уровень логирования: "trace", "debug", "info", "warn", "error" # Пример ```no_run
sdk/rust/src/builder.rs:143
↓ 2 callersFunctionmain_loop
( mut cli: Cli, config: Arc<RwLock<ClientConfig>>, command_tx: mpsc::Sender<Message>, command_
client/src/base.rs:175
↓ 2 callersFunctionmake_spinner
(msg: String)
client/src/base.rs:161
↓ 2 callersFunctionmonitor
(stream_in, stream_out, extract_url=False)
client/cloudpub.py:16
↓ 2 callersFunctionping_test
(endpoint: ServerEndpoint, bare: bool)
client/src/ping.rs:81
↓ 2 callersFunctionprocessQueue
(queueLane, outputArea)
docs/ru/static/js/fair-queue-animation.js:129
↓ 2 callersFunctionpublish
(command_tx: mpsc::Sender<Message>)
client/src/ping.rs:63
↓ 2 callersMethodpublish
Публикует сервис на сервере CloudPub. Это псевдоним для `register()`, который запускает сервис сразу после регистрации # Аргументы `protocol` - Тип
sdk/rust/src/connection.rs:597
↓ 2 callersFunctionread_message
New Protocol Buffers message reading and writing functions
common/src/protocol.rs:310
↓ 2 callersFunctionrun_client
( config: Arc<RwLock<ClientConfig>>, opts: ClientOpts, command_rx: mpsc::Receiver<Message>, re
client/src/client.rs:558
↓ 2 callersFunctionrun_upgrade_script
Run an upgrade script with logging support
client/src/upgrade/mod.rs:531
↓ 2 callersFunctionsend_single_ping_tcp
(client: &mut TcpStream, msg: &[u8], recv_buf: &mut [u8])
client/src/ping.rs:154
↓ 2 callersFunctionset_priority
(s: &dyn std::os::fd::AsRawFd, priority: libc::c_int)
common/src/transport/mod.rs:198
↓ 2 callersFunctionsetup_httpd
( config: &Arc<RwLock<ClientConfig>>, command_rx: &mut mpsc::Receiver<Message>, result_tx: &mpsc::
client/src/plugins/httpd.rs:72
↓ 2 callersFunctionstart
(port: u16)
client/src/ping.rs:20
↓ 2 callersMethodstart
Запускает сервис по его GUID. Запускает ранее зарегистрированный сервис, который мог быть остановлен. Это делает сервис снова доступным через его Clo
sdk/rust/src/connection.rs:682
↓ 2 callersFunctionstart_httpd
( endpoint: &ServerEndpoint, config_template: &str, config_subdir: &str, publish_dir: &str,
client/src/plugins/httpd.rs:162
↓ 2 callersMethodstop
(&mut self)
client/src/shell.rs:81
↓ 2 callersMethodtimeout_secs
Устанавливает таймаут в секундах. Удобный метод для установки таймаута в секундах вместо Duration. # Аргументы `secs` - Таймаут в секундах # Приме
sdk/rust/src/builder.rs:344
↓ 2 callersFunctionto_socket_addr
(addr: A)
common/src/utils.rs:22
↓ 2 callersFunctiontrace_message
(label: &str, msg: &ProtocolMessage)
common/src/utils.rs:209
↓ 2 callersMethodverbose
Включает или отключает подробное логирование в консоль. При включении сообщения логов выводятся в stderr в дополнение к файлу логов. Это полезно для
sdk/rust/src/builder.rs:170
↓ 2 callersFunctionwrite_message
( conn: &mut T, msg: &message::Message, )
common/src/protocol.rs:326
↓ 1 callersMethodaccept
(&self, a: &Self::Acceptor)
common/src/transport/rustls.rs:275
↓ 1 callersFunctionalgorithm_name
(oid: &der_parser::oid::Oid)
common/src/transport/rustls.rs:33
↓ 1 callersFunctionanimateFair
(container, config)
docs/ru/static/js/fair-queue-animation.js:145
↓ 1 callersFunctionanimateFifo
(container, config)
docs/ru/static/js/fair-queue-animation.js:87
↓ 1 callersFunctionapply_update_and_restart
(new_exe_path: &std::path::Path)
client/src/upgrade/mod.rs:631
↓ 1 callersMethodbind
(named_socket_addr: &NamedSocketAddr)
common/src/unix_tcp/listener.rs:69
next →1–100 of 376, ranked by callers