mirror of
https://github.com/hanzo-fi/stack.git
synced 2026-10-30 20:34:43 +00:00
1641c3c852
Co-authored-by: Antoine Wacheux <[email protected]> Co-authored-by: Maxence Maireaux <[email protected]> Co-authored-by: Brieuc Caillot <[email protected]>
55 lines
2.5 KiB
Go
55 lines
2.5 KiB
Go
package otlpmetrics
|
|
|
|
import (
|
|
"time"
|
|
|
|
"github.com/formancehq/stack/libs/go-libs/otlp"
|
|
flag "github.com/spf13/pflag"
|
|
"github.com/spf13/viper"
|
|
"go.uber.org/fx"
|
|
)
|
|
|
|
const (
|
|
OtelMetricsFlag = "otel-metrics"
|
|
OtelMetricsExporterPushIntervalFlag = "otel-metrics-exporter-push-interval"
|
|
OtelMetricsRuntimeFlag = "otel-metrics-runtime"
|
|
OtelMetricsRuntimeMinimumReadMemStatsIntervalFlag = "otel-metrics-runtime-minimum-read-mem-stats-interval"
|
|
OtelMetricsExporterFlag = "otel-metrics-exporter"
|
|
OtelMetricsExporterOTLPModeFlag = "otel-metrics-exporter-otlp-mode"
|
|
OtelMetricsExporterOTLPEndpointFlag = "otel-metrics-exporter-otlp-endpoint"
|
|
OtelMetricsExporterOTLPInsecureFlag = "otel-metrics-exporter-otlp-insecure"
|
|
)
|
|
|
|
func InitOTLPMetricsFlags(flags *flag.FlagSet) {
|
|
otlp.InitOTLPFlags(flags)
|
|
|
|
flags.Bool(OtelMetricsFlag, false, "Enable OpenTelemetry traces support")
|
|
flags.Duration(OtelMetricsExporterPushIntervalFlag, 10*time.Second, "OpenTelemetry metrics exporter push interval")
|
|
flags.Bool(OtelMetricsRuntimeFlag, false, "Enable OpenTelemetry runtime metrics")
|
|
flags.Duration(OtelMetricsRuntimeMinimumReadMemStatsIntervalFlag, 15*time.Second, "OpenTelemetry runtime metrics minimum read mem stats interval")
|
|
flags.String(OtelMetricsExporterFlag, "stdout", "OpenTelemetry metrics exporter")
|
|
flags.String(OtelMetricsExporterOTLPModeFlag, "grpc", "OpenTelemetry traces OTLP exporter mode (grpc|http)")
|
|
flags.String(OtelMetricsExporterOTLPEndpointFlag, "", "OpenTelemetry traces grpc endpoint")
|
|
flags.Bool(OtelMetricsExporterOTLPInsecureFlag, false, "OpenTelemetry traces grpc insecure")
|
|
}
|
|
|
|
func CLIMetricsModule(v *viper.Viper) fx.Option {
|
|
if v.GetBool(OtelMetricsFlag) {
|
|
return MetricsModule(ModuleConfig{
|
|
ServiceName: v.GetString(otlp.OtelServiceName),
|
|
ServiceVersion: "develop",
|
|
OTLPConfig: &OTLPConfig{
|
|
Mode: v.GetString(OtelMetricsExporterOTLPModeFlag),
|
|
Endpoint: v.GetString(OtelMetricsExporterOTLPEndpointFlag),
|
|
Insecure: v.GetBool(OtelMetricsExporterOTLPInsecureFlag),
|
|
},
|
|
Exporter: v.GetString(OtelMetricsExporterFlag),
|
|
RuntimeMetrics: v.GetBool(OtelMetricsRuntimeFlag),
|
|
MinimumReadMemStatsInterval: v.GetDuration(OtelMetricsRuntimeMinimumReadMemStatsIntervalFlag),
|
|
PushInterval: v.GetDuration(OtelMetricsExporterPushIntervalFlag),
|
|
ResourceAttributes: v.GetStringSlice(otlp.OtelResourceAttributes),
|
|
})
|
|
}
|
|
return fx.Options()
|
|
}
|