This commit is contained in:
@@ -2,14 +2,12 @@ use super::InternalRecord;
|
|||||||
use crate::{
|
use crate::{
|
||||||
action::{Action, MsgAction, Records},
|
action::{Action, MsgAction, Records},
|
||||||
document::record::Oid,
|
document::record::Oid,
|
||||||
message::{Message, MessageAction},
|
message::Message,
|
||||||
name::{Name, Names},
|
name::{Name, Names},
|
||||||
queue::{
|
queue::{
|
||||||
self,
|
|
||||||
data_director::{Include, Path, RegMsg, Register},
|
data_director::{Include, Path, RegMsg, Register},
|
||||||
router::Queue,
|
router::Queue,
|
||||||
},
|
},
|
||||||
Query,
|
|
||||||
};
|
};
|
||||||
use chrono::{DateTime, Utc};
|
use chrono::{DateTime, Utc};
|
||||||
use std::{
|
use std::{
|
||||||
@@ -56,7 +54,7 @@ impl Clock {
|
|||||||
fn respnse(timestamp: DateTime<Utc>) -> Records {
|
fn respnse(timestamp: DateTime<Utc>) -> Records {
|
||||||
let mut names = Names::new();
|
let mut names = Names::new();
|
||||||
let field_name = Name::english("time");
|
let field_name = Name::english("time");
|
||||||
names.add_names(vec![field_name.clone()]);
|
names.add_names(vec![field_name.clone()]).unwrap();
|
||||||
let field_id = names.get_id(field_name).unwrap();
|
let field_id = names.get_id(field_name).unwrap();
|
||||||
let mut recs = Records::new(Self::doc_names(), names);
|
let mut recs = Records::new(Self::doc_names(), names);
|
||||||
let mut rec = InternalRecord::new();
|
let mut rec = InternalRecord::new();
|
||||||
@@ -106,12 +104,12 @@ impl Clock {
|
|||||||
mod clocks {
|
mod clocks {
|
||||||
use super::*;
|
use super::*;
|
||||||
use crate::{
|
use crate::{
|
||||||
|
message::MessageAction,
|
||||||
queue::{
|
queue::{
|
||||||
self,
|
|
||||||
data_director::{Include, Path},
|
data_director::{Include, Path},
|
||||||
TestClock,
|
TestClock,
|
||||||
},
|
},
|
||||||
Field, NameType,
|
Field, Query,
|
||||||
};
|
};
|
||||||
use chrono::{TimeDelta, Utc};
|
use chrono::{TimeDelta, Utc};
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user