Changeset View
Changeset View
Standalone View
Standalone View
services/backup/src/service/mod.rs
use aws_sdk_dynamodb::Error as DynamoDBError; | use aws_sdk_dynamodb::Error as DynamoDBError; | ||||
use comm_services_lib::database::Error as DBError; | |||||
use proto::backup_service_server::BackupService; | use proto::backup_service_server::BackupService; | ||||
use std::pin::Pin; | use std::pin::Pin; | ||||
use tokio::sync::mpsc; | use tokio::sync::mpsc; | ||||
use tokio_stream::{wrappers::ReceiverStream, Stream, StreamExt}; | use tokio_stream::{wrappers::ReceiverStream, Stream, StreamExt}; | ||||
use tonic::{Request, Response, Status}; | use tonic::{Request, Response, Status}; | ||||
use tracing::{debug, error, info, instrument, trace, warn}; | use tracing::{debug, error, info, instrument, trace, warn}; | ||||
use tracing_futures::Instrument; | use tracing_futures::Instrument; | ||||
use crate::{ | use crate::{ | ||||
blob::BlobClient, | blob::BlobClient, constants::MPSC_CHANNEL_BUFFER_CAPACITY, | ||||
constants::MPSC_CHANNEL_BUFFER_CAPACITY, | database::DatabaseClient, | ||||
database::{DatabaseClient, Error as DBError}, | |||||
}; | }; | ||||
mod proto { | mod proto { | ||||
tonic::include_proto!("backup"); | tonic::include_proto!("backup"); | ||||
} | } | ||||
pub use proto::backup_service_server::BackupServiceServer; | pub use proto::backup_service_server::BackupServiceServer; | ||||
/// submodule containing gRPC endpoint handler implementations | /// submodule containing gRPC endpoint handler implementations | ||||
▲ Show 20 Lines • Show All 220 Lines • Show Last 20 Lines |