collector

package

v1.0.3 Latest Latest Go to latest Published: Apr 30, 2024 License: Apache-2.0 Imports: 33 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/coroot/coroot

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func StackHash(s []string) uint64
type Collector
- func New(database *db.DB) *Collector
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 ¶

View Source

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

Variables ¶

View Source

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

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL