Versions in this module Expand all Collapse all v0 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
Go to main page