ntppool/data-api
Private
Public Access
1
0
Fork 0
Code Activity

scorer: fix parsing leap column
All checks were successful
continuous-integration/drone/push Build is passing
Details

Browse Source
This commit is contained in:
Ask Bjørn Hansen
2024-01-20 23:43:22 -07:00
parent e1398e7472
commit 675e993353
1 changed files with 9 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
chdb/logscores.go
View File

@@ -60,7 +60,10 @@ func (d *ClickHouse) Logscores(ctx context.Context, serverID, monitorID int, sin
log.DebugContext(ctx, "clickhouse query", "query", query, "args", args)
rows, err := d.Scores.Query(clickhouse.Context(ctx, clickhouse.WithSpan(span.SpanContext())),
rows, err := d.Scores.Query(
clickhouse.Context(
ctx, clickhouse.WithSpan(span.SpanContext()),
),
query, args...,
)
if err != nil {
@@ -74,6 +77,8 @@ func (d *ClickHouse) Logscores(ctx context.Context, serverID, monitorID int, sin
row := ntpdb.LogScore{}
var leap uint8
if err := rows.Scan(
&row.ID,
&row.MonitorID,
@@ -83,7 +88,7 @@ func (d *ClickHouse) Logscores(ctx context.Context, serverID, monitorID int, sin
&row.Step,
&row.Offset,
&row.Rtt,
&row.Attributes.Leap,
&leap,
&row.Attributes.Warning,
&row.Attributes.Error,
); err != nil {
@@ -91,6 +96,8 @@ func (d *ClickHouse) Logscores(ctx context.Context, serverID, monitorID int, sin
continue
}
row.Attributes.Leap = int8(leap)
rv = append(rv, row)
}