collector

package
v1.19.2 Latest Latest
Warning

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

 Go to latest Published: Aug 26, 2026 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	QueryDetailsCollector      = "query_details"
	OP_QUERY_ASSOCIATION       = "query_association"
	OP_QUERY_PARSED_TABLE_NAME = "query_parsed_table_name"
)
View Source 
const (
	SchemaDetailsCollector = "schema_details"
	OP_TABLE_DETECTION     = "table_detection"
	OP_CREATE_STATEMENT    = "create_statement"
)
View Source 
const ConnectionInfoName = "connection_info"
View Source 
const QueryMetricsCollector = "query_metrics"

Variables

This section is empty.

Functions

This section is empty.

Types

type ConnectionInfo 

type ConnectionInfo struct {
	DSN           string
	Registry      *prometheus.Registry
	EngineVersion string
	InfoMetric    *prometheus.GaugeVec
	CloudProvider *database_observability.CloudProvider
	// contains filtered or unexported fields
}

func NewConnectionInfo 

func NewConnectionInfo(args ConnectionInfoArguments) (*ConnectionInfo, error)

func (*ConnectionInfo) Name 

func (c *ConnectionInfo) Name() string

func (*ConnectionInfo) Start 

func (c *ConnectionInfo) Start(ctx context.Context) error

func (*ConnectionInfo) Stop 

func (c *ConnectionInfo) Stop()

func (*ConnectionInfo) Stopped 

func (c *ConnectionInfo) Stopped() bool

type ConnectionInfoArguments 

type ConnectionInfoArguments struct {
	DSN           string
	Registry      *prometheus.Registry
	EngineVersion string
	CloudProvider *database_observability.CloudProvider
	DB            *sql.DB
}

type QueryDetails added in v1.19.0 

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

func NewQueryDetails added in v1.19.0 

func NewQueryDetails(args QueryDetailsArguments) (*QueryDetails, error)

func (*QueryDetails) Name added in v1.19.0 

func (c *QueryDetails) Name() string

func (*QueryDetails) Start added in v1.19.0 

func (c *QueryDetails) Start(ctx context.Context) error

func (*QueryDetails) Stop added in v1.19.0 

func (c *QueryDetails) Stop()

func (*QueryDetails) Stopped added in v1.19.0 

func (c *QueryDetails) Stopped() bool

type QueryDetailsArguments added in v1.19.0 

type QueryDetailsArguments struct {
	DB              *sql.DB
	CollectInterval time.Duration
	Tracker         QueryTracker
	EntryHandler    loki.EntryHandler

	Logger *slog.Logger
}

type QueryMetrics added in v1.19.0 

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

func NewQueryMetrics added in v1.19.0 

func NewQueryMetrics(args QueryMetricsArguments) (*QueryMetrics, error)

func (*QueryMetrics) Name added in v1.19.0 

func (c *QueryMetrics) Name() string

func (*QueryMetrics) Start added in v1.19.0 

func (c *QueryMetrics) Start(ctx context.Context) error

func (*QueryMetrics) Stop added in v1.19.0 

func (c *QueryMetrics) Stop()

func (*QueryMetrics) Stopped added in v1.19.0 

func (c *QueryMetrics) Stopped() bool

func (*QueryMetrics) Tracker added in v1.19.0 

func (c *QueryMetrics) Tracker() QueryTracker

Tracker exposes the collector's query-tracking state so other collectors (e.g. query_details) can restrict their work to the query_hashes that are currently tracked here. The returned value is safe for concurrent use and remains valid across collector restarts.

type QueryMetricsArguments added in v1.19.0 

type QueryMetricsArguments struct {
	DB              *sql.DB
	Registry        *prometheus.Registry
	CollectInterval time.Duration
	Limit           int
	Lookback        time.Duration
	Logger          *slog.Logger
}

type QueryTracker added in v1.19.0 

type QueryTracker interface {
	GetQueryHashes(database string) []string
}

QueryTracker reports which (database, query_hash) pairs are currently tracked by the query_metrics collector.

type SchemaDetails 

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

func NewSchemaDetails 

func NewSchemaDetails(args SchemaDetailsArguments) (*SchemaDetails, error)

func (*SchemaDetails) Name 

func (c *SchemaDetails) Name() string

func (*SchemaDetails) Start 

func (c *SchemaDetails) Start(ctx context.Context) error

func (*SchemaDetails) Stop 

func (c *SchemaDetails) Stop()

func (*SchemaDetails) Stopped 

func (c *SchemaDetails) Stopped() bool

type SchemaDetailsArguments 

type SchemaDetailsArguments struct {
	DB               *sql.DB
	CollectInterval  time.Duration
	ExcludeSchemas   []string
	ExcludeDatabases []string
	EntryHandler     loki.EntryHandler

	Logger *slog.Logger
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.