translator

Documentation

Index

• Constants
• func GetBuffer() *bytes.Buffer
• func HandleTracesPayload(req *http.Request) (tp []*pb.TracerPayload, err error)
• func PutBuffer(buffer *bytes.Buffer)
• func ToTraces(payload *pb.TracerPayload, req *http.Request) ptrace.Traces
• type DDInfo
• type MetricsTranslator
  • func NewMetricsTranslator(buildInfo component.BuildInfo) *MetricsTranslator
  • func (mt *MetricsTranslator) HandleSeriesV2Payload(req *http.Request) (mp []*gogen.MetricPayload_MetricSeries, err error)
  • func (mt *MetricsTranslator) HandleSketchesPayload(req *http.Request) (sp []gogen.SketchPayload_Sketch, err error)
  • func (mt *MetricsTranslator) TranslateSeriesV1(series SeriesList) pmetric.Metrics
  • func (mt *MetricsTranslator) TranslateSeriesV2(series []*gogen.MetricPayload_MetricSeries) pmetric.Metrics
  • func (mt *MetricsTranslator) TranslateServices(services []ServiceCheck) pmetric.Metrics
  • func (mt *MetricsTranslator) TranslateSketches(sketches []gogen.SketchPayload_Sketch) pmetric.Metrics
• type ReducedConfig
• type ReducedObfuscationConfig
• type SeriesList
• type ServiceCheck
• type StatsTranslator
  • func NewStatsTranslator() *StatsTranslator
  • func (st *StatsTranslator) TranslateStats(clientStats *pb.ClientStatsPayload, lang, tracerVersion string) (pmetric.Metrics, error)
• type StringPool
  • func (s *StringPool) Intern(str string) string

Constants

const (
	TypeGauge string = "gauge"
	TypeRate  string = "rate"
	TypeCount string = "count"
)

Functions

func GetBuffer

func GetBuffer() *bytes.Buffer

func HandleTracesPayload

func HandleTracesPayload(req *http.Request) (tp []*pb.TracerPayload, err error)

func PutBuffer

func PutBuffer(buffer *bytes.Buffer)

func ToTraces

func ToTraces(payload *pb.TracerPayload, req *http.Request) ptrace.Traces

Types

type DDInfo

type DDInfo struct {
	Version          string         `json:"version"`
	Endpoints        []string       `json:"endpoints"`
	ClientDropP0s    bool           `json:"client_drop_p0s"`
	SpanMetaStructs  bool           `json:"span_meta_structs"`
	LongRunningSpans bool           `json:"long_running_spans"`
	Config           *ReducedConfig `json:"config"`
}

type MetricsTranslator

type MetricsTranslator struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewMetricsTranslator

func NewMetricsTranslator(buildInfo component.BuildInfo) *MetricsTranslator

func (*MetricsTranslator) HandleSeriesV2Payload

func (mt *MetricsTranslator) HandleSeriesV2Payload(req *http.Request) (mp []*gogen.MetricPayload_MetricSeries, err error)

TODO: add handling for JSON format in additional to protobuf?

func (*MetricsTranslator) HandleSketchesPayload

func (mt *MetricsTranslator) HandleSketchesPayload(req *http.Request) (sp []gogen.SketchPayload_Sketch, err error)

Unmarshal the sketch payload, which contains the underlying Dogsketch structure used for the translation

func (*MetricsTranslator) TranslateSeriesV1

func (mt *MetricsTranslator) TranslateSeriesV1(series SeriesList) pmetric.Metrics

func (*MetricsTranslator) TranslateSeriesV2

func (mt *MetricsTranslator) TranslateSeriesV2(series []*gogen.MetricPayload_MetricSeries) pmetric.Metrics

func (*MetricsTranslator) TranslateServices

func (mt *MetricsTranslator) TranslateServices(services []ServiceCheck) pmetric.Metrics

More information on Datadog service checks: https://docs.datadoghq.com/api/latest/service-checks/

func (*MetricsTranslator) TranslateSketches

func (mt *MetricsTranslator) TranslateSketches(sketches []gogen.SketchPayload_Sketch) pmetric.Metrics

type ReducedConfig

type ReducedConfig struct {
	DefaultEnv             string                        `json:"default_env"`
	TargetTPS              float64                       `json:"target_tps"`
	MaxEPS                 float64                       `json:"max_eps"`
	ReceiverPort           int                           `json:"receiver_port"`
	ReceiverSocket         string                        `json:"receiver_socket"`
	ConnectionLimit        int                           `json:"connection_limit"`
	ReceiverTimeout        int                           `json:"receiver_timeout"`
	MaxRequestBytes        int64                         `json:"max_request_bytes"`
	StatsdPort             int                           `json:"statsd_port"`
	MaxMemory              float64                       `json:"max_memory"`
	MaxCPU                 float64                       `json:"max_cpu"`
	AnalyzedSpansByService map[string]map[string]float64 `json:"analyzed_spans_by_service"`
	Obfuscation            ReducedObfuscationConfig      `json:"obfuscation"`
}

type ReducedObfuscationConfig

type ReducedObfuscationConfig struct {
	ElasticSearch        bool                      `json:"elastic_search"`
	Mongo                bool                      `json:"mongo"`
	SQLExecPlan          bool                      `json:"sql_exec_plan"`
	SQLExecPlanNormalize bool                      `json:"sql_exec_plan_normalize"`
	HTTP                 obfuscate.HTTPConfig      `json:"http"`
	RemoveStackTraces    bool                      `json:"remove_stack_traces"`
	Redis                obfuscate.RedisConfig     `json:"redis"`
	Memcached            obfuscate.MemcachedConfig `json:"memcached"`
}

type SeriesList

type SeriesList struct {
	Series []datadogV1.Series `json:"series"`
}

type ServiceCheck

type ServiceCheck struct {
	Check     string                       `json:"check"`
	HostName  string                       `json:"host_name"`
	Status    datadogV1.ServiceCheckStatus `json:"status"`
	Timestamp int64                        `json:"timestamp,omitempty"`
	Tags      []string                     `json:"tags,omitempty"`
}

type StatsTranslator

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

func NewStatsTranslator

func NewStatsTranslator() *StatsTranslator

func (*StatsTranslator) TranslateStats

func (st *StatsTranslator) TranslateStats(clientStats *pb.ClientStatsPayload, lang, tracerVersion string) (pmetric.Metrics, error)

type StringPool

type StringPool struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func (*StringPool) Intern

func (s *StringPool) Intern(str string) string