[v2][feat] Introduce ClickHouse connection configuration

cmd/jaeger/config-clickhouse.yaml

@@ -0,0 +1,60 @@
+service:
+  extensions: [jaeger_storage, jaeger_query, healthcheckv2]
+  pipelines:
+    traces:
+      receivers: [otlp]
+      processors: [batch]
+      exporters: [jaeger_storage_exporter]
+  telemetry:
+    resource:
+      service.name: jaeger
+    metrics:
+      level: detailed
+      address: 0.0.0.0:8888
+    logs:
+      level: debug
+    # TODO Initialize telemetry tracer once OTEL released new feature.
+    # https://github.com/open-telemetry/opentelemetry-collector/issues/10663
+
+extensions:
+  healthcheckv2:
+    use_v2: true
+    http:
+
+  jaeger_query:
+    storage:
+      traces: some_storage
+      traces_archive: another_storage
+    ui:
+      config_file: ./cmd/jaeger/config-ui.json
+
+  jaeger_storage:
+    backends:
+      some_storage:
+        clickhouse:
+          connection:
+            addresses: "127.0.0.1:9000"
+            auth:
+              database: "jeager"
+              username: "default"
+              password: ""
+
+receivers:
+  otlp:
+    protocols:
+      grpc:
+      http:
+
+  jaeger:
+    protocols:
+      grpc:
+      thrift_binary:
+      thrift_compact:
+      thrift_http:
+
+processors:
+  batch:
+
+exporters:
+  jaeger_storage_exporter:
+    trace_storage: some_storage

cmd/jaeger/internal/extension/jaegerstorage/config.go

@@ -18,6 +18,7 @@ import (
 	"github.com/jaegertracing/jaeger/internal/storage/v1/grpc"
 	"github.com/jaegertracing/jaeger/internal/storage/v1/memory"
 	casCfg "github.com/jaegertracing/jaeger/pkg/cassandra/config"
+	chCfg "github.com/jaegertracing/jaeger/pkg/clickhouse/config"
 	esCfg "github.com/jaegertracing/jaeger/pkg/es/config"
 	promCfg "github.com/jaegertracing/jaeger/pkg/prometheus/config"
 	"github.com/jaegertracing/jaeger/plugin/metricstore/prometheus"
@@ -47,6 +48,7 @@ type TraceBackend struct {
 	Cassandra     *cassandra.Options    `mapstructure:"cassandra"`
 	Elasticsearch *esCfg.Configuration  `mapstructure:"elasticsearch"`
 	Opensearch    *esCfg.Configuration  `mapstructure:"opensearch"`
+	Clickhouse    *chCfg.Configuration  `mapstructure:"clickhouse"`
 }
 
 // MetricBackend contains configuration for a single metric storage backend.
@@ -94,6 +96,10 @@ func (cfg *TraceBackend) Unmarshal(conf *confmap.Conf) error {
 		v := es.DefaultConfig()
 		cfg.Opensearch = &v
 	}
+	if conf.IsSet("clickhouse") {
+		v := chCfg.DefaultConfiguration()
+		cfg.Clickhouse = &v
+	}
 	return conf.Unmarshal(cfg)
 }
 

cmd/jaeger/internal/extension/jaegerstorage/config_test.go

@@ -108,6 +108,17 @@ backends:
 	assert.NotEmpty(t, cfg.TraceBackends["some_storage"].Opensearch.Servers)
 }
 
+func TestConfigDefaultClickhouse(t *testing.T) {
+	conf := loadConf(t, `
+backends:
+  some_storage:
+    clickhouse:
+`)
+	cfg := createDefaultConfig().(*Config)
+	require.NoError(t, conf.Unmarshal(cfg))
+	assert.NotEmpty(t, cfg.TraceBackends["some_storage"].Clickhouse)
+}
+
 func TestConfigDefaultPrometheus(t *testing.T) {
 	conf := loadConf(t, `
 metric_backends:

cmd/jaeger/internal/extension/jaegerstorage/extension.go

@@ -166,6 +166,8 @@
 				scopedMetricsFactory(storageName, "opensearch", "tracestore"),
 				s.telset.Logger,
 			)
+		case cfg.Clickhouse != nil:
+			// TODO new clickhouse factory with config.
 		}
 		if err != nil {
 			return fmt.Errorf("failed to initialize storage '%s': %w", storageName, err)

pkg/clickhouse/config/config.go

@@ -0,0 +1,75 @@
+// Copyright (c) 2025 The Jaeger Authors.
+// SPDX-License-Identifier: Apache-2.0
+
+package config
+
+import (
+	"crypto/tls"
+	"time"
+
+	"go.opentelemetry.io/collector/config/configopaque"
+)
+
+const (
+	dialTimeout     = 10 * time.Second
+	connMaxLifetime = 10 * time.Minute
+
+	maxOpenConns          = 5
+	maxIdleConns          = 5
+	blockBufferSize uint8 = 10
+)
+
+// Configuration describes the configuration properties needed to connect to an ElasticSearch cluster
+type Configuration struct {
+	Connection Connection `mapstructure:"connection"`
+}
+
+// Connection More details see: https://clickhouse.com/docs/en/integrations/go#connecting
+type Connection struct {
+	// Addresses A slice of addresses including port.
+	Addresses []string `mapstructure:"addresses"`
+	// Auth Specify an auth struct in the connection details to specify a username and password.
+	Auth Authentication `mapstructure:"auth"`
+	// TLS options. A non-nil value enables TLS.
+	TLS *tls.Config `mapstructure:"tls"`
+	// DialTimeout the maximum time to establish a connection.
+	DialTimeout time.Duration `mapstructure:"dial_timeout"`
+	// MaxOpenConns max connections for use at any time. More or fewer connections may be in the idle pool,
+	// but only this number can be used at any time.
+	MaxOpenConns int `mapstructure:"max_open_conns"`
+	// MaxIdleConns number of connections to maintain in the pool. Connections will be reused if possible.
+	MaxIdleConns int `mapstructure:"max_idle_conns"`
+	// ConnMaxLifetime maximum lifetime to keep a connection available. Connections are destroyed after this time,
+	// with new connections added to the pool as required.
+	ConnMaxLifetime time.Duration `mapstructure:"conn_max_lifetime"`
+	// BlockBufferSize maximum number of blocks to decode into the buffer at once.
+	// larger values will increase parallelization at the expense of memory.
+	// block sizes are query dependent so while you can set this on the connection,
+	BlockBufferSize uint8 `mapstructure:"block_buffer_size"`
+}
+
+type Authentication struct {
+	Database string              `mapstructure:"database"`
+	Username string              `mapstructure:"username"`
+	Password configopaque.String `mapstructure:"password"`
+}
+
+func DefaultConfiguration() Configuration {
+	return Configuration{
+		Connection: Connection{
+			Addresses: []string{"127.0.0.1:9000"},
+			Auth: Authentication{
+				Database: "jeager",
+				Username: "default",
+				Password: "",
+			},
+			//nolint: gosec // G402
+			TLS:             &tls.Config{InsecureSkipVerify: true},
+			DialTimeout:     dialTimeout,
+			MaxOpenConns:    maxOpenConns,
+			MaxIdleConns:    maxIdleConns,
+			ConnMaxLifetime: connMaxLifetime,
+			BlockBufferSize: blockBufferSize,
+		},
+	}
+}

pkg/clickhouse/config/config_test.go

@@ -0,0 +1,32 @@
+// Copyright (c) 2025 The Jaeger Authors.
+// SPDX-License-Identifier: Apache-2.0
+
+package config
+
+import (
+	"testing"
+	"time"
+
+	"github.com/stretchr/testify/assert"
+	"go.opentelemetry.io/collector/config/configopaque"
+
+	"github.com/jaegertracing/jaeger/pkg/testutils"
+)
+
+func TestDefaultConfiguration(t *testing.T) {
+	cfg := DefaultConfiguration()
+	conn := cfg.Connection
+	assert.Equal(t, []string{"127.0.0.1:9000"}, conn.Addresses)
+	assert.Equal(t, "jeager", conn.Auth.Database)
+	assert.Equal(t, "default", conn.Auth.Username)
+	assert.Equal(t, configopaque.String(""), conn.Auth.Password)
+	assert.Equal(t, 10*time.Second, conn.DialTimeout)
+	assert.Equal(t, 5, conn.MaxOpenConns)
+	assert.Equal(t, 5, conn.MaxIdleConns)
+	assert.Equal(t, 10*time.Minute, conn.ConnMaxLifetime)
+	assert.Equal(t, uint8(10), conn.BlockBufferSize)
+}
+
+func TestMain(m *testing.M) {
+	testutils.VerifyGoLeaks(m)
+}