mirror of
https://github.com/hanzo-ds/go.git
synced 2026-10-30 19:45:01 +00:00
zeekay
22b3f5ce2b
Feature-complete v2.44.0 (lib/churl, lib/col, BFloat16, QBit, scanTypeDuration, Options.Logger *slog.Logger) — fixes the [email protected].0 downgrade RED caught. Package datastore, module github.com/hanzo-ds/go, depends only on hanzo-ds/native. Wire strings preserved VERBATIM (X-ClickHouse-* headers, sql.Register("clickhouse"), clickhouse:// DSN, ClientName="clickhouse-go") — consistent with native.
74 lines
1.5 KiB
Go
74 lines
1.5 KiB
Go
package datastore
|
|
|
|
import (
|
|
"context"
|
|
"log/slog"
|
|
"time"
|
|
|
|
"github.com/hanzo-ds/go/lib/proto"
|
|
)
|
|
|
|
type Log struct {
|
|
Time time.Time
|
|
TimeMicro uint32
|
|
Hostname string
|
|
QueryID string
|
|
ThreadID uint64
|
|
Priority int8
|
|
Source string
|
|
Text string
|
|
}
|
|
|
|
func (c *connect) logs(ctx context.Context) ([]Log, error) {
|
|
block, err := c.readData(ctx, proto.ServerLog, false)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
c.logger.Debug("server logs received", slog.Int("rows", block.Rows()))
|
|
var (
|
|
logs []Log
|
|
names = block.ColumnsNames()
|
|
)
|
|
for r := 0; r < block.Rows(); r++ {
|
|
var log Log
|
|
for i, b := range block.Columns {
|
|
switch names[i] {
|
|
case "event_time":
|
|
if err := b.ScanRow(&log.Time, r); err != nil {
|
|
return nil, err
|
|
}
|
|
case "event_time_microseconds":
|
|
if err := b.ScanRow(&log.TimeMicro, r); err != nil {
|
|
return nil, err
|
|
}
|
|
case "host_name":
|
|
if err := b.ScanRow(&log.Hostname, r); err != nil {
|
|
return nil, err
|
|
}
|
|
case "query_id":
|
|
if err := b.ScanRow(&log.QueryID, r); err != nil {
|
|
return nil, err
|
|
}
|
|
case "thread_id":
|
|
if err := b.ScanRow(&log.ThreadID, r); err != nil {
|
|
return nil, err
|
|
}
|
|
case "priority":
|
|
if err := b.ScanRow(&log.Priority, r); err != nil {
|
|
return nil, err
|
|
}
|
|
case "source":
|
|
if err := b.ScanRow(&log.Source, r); err != nil {
|
|
return nil, err
|
|
}
|
|
case "text":
|
|
if err := b.ScanRow(&log.Text, r); err != nil {
|
|
return nil, err
|
|
}
|
|
}
|
|
}
|
|
logs = append(logs, log)
|
|
}
|
|
return logs, nil
|
|
}
|