@@ -23,6 +23,8 @@ import (
2323 "github.com/paypal/hera/cal"
2424 "github.com/paypal/hera/config"
2525 "github.com/paypal/hera/utility/logger"
26+ otelconfig "github.com/paypal/hera/utility/logger/otel/config"
27+
2628 "os"
2729 "path/filepath"
2830 "strings"
@@ -236,7 +238,7 @@ func parseMapStrStr(encoded string) map[string]string {
236238}
237239
238240// InitConfig initializes the configuration, both the static configuration (from hera.txt) and the dynamic configuration
239- func InitConfig () error {
241+ func InitConfig (poolName string ) error {
240242 currentDir , abserr := filepath .Abs (filepath .Dir (os .Args [0 ]))
241243
242244 if abserr != nil {
@@ -488,9 +490,39 @@ func InitConfig() error {
488490 gAppConfig .MaxDesiredHealthyWorkerPct = 90
489491 }
490492
493+ //Initialize OTEL configs
494+ initializeOTELConfigs (cdb , poolName )
495+ if logger .GetLogger ().V (logger .Info ) {
496+ otelconfig .OTelConfigData .Dump ()
497+ }
491498 return nil
492499}
493500
501+ // This function takes care of initialize OTEL configuration
502+ func initializeOTELConfigs (cdb config.Config , poolName string ) {
503+ otelconfig .OTelConfigData = & otelconfig.OTelConfig {}
504+ //TODO initialize the values
505+ otelconfig .OTelConfigData .Enabled = cdb .GetOrDefaultBool ("enable_otel" , false )
506+ otelconfig .OTelConfigData .SkipCalStateLog = cdb .GetOrDefaultBool ("skip_cal_statelog" , false )
507+ otelconfig .OTelConfigData .MetricNamePrefix = cdb .GetOrDefaultString ("otel_metric_prefix" , "pp.occ" )
508+ otelconfig .OTelConfigData .Host = cdb .GetOrDefaultString ("otel_agent_host" , "localhost" )
509+ otelconfig .OTelConfigData .MetricsPort = cdb .GetOrDefaultInt ("otel_agent_metrics_port" , 4318 )
510+ otelconfig .OTelConfigData .TracePort = cdb .GetOrDefaultInt ("otel_agent_trace_port" , 4318 )
511+ otelconfig .OTelConfigData .OtelMetricGRPC = cdb .GetOrDefaultBool ("otel_agent_use_grpc_metric" , false )
512+ otelconfig .OTelConfigData .OtelTraceGRPC = cdb .GetOrDefaultBool ("otel_agent_use_grpc_trace" , false )
513+ otelconfig .OTelConfigData .MetricsURLPath = cdb .GetOrDefaultString ("otel_agent_metrics_uri" , "" )
514+ otelconfig .OTelConfigData .TraceURLPath = cdb .GetOrDefaultString ("otel_agent_trace_uri" , "" )
515+ otelconfig .OTelConfigData .PoolName = poolName
516+ otelconfig .OTelConfigData .UseTls = cdb .GetOrDefaultBool ("otel_use_tls" , false )
517+ otelconfig .OTelConfigData .TLSCertPath = cdb .GetOrDefaultString ("otel_tls_cert_path" , "" )
518+ otelconfig .OTelConfigData .ResolutionTimeInSec = cdb .GetOrDefaultInt ("otel_resolution_time_in_sec" , 1 )
519+ otelconfig .OTelConfigData .ExporterTimeout = cdb .GetOrDefaultInt ("otel_exporter_time_in_sec" , 30 )
520+ otelconfig .OTelConfigData .EnableRetry = cdb .GetOrDefaultBool ("otel_enable_exporter_retry" , false )
521+ otelconfig .OTelConfigData .ResourceType = gAppConfig .StateLogPrefix
522+ otelconfig .OTelConfigData .OTelErrorReportingInterval = cdb .GetOrDefaultInt ("otel_error_reporting_interval_in_sec" , 60 )
523+ otelconfig .SetOTelIngestToken (cdb .GetOrDefaultString ("otel_ingest_token" , "" ))
524+ }
525+
494526func LogOccConfigs () {
495527 whiteListConfigs := map [string ]map [string ]interface {}{
496528 "BACKLOG" : {
@@ -503,6 +535,18 @@ func LogOccConfigs() {
503535 "bouncer_startup_delay" : gAppConfig .BouncerStartupDelay ,
504536 "bouncer_poll_interval_ms" : gAppConfig .BouncerPollInterval ,
505537 },
538+ "OTEL" : {
539+ "enable_otel" : otelconfig .OTelConfigData .Enabled ,
540+ "otel_use_tls" : otelconfig .OTelConfigData .UseTls ,
541+ "skip_cal_statelog" : otelconfig .OTelConfigData .SkipCalStateLog ,
542+ "otel_agent_host" : otelconfig .OTelConfigData .Host ,
543+ "otel_agent_metrics_port" : otelconfig .OTelConfigData .MetricsPort ,
544+ "otel_agent_trace_port" : otelconfig .OTelConfigData .TracePort ,
545+ "otel_agent_metrics_uri" : otelconfig .OTelConfigData .MetricsURLPath ,
546+ "otel_agent_trace_uri" : otelconfig .OTelConfigData .TraceURLPath ,
547+ "otel_resolution_time_in_sec" : otelconfig .OTelConfigData .ResolutionTimeInSec ,
548+ "otel_error_reporting_interval_in_sec" : otelconfig .OTelConfigData .OTelErrorReportingInterval ,
549+ },
506550 "PROFILE" : {
507551 "enable_profile" : gAppConfig .EnableProfile ,
508552 "profile_http_port" : gAppConfig .ProfileHTTPPort ,
@@ -618,6 +662,10 @@ func LogOccConfigs() {
618662 if ! gAppConfig .BouncerEnabled {
619663 continue
620664 }
665+ case "OTEL" :
666+ if ! otelconfig .OTelConfigData .Enabled {
667+ continue
668+ }
621669 case "PROFILE" :
622670 if ! gAppConfig .EnableProfile {
623671 continue
@@ -679,7 +727,6 @@ func LogOccConfigs() {
679727 }
680728 evt .Completed ()
681729 }
682-
683730}
684731
685732// CheckOpsConfigChange checks if the ops config file needs to be reloaded and reloads it if necessary.
0 commit comments