Struct MemphisClient

pub struct MemphisClient { /* private fields */ }

Memphis Client

The Memphis Client is used to connect to Memphis.

use memphis_rust_community::memphis_client::MemphisClient;

#[tokio::main]
async fn main() {
    let client = MemphisClient::new("localhost:6666", "root", "memphis", None).await.unwrap();
}

Implementations

impl MemphisClient

pub async fn new( memphis_host: &str, memphis_username: &str, memphis_password: &str, account_id: Option<&str>, ) -> Result<MemphisClient, ConnectError>

Creates a new MemphisClient

Arguments

• memphis_host - The host of the Memphis server
• memphis_username - The username of the Memphis user
• memphis_password - The password of the Memphis user
• account_id - The account id of the Memphis account (Only used in cloud version) use None or “1” for self hosted

Example

use memphis_rust_community::memphis_client::MemphisClient;

#[tokio::main]
async fn main() {
    let client = MemphisClient::new(
        "localhost:6666",
        "root",
        "memphis",
        None
    ).await.unwrap();
}

pub fn is_connected(&self) -> bool

pub async fn create_station( &self, station_options: MemphisStationsOptions, ) -> Result<MemphisStation, RequestError>

pub fn get_jetstream_context(&self) -> &Context

Returns the Jetstream Context used behind the scenes, only use this if you know what you are doing

pub fn get_broker_connection(&self) -> &Client

Returns the Broker Connection used behind the scenes, only use this if you know what you are doing

Trait Implementations

impl Clone for MemphisClient

fn clone(&self) -> MemphisClient

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.