Improve container output
This commit is contained in:
@@ -36,7 +36,7 @@ pub async fn scylla_channel_event_stream(
|
|||||||
chconf: ChConf,
|
chconf: ChConf,
|
||||||
scyqueue: &ScyllaQueue,
|
scyqueue: &ScyllaQueue,
|
||||||
) -> Result<Pin<Box<dyn Stream<Item = Sitemty<ChannelEvents>> + Send>>, Error> {
|
) -> Result<Pin<Box<dyn Stream<Item = Sitemty<ChannelEvents>> + Send>>, Error> {
|
||||||
debug!("scylla_channel_event_stream {evq:?}");
|
trace!("scylla_channel_event_stream {evq:?}");
|
||||||
// TODO depends in general on the query
|
// TODO depends in general on the query
|
||||||
// TODO why both in PlainEventsQuery and as separate parameter? Check other usages.
|
// TODO why both in PlainEventsQuery and as separate parameter? Check other usages.
|
||||||
let _series = SeriesId::new(chconf.series());
|
let _series = SeriesId::new(chconf.series());
|
||||||
|
|||||||
@@ -46,7 +46,7 @@ pub async fn worker_write(
|
|||||||
stmts_cache: &StmtsCache,
|
stmts_cache: &StmtsCache,
|
||||||
scy: &ScySession,
|
scy: &ScySession,
|
||||||
) -> Result<(), streams::timebin::cached::reader::Error> {
|
) -> Result<(), streams::timebin::cached::reader::Error> {
|
||||||
for (((((((&ts1, &ts2), &cnt), min), max), &avg), lst), &fnl) in bins.zip_iter() {
|
for (((((((&ts1, &ts2), &cnt), min), max), avg), lst), &fnl) in bins.zip_iter() {
|
||||||
let bin_len = DtMs::from_ms_u64((ts2.ns() - ts1.ns()) / 1000000);
|
let bin_len = DtMs::from_ms_u64((ts2.ns() - ts1.ns()) / 1000000);
|
||||||
let div = streams::timebin::cached::reader::part_len(bin_len).ns();
|
let div = streams::timebin::cached::reader::part_len(bin_len).ns();
|
||||||
let msp = ts1.ns() / div;
|
let msp = ts1.ns() / div;
|
||||||
|
|||||||
Reference in New Issue
Block a user