Struct deluge_rpc::Session

pub struct Session { /* fields omitted */ }

Implementations

impl Session

pub async fn connect(endpoint: impl ToSocketAddrs) -> Result<Self>

pub async fn disconnect(self) -> Result<(), (TlsStream<TcpStream>, Error)>

pub fn subscribe_events(&self) -> Receiver<Event>

impl Session

pub async fn daemon_info<'_>(&'_ self) -> Result<String>

pub async fn login<'_, '_, '_>(
    &'_ mut self,
    username: &'_ str,
    password: &'_ str
) -> Result<AuthLevel>

pub async fn set_event_interest<'_, '_>(
    &'_ self,
    events: &'_ HashSet<EventKind>
) -> Result<bool>

pub async fn shutdown<'_>(&'_ self) -> Result<()>

pub async fn get_method_list<'_>(&'_ self) -> Result<Vec<String>>

pub async fn get_version<'_>(&'_ self) -> Result<String>

pub async fn authorized_call<'_, '_>(&'_ self, rpc: &'_ str) -> Result<bool>

impl Session

pub async fn add_torrent_file<'_, '_, '_, '_>(
    &'_ self,
    filename: &'_ str,
    filedump: &'_ str,
    options: &'_ TorrentOptions
) -> Result<Option<InfoHash>>

pub async fn add_torrent_files<'_, '_, '_, '_, '_>(
    &'_ self,
    torrent_files: &'_ [(&'_ str, &'_ str, &'_ TorrentOptions)]
) -> Result<()>

pub async fn add_torrent_magnet<'_, '_, '_>(
    &'_ self,
    uri: &'_ str,
    options: &'_ TorrentOptions
) -> Result<InfoHash>

pub async fn add_torrent_url<'_, '_, '_, '_>(
    &'_ self,
    url: &'_ str,
    options: &'_ TorrentOptions,
    headers: Option<&'_ HashMap<String, String>>
) -> Result<Option<InfoHash>>

pub async fn connect_peer<'_>(
    &'_ self,
    torrent_id: InfoHash,
    peer_addr: SocketAddr
) -> Result<()>

pub async fn create_account<'_, '_, '_>(
    &'_ self,
    username: &'_ str,
    password: &'_ str,
    auth_level: AuthLevel
) -> Result<()>

pub async fn create_torrent<'_, '_, '_, '_, '_, '_, '_>(
    &'_ self,
    path: &'_ str,
    comment: &'_ str,
    target: &'_ str,
    webseeds: &'_ [&'_ str],
    private: bool,
    created_by: &'_ str,
    add_to_session: bool
) -> Result<()>

pub async fn disable_plugin<'_, '_>(&'_ self, plugin: &'_ str) -> Result<()>

pub async fn enable_plugin<'_, '_>(&'_ self, plugin: &'_ str) -> Result<()>

pub async fn force_reannounce<'_, '_>(
    &'_ self,
    torrent_ids: &'_ [InfoHash]
) -> Result<()>

pub async fn force_recheck<'_, '_>(
    &'_ self,
    torrent_ids: &'_ [InfoHash]
) -> Result<()>

pub async fn get_auth_levels_mappings<'_>(
    &'_ self
) -> Result<(HashMap<String, AuthLevel>, HashMap<AuthLevel, String>)>

pub async fn get_config<'_, T: DeserializeOwned>(
    &'_ self
) -> Result<HashMap<String, T>>

pub async fn get_config_value<'_, '_, T: DeserializeOwned>(
    &'_ self,
    key: &'_ str
) -> Result<T>

pub async fn get_config_values<'_, '_, '_, T: DeserializeOwned>(
    &'_ self,
    keys: &'_ [&'_ str]
) -> Result<HashMap<String, T>>

pub async fn get_enabled_plugins<'_>(&'_ self) -> Result<Vec<String>>

pub async fn get_external_ip<'_>(&'_ self) -> Result<IpAddr>

pub async fn get_filter_tree<'_, '_, '_>(
    &'_ self,
    show_zero_hits: bool,
    hide_cat: &'_ [&'_ str]
) -> Result<FnvHashMap<FilterKey, Vec<(String, u64)>>>

pub async fn get_free_space<'_, '_>(
    &'_ self,
    path: Option<&'_ str>
) -> Result<u64>

pub async fn get_known_accounts<'_, T: DeserializeOwned>(
    &'_ self
) -> Result<Vec<HashMap<String, T>>>

pub async fn get_libtorrent_version<'_>(&'_ self) -> Result<String>

pub async fn get_listen_port<'_>(&'_ self) -> Result<u16>

pub async fn get_path_size<'_, '_>(&'_ self, path: &'_ str) -> Result<i64>

pub async fn get_proxy<'_, T: DeserializeOwned>(&'_ self) -> Result<T>

pub async fn get_session_state<'_>(&'_ self) -> Result<Vec<InfoHash>>

pub async fn get_session_status<'_, '_, '_, T: DeserializeOwned>(
    &'_ self,
    keys: &'_ [&'_ str]
) -> Result<HashMap<String, T>>

pub async fn get_torrent_status_dyn<'_, '_, '_, T: DeserializeOwned>(
    &'_ self,
    torrent_id: InfoHash,
    keys: &'_ [&'_ str],
    diff: bool
) -> Result<T>

pub async fn get_torrent_status<'_, T: Query>(
    &'_ self,
    torrent_id: InfoHash
) -> Result<T>

pub async fn get_torrent_status_diff<'_, T: Query>(
    &'_ self,
    torrent_id: InfoHash
) -> Result<T::Diff>

pub async fn get_torrents_status_dyn<'_, '_, '_, '_, T: DeserializeOwned>(
    &'_ self,
    filter_dict: Option<&'_ FilterDict>,
    keys: &'_ [&'_ str],
    diff: bool
) -> Result<FnvHashMap<InfoHash, T>>

pub async fn get_torrents_status<'_, '_, T: Query>(
    &'_ self,
    filter_dict: Option<&'_ FilterDict>
) -> Result<FnvHashMap<InfoHash, T>>

pub async fn get_torrents_status_diff<'_, '_, T: Query>(
    &'_ self,
    filter_dict: Option<&'_ FilterDict>
) -> Result<FnvHashMap<InfoHash, T::Diff>>

pub async fn glob<'_, '_>(&'_ self, path: &'_ str) -> Result<Vec<String>>

pub async fn is_libtorrent_session_paused<'_>(&'_ self) -> Result<bool>

pub async fn move_storage<'_, '_, '_>(
    &'_ self,
    torrent_ids: &'_ [InfoHash],
    dest: &'_ str
) -> Result<()>

pub async fn pause_libtorrent_session<'_>(&'_ self) -> Result<()>

pub async fn pause_torrent<'_>(&'_ self, torrent_id: InfoHash) -> Result<()>

pub async fn pause_torrents<'_, '_>(
    &'_ self,
    torrent_ids: &'_ [InfoHash]
) -> Result<()>

pub async fn prefetch_magnet_metadata<'_, '_, T: DeserializeOwned>(
    &'_ self,
    magnet: &'_ str,
    timeout: u64
) -> Result<(InfoHash, HashMap<String, T>)>

pub async fn queue_bottom<'_, '_>(
    &'_ self,
    torrent_ids: &'_ [InfoHash]
) -> Result<()>

pub async fn queue_down<'_, '_>(
    &'_ self,
    torrent_ids: &'_ [InfoHash]
) -> Result<()>

pub async fn queue_top<'_, '_>(
    &'_ self,
    torrent_ids: &'_ [InfoHash]
) -> Result<()>

pub async fn queue_up<'_, '_>(
    &'_ self,
    torrent_ids: &'_ [InfoHash]
) -> Result<()>

pub async fn remove_account<'_, '_>(&'_ self, username: &'_ str) -> Result<()>

pub async fn remove_torrent<'_>(
    &'_ self,
    torrent_id: InfoHash,
    remove_data: bool
) -> Result<()>

pub async fn remove_torrents<'_, '_>(
    &'_ self,
    torrent_ids: &'_ [InfoHash],
    remove_data: bool
) -> Result<()>

pub async fn rename_files<'_, '_, '_>(
    &'_ self,
    torrent_id: InfoHash,
    filenames: &'_ [(u64, &'_ str)]
) -> Result<()>

pub async fn rename_folder<'_, '_, '_>(
    &'_ self,
    torrent_id: InfoHash,
    folder: &'_ str,
    new_folder: &'_ str
) -> Result<()>

pub async fn rescan_plugins<'_>(&'_ self) -> Result<()>

pub async fn resume_libtorrent_session<'_>(&'_ self) -> Result<()>

pub async fn resume_torrent<'_>(&'_ self, torrent_id: InfoHash) -> Result<()>

pub async fn resume_torrents<'_, '_>(
    &'_ self,
    torrent_ids: &'_ [InfoHash]
) -> Result<()>

pub async fn set_config<'_, '_>(
    &'_ self,
    config: &'_ HashMap<String, impl Serialize>
) -> Result<()>

pub async fn set_torrent_options<'_, '_, '_>(
    &'_ self,
    torrent_ids: &'_ [InfoHash],
    options: &'_ TorrentOptions
) -> Result<()>

pub async fn test_listen_port<'_>(&'_ self) -> Result<bool>

pub async fn update_account<'_, '_, '_>(
    &'_ self,
    username: &'_ str,
    password: &'_ str,
    auth_level: AuthLevel
) -> Result<()>

pub async fn upload_plugin<'_, '_, '_>(
    &'_ self,
    filename: &'_ str,
    filedump: &'_ [u8]
) -> Result<()>

impl Session

pub async fn get_labels<'_>(&'_ self) -> Result<Vec<String>>

pub async fn add_label<'_, '_>(&'_ self, label_id: &'_ str) -> Result<()>

pub async fn remove_label<'_, '_>(&'_ self, label_id: &'_ str) -> Result<()>

pub async fn get_label_options<'_, '_, T: DeserializeOwned>(
    &'_ self,
    label_id: &'_ str
) -> Result<HashMap<String, T>>

pub async fn set_label_options<'_, '_, '_>(
    &'_ self,
    label_id: &'_ str,
    options: &'_ HashMap<String, impl Serialize>
) -> Result<()>

pub async fn set_torrent_label<'_, '_>(
    &'_ self,
    torrent_id: InfoHash,
    label_id: &'_ str
) -> Result<()>

pub async fn get_label_config<'_, T: DeserializeOwned>(
    &'_ self
) -> Result<HashMap<String, T>>

pub async fn set_label_config<'_, '_>(
    &'_ self,
    config: &'_ HashMap<String, impl Serialize>
) -> Result<()>

Trait Implementations

impl Debug for Session

fn fmt(&self, f: &mut Formatter) -> Result

Formats the value using the given formatter.