Struct client::Client

pub struct Client { /* private fields */ }

Instance of a single client for an Aurae consumer.

Implementations

impl Client

pub async fn default() -> Result<Self, ClientError>

pub async fn new(__arg0: AuraeConfig) -> Result<Self, ClientError>

Create a new Client.

Note: A new client is required for every independent execution of this process.

pub async fn new_no_tls(socket: AuraeSocket) -> Result<Self, ClientError>

Create a new Client without TLS, remote server should also expect no TLS.

Note: A new client is required for every independent execution of this process.

Trait Implementations

impl CellServiceClient for Client

fn allocate<'life0, 'async_trait>( &'life0 self, req: CellServiceAllocateRequest ) -> Pin<Box<dyn Future<Output = Result<Response<CellServiceAllocateResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn free<'life0, 'async_trait>( &'life0 self, req: CellServiceFreeRequest ) -> Pin<Box<dyn Future<Output = Result<Response<CellServiceFreeResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn start<'life0, 'async_trait>( &'life0 self, req: CellServiceStartRequest ) -> Pin<Box<dyn Future<Output = Result<Response<CellServiceStartResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn stop<'life0, 'async_trait>( &'life0 self, req: CellServiceStopRequest ) -> Pin<Box<dyn Future<Output = Result<Response<CellServiceStopResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn list<'life0, 'async_trait>( &'life0 self, req: CellServiceListRequest ) -> Pin<Box<dyn Future<Output = Result<Response<CellServiceListResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

impl Clone for Client

fn clone(&self) -> Client

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for Client

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

Formats the value using the given formatter.

impl DiscoveryServiceClient for Client

fn discover<'life0, 'async_trait>( &'life0 self, req: DiscoverRequest ) -> Pin<Box<dyn Future<Output = Result<Response<DiscoverResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

impl HealthClient for Client

fn check<'life0, 'async_trait>( &'life0 self, req: HealthCheckRequest ) -> Pin<Box<dyn Future<Output = Result<Response<HealthCheckResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn watch<'life0, 'async_trait>( &'life0 self, req: HealthCheckRequest ) -> Pin<Box<dyn Future<Output = Result<Response<Streaming<HealthCheckResponse>>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

impl ImageServiceClient for Client

fn list_images<'life0, 'async_trait>( &'life0 self, req: ListImagesRequest ) -> Pin<Box<dyn Future<Output = Result<Response<ListImagesResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn image_status<'life0, 'async_trait>( &'life0 self, req: ImageStatusRequest ) -> Pin<Box<dyn Future<Output = Result<Response<ImageStatusResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn pull_image<'life0, 'async_trait>( &'life0 self, req: PullImageRequest ) -> Pin<Box<dyn Future<Output = Result<Response<PullImageResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn remove_image<'life0, 'async_trait>( &'life0 self, req: RemoveImageRequest ) -> Pin<Box<dyn Future<Output = Result<Response<RemoveImageResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn image_fs_info<'life0, 'async_trait>( &'life0 self, req: ImageFsInfoRequest ) -> Pin<Box<dyn Future<Output = Result<Response<ImageFsInfoResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

impl ObserveServiceClient for Client

fn get_aurae_daemon_log_stream<'life0, 'async_trait>( &'life0 self, req: GetAuraeDaemonLogStreamRequest ) -> Pin<Box<dyn Future<Output = Result<Response<Streaming<GetAuraeDaemonLogStreamResponse>>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn get_sub_process_stream<'life0, 'async_trait>( &'life0 self, req: GetSubProcessStreamRequest ) -> Pin<Box<dyn Future<Output = Result<Response<Streaming<GetSubProcessStreamResponse>>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn get_posix_signals_stream<'life0, 'async_trait>( &'life0 self, req: GetPosixSignalsStreamRequest ) -> Pin<Box<dyn Future<Output = Result<Response<Streaming<GetPosixSignalsStreamResponse>>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

impl RuntimeServiceClient for Client

fn version<'life0, 'async_trait>( &'life0 self, req: VersionRequest ) -> Pin<Box<dyn Future<Output = Result<Response<VersionResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn run_pod_sandbox<'life0, 'async_trait>( &'life0 self, req: RunPodSandboxRequest ) -> Pin<Box<dyn Future<Output = Result<Response<RunPodSandboxResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn stop_pod_sandbox<'life0, 'async_trait>( &'life0 self, req: StopPodSandboxRequest ) -> Pin<Box<dyn Future<Output = Result<Response<StopPodSandboxResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn remove_pod_sandbox<'life0, 'async_trait>( &'life0 self, req: RemovePodSandboxRequest ) -> Pin<Box<dyn Future<Output = Result<Response<RemovePodSandboxResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn pod_sandbox_status<'life0, 'async_trait>( &'life0 self, req: PodSandboxStatusRequest ) -> Pin<Box<dyn Future<Output = Result<Response<PodSandboxStatusResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn list_pod_sandbox<'life0, 'async_trait>( &'life0 self, req: ListPodSandboxRequest ) -> Pin<Box<dyn Future<Output = Result<Response<ListPodSandboxResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn create_container<'life0, 'async_trait>( &'life0 self, req: CreateContainerRequest ) -> Pin<Box<dyn Future<Output = Result<Response<CreateContainerResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn start_container<'life0, 'async_trait>( &'life0 self, req: StartContainerRequest ) -> Pin<Box<dyn Future<Output = Result<Response<StartContainerResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn stop_container<'life0, 'async_trait>( &'life0 self, req: StopContainerRequest ) -> Pin<Box<dyn Future<Output = Result<Response<StopContainerResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn remove_container<'life0, 'async_trait>( &'life0 self, req: RemoveContainerRequest ) -> Pin<Box<dyn Future<Output = Result<Response<RemoveContainerResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn list_containers<'life0, 'async_trait>( &'life0 self, req: ListContainersRequest ) -> Pin<Box<dyn Future<Output = Result<Response<ListContainersResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn container_status<'life0, 'async_trait>( &'life0 self, req: ContainerStatusRequest ) -> Pin<Box<dyn Future<Output = Result<Response<ContainerStatusResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn update_container_resources<'life0, 'async_trait>( &'life0 self, req: UpdateContainerResourcesRequest ) -> Pin<Box<dyn Future<Output = Result<Response<UpdateContainerResourcesResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn reopen_container_log<'life0, 'async_trait>( &'life0 self, req: ReopenContainerLogRequest ) -> Pin<Box<dyn Future<Output = Result<Response<ReopenContainerLogResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn exec_sync<'life0, 'async_trait>( &'life0 self, req: ExecSyncRequest ) -> Pin<Box<dyn Future<Output = Result<Response<ExecSyncResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn exec<'life0, 'async_trait>( &'life0 self, req: ExecRequest ) -> Pin<Box<dyn Future<Output = Result<Response<ExecResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn attach<'life0, 'async_trait>( &'life0 self, req: AttachRequest ) -> Pin<Box<dyn Future<Output = Result<Response<AttachResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn port_forward<'life0, 'async_trait>( &'life0 self, req: PortForwardRequest ) -> Pin<Box<dyn Future<Output = Result<Response<PortForwardResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn container_stats<'life0, 'async_trait>( &'life0 self, req: ContainerStatsRequest ) -> Pin<Box<dyn Future<Output = Result<Response<ContainerStatsResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn list_container_stats<'life0, 'async_trait>( &'life0 self, req: ListContainerStatsRequest ) -> Pin<Box<dyn Future<Output = Result<Response<ListContainerStatsResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn pod_sandbox_stats<'life0, 'async_trait>( &'life0 self, req: PodSandboxStatsRequest ) -> Pin<Box<dyn Future<Output = Result<Response<PodSandboxStatsResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn list_pod_sandbox_stats<'life0, 'async_trait>( &'life0 self, req: ListPodSandboxStatsRequest ) -> Pin<Box<dyn Future<Output = Result<Response<ListPodSandboxStatsResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn update_runtime_config<'life0, 'async_trait>( &'life0 self, req: UpdateRuntimeConfigRequest ) -> Pin<Box<dyn Future<Output = Result<Response<UpdateRuntimeConfigResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn status<'life0, 'async_trait>( &'life0 self, req: StatusRequest ) -> Pin<Box<dyn Future<Output = Result<Response<StatusResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn checkpoint_container<'life0, 'async_trait>( &'life0 self, req: CheckpointContainerRequest ) -> Pin<Box<dyn Future<Output = Result<Response<CheckpointContainerResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn get_container_events<'life0, 'async_trait>( &'life0 self, req: GetEventsRequest ) -> Pin<Box<dyn Future<Output = Result<Response<Streaming<ContainerEventResponse>>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn list_metric_descriptors<'life0, 'async_trait>( &'life0 self, req: ListMetricDescriptorsRequest ) -> Pin<Box<dyn Future<Output = Result<Response<ListMetricDescriptorsResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn list_pod_sandbox_metrics<'life0, 'async_trait>( &'life0 self, req: ListPodSandboxMetricsRequest ) -> Pin<Box<dyn Future<Output = Result<Response<ListPodSandboxMetricsResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

impl VmServiceClient for Client

fn create<'life0, 'async_trait>( &'life0 self, req: VmServiceCreateRequest ) -> Pin<Box<dyn Future<Output = Result<Response<VmServiceCreateResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn free<'life0, 'async_trait>( &'life0 self, req: VmServiceFreeRequest ) -> Pin<Box<dyn Future<Output = Result<Response<VmServiceFreeResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn start<'life0, 'async_trait>( &'life0 self, req: VmServiceStartRequest ) -> Pin<Box<dyn Future<Output = Result<Response<VmServiceStartResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn stop<'life0, 'async_trait>( &'life0 self, req: VmServiceStopRequest ) -> Pin<Box<dyn Future<Output = Result<Response<VmServiceStopResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,