Influxdata
/
influxdb
mirror of https://github.com/influxdata/influxdb.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

refactor: rename src/server/rpc/storage.rs to src/server/rpc/service.rs (#513) 

* refactor: rename src/server/rpc/storage.rs src/server/rpc/service.rs

* refactor: update references
pull/24376/head
Andrew Lamb 2020-12-03 09:59:00 -05:00 committed by GitHub
parent 592c5c3679
commit 8c0e14e039
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
3 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/commands/server.rs
View File

@ -6,7 +6,7 @@ use std::sync::Arc;
use std::{env::VarError, path::PathBuf}; use std::{env::VarError, path::PathBuf};
use crate::server::http_routes; use crate::server::http_routes;
use crate::server::rpc::storage; use crate::server::rpc::service;
use hyper::service::{make_service_fn, service_fn}; use hyper::service::{make_service_fn, service_fn};
use hyper::Server; use hyper::Server;
@ -50,7 +50,7 @@ pub enum Error {
#[snafu(display("Error serving RPC: {}", source))] #[snafu(display("Error serving RPC: {}", source))]
ServingRPC { ServingRPC {
source: crate::server::rpc::storage::Error, source: crate::server::rpc::service::Error,
}, },
} }
@ -107,7 +107,7 @@ pub async fn main() -> Result<()> {
.await .await
.expect("failed to bind server"); .expect("failed to bind server");
let grpc_server = storage::make_server(socket, storage.clone(), executor); let grpc_server = service::make_server(socket, storage.clone(), executor);
info!("gRPC server listening on http://{}", grpc_bind_addr); info!("gRPC server listening on http://{}", grpc_bind_addr);

2
src/server/rpc.rs
View File

@ -11,4 +11,4 @@ pub(crate) const TAG_KEY_FIELD: &[u8] = &[255];
pub mod data; pub mod data;
pub mod expr; pub mod expr;
pub mod input; pub mod input;
pub mod storage; pub mod service;

2
src/server/rpc/storage.rs → src/server/rpc/service.rs
View File

@ -1736,7 +1736,7 @@ mod tests {
// Note we don't include the actual line / column in the // Note we don't include the actual line / column in the
// expected panic message to avoid needing to update the test // expected panic message to avoid needing to update the test
// whenever the source code file changed. // whenever the source code file changed.
let expected_error = "panicked at 'This is a test panic', src/server/rpc/storage.rs"; let expected_error = "panicked at 'This is a test panic', src/server/rpc/service.rs";
assert!( assert!(
captured_logs.contains(expected_error), captured_logs.contains(expected_error),
"Logs did not contain expected panic message '{}'. They were\n{}", "Logs did not contain expected panic message '{}'. They were\n{}",