File tree Expand file tree Collapse file tree 2 files changed +4
-0
lines changed Expand file tree Collapse file tree 2 files changed +4
-0
lines changed Original file line number Diff line number Diff line change @@ -988,6 +988,7 @@ where
988988 compression : config. compression ,
989989 tcp_nodelay : config. tcp_nodelay ,
990990 tcp_keepalive_interval : config. tcp_keepalive_interval ,
991+ timestamp_generator : config. timestamp_generator ,
991992 #[ cfg( feature = "ssl" ) ]
992993 ssl_config : config. ssl_context . map ( SslConfig :: new_with_global_context) ,
993994 authenticator : config. authenticator . clone ( ) ,
Original file line number Diff line number Diff line change @@ -22,6 +22,7 @@ use crate::frame::{
2222 FrameParams , SerializedRequest ,
2323} ;
2424use crate :: policies:: address_translator:: AddressTranslator ;
25+ use crate :: policies:: timestamp_generator:: TimestampGenerator ;
2526use crate :: query:: Query ;
2627use crate :: response:: query_result:: QueryResult ;
2728use crate :: response:: {
@@ -324,6 +325,7 @@ pub(crate) struct ConnectionConfig {
324325 pub ( crate ) compression : Option < Compression > ,
325326 pub ( crate ) tcp_nodelay : bool ,
326327 pub ( crate ) tcp_keepalive_interval : Option < Duration > ,
328+ pub ( crate ) timestamp_generator : Option < Arc < dyn TimestampGenerator > > ,
327329 #[ cfg( feature = "ssl" ) ]
328330 pub ( crate ) ssl_config : Option < SslConfig > ,
329331 pub ( crate ) connect_timeout : std:: time:: Duration ,
@@ -349,6 +351,7 @@ impl Default for ConnectionConfig {
349351 compression : None ,
350352 tcp_nodelay : true ,
351353 tcp_keepalive_interval : None ,
354+ timestamp_generator : None ,
352355 event_sender : None ,
353356 #[ cfg( feature = "ssl" ) ]
354357 ssl_config : None ,
You can’t perform that action at this time.
0 commit comments