Struct MachineServiceClient 

pub struct MachineServiceClient<T> { /* private fields */ }

The machine service definition.

Implementations

impl MachineServiceClient<Channel>

pub async fn connect<D>(dst: D) -> Result<Self, Error>

where D: TryInto<Endpoint>, D::Error: Into<StdError>,

Attempt to create a new client by connecting to a given endpoint.

impl<T> MachineServiceClient<T>

where T: GrpcService<BoxBody>, T::Error: Into<StdError>, T::ResponseBody: Body<Data = Bytes> + Send + 'static, <T::ResponseBody as Body>::Error: Into<StdError> + Send,

pub fn new(inner: T) -> Self

pub fn with_origin(inner: T, origin: Uri) -> Self

pub fn with_interceptor<F>( inner: T, interceptor: F, ) -> MachineServiceClient<InterceptedService<T, F>>

where F: Interceptor, T::ResponseBody: Default, T: Service<Request<BoxBody>, Response = Response<<T as GrpcService<BoxBody>>::ResponseBody>>, <T as Service<Request<BoxBody>>>::Error: Into<StdError> + Send + Sync,

pub fn send_compressed(self, encoding: CompressionEncoding) -> Self

Compress requests with the given encoding.

This requires the server to support it otherwise it might respond with an error.

pub fn accept_compressed(self, encoding: CompressionEncoding) -> Self

Enable decompressing responses.

pub fn max_decoding_message_size(self, limit: usize) -> Self

Limits the maximum size of a decoded message.

Default: 4MB

pub fn max_encoding_message_size(self, limit: usize) -> Self

Limits the maximum size of an encoded message.

Default: usize::MAX

pub async fn apply_configuration( &mut self, request: impl IntoRequest<ApplyConfigurationRequest>, ) -> Result<Response<ApplyConfigurationResponse>, Status>

pub async fn bootstrap( &mut self, request: impl IntoRequest<BootstrapRequest>, ) -> Result<Response<BootstrapResponse>, Status>

Bootstrap method makes control plane node enter etcd bootstrap mode. Node aborts etcd join sequence and creates single-node etcd cluster. If recover_etcd argument is specified, etcd is recovered from a snapshot uploaded with EtcdRecover.

pub async fn containers( &mut self, request: impl IntoRequest<ContainersRequest>, ) -> Result<Response<ContainersResponse>, Status>

pub async fn copy( &mut self, request: impl IntoRequest<CopyRequest>, ) -> Result<Response<Streaming<Data>>, Status>

pub async fn cpu_freq_stats( &mut self, request: impl IntoRequest<Empty>, ) -> Result<Response<CpuFreqStatsResponse>, Status>

pub async fn cpu_info( &mut self, request: impl IntoRequest<Empty>, ) -> Result<Response<CpuInfoResponse>, Status>

pub async fn disk_stats( &mut self, request: impl IntoRequest<Empty>, ) -> Result<Response<DiskStatsResponse>, Status>

pub async fn dmesg( &mut self, request: impl IntoRequest<DmesgRequest>, ) -> Result<Response<Streaming<Data>>, Status>

pub async fn events( &mut self, request: impl IntoRequest<EventsRequest>, ) -> Result<Response<Streaming<Event>>, Status>

pub async fn etcd_member_list( &mut self, request: impl IntoRequest<EtcdMemberListRequest>, ) -> Result<Response<EtcdMemberListResponse>, Status>

pub async fn etcd_remove_member_by_id( &mut self, request: impl IntoRequest<EtcdRemoveMemberByIdRequest>, ) -> Result<Response<EtcdRemoveMemberByIdResponse>, Status>

EtcdRemoveMemberByID removes a member from the etcd cluster identified by member ID. This API should be used to remove members which don’t have an associated Talos node anymore. To remove a member with a running Talos node, use EtcdLeaveCluster API on the node to be removed.

pub async fn etcd_leave_cluster( &mut self, request: impl IntoRequest<EtcdLeaveClusterRequest>, ) -> Result<Response<EtcdLeaveClusterResponse>, Status>

pub async fn etcd_forfeit_leadership( &mut self, request: impl IntoRequest<EtcdForfeitLeadershipRequest>, ) -> Result<Response<EtcdForfeitLeadershipResponse>, Status>

pub async fn etcd_recover( &mut self, request: impl IntoStreamingRequest<Message = Data>, ) -> Result<Response<EtcdRecoverResponse>, Status>

EtcdRecover method uploads etcd data snapshot created with EtcdSnapshot to the node. Snapshot can be later used to recover the cluster via Bootstrap method.

pub async fn etcd_snapshot( &mut self, request: impl IntoRequest<EtcdSnapshotRequest>, ) -> Result<Response<Streaming<Data>>, Status>

EtcdSnapshot method creates etcd data snapshot (backup) from the local etcd instance and streams it back to the client. This method is available only on control plane nodes (which run etcd).

pub async fn etcd_alarm_list( &mut self, request: impl IntoRequest<Empty>, ) -> Result<Response<EtcdAlarmListResponse>, Status>

EtcdAlarmList lists etcd alarms for the current node. This method is available only on control plane nodes (which run etcd).

pub async fn etcd_alarm_disarm( &mut self, request: impl IntoRequest<Empty>, ) -> Result<Response<EtcdAlarmDisarmResponse>, Status>

EtcdAlarmDisarm disarms etcd alarms for the current node. This method is available only on control plane nodes (which run etcd).

pub async fn etcd_defragment( &mut self, request: impl IntoRequest<Empty>, ) -> Result<Response<EtcdDefragmentResponse>, Status>

EtcdDefragment defragments etcd data directory for the current node. Defragmentation is a resource-heavy operation, so it should only run on a specific node. This method is available only on control plane nodes (which run etcd).

pub async fn etcd_status( &mut self, request: impl IntoRequest<Empty>, ) -> Result<Response<EtcdStatusResponse>, Status>

EtcdStatus returns etcd status for the current member. This method is available only on control plane nodes (which run etcd).

pub async fn generate_configuration( &mut self, request: impl IntoRequest<GenerateConfigurationRequest>, ) -> Result<Response<GenerateConfigurationResponse>, Status>

pub async fn hostname( &mut self, request: impl IntoRequest<Empty>, ) -> Result<Response<HostnameResponse>, Status>

pub async fn kubeconfig( &mut self, request: impl IntoRequest<Empty>, ) -> Result<Response<Streaming<Data>>, Status>

pub async fn list( &mut self, request: impl IntoRequest<ListRequest>, ) -> Result<Response<Streaming<FileInfo>>, Status>

pub async fn disk_usage( &mut self, request: impl IntoRequest<DiskUsageRequest>, ) -> Result<Response<Streaming<DiskUsageInfo>>, Status>

pub async fn load_avg( &mut self, request: impl IntoRequest<Empty>, ) -> Result<Response<LoadAvgResponse>, Status>

pub async fn logs( &mut self, request: impl IntoRequest<LogsRequest>, ) -> Result<Response<Streaming<Data>>, Status>

pub async fn logs_containers( &mut self, request: impl IntoRequest<Empty>, ) -> Result<Response<LogsContainersResponse>, Status>

pub async fn memory( &mut self, request: impl IntoRequest<Empty>, ) -> Result<Response<MemoryResponse>, Status>

pub async fn mounts( &mut self, request: impl IntoRequest<Empty>, ) -> Result<Response<MountsResponse>, Status>

pub async fn network_device_stats( &mut self, request: impl IntoRequest<Empty>, ) -> Result<Response<NetworkDeviceStatsResponse>, Status>

pub async fn processes( &mut self, request: impl IntoRequest<Empty>, ) -> Result<Response<ProcessesResponse>, Status>

pub async fn read( &mut self, request: impl IntoRequest<ReadRequest>, ) -> Result<Response<Streaming<Data>>, Status>

pub async fn reboot( &mut self, request: impl IntoRequest<RebootRequest>, ) -> Result<Response<RebootResponse>, Status>

pub async fn restart( &mut self, request: impl IntoRequest<RestartRequest>, ) -> Result<Response<RestartResponse>, Status>

pub async fn rollback( &mut self, request: impl IntoRequest<RollbackRequest>, ) -> Result<Response<RollbackResponse>, Status>

pub async fn reset( &mut self, request: impl IntoRequest<ResetRequest>, ) -> Result<Response<ResetResponse>, Status>

pub async fn service_list( &mut self, request: impl IntoRequest<Empty>, ) -> Result<Response<ServiceListResponse>, Status>

pub async fn service_restart( &mut self, request: impl IntoRequest<ServiceRestartRequest>, ) -> Result<Response<ServiceRestartResponse>, Status>

pub async fn service_start( &mut self, request: impl IntoRequest<ServiceStartRequest>, ) -> Result<Response<ServiceStartResponse>, Status>

pub async fn service_stop( &mut self, request: impl IntoRequest<ServiceStopRequest>, ) -> Result<Response<ServiceStopResponse>, Status>

pub async fn shutdown( &mut self, request: impl IntoRequest<ShutdownRequest>, ) -> Result<Response<ShutdownResponse>, Status>

pub async fn stats( &mut self, request: impl IntoRequest<StatsRequest>, ) -> Result<Response<StatsResponse>, Status>

pub async fn system_stat( &mut self, request: impl IntoRequest<Empty>, ) -> Result<Response<SystemStatResponse>, Status>

pub async fn upgrade( &mut self, request: impl IntoRequest<UpgradeRequest>, ) -> Result<Response<UpgradeResponse>, Status>

pub async fn version( &mut self, request: impl IntoRequest<Empty>, ) -> Result<Response<VersionResponse>, Status>

pub async fn generate_client_configuration( &mut self, request: impl IntoRequest<GenerateClientConfigurationRequest>, ) -> Result<Response<GenerateClientConfigurationResponse>, Status>

GenerateClientConfiguration generates talosctl client configuration (talosconfig).

pub async fn packet_capture( &mut self, request: impl IntoRequest<PacketCaptureRequest>, ) -> Result<Response<Streaming<Data>>, Status>

PacketCapture performs packet capture and streams back pcap file.

pub async fn netstat( &mut self, request: impl IntoRequest<NetstatRequest>, ) -> Result<Response<NetstatResponse>, Status>

Netstat provides information about network connections.

pub async fn meta_write( &mut self, request: impl IntoRequest<MetaWriteRequest>, ) -> Result<Response<MetaWriteResponse>, Status>

MetaWrite writes a META key-value pair.

pub async fn meta_delete( &mut self, request: impl IntoRequest<MetaDeleteRequest>, ) -> Result<Response<MetaDeleteResponse>, Status>

MetaDelete deletes a META key.

pub async fn image_list( &mut self, request: impl IntoRequest<ImageListRequest>, ) -> Result<Response<Streaming<ImageListResponse>>, Status>

ImageList lists images in the CRI.

pub async fn image_pull( &mut self, request: impl IntoRequest<ImagePullRequest>, ) -> Result<Response<ImagePullResponse>, Status>

ImagePull pulls an image into the CRI.

Trait Implementations

impl<T: Clone> Clone for MachineServiceClient<T>

fn clone(&self) -> MachineServiceClient<T>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T: Debug> Debug for MachineServiceClient<T>

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

Formats the value using the given formatter.