Struct PlaneClient

pub struct PlaneClient { /* private fields */ }

Implementations

impl PlaneClient

pub fn new(base_url: Url) -> Self

pub async fn status(&self) -> Result<StatusResponse, PlaneClientError>

pub fn drone_connection( &self, cluster: &ClusterName, pool: &DronePoolName, ) -> TypedSocketConnector<MessageFromDrone>

pub fn proxy_connection( &self, cluster: &ClusterName, ) -> TypedSocketConnector<MessageFromProxy>

pub fn dns_connection(&self) -> TypedSocketConnector<MessageFromDns>

pub async fn connect( &self, connect_request: &ConnectRequest, ) -> Result<ConnectResponse, PlaneClientError>

pub async fn drain( &self, cluster: &ClusterName, drone: &DroneName, ) -> Result<DrainResult, PlaneClientError>

pub async fn soft_terminate( &self, backend_id: &BackendName, ) -> Result<(), PlaneClientError>

pub async fn hard_terminate( &self, backend_id: &BackendName, ) -> Result<(), PlaneClientError>

pub async fn revoke( &self, request: &RevokeRequest, ) -> Result<(), PlaneClientError>

pub fn backend_status_url(&self, backend_id: &BackendName) -> Url

pub async fn backend_status( &self, backend_id: &BackendName, ) -> Result<BackendStatusStreamEntry, PlaneClientError>

pub fn backend_status_stream_url(&self, backend_id: &BackendName) -> Url

pub async fn backend_status_stream( &self, backend_id: &BackendName, ) -> Result<SseStream<BackendStatusStreamEntry>, PlaneClientError>

pub async fn cluster_state( &self, cluster: &ClusterName, ) -> Result<ClusterState, PlaneClientError>

pub async fn health_check(&self) -> Result<(), PlaneClientError>

Trait Implementations

impl Clone for PlaneClient

fn clone(&self) -> PlaneClient

Returns a duplicate of the value.

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

Performs copy-assignment from source.