mirror of
https://git.mirrors.martin98.com/https://github.com/SigNoz/signoz
synced 2025-10-18 06:01:34 +08:00
43 lines
1002 B
Go
43 lines
1002 B
Go
package db
|
|
|
|
import (
|
|
"time"
|
|
|
|
"github.com/ClickHouse/clickhouse-go/v2"
|
|
|
|
"github.com/jmoiron/sqlx"
|
|
|
|
"github.com/SigNoz/signoz/pkg/cache"
|
|
basechr "github.com/SigNoz/signoz/pkg/query-service/app/clickhouseReader"
|
|
"github.com/SigNoz/signoz/pkg/query-service/interfaces"
|
|
)
|
|
|
|
type ClickhouseReader struct {
|
|
conn clickhouse.Conn
|
|
appdb *sqlx.DB
|
|
*basechr.ClickHouseReader
|
|
}
|
|
|
|
func NewDataConnector(
|
|
localDB *sqlx.DB,
|
|
ch clickhouse.Conn,
|
|
promConfigPath string,
|
|
lm interfaces.FeatureLookup,
|
|
cluster string,
|
|
useLogsNewSchema bool,
|
|
useTraceNewSchema bool,
|
|
fluxIntervalForTraceDetail time.Duration,
|
|
cache cache.Cache,
|
|
) *ClickhouseReader {
|
|
chReader := basechr.NewReader(localDB, ch, promConfigPath, lm, cluster, useLogsNewSchema, useTraceNewSchema, fluxIntervalForTraceDetail, cache)
|
|
return &ClickhouseReader{
|
|
conn: ch,
|
|
appdb: localDB,
|
|
ClickHouseReader: chReader,
|
|
}
|
|
}
|
|
|
|
func (r *ClickhouseReader) Start(readerReady chan bool) {
|
|
r.ClickHouseReader.Start(readerReady)
|
|
}
|