collector

package
v1.11.0 Latest Latest
Warning

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

 Go to latest Published: Sep 30, 2025 License: Apache-2.0 Imports: 28 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ExplainPlansCollector  = "explain_plans"
	OP_EXPLAIN_PLAN_OUTPUT = "explain_plan_output"
)
View Source 
const (
	LocksCollector = "locks"
	OP_DATA_LOCKS  = "query_data_locks"
)
View Source 
const (
	QuerySamplesCollector = "query_samples"
	OP_QUERY_SAMPLE       = "query_sample"
	OP_WAIT_EVENT         = "wait_event"
)
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_SCHEMA_DETECTION    = "schema_detection"
	OP_TABLE_DETECTION     = "table_detection"
	OP_CREATE_STATEMENT    = "create_statement"
)
View Source 
const ConnectionInfoName = "connection_info"
View Source 
const (
	SetupConsumersCollector = "setup_consumers"
)

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
}

type ExplainPlans added in v1.11.0 

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

func NewExplainPlans added in v1.11.0 

func NewExplainPlans(args ExplainPlansArguments) (*ExplainPlans, error)

func (*ExplainPlans) Name added in v1.11.0 

func (c *ExplainPlans) Name() string

func (*ExplainPlans) Start added in v1.11.0 

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

func (*ExplainPlans) Stop added in v1.11.0 

func (c *ExplainPlans) Stop()

func (*ExplainPlans) Stopped added in v1.11.0 

func (c *ExplainPlans) Stopped() bool

type ExplainPlansArguments added in v1.11.0 

type ExplainPlansArguments struct {
	DB              *sql.DB
	ScrapeInterval  time.Duration
	PerScrapeRatio  float64
	ExcludeSchemas  []string
	EntryHandler    loki.EntryHandler
	InitialLookback time.Time
	DBVersion       string

	Logger log.Logger
}

type Locks added in v1.11.0 

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

func NewLocks added in v1.11.0 

func NewLocks(args LocksArguments) (*Locks, error)

func (*Locks) Name added in v1.11.0 

func (c *Locks) Name() string

func (*Locks) Start added in v1.11.0 

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

func (*Locks) Stop added in v1.11.0 

func (c *Locks) Stop()

Stop should be kept idempotent

func (*Locks) Stopped added in v1.11.0 

func (c *Locks) Stopped() bool

type LocksArguments added in v1.11.0 

type LocksArguments struct {
	DB                *sql.DB
	CollectInterval   time.Duration
	LockWaitThreshold time.Duration
	EntryHandler      loki.EntryHandler

	Logger log.Logger
}

type QueryDetails added in v1.11.0 

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

func NewQueryDetails added in v1.11.0 

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

func (*QueryDetails) Name added in v1.11.0 

func (c *QueryDetails) Name() string

func (*QueryDetails) Start added in v1.11.0 

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

func (*QueryDetails) Stop added in v1.11.0 

func (c *QueryDetails) Stop()

Stop should be kept idempotent

func (*QueryDetails) Stopped added in v1.11.0 

func (c *QueryDetails) Stopped() bool

type QueryDetailsArguments added in v1.11.0 

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

	Logger log.Logger
}

type QuerySamples added in v1.11.0 

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

func NewQuerySamples added in v1.11.0 

func NewQuerySamples(args QuerySamplesArguments) (*QuerySamples, error)

func (*QuerySamples) Name added in v1.11.0 

func (c *QuerySamples) Name() string

func (*QuerySamples) Start added in v1.11.0 

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

func (*QuerySamples) Stop added in v1.11.0 

func (c *QuerySamples) Stop()

Stop should be kept idempotent

func (*QuerySamples) Stopped added in v1.11.0 

func (c *QuerySamples) Stopped() bool

type QuerySamplesArguments added in v1.11.0 

type QuerySamplesArguments struct {
	DB                          *sql.DB
	EngineVersion               semver.Version
	CollectInterval             time.Duration
	EntryHandler                loki.EntryHandler
	DisableQueryRedaction       bool
	AutoEnableSetupConsumers    bool
	SetupConsumersCheckInterval time.Duration

	Logger log.Logger
}

type SchemaDetails added in v1.11.0 

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

func NewSchemaDetails added in v1.11.0 

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

func (*SchemaDetails) Name added in v1.11.0 

func (c *SchemaDetails) Name() string

func (*SchemaDetails) Start added in v1.11.0 

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

func (*SchemaDetails) Stop added in v1.11.0 

func (c *SchemaDetails) Stop()

Stop should be kept idempotent

func (*SchemaDetails) Stopped added in v1.11.0 

func (c *SchemaDetails) Stopped() bool

type SchemaDetailsArguments added in v1.11.0 

type SchemaDetailsArguments struct {
	DB              *sql.DB
	CollectInterval time.Duration
	EntryHandler    loki.EntryHandler

	CacheEnabled bool
	CacheSize    int
	CacheTTL     time.Duration

	Logger log.Logger
}

type SetupConsumers added in v1.9.0 

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

func NewSetupConsumers added in v1.11.0 

func NewSetupConsumers(args SetupConsumersArguments) (*SetupConsumers, error)

func (*SetupConsumers) Name added in v1.9.0 

func (c *SetupConsumers) Name() string

func (*SetupConsumers) Start added in v1.9.0 

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

func (*SetupConsumers) Stop added in v1.9.0 

func (c *SetupConsumers) Stop()

func (*SetupConsumers) Stopped added in v1.9.0 

func (c *SetupConsumers) Stopped() bool

type SetupConsumersArguments added in v1.11.0 

type SetupConsumersArguments struct {
	DB       *sql.DB
	Registry *prometheus.Registry

	Logger          log.Logger
	CollectInterval time.Duration
}

Source Files

View all Source files

Directories

Path Synopsis

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.