Struct DevicePluginClient

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

DevicePlugin is the service advertised by Device Plugins

Implementations

impl DevicePluginClient<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> DevicePluginClient<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_interceptor<F>( inner: T, interceptor: F, ) -> DevicePluginClient<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_gzip(self) -> Self

Compress requests with gzip.

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

pub fn accept_gzip(self) -> Self

Enable decompressing responses with gzip.

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

GetDevicePluginOptions returns options to be communicated with Device Manager

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

ListAndWatch returns a stream of List of Devices Whenever a Device state change or a Device disappears, ListAndWatch returns the new list

pub async fn get_preferred_allocation( &mut self, request: impl IntoRequest<PreferredAllocationRequest>, ) -> Result<Response<PreferredAllocationResponse>, Status>

GetPreferredAllocation returns a preferred set of devices to allocate from a list of available ones. The resulting preferred allocation is not guaranteed to be the allocation ultimately performed by the devicemanager. It is only designed to help the devicemanager make a more informed allocation decision when possible.

pub async fn allocate( &mut self, request: impl IntoRequest<AllocateRequest>, ) -> Result<Response<AllocateResponse>, Status>

Allocate is called during container creation so that the Device Plugin can run device specific operations and instruct Kubelet of the steps to make the Device available in the container

pub async fn pre_start_container( &mut self, request: impl IntoRequest<PreStartContainerRequest>, ) -> Result<Response<PreStartContainerResponse>, Status>

PreStartContainer is called, if indicated by Device Plugin during registeration phase, before each container start. Device plugin can run device specific operations such as resetting the device before making devices available to the container

Trait Implementations

impl<T: Clone> Clone for DevicePluginClient<T>

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

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T: Debug> Debug for DevicePluginClient<T>

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

Formats the value using the given formatter.