Struct ApplicationServiceClient

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

Expand description

ApplicationService is the service providing API methods for managing applications.

Implementations§

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

Compress requests with the given encoding.

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

Enable decompressing responses.

Limits the maximum size of a decoded message.

Default: 4MB

Limits the maximum size of an encoded message.

Default: usize::MAX

Create creates the given application.

Get the application for the given ID.

Update updates the given application.

Delete the application for the given ID.

Get the list of applications.

List all configured integrations.

Create HTTP integration.

Get the configured HTTP integration.

Update the HTTP integration.

Delete the HTTP integration.

Create InfluxDb integration.

Get InfluxDb integration.

Update InfluxDb integration.

Delete InfluxDb integration.

Create ThingsBoard integration.

Get ThingsBoard integration.

Update ThingsBoard integration.

Delete ThingsBoard integration.

Create myDevices integration.

Get myDevices integration.

Update myDevices integration.

Delete myDevices integration.

Create GCP Pub/Sub integration.

Get GCP Pub/Sub integration.

Update GCP Pub/Sub integration.

Delete GCP Pub/Sub integration.

Create AWS SNS integration.

Get AWS SNS integration.

Update AWS SNS integration.

Delete AWS SNS integration.

Create Azure Service-Bus integration.

Get Azure Service-Bus integration.

Update Azure Service-Bus integration.

Delete Azure Service-Bus integration.

Create Pilot Things integration.

Get Pilot Things integration.

Update Pilot Things integration.

Delete Pilot Things integration.

Create IFTTT integration.

Get IFTTT integration.

Update IFTTT integration.

Delete IFTTT integration.

Create Blynk integration.

Get Blynk integration.

Update Blynk integration.

Delete Blynk integration.

Generates application ID specific client-certificate.

List device-profiles used within the given application.

List device tags used within the given application.

Trait Implementations§

Returns a duplicate of the value. Read more

Performs copy-assignment from source. Read more

Formats the value using the given formatter. Read more

Auto Trait Implementations§

Blanket Implementations§

Gets the TypeId of self. Read more

Immutably borrows from an owned value. Read more

Mutably borrows from an owned value. Read more

🔬This is a nightly-only experimental API. (clone_to_uninit)

Performs copy-assignment from self to dest. Read more

Returns the argument unchanged.

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more

Instruments this type with the current Span, returning an Instrumented wrapper. Read more

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Wrap the input message T in a tonic::Request

Applies the layer to a service and wraps it in Layered.

The resulting type after obtaining ownership.

Creates owned data from borrowed data, usually by cloning. Read more

Uses borrowed data to replace owned data, usually by cloning. Read more

The type returned in the event of a conversion error.

Performs the conversion.

The type returned in the event of a conversion error.

Performs the conversion.

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more

ApplicationServiceClient

Struct ApplicationServiceClient Copy item path

Implementations§

impl ApplicationServiceClient<Channel>

pub async fn connect<D>(dst: D) -> Result<Self, Error>where D: TryInto<Endpoint>, D::Error: Into<StdError>,

impl<T> ApplicationServiceClient<T>where T: GrpcService<Body>, 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 send_compressed(self, encoding: CompressionEncoding) -> Self

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

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

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

pub async fn create( &mut self, request: impl IntoRequest<CreateApplicationRequest>, ) -> Result<Response<CreateApplicationResponse>, Status>

pub async fn get( &mut self, request: impl IntoRequest<GetApplicationRequest>, ) -> Result<Response<GetApplicationResponse>, Status>

pub async fn update( &mut self, request: impl IntoRequest<UpdateApplicationRequest>, ) -> Result<Response<()>, Status>

pub async fn delete( &mut self, request: impl IntoRequest<DeleteApplicationRequest>, ) -> Result<Response<()>, Status>

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

pub async fn list_integrations( &mut self, request: impl IntoRequest<ListIntegrationsRequest>, ) -> Result<Response<ListIntegrationsResponse>, Status>

pub async fn create_http_integration( &mut self, request: impl IntoRequest<CreateHttpIntegrationRequest>, ) -> Result<Response<()>, Status>

pub async fn get_http_integration( &mut self, request: impl IntoRequest<GetHttpIntegrationRequest>, ) -> Result<Response<GetHttpIntegrationResponse>, Status>

pub async fn update_http_integration( &mut self, request: impl IntoRequest<UpdateHttpIntegrationRequest>, ) -> Result<Response<()>, Status>

pub async fn delete_http_integration( &mut self, request: impl IntoRequest<DeleteHttpIntegrationRequest>, ) -> Result<Response<()>, Status>

pub async fn create_influx_db_integration( &mut self, request: impl IntoRequest<CreateInfluxDbIntegrationRequest>, ) -> Result<Response<()>, Status>

pub async fn get_influx_db_integration( &mut self, request: impl IntoRequest<GetInfluxDbIntegrationRequest>, ) -> Result<Response<GetInfluxDbIntegrationResponse>, Status>

pub async fn update_influx_db_integration( &mut self, request: impl IntoRequest<UpdateInfluxDbIntegrationRequest>, ) -> Result<Response<()>, Status>

pub async fn delete_influx_db_integration( &mut self, request: impl IntoRequest<DeleteInfluxDbIntegrationRequest>, ) -> Result<Response<()>, Status>

pub async fn create_things_board_integration( &mut self, request: impl IntoRequest<CreateThingsBoardIntegrationRequest>, ) -> Result<Response<()>, Status>

pub async fn get_things_board_integration( &mut self, request: impl IntoRequest<GetThingsBoardIntegrationRequest>, ) -> Result<Response<GetThingsBoardIntegrationResponse>, Status>

pub async fn update_things_board_integration( &mut self, request: impl IntoRequest<UpdateThingsBoardIntegrationRequest>, ) -> Result<Response<()>, Status>

pub async fn delete_things_board_integration( &mut self, request: impl IntoRequest<DeleteThingsBoardIntegrationRequest>, ) -> Result<Response<()>, Status>

pub async fn create_my_devices_integration( &mut self, request: impl IntoRequest<CreateMyDevicesIntegrationRequest>, ) -> Result<Response<()>, Status>

pub async fn get_my_devices_integration( &mut self, request: impl IntoRequest<GetMyDevicesIntegrationRequest>, ) -> Result<Response<GetMyDevicesIntegrationResponse>, Status>

pub async fn update_my_devices_integration( &mut self, request: impl IntoRequest<UpdateMyDevicesIntegrationRequest>, ) -> Result<Response<()>, Status>

pub async fn delete_my_devices_integration( &mut self, request: impl IntoRequest<DeleteMyDevicesIntegrationRequest>, ) -> Result<Response<()>, Status>

pub async fn create_gcp_pub_sub_integration( &mut self, request: impl IntoRequest<CreateGcpPubSubIntegrationRequest>, ) -> Result<Response<()>, Status>

pub async fn get_gcp_pub_sub_integration( &mut self, request: impl IntoRequest<GetGcpPubSubIntegrationRequest>, ) -> Result<Response<GetGcpPubSubIntegrationResponse>, Status>

pub async fn update_gcp_pub_sub_integration( &mut self, request: impl IntoRequest<UpdateGcpPubSubIntegrationRequest>, ) -> Result<Response<()>, Status>

pub async fn delete_gcp_pub_sub_integration( &mut self, request: impl IntoRequest<DeleteGcpPubSubIntegrationRequest>, ) -> Result<Response<()>, Status>

pub async fn create_aws_sns_integration( &mut self, request: impl IntoRequest<CreateAwsSnsIntegrationRequest>, ) -> Result<Response<()>, Status>

pub async fn get_aws_sns_integration( &mut self, request: impl IntoRequest<GetAwsSnsIntegrationRequest>, ) -> Result<Response<GetAwsSnsIntegrationResponse>, Status>

pub async fn update_aws_sns_integration( &mut self, request: impl IntoRequest<UpdateAwsSnsIntegrationRequest>, ) -> Result<Response<()>, Status>

pub async fn delete_aws_sns_integration( &mut self, request: impl IntoRequest<DeleteAwsSnsIntegrationRequest>, ) -> Result<Response<()>, Status>

pub async fn create_azure_service_bus_integration( &mut self, request: impl IntoRequest<CreateAzureServiceBusIntegrationRequest>, ) -> Result<Response<()>, Status>

pub async fn get_azure_service_bus_integration( &mut self, request: impl IntoRequest<GetAzureServiceBusIntegrationRequest>, ) -> Result<Response<GetAzureServiceBusIntegrationResponse>, Status>

pub async fn update_azure_service_bus_integration( &mut self, request: impl IntoRequest<UpdateAzureServiceBusIntegrationRequest>, ) -> Result<Response<()>, Status>

pub async fn delete_azure_service_bus_integration( &mut self, request: impl IntoRequest<DeleteAzureServiceBusIntegrationRequest>, ) -> Result<Response<()>, Status>

pub async fn create_pilot_things_integration( &mut self, request: impl IntoRequest<CreatePilotThingsIntegrationRequest>, ) -> Result<Response<()>, Status>

pub async fn get_pilot_things_integration( &mut self, request: impl IntoRequest<GetPilotThingsIntegrationRequest>, ) -> Result<Response<GetPilotThingsIntegrationResponse>, Status>

pub async fn update_pilot_things_integration( &mut self, request: impl IntoRequest<UpdatePilotThingsIntegrationRequest>, ) -> Result<Response<()>, Status>

pub async fn delete_pilot_things_integration( &mut self, request: impl IntoRequest<DeletePilotThingsIntegrationRequest>, ) -> Result<Response<()>, Status>

pub async fn create_ifttt_integration( &mut self, request: impl IntoRequest<CreateIftttIntegrationRequest>, ) -> Result<Response<()>, Status>

pub async fn get_ifttt_integration( &mut self, request: impl IntoRequest<GetIftttIntegrationRequest>, ) -> Result<Response<GetIftttIntegrationResponse>, Status>

pub async fn update_ifttt_integration( &mut self, request: impl IntoRequest<UpdateIftttIntegrationRequest>, ) -> Result<Response<()>, Status>

pub async fn delete_ifttt_integration( &mut self, request: impl IntoRequest<DeleteIftttIntegrationRequest>, ) -> Result<Response<()>, Status>

pub async fn create_blynk_integration( &mut self, request: impl IntoRequest<CreateBlynkIntegrationRequest>, ) -> Result<Response<()>, Status>

pub async fn get_blynk_integration( &mut self, request: impl IntoRequest<GetBlynkIntegrationRequest>, ) -> Result<Response<GetBlynkIntegrationResponse>, Status>

pub async fn update_blynk_integration( &mut self, request: impl IntoRequest<UpdateBlynkIntegrationRequest>, ) -> Result<Response<()>, Status>

pub async fn delete_blynk_integration( &mut self, request: impl IntoRequest<DeleteBlynkIntegrationRequest>, ) -> Result<Response<()>, Status>

pub async fn generate_mqtt_integration_client_certificate( &mut self, request: impl IntoRequest<GenerateMqttIntegrationClientCertificateRequest>, ) -> Result<Response<GenerateMqttIntegrationClientCertificateResponse>, Status>

pub async fn list_device_profiles( &mut self, request: impl IntoRequest<ListApplicationDeviceProfilesRequest>, ) -> Result<Response<ListApplicationDeviceProfilesResponse>, Status>

pub async fn list_device_tags( &mut self, request: impl IntoRequest<ListApplicationDeviceTagsRequest>, ) -> Result<Response<ListApplicationDeviceTagsResponse>, Status>

Trait Implementations§

impl<T: Clone> Clone for ApplicationServiceClient<T>

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

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

impl<T: Debug> Debug for ApplicationServiceClient<T>

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

Auto Trait Implementations§

impl<T> !Freeze for ApplicationServiceClient<T>

impl<T> RefUnwindSafe for ApplicationServiceClient<T>where T: RefUnwindSafe,

impl<T> Send for ApplicationServiceClient<T>where T: Send,

impl<T> Sync for ApplicationServiceClient<T>where T: Sync,

impl<T> Unpin for ApplicationServiceClient<T>where T: Unpin,

impl<T> UnwindSafe for ApplicationServiceClient<T>where T: UnwindSafe,

Blanket Implementations§

impl<T> Any for Twhere T: 'static + ?Sized,

fn type_id(&self) -> TypeId

impl<T> Borrow<T> for Twhere T: ?Sized,

fn borrow(&self) -> &T

impl<T> BorrowMut<T> for Twhere T: ?Sized,

Struct ApplicationServiceClient

pub async fn connect<D>(dst: D) -> Result<Self, Error>
where D: TryInto<Endpoint>, D::Error: Into<StdError>,

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

impl<T> RefUnwindSafe for ApplicationServiceClient<T>
where T: RefUnwindSafe,

impl<T> Send for ApplicationServiceClient<T>
where T: Send,

impl<T> Sync for ApplicationServiceClient<T>
where T: Sync,

impl<T> Unpin for ApplicationServiceClient<T>
where T: Unpin,

impl<T> UnwindSafe for ApplicationServiceClient<T>
where T: UnwindSafe,

impl<T> Any for T
where T: 'static + ?Sized,

impl<T> Borrow<T> for T
where T: ?Sized,

impl<T> BorrowMut<T> for T
where T: ?Sized,

impl<T> CloneToUninit for T
where T: Clone,

impl<T, U> Into<U> for T
where U: From<T>,

fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>
where L: Layer<S>,

impl<T> ToOwned for T
where T: Clone,

impl<T, U> TryFrom<U> for T
where U: Into<T>,

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,