Skip to content

Commit

Permalink
Apply suggestions from code review
Browse files Browse the repository at this point in the history
  • Loading branch information
jonhoo authored May 25, 2024
1 parent 68c68f5 commit a36bf2a
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 3 deletions.
4 changes: 2 additions & 2 deletions src/proto/single/resp.rs
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
use super::utils;
use crate::error::{self, Error};
use chrono::{DateTime, Utc};
use std::collections::HashMap;
use std::collections::BTreeMap;
use std::time::Duration;
use tokio::io::{AsyncBufRead, AsyncBufReadExt, AsyncReadExt};

Expand Down Expand Up @@ -149,7 +149,7 @@ pub struct DataSnapshot {
/// A mapping between a queue name and its size (number of jobs on the queue).
/// The keys of this map effectively make up a list of queues that are currently
/// registered in the Faktory service.
pub queues: HashMap<String, u64>,
pub queues: BTreeMap<String, u64>,

/// ***Deprecated***. Faktory's task runner stats.
///
Expand Down
2 changes: 1 addition & 1 deletion tests/real/community.rs
Original file line number Diff line number Diff line change
Expand Up @@ -90,7 +90,7 @@ async fn server_state() {
let server_state = client.current_info().await.unwrap();
// the Faktory release we are writing bindings and testing
// against is at least "1.8.0"
assert_gte!(server_state.server.version.major, 1);
assert_eq!(server_state.server.version.major, 1);
assert_gte!(server_state.server.version.minor, 8);
assert!(server_state.data.queues.get(local).is_none());
// the following two assertions are not super-helpful but
Expand Down

0 comments on commit a36bf2a

Please sign in to comment.