table

Documentation

Index

• Variables
• type DDWrapper
• type TableTranslator
  • func NewTableTranslator() *TableTranslator
  • func (l *TableTranslator) LogsFromOtel(ol *plog.Logs, environment authenv.Environment) ([]map[string]any, error)
  • func (l *TableTranslator) MetricsFromOtel(om *pmetric.Metrics, environment authenv.Environment) ([]map[string]any, error)
  • func (l *TableTranslator) TracesFromOtel(ot *ptrace.Traces, environment authenv.Environment) ([]map[string]any, error)
• type Translator

Variables

var MapNames = false

var OtelToDatadogHostnameSearch = []string{
	"host",
	"datadog.host.name",
	"host.name",
	"host.id",
}

var OtelToDatadogResource = map[string]string{
	"aws.ecs.cluster.arn":     "ecs_cluster_name",
	"aws.ecs.container.arn":   "ecs_container_name",
	"aws.ecs.task.arn":        "task_arn",
	"aws.ecs.task.family":     "task_family",
	"aws.ecs.task.revision":   "task_revision",
	"cloud.availability_zone": "zone",
	"cloud.provider":          "cloud_provider",
	"cloud.region":            "region",
	"container.id":            "container_id",
	"container.image.name":    "image_name",
	"container.image.tag":     "image_tag",
	"container.name":          "container_name",
	"deployment.environment":  "env",
	"k8s.cluster.name":        "kube_cluster_name",
	"k8s.container.name":      "kube_container_name",
	"k8s.cronjob.name":        "kube_cronjob",
	"k8s.daemonset.name":      "kube_daemon_set",
	"k8s.deployment.name":     "kube_deployment",
	"k8s.job.name":            "kube_job",
	"k8s.namespace.name":      "kube_namespace",
	"k8s.pod.name":            "pod_name",
	"k8s.replicaset.name":     "kube_replica_set",
	"k8s.statefulset.name":    "kube_stateful_set",
	"service.name":            "service",
	"service.version":         "version",
}

Types

type DDWrapper

type DDWrapper struct {
	Sketch         *ddsketch.DDSketch
	StartTimestamp time.Time
	Timestamp      time.Time
	Attributes     map[string]any
}

type TableTranslator

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

func NewTableTranslator

func NewTableTranslator() *TableTranslator

func (*TableTranslator) LogsFromOtel

func (l *TableTranslator) LogsFromOtel(ol *plog.Logs, environment authenv.Environment) ([]map[string]any, error)

func (*TableTranslator) MetricsFromOtel

func (l *TableTranslator) MetricsFromOtel(om *pmetric.Metrics, environment authenv.Environment) ([]map[string]any, error)

func (*TableTranslator) TracesFromOtel

func (l *TableTranslator) TracesFromOtel(ot *ptrace.Traces, environment authenv.Environment) ([]map[string]any, error)

type Translator

type Translator interface {
	LogsFromOtel(ol *plog.Logs, environment authenv.Environment) ([]map[string]any, error)
	MetricsFromOtel(om *pmetric.Metrics, environment authenv.Environment) ([]map[string]any, error)
	TracesFromOtel(ot *ptrace.Traces, environment authenv.Environment) ([]map[string]any, error)
}