collector

Apr 22, 2024

Changes in this version

+ const ApiKeyHeader

+ var ErrClickhouseNotConfigured = errors.New("clickhouse integration is not configured")

+ var ErrProjectNotFound = errors.New("project not found")

+ func StackHash(s []string) uint64

+ type Collector struct

+ func New(database *db.DB) *Collector

+ func (c *Collector) Close()

+ func (c *Collector) Logs(w http.ResponseWriter, r *http.Request)

+ func (c *Collector) Metrics(w http.ResponseWriter, r *http.Request)

+ func (c *Collector) Migrate(ctx context.Context, cfg *db.IntegrationClickhouse) error

+ func (c *Collector) Profiles(w http.ResponseWriter, r *http.Request)

+ func (c *Collector) Traces(w http.ResponseWriter, r *http.Request)

+ func (c *Collector) UpdateClickhouseClient(ctx context.Context, projectId db.ProjectId, cfg *db.IntegrationClickhouse) error

+ type LogsBatch struct

+ Body *chproto.ColStr

+ LogAttributes *chproto.ColMap[string, string]

+ ResourceAttributes *chproto.ColMap[string, string]

+ ServiceName *chproto.ColLowCardinality[string]

+ SeverityNumber *chproto.ColInt32

+ SeverityText *chproto.ColLowCardinality[string]

+ SpanId *chproto.ColStr

+ Timestamp *chproto.ColDateTime64

+ TraceFlags *chproto.ColUInt32

+ TraceId *chproto.ColStr

+ func NewLogsBatch(limit int, timeout time.Duration, exec func(query ch.Query) error) *LogsBatch

+ func (b *LogsBatch) Add(req *v1.ExportLogsServiceRequest)

+ func (b *LogsBatch) Close()

+ type ProfilesBatch struct

+ End *chproto.ColDateTime64

+ Labels *chproto.ColMap[string, string]

+ ServiceName *chproto.ColLowCardinality[string]

+ Stack *chproto.ColArr[string]

+ StackHash *chproto.ColUInt64

+ Start *chproto.ColDateTime64

+ Type *chproto.ColLowCardinality[string]

+ Value *chproto.ColInt64

+ func NewProfilesBatch(limit int, timeout time.Duration, exec func(query ch.Query) error) *ProfilesBatch

+ func (b *ProfilesBatch) Add(serviceName string, labels model.Labels, p *profile.Profile)

+ func (b *ProfilesBatch) Close()

+ type TracesBatch struct

+ Duration *chproto.ColInt64

+ EventsAttributes *chproto.ColArr[map[string]string]

+ EventsName *chproto.ColArr[string]

+ EventsTimestamp *chproto.ColArr[time.Time]

+ LinksAttributes *chproto.ColArr[map[string]string]

+ LinksSpanId *chproto.ColArr[string]

+ LinksTraceId *chproto.ColArr[string]

+ LinksTraceState *chproto.ColArr[string]

+ ParentSpanId *chproto.ColStr

+ ResourceAttributes *chproto.ColMap[string, string]

+ ServiceName *chproto.ColLowCardinality[string]

+ SpanAttributes *chproto.ColMap[string, string]

+ SpanId *chproto.ColStr

+ SpanKind *chproto.ColLowCardinality[string]

+ SpanName *chproto.ColLowCardinality[string]

+ StatusCode *chproto.ColLowCardinality[string]

+ StatusMessage *chproto.ColStr

+ Timestamp *chproto.ColDateTime64

+ TraceId *chproto.ColStr

+ TraceState *chproto.ColStr

+ func NewTracesBatch(limit int, timeout time.Duration, exec func(query ch.Query) error) *TracesBatch

+ func (b *TracesBatch) Add(req *v1.ExportTraceServiceRequest)

+ func (b *TracesBatch) Close()