Struct AirVinegRPCService

pub struct AirVinegRPCService { /* private fields */ }

Expand description

The concrete implementation of the Air gRPC service

Implementations§

Creates a new instance of the Air gRPC service

Trait Implementations§

Handle streaming download requests with bidirectional streaming and chunk delivery

Handle authentication requests from Mountain

Handle update check requests from Mountain

Handle download requests from Mountain

Handle file indexing requests from Mountain

Handle status check requests from Mountain

Handle service health check

Handle download update requests

Handle apply update requests

Handle file search requests

Handle get file info requests

Handle get metrics requests

Handle get resource usage requests

Handle set resource limits requests

Handle get configuration requests

Handle update configuration requests

Returns a duplicate of the value. Read more

Performs copy-assignment from source. 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.

§

§

Converts to this type from a reference to the input type.

§

§

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 alignment of pointer.

§

The type for initializers.

§

Initializes a with the given initializer. Read more

§

Dereferences the given pointer. Read more

§

Mutably dereferences the given pointer. Read more

§

Drops the object pointed to by the given pointer. Read more

§

§

Create a new Policy that returns [Action::Follow] only if self and other return Action::Follow. Read more

§

Create a new Policy that returns [Action::Follow] if either self or other returns Action::Follow. Read more

Should always be Self

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

AirVinegRPCService

Struct AirVinegRPCService Copy item path

Implementations§

impl AirVinegRPCService

pub fn new( AppState: Arc<ApplicationState>, AuthService: Arc<AuthenticationService>, UpdateManager: Arc<UpdateManager>, DownloadManager: Arc<DownloadManager>, FileIndexer: Arc<FileIndexer>, ) -> Self

Trait Implementations§

impl AirService for AirVinegRPCService

type DownloadStreamStream = ReceiverStream<Result<DownloadStreamResponse, Status>>

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

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

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

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

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

fn health_check<'life0, 'async_trait>( &'life0 self, _request: Request<HealthCheckRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<HealthCheckResponse>, Status>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

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

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

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

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

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

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

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

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

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

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

impl Clone for AirVinegRPCService

fn clone(&self) -> AirVinegRPCService

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

Auto Trait Implementations§

impl Freeze for AirVinegRPCService

impl !RefUnwindSafe for AirVinegRPCService

impl Send for AirVinegRPCService

impl Sync for AirVinegRPCService

impl Unpin for AirVinegRPCService

impl !UnwindSafe for AirVinegRPCService

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,

fn borrow_mut(&mut self) -> &mut T

impl<T> CloneToUninit for Twhere T: Clone,

unsafe fn clone_to_uninit(&self, dest: *mut u8)

impl<T> From<T> for T

fn from(t: T) -> T

impl<T> FromRef<T> for Twhere T: Clone,

fn from_ref(input: &T) -> T

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

fn in_current_span(self) -> Instrumented<Self>

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

fn into(self) -> U

impl<T> IntoRequest<T> for T

fn into_request(self) -> Request<T>

impl<L> LayerExt<L> for L

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

impl<T> Pointable for T

const ALIGN: usize

type Init = T

unsafe fn init(init: <T as Pointable>::Init) -> usize

unsafe fn deref<'a>(ptr: usize) -> &'a T

unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

unsafe fn drop(ptr: usize)

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

fn and<P, B, E>(self, other: P) -> And<T, P>where T: Policy<B, E>, P: Policy<B, E>,

fn or<P, B, E>(self, other: P) -> Or<T, P>where T: Policy<B, E>, P: Policy<B, E>,

impl<T> Same for T

type Output = T

impl<T> ToOwned for Twhere T: Clone,

type Owned = T

fn to_owned(&self) -> T

fn clone_into(&self, target: &mut T)

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

type Error = Infallible

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

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

type Error = <U as TryFrom<T>>::Error

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

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

fn vzip(self) -> V

Struct AirVinegRPCService

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

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

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

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

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

fn health_check<'life0, 'async_trait>( &'life0 self, _request: Request<HealthCheckRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<HealthCheckResponse>, Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

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

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

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

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

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

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

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

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

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

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

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> FromRef<T> 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> PolicyExt for T
where T: ?Sized,

fn and<P, B, E>(self, other: P) -> And<T, P>
where T: Policy<B, E>, P: Policy<B, E>,

fn or<P, B, E>(self, other: P) -> Or<T, P>
where T: Policy<B, E>, P: Policy<B, E>,

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>,