Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

transform

package

Go to main page

Versions in this module

v0

v0.2.0

Apr 7, 2026

Changes in this version

+ func ToWriteRequest(metrics []MetricData) *prompb.WriteRequest

+ type KustoToMetricsTransformer struct

+ func NewKustoToMetricsTransformer(config TransformConfig, meter metric.Meter) *KustoToMetricsTransformer

+ func (t *KustoToMetricsTransformer) RegisterMetrics(ctx context.Context, metrics []MetricData) error

+ func (t *KustoToMetricsTransformer) Transform(results []map[string]any) ([]MetricData, error)

+ func (t *KustoToMetricsTransformer) Validate(results []map[string]any) error

+ type MetricData struct

+ Labels map[string]string

+ Name string

+ Timestamp time.Time

+ Value float64

type RequestTransformer

+ DynamicLabeler metadata.MetricLabeler

+ func (f *RequestTransformer) WalkLabels(v *prompb.TimeSeries, callback func(name []byte, value []byte))

+ type TransformConfig struct

+ DefaultMetricName string

+ LabelColumns []string

+ MetricNameColumn string

+ MetricNamePrefix string

+ TimestampColumn string

+ ValueColumns []string

v0.1.0

Jan 22, 2025

Changes in this version

+ type CSVWriter struct

+ func NewCSVWriter(w *bytes.Buffer, columns []string) *CSVWriter

+ func (w *CSVWriter) Bytes() []byte

+ func (w *CSVWriter) InitColumns(columns []string)

+ func (w *CSVWriter) MarshalLog(logs *otlp.Logs) error

+ func (w *CSVWriter) Reset()

+ type Field struct

+ Name string

+ Source string

+ Type string

+ type Fields []Field

+ type MetricsCSVWriter struct

+ func NewMetricsCSVWriter(w *bytes.Buffer, lifted Fields) *MetricsCSVWriter

+ func NewMetricsCSVWriterWithSchema(w *bytes.Buffer, lifted Fields, mapping schema.SchemaMapping) *MetricsCSVWriter

+ func (w *MetricsCSVWriter) Bytes() []byte

+ func (w *MetricsCSVWriter) InitColumns(columns []string)

+ func (w *MetricsCSVWriter) MarshalCSV(ts *prompb.TimeSeries) error

+ func (w *MetricsCSVWriter) Reset()

+ func (w *MetricsCSVWriter) SchemaHash() uint64

+ type NativeLogsCSVWriter struct

+ func NewCSVNativeLogsCSVWriter(w *bytes.Buffer, columns []string) *NativeLogsCSVWriter

+ func NewCSVNativeLogsCSVWriterWithSchema(w *bytes.Buffer, columns []string, mapping schema.SchemaMapping) *NativeLogsCSVWriter

+ func (w *NativeLogsCSVWriter) Bytes() []byte

+ func (w *NativeLogsCSVWriter) InitColumns(columns []string)

+ func (w *NativeLogsCSVWriter) MarshalNativeLog(log *types.Log) error

+ func (w *NativeLogsCSVWriter) Reset()

+ func (w *NativeLogsCSVWriter) SchemaHash() uint64

+ type RequestTransformer struct

+ AddLabels map[string]string

+ AllowedDatabase map[string]struct{}

+ DefaultDropMetrics bool

+ DropLabels map[*regexp.Regexp]*regexp.Regexp

+ DropMetrics []*regexp.Regexp

+ KeepMetrics []*regexp.Regexp

+ KeepMetricsWithLabelValue map[*regexp.Regexp]*regexp.Regexp

+ func (f *RequestTransformer) ShouldDropMetric(v *prompb.TimeSeries, name []byte) bool

+ func (f *RequestTransformer) TransformTimeSeries(v *prompb.TimeSeries) *prompb.TimeSeries

+ func (f *RequestTransformer) TransformWriteRequest(req *prompb.WriteRequest) *prompb.WriteRequest