oteldatabasesql

package
v0.0.0-...-e8ceb3a Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 27, 2026 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var DBClientConnectionCount = mustInt64ObservableGauge(
	(dbconv.ClientConnectionCount{}).Name(),
	metric.WithDescription((dbconv.ClientConnectionCount{}).Description()),
	metric.WithUnit((dbconv.ClientConnectionCount{}).Unit()),
)

DBClientConnectionCount is https://opentelemetry.io/docs/specs/semconv/database/database-metrics/#metric-dbclientconnectioncount

View Source
var DBClientConnectionCreateTimeHistogram, _ = dbconv.NewClientConnectionCreateTime(
	meter,

	metric.WithExplicitBucketBoundaries(
		0.005,
		0.01,
		0.025,
		0.05,
		0.075,
		0.1,
		0.25,
		0.5,
		0.75,
		1,
		2.5,
		5,
		7.5,
		10,
	),
)

DBClientConnectionCreateTimeHistogram is https://opentelemetry.io/docs/specs/semconv/database/database-metrics/#metric-dbclientconnectioncreate_time

View Source
var DBClientConnectionIdleMax = mustInt64ObservableGauge(
	(dbconv.ClientConnectionIdleMax{}).Name(),
	metric.WithDescription((dbconv.ClientConnectionIdleMax{}).Description()),
	metric.WithUnit((dbconv.ClientConnectionIdleMax{}).Unit()),
)

DBClientConnectionIdleMax is https://opentelemetry.io/docs/specs/semconv/database/database-metrics/#metric-dbclientconnectionidlemax

View Source
var DBClientConnectionMax = mustInt64ObservableGauge(
	(dbconv.ClientConnectionMax{}).Name(),
	metric.WithDescription((dbconv.ClientConnectionMax{}).Description()),
	metric.WithUnit((dbconv.ClientConnectionMax{}).Unit()),
)

DBClientConnectionMax is https://opentelemetry.io/docs/specs/semconv/database/database-metrics/#metric-dbclientconnectionmax

View Source
var DBClientConnectionUseTimeHistogram, _ = dbconv.NewClientConnectionUseTime(
	meter,

	metric.WithExplicitBucketBoundaries(
		0.005,
		0.01,
		0.025,
		0.05,
		0.075,
		0.1,
		0.25,
		0.5,
		0.75,
		1,
		2.5,
		5,
		7.5,
		10,
	),
)

DBClientConnectionUseTimeHistogram is https://opentelemetry.io/docs/specs/semconv/database/database-metrics/#metric-dbclientconnectionuse_time

View Source
var DBClientConnectionWaitTimeHistogram, _ = dbconv.NewClientConnectionWaitTime(
	meter,

	metric.WithExplicitBucketBoundaries(
		0.005,
		0.01,
		0.025,
		0.05,
		0.075,
		0.1,
		0.25,
		0.5,
		0.75,
		1,
		2.5,
		5,
		7.5,
		10,
	),
)

DBClientConnectionWaitTimeHistogram is https://opentelemetry.io/docs/specs/semconv/database/database-metrics/#metric-dbclientconnectionwait_time

View Source
var DBClientOperationDurationHistogram, _ = dbconv.NewClientOperationDuration(
	meter,
	metric.WithExplicitBucketBoundaries(
		0.001,
		0.005,
		0.01,
		0.05,
		0.1,
		0.5,
		1,
		5,
		10,
	),
)

DBClientOperationDurationHistogram is https://opentelemetry.io/docs/specs/semconv/database/database-metrics/#metric-dbclientoperationduration

Functions

This section is empty.

Types

type Conn

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

Conn is a wrapper around *sql.Conn. Conn is used to track connection use time.

func (*Conn) BeginTx

func (c *Conn) BeginTx(ctx context.Context, opts *sql.TxOptions) (*sql.Tx, error)

func (*Conn) Close

func (c *Conn) Close() error

func (*Conn) PrepareContext

func (c *Conn) PrepareContext(ctx context.Context, query string) (*sql.Stmt, error)

type ConnPool

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

ConnPool is a wrapper around *sql.DB. ConnPool only supports Conn() which returns a wrapped *sql.Conn. ConnPool is used to track connection wait time.

func (*ConnPool) Close

func (p *ConnPool) Close() error

func (*ConnPool) Conn

func (p *ConnPool) Conn(ctx context.Context) (Conn_, error)

func (*ConnPool) SetConnMaxIdleTime

func (p *ConnPool) SetConnMaxIdleTime(d time.Duration)

func (*ConnPool) SetConnMaxLifetime

func (p *ConnPool) SetConnMaxLifetime(d time.Duration)

func (*ConnPool) SetMaxIdleConns

func (p *ConnPool) SetMaxIdleConns(n int)

func (*ConnPool) SetMaxOpenConns

func (p *ConnPool) SetMaxOpenConns(n int)

type ConnPool_

type ConnPool_ interface {
	Conn(ctx context.Context) (Conn_, error)
	Close() error
	SetConnMaxIdleTime(d time.Duration)
	SetConnMaxLifetime(d time.Duration)
	SetMaxIdleConns(n int)
	SetMaxOpenConns(n int)
}

func Open

func Open(opts OpenOptions) (ConnPool_, error)

type Conn_

type Conn_ interface {
	BeginTx(ctx context.Context, opts *sql.TxOptions) (*sql.Tx, error)
	PrepareContext(ctx context.Context, query string) (*sql.Stmt, error)
	Close() error
}

type OpenOptions

type OpenOptions struct {
	DriverName string
	DSN        string
	PoolName   string
	IdleMax    int
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL