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

fix: Change WAL not found errors to Write Buffer not found

pull/24376/head
Carol (Nichols || Goulding) 2021-04-19 16:19:38 -04:00 committed by kodiakhq[bot]
parent cdb9574beb
commit 4350a2e5ef
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/influxdb_ioxd/http.rs
View File

@ -182,8 +182,8 @@ pub enum ApplicationError {
#[snafu(display("Database {} not found", name))]
DatabaseNotFound { name: String },
#[snafu(display("Database {} does not have a WAL", name))]
WalNotFound { name: String },
#[snafu(display("Database {} does not have a Write Buffer", name))]
WriteBufferNotFound { name: String },
#[snafu(display("Internal error creating HTTP response: {}", source))]
CreatingResponse { source: http::Error },
@ -236,7 +236,7 @@ impl ApplicationError {
Self::ErrorCreatingDatabase { .. } => self.bad_request(),
Self::DatabaseNameError { .. } => self.bad_request(),
Self::DatabaseNotFound { .. } => self.not_found(),
Self::WalNotFound { .. } => self.not_found(),
Self::WriteBufferNotFound { .. } => self.not_found(),
Self::CreatingResponse { .. } => self.internal_error(),
Self::FormattingResult { .. } => self.internal_error(),
Self::ParsingFormat { .. } => self.bad_request(),
@ -576,7 +576,7 @@ async fn get_write_buffer_meta<M: ConnectionManager + Send + Sync + Debug + 'sta
let wb = db
.write_buffer
.as_ref()
.context(WalNotFound { name: &db_name_str })?;
.context(WriteBufferNotFound { name: &db_name_str })?;
let write_buffer = wb.lock();
let segments = write_buffer