pub trait InternalService: Send + Sync + 'static {
type StreamGatewayFramesStream: Stream<Item = Result<LogItem, Status>> + Send + 'static;
type StreamDeviceFramesStream: Stream<Item = Result<LogItem, Status>> + Send + 'static;
type StreamDeviceEventsStream: Stream<Item = Result<LogItem, Status>> + Send + 'static;
Show 13 methods
fn login<'life0, 'async_trait>(
&'life0 self,
request: Request<LoginRequest>
) -> Pin<Box<dyn Future<Output = Result<Response<LoginResponse>, Status>> + Send + 'async_trait>>
where
'life0: 'async_trait,
Self: 'async_trait;
fn profile<'life0, 'async_trait>(
&'life0 self,
request: Request<()>
) -> Pin<Box<dyn Future<Output = Result<Response<ProfileResponse>, Status>> + Send + 'async_trait>>
where
'life0: 'async_trait,
Self: 'async_trait;
fn global_search<'life0, 'async_trait>(
&'life0 self,
request: Request<GlobalSearchRequest>
) -> Pin<Box<dyn Future<Output = Result<Response<GlobalSearchResponse>, Status>> + Send + 'async_trait>>
where
'life0: 'async_trait,
Self: 'async_trait;
fn create_api_key<'life0, 'async_trait>(
&'life0 self,
request: Request<CreateApiKeyRequest>
) -> Pin<Box<dyn Future<Output = Result<Response<CreateApiKeyResponse>, Status>> + Send + 'async_trait>>
where
'life0: 'async_trait,
Self: 'async_trait;
fn delete_api_key<'life0, 'async_trait>(
&'life0 self,
request: Request<DeleteApiKeyRequest>
) -> Pin<Box<dyn Future<Output = Result<Response<()>, Status>> + Send + 'async_trait>>
where
'life0: 'async_trait,
Self: 'async_trait;
fn list_api_keys<'life0, 'async_trait>(
&'life0 self,
request: Request<ListApiKeysRequest>
) -> Pin<Box<dyn Future<Output = Result<Response<ListApiKeysResponse>, Status>> + Send + 'async_trait>>
where
'life0: 'async_trait,
Self: 'async_trait;
fn settings<'life0, 'async_trait>(
&'life0 self,
request: Request<()>
) -> Pin<Box<dyn Future<Output = Result<Response<SettingsResponse>, Status>> + Send + 'async_trait>>
where
'life0: 'async_trait,
Self: 'async_trait;
fn open_id_connect_login<'life0, 'async_trait>(
&'life0 self,
request: Request<OpenIdConnectLoginRequest>
) -> Pin<Box<dyn Future<Output = Result<Response<OpenIdConnectLoginResponse>, Status>> + Send + 'async_trait>>
where
'life0: 'async_trait,
Self: 'async_trait;
fn get_devices_summary<'life0, 'async_trait>(
&'life0 self,
request: Request<GetDevicesSummaryRequest>
) -> Pin<Box<dyn Future<Output = Result<Response<GetDevicesSummaryResponse>, Status>> + Send + 'async_trait>>
where
'life0: 'async_trait,
Self: 'async_trait;
fn get_gateways_summary<'life0, 'async_trait>(
&'life0 self,
request: Request<GetGatewaysSummaryRequest>
) -> Pin<Box<dyn Future<Output = Result<Response<GetGatewaysSummaryResponse>, Status>> + Send + 'async_trait>>
where
'life0: 'async_trait,
Self: 'async_trait;
fn stream_gateway_frames<'life0, 'async_trait>(
&'life0 self,
request: Request<StreamGatewayFramesRequest>
) -> Pin<Box<dyn Future<Output = Result<Response<Self::StreamGatewayFramesStream>, Status>> + Send + 'async_trait>>
where
'life0: 'async_trait,
Self: 'async_trait;
fn stream_device_frames<'life0, 'async_trait>(
&'life0 self,
request: Request<StreamDeviceFramesRequest>
) -> Pin<Box<dyn Future<Output = Result<Response<Self::StreamDeviceFramesStream>, Status>> + Send + 'async_trait>>
where
'life0: 'async_trait,
Self: 'async_trait;
fn stream_device_events<'life0, 'async_trait>(
&'life0 self,
request: Request<StreamDeviceEventsRequest>
) -> Pin<Box<dyn Future<Output = Result<Response<Self::StreamDeviceEventsStream>, Status>> + Send + 'async_trait>>
where
'life0: 'async_trait,
Self: 'async_trait;
}
Expand description
Generated trait containing gRPC methods that should be implemented for use with InternalServiceServer.
Required Associated Types
Server streaming response type for the StreamGatewayFrames method.
Server streaming response type for the StreamDeviceFrames method.
Required Methods
Log in a user
Get the current user’s profile
fn global_search<'life0, 'async_trait>(
&'life0 self,
request: Request<GlobalSearchRequest>
) -> Pin<Box<dyn Future<Output = Result<Response<GlobalSearchResponse>, Status>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
fn global_search<'life0, 'async_trait>(
&'life0 self,
request: Request<GlobalSearchRequest>
) -> Pin<Box<dyn Future<Output = Result<Response<GlobalSearchResponse>, Status>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
Perform a global search.
fn create_api_key<'life0, 'async_trait>(
&'life0 self,
request: Request<CreateApiKeyRequest>
) -> Pin<Box<dyn Future<Output = Result<Response<CreateApiKeyResponse>, Status>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
fn create_api_key<'life0, 'async_trait>(
&'life0 self,
request: Request<CreateApiKeyRequest>
) -> Pin<Box<dyn Future<Output = Result<Response<CreateApiKeyResponse>, Status>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
CreateApiKey creates the given API key.
DeleteApiKey deletes the API key.
fn list_api_keys<'life0, 'async_trait>(
&'life0 self,
request: Request<ListApiKeysRequest>
) -> Pin<Box<dyn Future<Output = Result<Response<ListApiKeysResponse>, Status>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
fn list_api_keys<'life0, 'async_trait>(
&'life0 self,
request: Request<ListApiKeysRequest>
) -> Pin<Box<dyn Future<Output = Result<Response<ListApiKeysResponse>, Status>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
ListApiKeys lists the available API keys.
Get the global settings.
fn open_id_connect_login<'life0, 'async_trait>(
&'life0 self,
request: Request<OpenIdConnectLoginRequest>
) -> Pin<Box<dyn Future<Output = Result<Response<OpenIdConnectLoginResponse>, Status>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
fn open_id_connect_login<'life0, 'async_trait>(
&'life0 self,
request: Request<OpenIdConnectLoginRequest>
) -> Pin<Box<dyn Future<Output = Result<Response<OpenIdConnectLoginResponse>, Status>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
OpenId Connect login.
fn get_devices_summary<'life0, 'async_trait>(
&'life0 self,
request: Request<GetDevicesSummaryRequest>
) -> Pin<Box<dyn Future<Output = Result<Response<GetDevicesSummaryResponse>, Status>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
fn get_devices_summary<'life0, 'async_trait>(
&'life0 self,
request: Request<GetDevicesSummaryRequest>
) -> Pin<Box<dyn Future<Output = Result<Response<GetDevicesSummaryResponse>, Status>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
GetDevicesSummary returns an aggregated summary of the devices.
fn get_gateways_summary<'life0, 'async_trait>(
&'life0 self,
request: Request<GetGatewaysSummaryRequest>
) -> Pin<Box<dyn Future<Output = Result<Response<GetGatewaysSummaryResponse>, Status>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
fn get_gateways_summary<'life0, 'async_trait>(
&'life0 self,
request: Request<GetGatewaysSummaryRequest>
) -> Pin<Box<dyn Future<Output = Result<Response<GetGatewaysSummaryResponse>, Status>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
GetGatewaysSummary returns an aggregated summary of the gateways.
fn stream_gateway_frames<'life0, 'async_trait>(
&'life0 self,
request: Request<StreamGatewayFramesRequest>
) -> Pin<Box<dyn Future<Output = Result<Response<Self::StreamGatewayFramesStream>, Status>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
fn stream_gateway_frames<'life0, 'async_trait>(
&'life0 self,
request: Request<StreamGatewayFramesRequest>
) -> Pin<Box<dyn Future<Output = Result<Response<Self::StreamGatewayFramesStream>, Status>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
Stream frame for the given Gateway ID.
fn stream_device_frames<'life0, 'async_trait>(
&'life0 self,
request: Request<StreamDeviceFramesRequest>
) -> Pin<Box<dyn Future<Output = Result<Response<Self::StreamDeviceFramesStream>, Status>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
fn stream_device_frames<'life0, 'async_trait>(
&'life0 self,
request: Request<StreamDeviceFramesRequest>
) -> Pin<Box<dyn Future<Output = Result<Response<Self::StreamDeviceFramesStream>, Status>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
Stream frames for the given Device EUI.
fn stream_device_events<'life0, 'async_trait>(
&'life0 self,
request: Request<StreamDeviceEventsRequest>
) -> Pin<Box<dyn Future<Output = Result<Response<Self::StreamDeviceEventsStream>, Status>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
fn stream_device_events<'life0, 'async_trait>(
&'life0 self,
request: Request<StreamDeviceEventsRequest>
) -> Pin<Box<dyn Future<Output = Result<Response<Self::StreamDeviceEventsStream>, Status>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
Stream events for the given Device EUI.