collector

Documentation

Index

• Constants
• Variables
• func ReplaceTables(query string, distributed bool) string
• func SelectIP(ips []netaddr.IP) *netaddr.IP
• func StackHash(s []string) uint64
• type ApplicationInstrumentation
• type ClickhouseClient
  • func NewClickhouseClient(ctx context.Context, cfg *db.IntegrationClickhouse) (*ClickhouseClient, error)
  • func (c *ClickhouseClient) Close()
  • func (c *ClickhouseClient) Exec(ctx context.Context, query string) error
• type Collector
  • func New(cfg Config, database *db.DB, cache *cache.Cache, ...) *Collector
  • func (c *Collector) Close()
  • func (c *Collector) Config(w http.ResponseWriter, r *http.Request)
  • func (c *Collector) IsClickhouseDistributed(project *db.Project) (bool, error)
  • func (c *Collector) Logs(w http.ResponseWriter, r *http.Request)
  • func (c *Collector) Metrics(w http.ResponseWriter, r *http.Request)
  • func (c *Collector) MigrateClickhouseDatabase(ctx context.Context, project *db.Project) 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, project *db.Project) error
• type Config
• type ConfigData
• 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 ReplaceTables

func ReplaceTables(query string, distributed bool) string

func SelectIP

func SelectIP(ips []netaddr.IP) *netaddr.IP

func StackHash

func StackHash(s []string) uint64

Types

type ApplicationInstrumentation

type ApplicationInstrumentation struct {
	Type        model.ApplicationType `json:"type"`
	Host        string                `json:"host"`
	Port        string                `json:"port"`
	Credentials model.Credentials     `json:"credentials"`
	Params      map[string]string     `json:"params"`
	Instance    string                `json:"instance"`
}

type ClickhouseClient

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

func NewClickhouseClient

func NewClickhouseClient(ctx context.Context, cfg *db.IntegrationClickhouse) (*ClickhouseClient, error)

func (*ClickhouseClient) Close

func (c *ClickhouseClient) Close()

func (*ClickhouseClient) Exec

func (c *ClickhouseClient) Exec(ctx context.Context, query string) error

type Collector

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

func New

func New(cfg Config, database *db.DB, cache *cache.Cache, globalClickHouse *db.IntegrationClickhouse, globalPrometheus *db.IntegrationPrometheus) *Collector

func (*Collector) Close

func (c *Collector) Close()

func (*Collector) Config

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

func (*Collector) IsClickhouseDistributed

func (c *Collector) IsClickhouseDistributed(project *db.Project) (bool, error)

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) MigrateClickhouseDatabase

func (c *Collector) MigrateClickhouseDatabase(ctx context.Context, project *db.Project) 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, project *db.Project) error

type Config

type Config struct {
	TracesTTL   timeseries.Duration
	LogsTTL     timeseries.Duration
	ProfilesTTL timeseries.Duration
}

type ConfigData

type ConfigData struct {
	ApplicationInstrumentation []ApplicationInstrumentation `json:"application_instrumentation"`

	AWSConfig *db.IntegrationAWS `json:"aws_config"`
}

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()