Method register

sdk/python/src/lib.rs:629–671

(
        &self,
        protocol: Protocol,
        address: String,
        name: Option<String>,
        auth: Option<Auth>,
        acl: Option<Vec<Acl>>,
        headers: Option<Vec<Header>>,
   

    ///     CloudPubError: Если регистрация не удалась
    #[pyo3(signature = (protocol, address, name=None, auth=None, acl=None, headers=None, rules=None))]
    fn register(
        &self,
        protocol: Protocol,
        address: String,
        name: Option<String>,
        auth: Option<Auth>,
        acl: Option<Vec<Acl>>,
        headers: Option<Vec<Header>>,
        rules: Option<Vec<FilterRule>>,
    ) -> PyResult<ServerEndpoint> {
        let proto: protocol::Protocol = protocol.into();
        let auth_type = auth.map(|a| a.into());
        let acl_list = acl.map(|list| list.into_iter().map(|a| a.into()).collect());
        let header_list = headers.map(|list| list.into_iter().map(|h| h.into()).collect());
        let rule_list = rules.map(|list| list.into_iter().map(|r| r.into()).collect());

        let endpoint = self
            .runtime
            .block_on(async {
                let mut conn = self.connection.write();
                conn.register(
                    proto,
                    address,
                    name,
                    auth_type,
                    acl_list,
                    header_list,
                    rule_list,
                )
                .await
            })
            .map_err(|e| CloudPubError::new_err(format!("Регистрация не удалась: {}", e)))?;

        Ok(ServerEndpoint {
            url: endpoint.as_url(),
            guid: endpoint.guid,
            status: endpoint.status,
            remote_proto: format!("{:?}", endpoint.remote_proto).to_lowercase(),
            remote_addr: endpoint.remote_addr,
            remote_port: endpoint.remote_port,
            error: endpoint.error,
        })
    }

    /// Опубликовать сервис (зарегистрировать и запустить)
    ///