Trait chirpstack_api::api::internal_service_server::InternalService

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;

    // Required methods
    fn login<'life0, 'async_trait>(
        &'life0 self,
        request: Request<LoginRequest>
    ) -> Pin<Box<dyn Future<Output = Result<Response<LoginResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn profile<'life0, 'async_trait>(
        &'life0 self,
        request: Request<()>
    ) -> Pin<Box<dyn Future<Output = Result<Response<ProfileResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: '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 Self: 'async_trait,
             'life0: '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 Self: 'async_trait,
             'life0: '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 Self: 'async_trait,
             'life0: '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 Self: 'async_trait,
             'life0: 'async_trait;
    fn settings<'life0, 'async_trait>(
        &'life0 self,
        request: Request<()>
    ) -> Pin<Box<dyn Future<Output = Result<Response<SettingsResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: '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 Self: 'async_trait,
             'life0: '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 Self: 'async_trait,
             'life0: '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 Self: 'async_trait,
             'life0: '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 Self: 'async_trait,
             'life0: '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 Self: 'async_trait,
             'life0: '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 Self: 'async_trait,
             'life0: 'async_trait;
    fn list_regions<'life0, 'async_trait>(
        &'life0 self,
        request: Request<()>
    ) -> Pin<Box<dyn Future<Output = Result<Response<ListRegionsResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn get_region<'life0, 'async_trait>(
        &'life0 self,
        request: Request<GetRegionRequest>
    ) -> Pin<Box<dyn Future<Output = Result<Response<GetRegionResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
}

Generated trait containing gRPC methods that should be implemented for use with InternalServiceServer.

Required Associated Types

type StreamGatewayFramesStream: Stream<Item = Result<LogItem, Status>> + Send + 'static

Server streaming response type for the StreamGatewayFrames method.

type StreamDeviceFramesStream: Stream<Item = Result<LogItem, Status>> + Send + 'static

Server streaming response type for the StreamDeviceFrames method.

type StreamDeviceEventsStream: Stream<Item = Result<LogItem, Status>> + Send + 'static

Server streaming response type for the StreamDeviceEvents method.

Required Methods

fn login<'life0, 'async_trait>( &'life0 self, request: Request<LoginRequest> ) -> Pin<Box<dyn Future<Output = Result<Response<LoginResponse>, Status>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Log in a user

fn profile<'life0, 'async_trait>( &'life0 self, request: Request<()> ) -> Pin<Box<dyn Future<Output = Result<Response<ProfileResponse>, Status>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

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 Self: 'async_trait, 'life0: '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 Self: 'async_trait, 'life0: 'async_trait,

CreateApiKey creates the given API key.

fn delete_api_key<'life0, 'async_trait>( &'life0 self, request: Request<DeleteApiKeyRequest> ) -> Pin<Box<dyn Future<Output = Result<Response<()>, Status>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

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 Self: 'async_trait, 'life0: 'async_trait,

ListApiKeys lists the available API keys.

fn settings<'life0, 'async_trait>( &'life0 self, request: Request<()> ) -> Pin<Box<dyn Future<Output = Result<Response<SettingsResponse>, Status>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

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 Self: 'async_trait, 'life0: '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 Self: 'async_trait, 'life0: '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 Self: 'async_trait, 'life0: '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 Self: 'async_trait, 'life0: '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 Self: 'async_trait, 'life0: '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 Self: 'async_trait, 'life0: 'async_trait,

Stream events for the given Device EUI.

fn list_regions<'life0, 'async_trait>( &'life0 self, request: Request<()> ) -> Pin<Box<dyn Future<Output = Result<Response<ListRegionsResponse>, Status>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

ListRegions lists the available (configured) regions.

fn get_region<'life0, 'async_trait>( &'life0 self, request: Request<GetRegionRequest> ) -> Pin<Box<dyn Future<Output = Result<Response<GetRegionResponse>, Status>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

GetRegion returns the region details for the given region.

Implementors