@@ -34,7 +34,6 @@ impl From<(Bar, String)> for types::Bar {
|
|||||||
close: bar.close,
|
close: bar.close,
|
||||||
volume: bar.volume,
|
volume: bar.volume,
|
||||||
trades: bar.trades,
|
trades: bar.trades,
|
||||||
vwap: bar.vwap,
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
@@ -36,7 +36,6 @@ impl From<Message> for Bar {
|
|||||||
close: bar.close,
|
close: bar.close,
|
||||||
volume: bar.volume,
|
volume: bar.volume,
|
||||||
trades: bar.trades,
|
trades: bar.trades,
|
||||||
vwap: bar.vwap,
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
@@ -13,5 +13,4 @@ pub struct Bar {
|
|||||||
pub close: f64,
|
pub close: f64,
|
||||||
pub volume: f64,
|
pub volume: f64,
|
||||||
pub trades: i64,
|
pub trades: i64,
|
||||||
pub vwap: f64,
|
|
||||||
}
|
}
|
||||||
|
@@ -26,8 +26,7 @@ CREATE TABLE IF NOT EXISTS qrust.bars (
|
|||||||
low Float64,
|
low Float64,
|
||||||
close Float64,
|
close Float64,
|
||||||
volume Float64,
|
volume Float64,
|
||||||
trades Int64,
|
trades Int64
|
||||||
vwap Float64
|
|
||||||
)
|
)
|
||||||
ENGINE = ReplacingMergeTree()
|
ENGINE = ReplacingMergeTree()
|
||||||
PRIMARY KEY (symbol, time)
|
PRIMARY KEY (symbol, time)
|
||||||
|
Reference in New Issue
Block a user