Struct AgentClient 

pub struct AgentClient { /* private fields */ }

Implementations

impl AgentClient

pub async fn connect( endpoint: &str, box_id: &str, ca_pem: &str, client_identity: &CertificateMaterial, ) -> Result<Self, AgentClientError>

pub async fn connect_with_relay( endpoint: &str, box_id: &str, ca_pem: &str, client_identity: &CertificateMaterial, relay: Option<&RelayAccess>, ) -> Result<Self, AgentClientError>

Connect directly or carry the same mutual TLS connection through a relay.

pub async fn connect_with_relay_route( endpoint: &str, box_id: &str, ca_pem: &str, client_identity: &CertificateMaterial, relay: Option<&RelayAccess>, route: &str, ) -> Result<Self, AgentClientError>

pub async fn info(&mut self) -> Result<InfoResponse, AgentClientError>

pub async fn ping(&mut self) -> Result<PingResponse, AgentClientError>

pub async fn exec( &mut self, argv: Vec<String>, cwd: impl Into<String>, env: impl IntoIterator<Item = (String, String)>, user: impl Into<String>, ) -> Result<ExecResult, AgentClientError>

pub async fn exec_pty( &mut self, argv: Vec<String>, cwd: impl Into<String>, env: impl IntoIterator<Item = (String, String)>, user: impl Into<String>, stdin: Vec<u8>, ) -> Result<ExecResult, AgentClientError>

pub async fn exec_stream<S>( &mut self, requests: S, ) -> Result<Streaming<ExecEvent>, AgentClientError>

where S: IntoStreamingRequest<Message = ExecRequest>,

pub async fn exec_pty_session( &mut self, argv: Vec<String>, cwd: impl Into<String>, env: impl IntoIterator<Item = (String, String)>, user: impl Into<String>, ) -> Result<ExecPtySession, AgentClientError>

pub async fn exec_pty_session_with_size( &mut self, argv: Vec<String>, cwd: impl Into<String>, env: impl IntoIterator<Item = (String, String)>, user: impl Into<String>, terminal_rows: u32, terminal_cols: u32, ) -> Result<ExecPtySession, AgentClientError>

pub async fn terminal_session( &mut self, request: ExecRequest, ) -> Result<ExecPtySession, AgentClientError>

Attach to an agent-owned terminal, creating it when its name is unused.

pub async fn list_sessions( &mut self, ) -> Result<Vec<TerminalSession>, AgentClientError>

pub async fn start_session( &mut self, request: ExecRequest, ) -> Result<TerminalSession, AgentClientError>

pub async fn read_session( &mut self, name: impl Into<String>, ) -> Result<ReadSessionResponse, AgentClientError>

pub async fn read_session_history( &mut self, name: impl Into<String>, ) -> Result<ReadSessionResponse, AgentClientError>

pub async fn send_session( &mut self, name: impl Into<String>, text: String, keys: Vec<String>, ) -> Result<(), AgentClientError>

pub async fn close_session( &mut self, name: impl Into<String>, ) -> Result<(), AgentClientError>

pub async fn exec_with_mode( &mut self, argv: Vec<String>, cwd: impl Into<String>, env: impl IntoIterator<Item = (String, String)>, user: impl Into<String>, allocate_pty: bool, stdin: Vec<u8>, ) -> Result<ExecResult, AgentClientError>

pub async fn forward_stream<S>( &mut self, requests: S, ) -> Result<Streaming<ForwardEvent>, AgentClientError>

where S: IntoStreamingRequest<Message = ForwardEvent>,

pub async fn forward_tcp( &mut self, socket: TcpStream, host: impl Into<String>, port: u16, ) -> Result<(), AgentClientError>

pub async fn put_file( &mut self, path: impl Into<String>, data: Vec<u8>, mode: u32, atomic_write: bool, ) -> Result<FileResult, AgentClientError>

pub async fn get_file( &mut self, path: impl Into<String>, ) -> Result<Vec<u8>, AgentClientError>

Trait Implementations

impl Clone for AgentClient

fn clone(&self) -> AgentClient

Returns a duplicate of the value.

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

Performs copy-assignment from source.