collector

package

Go to main page

Versions in this module

v1

v1.11.0

Sep 30, 2025

Changes in this version

+ const OP_CREATE_STATEMENT

+ const OP_QUERY_ASSOCIATION

+ const OP_QUERY_PARSED_TABLE_NAME

+ const OP_QUERY_SAMPLE

+ const OP_SCHEMA_DETECTION

+ const OP_TABLE_DETECTION

+ const OP_WAIT_EVENT

+ const QueryDetailsCollector

+ const QuerySamplesCollector

+ const SchemaDetailsCollector

type ConnectionInfo

+ EngineVersion string

type ConnectionInfoArguments

+ EngineVersion string

+ type PgSQLExplainplan struct

+ Plan PlanNode

+ type PlanNode struct

+ Alias string

+ AsyncCapable bool

+ Filter string

+ GroupKey []string

+ HashCond string

+ IndexName string

+ InnerUnique bool

+ JoinType string

+ NodeType string

+ ParallelAware bool

+ ParentRelationship string

+ PartialMode string

+ PlanRows int64

+ PlanWidth int64

+ PlannedPartitions int64

+ Plans []PlanNode

+ RelationName string

+ SortKey []string

+ StartupCost float64

+ Strategy string

+ TotalCost float64

+ WorkersPlanned int64

+ func (p *PlanNode) ToExplainPlanOutputNode() (database_observability.ExplainPlanNode, error)

+ type QueryDetails struct

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

+ func (c *QueryDetails) Name() string

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

+ func (c *QueryDetails) Stop()

+ func (c *QueryDetails) Stopped() bool

+ type QueryDetailsArguments struct

+ CollectInterval time.Duration

+ DB *sql.DB

+ EntryHandler loki.EntryHandler

+ Logger log.Logger

+ type QuerySamples struct

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

+ func (c *QuerySamples) Name() string

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

+ func (c *QuerySamples) Stop()

+ func (c *QuerySamples) Stopped() bool

+ type QuerySamplesArguments struct

+ CollectInterval time.Duration

+ DB *sql.DB

+ DisableQueryRedaction bool

+ EntryHandler loki.EntryHandler

+ Logger log.Logger

+ type QuerySamplesInfo struct

+ ApplicationName sql.NullString

+ BackendStart sql.NullTime

+ BackendType sql.NullString

+ BackendXID sql.NullInt32

+ BackendXmin sql.NullInt32

+ BlockedByPIDs pq.Int64Array

+ ClientAddr sql.NullString

+ ClientPort sql.NullInt32

+ DatabaseID int

+ DatabaseName sql.NullString

+ LeaderPID sql.NullInt64

+ Now time.Time

+ PID int

+ Query sql.NullString

+ QueryID sql.NullInt64

+ QueryStart sql.NullTime

+ State sql.NullString

+ StateChange sql.NullTime

+ UserSysID int

+ Username sql.NullString

+ WaitEvent sql.NullString

+ WaitEventType sql.NullString

+ XactStart sql.NullTime

+ type SchemaDetails struct

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

+ func (c *SchemaDetails) Name() string

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

+ func (c *SchemaDetails) Stop()

+ func (c *SchemaDetails) Stopped() bool

+ type SchemaDetailsArguments struct

+ DB *sql.DB

+ EntryHandler loki.EntryHandler

+ Logger log.Logger

v1.11.0-rc.2

Sep 23, 2025

v1.11.0-rc.1

Sep 19, 2025

v1.10.2

Aug 19, 2025

v1.10.1

Aug 7, 2025

v1.10.0

Jul 16, 2025

Changes in this version

+ const ConnectionInfoName

+ func ParseURL(url string) (map[string]string, error)

+ type ConnectionInfo struct

+ DSN string

+ InfoMetric *prometheus.GaugeVec

+ Registry *prometheus.Registry

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

+ func (c *ConnectionInfo) Name() string

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

+ func (c *ConnectionInfo) Stop()

+ func (c *ConnectionInfo) Stopped() bool

+ type ConnectionInfoArguments struct

+ DSN string

+ Registry *prometheus.Registry

v1.10.0-rc.0

Jul 10, 2025

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