Struct AgentEndpointServiceClient 

pub struct AgentEndpointServiceClient {
    pub client: Client,
}

Fields

client: Client

Implementations

impl AgentEndpointServiceClient

pub fn new(channel: Channel) -> Self

pub fn receive_task_notification_opt( &self, req: &ReceiveTaskNotificationRequest, opt: CallOption, ) -> Result<ClientSStreamReceiver<ReceiveTaskNotificationResponse>>

pub fn receive_task_notification( &self, req: &ReceiveTaskNotificationRequest, ) -> Result<ClientSStreamReceiver<ReceiveTaskNotificationResponse>>

pub fn start_next_task_opt( &self, req: &StartNextTaskRequest, opt: CallOption, ) -> Result<StartNextTaskResponse>

pub fn start_next_task( &self, req: &StartNextTaskRequest, ) -> Result<StartNextTaskResponse>

pub fn start_next_task_async_opt( &self, req: &StartNextTaskRequest, opt: CallOption, ) -> Result<ClientUnaryReceiver<StartNextTaskResponse>>

pub fn start_next_task_async( &self, req: &StartNextTaskRequest, ) -> Result<ClientUnaryReceiver<StartNextTaskResponse>>

pub fn report_task_progress_opt( &self, req: &ReportTaskProgressRequest, opt: CallOption, ) -> Result<ReportTaskProgressResponse>

pub fn report_task_progress( &self, req: &ReportTaskProgressRequest, ) -> Result<ReportTaskProgressResponse>

pub fn report_task_progress_async_opt( &self, req: &ReportTaskProgressRequest, opt: CallOption, ) -> Result<ClientUnaryReceiver<ReportTaskProgressResponse>>

pub fn report_task_progress_async( &self, req: &ReportTaskProgressRequest, ) -> Result<ClientUnaryReceiver<ReportTaskProgressResponse>>

pub fn report_task_complete_opt( &self, req: &ReportTaskCompleteRequest, opt: CallOption, ) -> Result<ReportTaskCompleteResponse>

pub fn report_task_complete( &self, req: &ReportTaskCompleteRequest, ) -> Result<ReportTaskCompleteResponse>

pub fn report_task_complete_async_opt( &self, req: &ReportTaskCompleteRequest, opt: CallOption, ) -> Result<ClientUnaryReceiver<ReportTaskCompleteResponse>>

pub fn report_task_complete_async( &self, req: &ReportTaskCompleteRequest, ) -> Result<ClientUnaryReceiver<ReportTaskCompleteResponse>>

pub fn register_agent_opt( &self, req: &RegisterAgentRequest, opt: CallOption, ) -> Result<RegisterAgentResponse>

pub fn register_agent( &self, req: &RegisterAgentRequest, ) -> Result<RegisterAgentResponse>

pub fn register_agent_async_opt( &self, req: &RegisterAgentRequest, opt: CallOption, ) -> Result<ClientUnaryReceiver<RegisterAgentResponse>>

pub fn register_agent_async( &self, req: &RegisterAgentRequest, ) -> Result<ClientUnaryReceiver<RegisterAgentResponse>>

pub fn report_inventory_opt( &self, req: &ReportInventoryRequest, opt: CallOption, ) -> Result<ReportInventoryResponse>

pub fn report_inventory( &self, req: &ReportInventoryRequest, ) -> Result<ReportInventoryResponse>

pub fn report_inventory_async_opt( &self, req: &ReportInventoryRequest, opt: CallOption, ) -> Result<ClientUnaryReceiver<ReportInventoryResponse>>

pub fn report_inventory_async( &self, req: &ReportInventoryRequest, ) -> Result<ClientUnaryReceiver<ReportInventoryResponse>>

pub fn spawn<F>(&self, f: F)

where F: Future<Output = ()> + Send + 'static,

Trait Implementations

impl Clone for AgentEndpointServiceClient

fn clone(&self) -> AgentEndpointServiceClient

Returns a duplicate of the value.

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

Performs copy-assignment from source.