stats

type Aggregation struct {
	BucketsAggregationKey
	PayloadAggregationKey
}

type BucketsAggregationKey struct {
	Service        string
	Name           string
	Resource       string
	Type           string
	SpanKind       string
	StatusCode     uint32
	Synthetics     bool
	PeerTagsHash   uint64
	IsTraceRoot    pb.Trilean
	GRPCStatusCode string
	HTTPMethod     string
	HTTPEndpoint   string
}

type ClientStatsAggregator struct {
	In chan *pb.ClientStatsPayload
	// contains filtered or unexported fields
}

type Concentrator struct {
	Writer Writer
	// contains filtered or unexported fields
}

type Input struct {
	Traces        []traceutil.ProcessedTrace
	ContainerID   string
	ContainerTags []string
	ProcessTags   string
}

type InputV1 struct {
	Traces        []traceutil.ProcessedTraceV1
	ContainerID   string
	ContainerTags []string
	ProcessTags   string
}

type PayloadAggregationKey struct {
	Env             string
	Hostname        string
	Version         string
	ContainerID     string
	GitCommitSha    string
	ImageTag        string
	Lang            string
	ProcessTagsHash uint64
}

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

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

type SpanConcentratorConfig struct {
	// ComputeStatsBySpanKind enables/disables the computing of stats based on a span's `span.kind` field
	ComputeStatsBySpanKind bool
	// BucketInterval the size of our pre-aggregation per bucket
	BucketInterval int64
}

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

type StatSpanConfig struct {
	Service      string
	Resource     string
	Name         string
	Type         string
	ParentID     uint64
	Start        int64
	Duration     int64
	Error        int32
	Meta         map[string]string
	Metrics      map[string]float64
	PeerTags     []string
	HTTPMethod   string
	HTTPEndpoint string
}

type Writer interface {
	// Write this payload
	Write(*pb.StatsPayload)
}