Skip to main content

Module v5

tuwunel_api_client::sync

Module v5 

Source

Re-exports§

use std::collections::BTreeMap; 🔒
use std::collections::BTreeSet; 🔒
use std::fmt::Debug; 🔒
use std::fmt::Debug; 🔒
use std::iter::once; 🔒
use std::iter::repeat; 🔒
use std::mem::take; 🔒
use std::sync::Arc; 🔒
use axum::extract::Extension; 🔒
use axum::extract::State; 🔒
use futures::TryFutureExt; 🔒
use futures::future::join; 🔒
use ruma::DeviceId; 🔒
use ruma::OwnedRoomId; 🔒
use ruma::RoomId; 🔒
use ruma::UserId; 🔒
use ruma::api::client::sync::sync_events::v5::ListId; 🔒
use ruma::api::client::sync::sync_events::v5::Request; 🔒
use ruma::api::client::sync::sync_events::v5::Response; 🔒
use ruma::api::client::sync::sync_events::v5::response; 🔒
use ruma::events::AnyStrippedStateEvent; 🔒
use ruma::events::StateEventType; 🔒
use ruma::events::room::member::MembershipState; 🔒
use ruma::serde::Raw; 🔒
use serde::Deserialize; 🔒
use serde::Deserialize; 🔒
use tokio::sync::Notify; 🔒
use tokio::time::timeout_at; 🔒
use tuwunel_core::Err; 🔒
use tuwunel_core::Result; 🔒
use tuwunel_core::debug; 🔒
use tuwunel_core::debug; 🔒
use tuwunel_core::debug::INFO_SPAN_LEVEL; 🔒
use tuwunel_core::debug_warn; 🔒
use tuwunel_core::error::inspect_log; 🔒
use tuwunel_core::smallvec::SmallVec; 🔒
use tuwunel_core::trace; 🔒
use tuwunel_core::utils::TryFutureExtExt; 🔒
use tuwunel_core::utils::result::FlatOk; 🔒
use tuwunel_core::utils::result::NotFound; 🔒
use tuwunel_core::utils::time::millis; 🔒
use tuwunel_core::warn; 🔒
use tuwunel_service::Services; 🔒
use tuwunel_service::presence::Ping; 🔒
use tuwunel_service::rooms::state_cache::StrippedRoomState; 🔒
use tuwunel_service::sync::Connection; 🔒
use tuwunel_service::sync::ConnectionKey; 🔒
use tuwunel_service::sync::ConnectionVal; 🔒
use tuwunel_service::sync::into_connection_key; 🔒
use self::extensions::acknowledge_to_device; 🔒
use self::extensions::apply_profiles; 🔒
use self::extensions::apply_ranges; 🔒
use self::extensions::check_to_device; 🔒
use self::extensions::handle as handle_extensions; 🔒
use self::extensions::to_device_pending; 🔒
use self::range::collect as collect_ranges; 🔒
use self::selector::selector; 🔒
use super::joined_since; 🔒
use super::share_encrypted_room; 🔒
use crate::ClientIp; 🔒
use crate::Ruma; 🔒
use crate::utils::poll_deadline; 🔒

Modules§

extensions 🔒
filter 🔒
range 🔒
rooms 🔒
selector 🔒

Structs§

SyncInfo 🔒
WindowRoom 🔒

Functions§

check_profile_selection 🔒
config_change_needs_position 🔒
departed 🔒
is_empty_response 🔒
Whether a pass has nothing to answer the client with.
poll_timeout 🔒
How long a request may long-poll, in milliseconds.
respond 🔒
Positions a response at the connection’s next batch and stores the connection.
stripped_content 🔒
The content of the stripped state event with this type and an empty state key.
stripped_state 🔒
The stripped state MSC4186 sends for an invited or knocked room.
sync_events_v5_route 🔒
POST /_matrix/client/unstable/org.matrix.simplified_msc3575/sync (MSC4186)

Type Aliases§

ListIds 🔒
ResponseLists 🔒
Window 🔒