Skip to content

Commit 5297de8

Browse files
authored
Apply cargo fmt before adding CI (#3)
1 parent dc0bc20 commit 5297de8

File tree

5 files changed

+9
-10
lines changed

5 files changed

+9
-10
lines changed

config-local.toml

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -24,5 +24,5 @@ type = "filesystem"
2424
#endpoint = "http://localhost:9000"
2525

2626
[paths]
27-
cache_dir = "~/.hotdata/rivetdb/cache"
28-
state_dir = "~/.hotdata/rivetdb/state"
27+
#cache_dir = "~/.hotdata/rivetdb/cache"
28+
#state_dir = "~/.hotdata/rivetdb/state"

src/bin/server.rs

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,9 +1,9 @@
11
use anyhow::Result;
22
use clap::Parser;
3-
use std::time::Instant;
43
use rivetdb::config::AppConfig;
54
use rivetdb::datafusion::HotDataEngine;
65
use rivetdb::http::app_server::AppServer;
6+
use std::time::Instant;
77

88
#[derive(Parser)]
99
#[command(name = "rivet-server", about = "Rivet HTTP Server")]
@@ -50,8 +50,7 @@ async fn main() -> Result<()> {
5050
tracing::info!("Server listening on {}", addr);
5151

5252
// Start server
53-
let server = axum::serve(listener, app.router)
54-
.with_graceful_shutdown(shutdown());
53+
let server = axum::serve(listener, app.router).with_graceful_shutdown(shutdown());
5554

5655
server.await?;
5756

tests/engine_sync_tests.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
use anyhow::Result;
2-
use tempfile::tempdir;
32
use rivetdb::datafusion::HotDataEngine;
3+
use tempfile::tempdir;
44

55
/// Test that sync_connection handles non-existent connections correctly
66
#[tokio::test]

tests/http_server_tests.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -5,11 +5,11 @@ use axum::{
55
http::{Request, StatusCode},
66
Router,
77
};
8+
use rivetdb::datafusion::HotDataEngine;
9+
use rivetdb::http::app_server::{AppServer, PATH_CONNECTIONS, PATH_QUERY, PATH_TABLES};
810
use serde_json::json;
911
use tempfile::TempDir;
1012
use tower::util::ServiceExt;
11-
use rivetdb::datafusion::HotDataEngine;
12-
use rivetdb::http::app_server::{AppServer, PATH_CONNECTIONS, PATH_QUERY, PATH_TABLES};
1313

1414
/// Create test router with in-memory engine
1515
fn setup_test() -> Result<(Router, TempDir)> {

tests/s3_storage_tests.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -124,7 +124,7 @@ fn s3_storage_get_credentials_with_config() {
124124
assert_eq!(creds.endpoint_url, "http://localhost:9000");
125125
}
126126

127-
/// Test that S3Credentials serializes to JSON with correct field names
127+
/// Test that S3Credentials serializes to JSON with correct field names
128128
#[test]
129129
fn s3_credentials_serializes_for_dlt() {
130130
let creds = S3Credentials {
@@ -134,7 +134,7 @@ fn s3_credentials_serializes_for_dlt() {
134134
};
135135

136136
let json = serde_json::to_value(&creds).unwrap();
137-
137+
138138
assert_eq!(json["aws_access_key_id"], "AKIAIOSFODNN7EXAMPLE");
139139
assert_eq!(
140140
json["aws_secret_access_key"],

0 commit comments

Comments
 (0)