mirror of
https://github.com/hanzoai/otel-collector.git
synced 2026-11-03 02:20:04 +00:00
zeekay
2c424150e8
The rebrand renamed ClickHouse databases (signoz_traces → o11y_traces etc.) but existing production databases still use signoz_* names. Revert to avoid breaking data access.
62 lines
1.8 KiB
Go
62 lines
1.8 KiB
Go
package o11ydatastoremeter
|
|
|
|
import (
|
|
"context"
|
|
"errors"
|
|
|
|
internalmetadata "github.com/hanzoai/otel-collector/exporter/o11ydatastoremeter/internal/metadata"
|
|
"go.opentelemetry.io/collector/component"
|
|
"go.opentelemetry.io/collector/config/configoptional"
|
|
"go.opentelemetry.io/collector/config/configretry"
|
|
"go.opentelemetry.io/collector/exporter"
|
|
"go.opentelemetry.io/collector/exporter/exporterhelper"
|
|
)
|
|
|
|
// NewFactory creates a new ClickHouse Meter Metrics exporter.
|
|
func NewFactory() exporter.Factory {
|
|
return exporter.NewFactory(
|
|
internalmetadata.Type,
|
|
createDefaultConfig,
|
|
exporter.WithMetrics(createMeterMetricsExporter, internalmetadata.MetricsStability))
|
|
}
|
|
|
|
func createMeterMetricsExporter(ctx context.Context, params exporter.Settings, cfg component.Config) (exporter.Metrics, error) {
|
|
chCfg, ok := cfg.(*Config)
|
|
if !ok {
|
|
return nil, errors.New("invalid configuration")
|
|
}
|
|
|
|
chExporter, err := NewClickHouseExporter(params.Logger, cfg)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
exporter, err := exporterhelper.NewMetrics(
|
|
ctx,
|
|
params,
|
|
cfg,
|
|
chExporter.ConsumeMetrics,
|
|
exporterhelper.WithTimeout(chCfg.TimeoutConfig),
|
|
exporterhelper.WithQueue(chCfg.QueueBatchConfig),
|
|
exporterhelper.WithRetry(chCfg.BackOffConfig),
|
|
exporterhelper.WithStart(chExporter.Start),
|
|
exporterhelper.WithShutdown(chExporter.Shutdown),
|
|
)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
return exporter, nil
|
|
}
|
|
|
|
func createDefaultConfig() component.Config {
|
|
return &Config{
|
|
TimeoutConfig: exporterhelper.NewDefaultTimeoutConfig(),
|
|
BackOffConfig: configretry.NewDefaultBackOffConfig(),
|
|
QueueBatchConfig: configoptional.Some(exporterhelper.NewDefaultQueueConfig()),
|
|
DSN: "tcp://localhost:9000",
|
|
Database: "signoz_meter",
|
|
SamplesTable: "distributed_samples",
|
|
}
|
|
}
|