Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
- API
  
  Reference documentation for the pkg.go.dev API
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

querymetrics

package

Go to main page

Versions in this module

v0

v0.1.3

Jul 27, 2026

Changes in this version

+ const CollectorVersionAttribute

+ const DatabaseSystemAttribute

+ const MaxQueryTextBytes

+ const ServiceNameAttribute

+ func LimitQueryText(queryText string) string

+ func NewResourceLogsConsumer(next consumer.Logs, databaseSystem string, serviceName string, ...) consumer.Logs

+ func NewResourceMetricsConsumer(next consumer.Metrics, databaseSystem string, serviceName string, ...) consumer.Metrics

+ func SetDatabaseResourceAttributes(attributes pcommon.Map, databaseSystem string, serviceName string, ...)

+ func ValidateCandidateLimit(limit, candidateLimit, maximum int) error

type Config

+ ExplainPlans ExplainPlansConfig

+ type ExplainPlansConfig struct

+ CacheSize int

+ CacheTTL time.Duration

+ CollectionInterval time.Duration

+ CollectionTimeout time.Duration

+ Enabled bool

+ FailureCacheTTL time.Duration

+ MaxPerInterval int

+ MaxPlanBytes int

+ QueryTimeout time.Duration

+ func (c ExplainPlansConfig) Validate() error

+ type Snapshot struct

+ CollectedAt time.Time

+ Rows []T

+ type SnapshotStore struct

+ func NewSnapshotStore[T any]() *SnapshotStore[T]

+ func (*SnapshotStore[T]) Shutdown(context.Context) error

+ func (*SnapshotStore[T]) Start(context.Context, component.Host) error

+ func (s *SnapshotStore[T]) Load() Snapshot[T]

+ func (s *SnapshotStore[T]) Publish(rows []T, collectedAt time.Time)

v0.1.2

Jul 13, 2026

Changes in this version

+ const AgentVersionAttribute

+ func AddAgentVersion(metrics pmetric.Metrics, version string) pmetric.Metrics

v0.1.0

Jul 12, 2026

Changes in this version

+ const DefaultLimit

+ func SQLSignature(normalizedQuery string) string

+ type Config struct

+ Enabled bool

+ Limit int

+ func DefaultConfig() Config

+ func (c Config) Validate() error