File tree Expand file tree Collapse file tree 2 files changed +5
-4
lines changed
libsql-server/src/namespace/configurator Expand file tree Collapse file tree 2 files changed +5
-4
lines changed Original file line number Diff line number Diff line change @@ -269,7 +269,7 @@ impl ConfigureNamespace for LibsqlPrimaryConfigurator {
269269 _from_config : MetaStoreHandle ,
270270 _to_ns : NamespaceName ,
271271 _to_config : MetaStoreHandle ,
272- _timestamp : Option < chrono:: prelude:: NaiveDateTime > ,
272+ timestamp : Option < chrono:: prelude:: NaiveDateTime > ,
273273 _store : NamespaceStore ,
274274 ) -> Pin < Box < dyn Future < Output = crate :: Result < Namespace > > + Send + ' a > > {
275275 Box :: pin ( async move {
@@ -283,7 +283,9 @@ impl ConfigureNamespace for LibsqlPrimaryConfigurator {
283283 . find_segment (
284284 & s. backend ( ) . default_config ( ) ,
285285 & ns,
286- libsql_wal:: storage:: backend:: FindSegmentReq :: Timestamp ( ts) ,
286+ libsql_wal:: storage:: backend:: FindSegmentReq :: Timestamp (
287+ ts. and_utc ( ) ,
288+ ) ,
287289 )
288290 . await
289291 . unwrap ( ) ;
Original file line number Diff line number Diff line change @@ -2,7 +2,6 @@ use std::pin::Pin;
22use std:: sync:: atomic:: AtomicBool ;
33use std:: sync:: Arc ;
44
5- use chrono:: { DateTime , Utc } ;
65use futures:: Future ;
76use hyper:: Uri ;
87use libsql_replication:: rpc:: replication:: log_offset:: WalFlavor ;
@@ -256,7 +255,7 @@ impl ConfigureNamespace for ReplicaConfigurator {
256255 _from_config : MetaStoreHandle ,
257256 _to_ns : NamespaceName ,
258257 _to_config : MetaStoreHandle ,
259- _timestamp : Option < DateTime < Utc > > ,
258+ _timestamp : Option < chrono :: NaiveDateTime > ,
260259 _store : NamespaceStore ,
261260 ) -> Pin < Box < dyn Future < Output = crate :: Result < Namespace > > + Send + ' a > > {
262261 Box :: pin ( std:: future:: ready ( Err ( crate :: Error :: Fork (
You can’t perform that action at this time.
0 commit comments