@@ -12,7 +12,6 @@ use std::time::{Duration, SystemTime, UNIX_EPOCH};
12
12
13
13
use scylla_proxy:: { Node , Proxy , ProxyError , RunningProxy , ShardAwareness } ;
14
14
15
- #[ cfg( test) ]
16
15
pub ( crate ) fn setup_tracing ( ) {
17
16
let _ = tracing_subscriber:: fmt:: fmt ( )
18
17
. with_env_filter ( tracing_subscriber:: EnvFilter :: from_default_env ( ) )
@@ -22,7 +21,6 @@ pub(crate) fn setup_tracing() {
22
21
23
22
static UNIQUE_COUNTER : AtomicUsize = AtomicUsize :: new ( 0 ) ;
24
23
25
- #[ allow( unused) ]
26
24
pub ( crate ) fn unique_keyspace_name ( ) -> String {
27
25
let cnt = UNIQUE_COUNTER . fetch_add ( 1 , Ordering :: SeqCst ) ;
28
26
let name = format ! (
87
85
running_proxy. finish ( ) . await
88
86
}
89
87
90
- #[ allow( unused) ]
91
88
pub ( crate ) async fn supports_feature ( session : & Session , feature : & str ) -> bool {
92
89
// Cassandra doesn't have a concept of features, so first detect
93
90
// if there is the `supported_features` column in system.local
@@ -120,15 +117,13 @@ pub(crate) async fn supports_feature(session: &Session, feature: &str) -> bool {
120
117
. any ( |f| f == feature)
121
118
}
122
119
123
- #[ allow( unused) ]
124
120
pub ( crate ) async fn scylla_supports_tablets ( session : & Session ) -> bool {
125
121
supports_feature ( session, "TABLETS" ) . await
126
122
}
127
123
128
124
// Creates a generic session builder based on conditional compilation configuration
129
125
// For SessionBuilder of DefaultMode type, adds localhost to known hosts, as all of the tests
130
126
// connect to localhost.
131
- #[ allow( unused) ]
132
127
pub ( crate ) fn create_new_session_builder ( ) -> GenericSessionBuilder < impl SessionBuilderKind > {
133
128
let session_builder = {
134
129
#[ cfg( not( scylla_cloud_tests) ) ]
0 commit comments