collector

Documentation

Index

• Constants
• Variables
• func StackHash(s []string) uint64
• type Collector
  • 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
  • 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
  • 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
  • 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()

Constants

const (
	ApiKeyHeader = "X-API-Key"
)

Variables

var (
	ErrProjectNotFound         = errors.New("project not found")
	ErrClickhouseNotConfigured = errors.New("clickhouse integration is not configured")
)

Functions

func StackHash

func StackHash(s []string) uint64

Types

type Collector

type Collector struct {
	// contains filtered or unexported fields
}

func New

func New(database *db.DB) *Collector

func (*Collector) Close

func (c *Collector) Close()

func (*Collector) Logs

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

func (*Collector) Metrics

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

func (*Collector) Migrate

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

func (*Collector) Profiles

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

func (*Collector) Traces

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

func (*Collector) UpdateClickhouseClient

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

type LogsBatch

type LogsBatch struct {
	Timestamp          *chproto.ColDateTime64
	TraceId            *chproto.ColStr
	SpanId             *chproto.ColStr
	TraceFlags         *chproto.ColUInt32
	SeverityText       *chproto.ColLowCardinality[string]
	SeverityNumber     *chproto.ColInt32
	ServiceName        *chproto.ColLowCardinality[string]
	ResourceAttributes *chproto.ColMap[string, string]
	LogAttributes      *chproto.ColMap[string, string]
	Body               *chproto.ColStr
	// contains filtered or unexported fields
}

func NewLogsBatch

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

func (*LogsBatch) Add

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

func (*LogsBatch) Close

func (b *LogsBatch) Close()

type ProfilesBatch

type ProfilesBatch struct {
	ServiceName *chproto.ColLowCardinality[string]
	Type        *chproto.ColLowCardinality[string]
	Start       *chproto.ColDateTime64
	End         *chproto.ColDateTime64
	Labels      *chproto.ColMap[string, string]
	Value       *chproto.ColInt64
	StackHash   *chproto.ColUInt64
	Stack       *chproto.ColArr[string]
	// contains filtered or unexported fields
}

func NewProfilesBatch

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

func (*ProfilesBatch) Add

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

func (*ProfilesBatch) Close

func (b *ProfilesBatch) Close()

type TracesBatch

type TracesBatch struct {
	Timestamp          *chproto.ColDateTime64
	TraceId            *chproto.ColStr
	SpanId             *chproto.ColStr
	ParentSpanId       *chproto.ColStr
	TraceState         *chproto.ColStr
	SpanName           *chproto.ColLowCardinality[string]
	SpanKind           *chproto.ColLowCardinality[string]
	ServiceName        *chproto.ColLowCardinality[string]
	ResourceAttributes *chproto.ColMap[string, string]
	SpanAttributes     *chproto.ColMap[string, string]
	Duration           *chproto.ColInt64
	StatusCode         *chproto.ColLowCardinality[string]
	StatusMessage      *chproto.ColStr
	EventsTimestamp    *chproto.ColArr[time.Time]
	EventsName         *chproto.ColArr[string]
	EventsAttributes   *chproto.ColArr[map[string]string]
	LinksTraceId       *chproto.ColArr[string]
	LinksSpanId        *chproto.ColArr[string]
	LinksTraceState    *chproto.ColArr[string]
	LinksAttributes    *chproto.ColArr[map[string]string]
	// contains filtered or unexported fields
}

func NewTracesBatch

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

func (*TracesBatch) Add

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

func (*TracesBatch) Close

func (b *TracesBatch) Close()