Differential D6854 Diff 23165 services/backup/src/service/mod.rs

Changeset View

Standalone View

	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