clickhouseotel

package

v1.0.0-beta.227 Latest Latest Go to latest Published: Feb 12, 2026 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation ¶

This section is empty.

This section is empty.

func NewClickHouseTracer(cfg ClickHouseTracerConfig) (clickhouse.Conn, error)

type ClickHouseTracer struct {
	clickhouse.Conn

	Tracer trace.Tracer
}

func (c *ClickHouseTracer) AsyncInsert(ctx context.Context, query string, wait bool, args ...any) error

func (c *ClickHouseTracer) Exec(ctx context.Context, query string, args ...any) error

func (c *ClickHouseTracer) Query(ctx context.Context, query string, args ...any) (rows driver.Rows, err error)

func (c *ClickHouseTracer) QueryRow(ctx context.Context, query string, args ...any) driver.Row

type ClickHouseTracerConfig struct {
	Tracer trace.Tracer
	Conn   clickhouse.Conn
}

func (c ClickHouseTracerConfig) Validate() error

type ConnPoolMetrics struct {
	// contains filtered or unexported fields
}

func NewConnPoolMetrics(cfg ConnPoolMetricsConfig) (*ConnPoolMetrics, error)

func (m *ConnPoolMetrics) Shutdown() error

func (m *ConnPoolMetrics) Start(ctx context.Context) error

type ConnPoolMetricsConfig struct {
	Conn         clickhouse.Conn
	Meter        metric.Meter
	Logger       *slog.Logger
	PollInterval time.Duration
}

func (c ConnPoolMetricsConfig) Validate() error