mirror of
https://github.com/hanzoai/traces.git
synced 2026-10-30 18:20:41 +00:00
JaviandGitHub
5ba6c3c285
* update otel * update otel-collector-contrib * rollback upgrade of jaegerreceiver and kafkareceiver * fix go.sum * update opentelemetry-collector-contrib and jaegertracing * fix factory initialization * fix e2e * use the new jaeger definitions * fix factory initialization for otelexporter * use proper prefix * fix metric matcher for integration tests * changelog
55 lines
2.1 KiB
Go
55 lines
2.1 KiB
Go
package tempo
|
|
|
|
import (
|
|
"github.com/grafana/dskit/crypto/tls"
|
|
"github.com/spf13/viper"
|
|
)
|
|
|
|
// BearerTokenKey is the key name for the bearer token context value.
|
|
const bearerTokenKey = "bearer.token"
|
|
|
|
// Config holds the configuration for redbull.
|
|
type Config struct {
|
|
Address string `yaml:"address"`
|
|
Backend string `yaml:"backend"`
|
|
// TLSEnabled enables tls outgoing requests from tempo-query to tempo.
|
|
TLSEnabled bool `yaml:"tls_enabled" category:"advanced"`
|
|
// TLSServerEnabeld enables tls for incoming requests to the tempo-query API.
|
|
TLSServerEnabeld bool `yaml:"tls_server_enabled" category:"advanced"`
|
|
TLS tls.ClientConfig `yaml:",inline"`
|
|
TenantHeaderKey string `yaml:"tenant_header_key"`
|
|
QueryServicesDuration string `yaml:"services_query_duration"`
|
|
// FindTracesConcurrentRequests defines how many concurrent requests trace search submits to get a trace.
|
|
FindTracesConcurrentRequests int `yaml:"find_traces_concurrent_requests"`
|
|
}
|
|
|
|
// InitFromViper initializes the options struct with values from Viper
|
|
func (c *Config) InitFromViper(v *viper.Viper) {
|
|
address := v.GetString("address")
|
|
if address == "" {
|
|
address = "0.0.0.0:7777"
|
|
}
|
|
c.Address = address
|
|
c.Backend = v.GetString("backend")
|
|
c.TLSEnabled = v.GetBool("tls_enabled")
|
|
c.TLSServerEnabeld = v.GetBool("tls_server_enabled")
|
|
c.TLS.CertPath = v.GetString("tls_cert_path")
|
|
c.TLS.KeyPath = v.GetString("tls_key_path")
|
|
c.TLS.CAPath = v.GetString("tls_ca_path")
|
|
c.TLS.ServerName = v.GetString("tls_server_name")
|
|
c.TLS.InsecureSkipVerify = v.GetBool("tls_insecure_skip_verify")
|
|
c.TLS.CipherSuites = v.GetString("tls_cipher_suites")
|
|
c.TLS.MinVersion = v.GetString("tls_min_version")
|
|
c.QueryServicesDuration = v.GetString("services_query_duration")
|
|
c.FindTracesConcurrentRequests = v.GetInt("find_traces_concurrent_requests")
|
|
|
|
if c.FindTracesConcurrentRequests == 0 {
|
|
c.FindTracesConcurrentRequests = 1
|
|
}
|
|
tenantHeader := v.GetString("tenant_header_key")
|
|
if tenantHeader == "" {
|
|
tenantHeader = bearerTokenKey
|
|
}
|
|
c.TenantHeaderKey = tenantHeader
|
|
}
|