collector

Documentation

Index

• Constants
• func ParseURL(url string) (map[string]string, error)
• type ConnectionInfo
  • 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
• type PgSQLExplainplan
• type PlanNode
  • func (p *PlanNode) ToExplainPlanOutputNode() (database_observability.ExplainPlanNode, error)
• type QueryDetails
  • 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
• type QuerySamples
  • 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
• type QuerySamplesInfo
• type SchemaDetails
  • 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

Constants

const (
	QueryDetailsCollector      = "query_details"
	OP_QUERY_ASSOCIATION       = "query_association"
	OP_QUERY_PARSED_TABLE_NAME = "query_parsed_table_name"
)

const (
	QuerySamplesCollector = "query_samples"
	OP_QUERY_SAMPLE       = "query_sample"
	OP_WAIT_EVENT         = "wait_event"
)

const (
	SchemaDetailsCollector = "schema_details"
	OP_SCHEMA_DETECTION    = "schema_detection"
	OP_TABLE_DETECTION     = "table_detection"
	OP_CREATE_STATEMENT    = "create_statement"
)

const ConnectionInfoName = "connection_info"

Functions

func ParseURL

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

Types

type ConnectionInfo

type ConnectionInfo struct {
	DSN           string
	Registry      *prometheus.Registry
	EngineVersion string
	InfoMetric    *prometheus.GaugeVec
	// 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
}

type PgSQLExplainplan

type PgSQLExplainplan struct {
	Plan PlanNode `json:"Plan"`
}

type PlanNode

type PlanNode struct {
	NodeType           string     `json:"Node Type"`
	Alias              string     `json:"Alias"`
	RelationName       string     `json:"Relation Name"`
	ParentRelationship string     `json:"Parent Relationship"`
	PartialMode        string     `json:"Partial Mode"`
	Strategy           string     `json:"Strategy"`
	ParallelAware      bool       `json:"Parallel Aware"`
	AsyncCapable       bool       `json:"Async Capable"`
	JoinType           string     `json:"Join Type"`
	InnerUnique        bool       `json:"Inner Unique"`
	HashCond           string     `json:"Hash Cond"`
	Filter             string     `json:"Filter"`
	StartupCost        float64    `json:"Startup Cost"`
	TotalCost          float64    `json:"Total Cost"`
	PlanRows           int64      `json:"Plan Rows"`
	PlanWidth          int64      `json:"Plan Width"`
	GroupKey           []string   `json:"Group Key"`
	SortKey            []string   `json:"Sort Key"`
	WorkersPlanned     int64      `json:"Workers Planned"`
	PlannedPartitions  int64      `json:"Planned Partitions"`
	Plans              []PlanNode `json:"Plans"`
	IndexName          string     `json:"Index Name"`
}

func (*PlanNode) ToExplainPlanOutputNode

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

type QueryDetails

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

func NewQueryDetails

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

func (*QueryDetails) Name

func (c *QueryDetails) Name() string

func (*QueryDetails) Start

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

func (*QueryDetails) Stop

func (c *QueryDetails) Stop()

Stop should be kept idempotent

func (*QueryDetails) Stopped

func (c *QueryDetails) Stopped() bool

type QueryDetailsArguments

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

	Logger log.Logger
}

type QuerySamples

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

func NewQuerySamples

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

func (*QuerySamples) Name

func (c *QuerySamples) Name() string

func (*QuerySamples) Start

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

func (*QuerySamples) Stop

func (c *QuerySamples) Stop()

Stop should be kept idempotent

func (*QuerySamples) Stopped

func (c *QuerySamples) Stopped() bool

type QuerySamplesArguments

type QuerySamplesArguments struct {
	DB                    *sql.DB
	CollectInterval       time.Duration
	EntryHandler          loki.EntryHandler
	Logger                log.Logger
	DisableQueryRedaction bool
}

type QuerySamplesInfo

type QuerySamplesInfo struct {
	DatabaseName    sql.NullString
	DatabaseID      int
	PID             int
	LeaderPID       sql.NullInt64
	UserSysID       int
	Username        sql.NullString
	ApplicationName sql.NullString
	ClientAddr      sql.NullString
	ClientPort      sql.NullInt32
	StateChange     sql.NullTime
	Now             time.Time
	BackendStart    sql.NullTime
	XactStart       sql.NullTime
	QueryStart      sql.NullTime
	WaitEventType   sql.NullString
	WaitEvent       sql.NullString
	State           sql.NullString
	BackendType     sql.NullString
	BackendXID      sql.NullInt32
	BackendXmin     sql.NullInt32
	QueryID         sql.NullInt64
	Query           sql.NullString
	BlockedByPIDs   pq.Int64Array
}

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()

Stop should be kept idempotent

func (*SchemaDetails) Stopped

func (c *SchemaDetails) Stopped() bool

type SchemaDetailsArguments

type SchemaDetailsArguments struct {
	DB           *sql.DB
	EntryHandler loki.EntryHandler

	Logger log.Logger
}