queries

type Anyarray = json.RawMessage

type AutovacuumCountRow struct {
	Count Bigint `json:"count" db:"count"`
}

type Bigint int64 // pg: bigint / int8

type Boolean bool // pg: boolean

type CatalogCollector struct {
	Name     string
	Interval time.Duration
	Collect  func(ctx context.Context) (*CollectResult, error)
}

type CollectResult struct {
	JSON []byte // Pre-marshaled JSON of the payload
}

type CollectorOption func(*collectorOpts)

type ConnectionStatsRow struct {
	Active                 Bigint `json:"active_connections" db:"active_connections"`
	Idle                   Bigint `json:"idle_connections" db:"idle_connections"`
	IdleInTransaction      Bigint `json:"idle_in_transaction_connections" db:"idle_in_transaction_connections"`
	IdleInTransactionAbort Bigint `json:"idle_in_transaction_aborted_connections" db:"idle_in_transaction_aborted_connections"`
	Total                  Bigint `json:"total_connections" db:"total_connections"`
}

type DDLColumn struct {
	TableOID    uint32  // c.oid — for grouping with DDLTable
	TableName   string  // quote_ident(c.relname) — for ALTER TABLE statements
	AttNum      int16   // a.attnum — for ordering
	Name        string  // quote_ident(a.attname)
	TypeName    string  // format_type(a.atttypid, a.atttypmod)
	Collation   *string // quote_ident(collname) if non-default, nil otherwise
	Identity    *string // a.attidentity: "a" or "d", nil if not identity
	Generated   *string // a.attgenerated: "s", nil if not generated
	NotNull     bool    // a.attnotnull
	DefaultExpr *string // pg_get_expr(d.adbin, d.adrelid), nil if no default
	Storage     *string // attstorage if differs from type default, nil otherwise
	Statistics  *int32  // attstattarget if non-default (>= 0), nil otherwise
}

type DDLCompositeType struct {
	SchemaName string // quote_ident(tn.nspname)
	TypeName   string // quote_ident(t.typname)
	Attributes string // formatted attribute list: "field1 type1, field2 type2, ..."
}

type DDLConstraint struct {
	TableName     string // c.relname (raw, for grouping)
	QuotedTable   string // quote_ident(c.relname)
	ConName       string // con.conname (for ordering)
	QuotedConName string // quote_ident(con.conname)
	ConType       string // con.contype: "p","u","c","x"
	ConstraintDef string // pg_get_constraintdef(con.oid)
}

type DDLDomainType struct {
	SchemaName     string   // quote_ident(tn.nspname)
	TypeName       string   // quote_ident(t.typname)
	BaseType       string   // format_type(t.typbasetype, t.typtypmod)
	NotNull        bool     // t.typnotnull
	Default        *string  // t.typdefault (nil = no default)
	ConstraintDefs []string // pg_get_constraintdef() for each domain constraint
}

type DDLEnumType struct {
	SchemaName string   // quote_ident(tn.nspname)
	TypeName   string   // quote_ident(t.typname)
	Labels     []string // ordered enum labels (raw, need quote_literal in formatter)
}

type DDLForeignKey struct {
	TableName     string // quote_ident(c.relname)
	ConName       string // quote_ident(con.conname)
	ConstraintDef string // pg_get_constraintdef(con.oid)
}

type DDLFunction struct {
	OID         uint32 // p.oid (for stable ordering)
	Name        string // p.proname (for stable ordering)
	FunctionDef string // pg_get_functiondef(p.oid) — full CREATE FUNCTION text
}

type DDLIdentitySequence struct {
	SeqParams
	TableName    string // owning table (quoted)
	ColumnName   string // owning column (quoted)
	IdentityKind string // 'a' (ALWAYS) or 'd' (BY DEFAULT)
	Partitioned  bool   // true if the owning table is partitioned (relkind = 'p')
}

type DDLIndex struct {
	IndexName string // indexname (for ordering)
	IndexDef  string // indexdef (full CREATE INDEX statement)
}

type DDLMaterializedView struct {
	Name       string  // quote_ident(c.relname)
	ViewDef    string  // pg_get_viewdef(c.oid)
	RelOptions *string // array_to_string(c.reloptions, ', '), nil if none
	Tablespace *string // quote_ident(spcname), nil if default
}

type DDLPartitionChild struct {
	ChildName  string // quote_ident(c.relname)
	ParentName string // quote_ident(pc.relname)
	BoundExpr  string // pg_get_expr(c.relpartbound, c.oid)
}

type DDLRLSEnabled struct {
	TableName string // quote_ident(c.relname)
	Force     bool   // c.relforcerowsecurity
}

type DDLRLSPolicy struct {
	PolicyName string   // quote_ident(pol.polname)
	TableName  string   // quote_ident(c.relname)
	Command    string   // pol.polcmd: "r","a","w","d","*"
	Permissive bool     // pol.polpermissive
	Roles      []string // role names from polroles (empty or ["PUBLIC"] = default)
	UsingExpr  *string  // pg_get_expr(pol.polqual, pol.polrelid)
	WithCheck  *string  // pg_get_expr(pol.polwithcheck, pol.polrelid)
}

type DDLSequenceRaw struct {
	SeqParams
	Kind         string  // 'standalone', 'serial', or 'identity'
	OwnerTable   *string // quote_ident(owning table) for serial/identity
	OwnerColumn  *string // quote_ident(owning column) for serial/identity
	IdentityKind *string // 'a' or 'd' for identity sequences
	DefaultExpr  *string // nextval(...) expression for serial sequences
	OwnerRelKind *string // relkind of owning table ('r' or 'p')
}

type DDLSerialSequence struct {
	SeqParams
	TableName   string // owning table (quoted)
	ColumnName  string // owning column (quoted)
	DefaultExpr string // the nextval(...) expression
}

type DDLTable struct {
	OID          uint32
	Name         string  // c.relname (raw, for grouping)
	QuotedName   string  // quote_ident(c.relname)
	RelKind      string  // c.relkind: "r" or "p"
	Persistence  string  // c.relpersistence: "p" (permanent), "u" (unlogged)
	RelOptions   *string // array_to_string(c.reloptions, ', '), nil if none
	Tablespace   *string // quote_ident(spcname), nil if default
	PartitionKey *string // pg_get_partkeydef(c.oid), nil if not partitioned
	InheritsFrom *string // comma-separated quoted parent names, nil if none
}

type DDLTrigger struct {
	TableName  string // c.relname (for ordering)
	TrigName   string // t.tgname (for ordering)
	TriggerDef string // pg_get_triggerdef(t.oid) — full CREATE TRIGGER text
}

type DDLView struct {
	Name       string  // quote_ident(c.relname)
	ViewDef    string  // pg_get_viewdef(c.oid)
	RelOptions *string // array_to_string(c.reloptions, ', '), nil if none
}

type DatabaseSizeRow struct {
	TotalSizeBytes Bigint `json:"total_size_bytes" db:"total_size_bytes"`
}

type DoublePrecision float64 // pg: double precision / float8

type Float4Array = json.RawMessage

type Inet string

type Integer int64 // pg: integer / int4

type Interval int64

type Name string // pg: name — 63-byte SQL identifier

type Oid uint32 // pg: oid — object identifier

type Payload[T any] struct {
	CollectedAt time.Time `json:"collected_at"`
	Rows        []T       `json:"rows"`
}

type PgAttributeRow struct {
	AttRelID       *Oid      `json:"attrelid" db:"attrelid"`
	AttName        *Name     `json:"attname" db:"attname"`
	AttTypID       *Bigint   `json:"atttypid" db:"atttypid"`
	AttLen         *Smallint `json:"attlen" db:"attlen"`
	AttNum         *Smallint `json:"attnum" db:"attnum"`
	AttStorage     *Text     `json:"attstorage" db:"attstorage"`
	AttCompression *Text     `json:"attcompression" db:"attcompression"` // PG14+; nil on older versions (column not in query)
	AttNotNull     *Boolean  `json:"attnotnull" db:"attnotnull"`
	AttStatTarget  *Integer  `json:"attstattarget" db:"attstattarget"`
	AttAlign       *Text     `json:"attalign" db:"attalign"`
	AttTypMod      *Integer  `json:"atttypmod" db:"atttypmod"`
}

type PgClassConfig struct {
	BackfillBatchSize int `config:"backfill_batch_size" default:"500" min:"0"`
}

type PgClassRow struct {
	Oid             Oid     `json:"oid"`
	SchemaName      Name    `json:"schemaname"`
	RelName         Name    `json:"relname"`
	RelKind         Text    `json:"relkind"`
	RelTuples       Real    `json:"reltuples"`
	RelPages        Integer `json:"relpages"`
	RelFrozenXID    Xid     `json:"relfrozenxid"`
	RelFrozenXIDAge Bigint  `json:"relfrozenxid_age" db:"relfrozenxid_age"`
	RelMinMXID      Xid     `json:"relminmxid"`
	RelMinMXIDAge   Bigint  `json:"relminmxid_age" db:"relminmxid_age"`
	RelOptions      []Text  `json:"reloptions"`
	AccessMethod    *Text   `json:"access_method" db:"access_method"`
	RelAllVisible   Integer `json:"relallvisible"`
	RelPersistence  Text    `json:"relpersistence"`
	RelIsPartition  Boolean `json:"relispartition"`
	RelHasSubClass  Boolean `json:"relhassubclass"`
	RelToastRelID   Oid     `json:"reltoastrelid"`
	RelTablespace   Oid     `json:"reltablespace"`
}

type PgConstraintRow struct {
	Oid           *Oid       `json:"oid" db:"oid"`
	ConName       *Name      `json:"conname" db:"conname"`
	ConType       *Text      `json:"contype" db:"contype"`
	ConRelID      *Oid       `json:"conrelid" db:"conrelid"`
	ConIndID      *Oid       `json:"conindid" db:"conindid"`
	ConfRelID     *Oid       `json:"confrelid" db:"confrelid"`
	ConKey        []Smallint `json:"conkey" db:"conkey"`
	ConfKey       []Smallint `json:"confkey" db:"confkey"`
	ConDeferrable *Boolean   `json:"condeferrable" db:"condeferrable"`
	ConDeferred   *Boolean   `json:"condeferred" db:"condeferred"`
	ConValidated  *Boolean   `json:"convalidated" db:"convalidated"`
}

type PgDatabaseRow struct {
	Oid             Oid     `json:"oid"`
	DatName         Name    `json:"datname"`
	DatIsTemplate   Boolean `json:"datistemplate"`
	DatFrozenXID    Xid     `json:"datfrozenxid"`
	DatFrozenXIDAge Bigint  `json:"datfrozenxid_age" db:"datfrozenxid_age"`
	DatMinMXID      Xid     `json:"datminmxid"`
	DatMinMXIDAge   Bigint  `json:"datminmxid_age" db:"datminmxid_age"`
}

type PgIndexInventoryRow struct {
	SchemaName          *Name      `json:"schemaname" db:"schemaname"`
	TableName           *Name      `json:"tablename" db:"tablename"`
	IndexName           *Name      `json:"indexname" db:"indexname"`
	IndexRelID          *Oid       `json:"indexrelid" db:"indexrelid"`
	IndRelID            *Oid       `json:"indrelid" db:"indrelid"`
	IndNatts            *Smallint  `json:"indnatts" db:"indnatts"`
	IndNKeyAtts         *Smallint  `json:"indnkeyatts" db:"indnkeyatts"`
	IndIsUnique         *Boolean   `json:"indisunique" db:"indisunique"`
	IndNullsNotDistinct *Boolean   `json:"indnullsnotdistinct" db:"indnullsnotdistinct"` // PG15+
	IndIsPrimary        *Boolean   `json:"indisprimary" db:"indisprimary"`
	IndIsExclusion      *Boolean   `json:"indisexclusion" db:"indisexclusion"`
	IndexDef            *Text      `json:"indexdef" db:"indexdef"`
	IsPartial           *Boolean   `json:"is_partial" db:"is_partial"`
	IndPredSQL          *Text      `json:"indpred_sql" db:"indpred_sql"`
	IndKey              []Smallint `json:"indkey" db:"indkey"`
	IndOption           []Smallint `json:"indoption" db:"indoption"`
	IndClass            []Oid      `json:"indclass" db:"indclass"`
	IndCollation        []Oid      `json:"indcollation" db:"indcollation"`
	IndExprsSQL         *Text      `json:"indexprs_sql" db:"indexprs_sql"`
}

type PgIndexRow struct {
	SchemaName     *Name    `json:"schemaname" db:"schemaname"`
	IndexName      *Name    `json:"indexname" db:"indexname"`
	RelTuples      *Real    `json:"reltuples" db:"reltuples"`
	RelPages       *Integer `json:"relpages" db:"relpages"`
	IndIsValid     *Boolean `json:"indisvalid" db:"indisvalid"`
	IndIsReady     *Boolean `json:"indisready" db:"indisready"`
	IndIsLive      *Boolean `json:"indislive" db:"indislive"`
	IndImmediate   *Boolean `json:"indimmediate" db:"indimmediate"`
	IndIsClustered *Boolean `json:"indisclustered" db:"indisclustered"`
	IndIsReplIdent *Boolean `json:"indisreplident" db:"indisreplident"`
	IndCheckXmin   *Boolean `json:"indcheckxmin" db:"indcheckxmin"`
}

type PgLocksRow struct {
	LockType           *Text        `json:"locktype" db:"locktype"`
	Database           *Oid         `json:"database" db:"database"`
	Relation           *Oid         `json:"relation" db:"relation"`
	Page               *Integer     `json:"page" db:"page"`
	Tuple              *Smallint    `json:"tuple" db:"tuple"`
	VirtualXID         *Text        `json:"virtualxid" db:"virtualxid"`
	TransactionID      *Xid         `json:"transactionid" db:"transactionid"`
	TransactionIDAge   *Bigint      `json:"transactionid_age" db:"transactionid_age"`
	ClassID            *Oid         `json:"classid" db:"classid"`
	ObjID              *Oid         `json:"objid" db:"objid"`
	ObjSubID           *Smallint    `json:"objsubid" db:"objsubid"`
	VirtualTransaction *Text        `json:"virtualtransaction" db:"virtualtransaction"`
	PID                *Integer     `json:"pid" db:"pid"`
	Mode               *Text        `json:"mode" db:"mode"`
	Granted            *Boolean     `json:"granted" db:"granted"`
	FastPath           *Boolean     `json:"fastpath" db:"fastpath"`
	WaitStart          *TimestampTZ `json:"waitstart" db:"waitstart"`
}

type PgLsn string // pg: pg_lsn — log sequence number

type PgPreparedXactsRow struct {
	Transaction    *Xid         `json:"transaction" db:"transaction"`
	TransactionAge *Bigint      `json:"transaction_age" db:"transaction_age"`
	GID            *Text        `json:"gid" db:"gid"`
	Prepared       *TimestampTZ `json:"prepared" db:"prepared"`
	Owner          *Name        `json:"owner" db:"owner"`
	Database       *Name        `json:"database" db:"database"`
}

type PgReplicationSlotsRow struct {
	SlotName           *Name    `json:"slot_name" db:"slot_name"`
	Plugin             *Name    `json:"plugin" db:"plugin"`
	SlotType           *Text    `json:"slot_type" db:"slot_type"`
	DatOID             *Oid     `json:"datoid" db:"datoid"`
	Database           *Name    `json:"database" db:"database"`
	Temporary          *Boolean `json:"temporary" db:"temporary"`
	Active             *Boolean `json:"active" db:"active"`
	ActivePID          *Integer `json:"active_pid" db:"active_pid"`
	Xmin               *Xid     `json:"xmin" db:"xmin"`
	XminAge            *Bigint  `json:"xmin_age" db:"xmin_age"`
	CatalogXmin        *Xid     `json:"catalog_xmin" db:"catalog_xmin"`
	CatalogXminAge     *Bigint  `json:"catalog_xmin_age" db:"catalog_xmin_age"`
	RestartLsn         *PgLsn   `json:"restart_lsn" db:"restart_lsn"`
	ConfirmedFlushLsn  *PgLsn   `json:"confirmed_flush_lsn" db:"confirmed_flush_lsn"`
	WalStatus          *Text    `json:"wal_status" db:"wal_status"`
	SafeWalSize        *Bigint  `json:"safe_wal_size" db:"safe_wal_size"`
	TwoPhase           *Boolean `json:"two_phase" db:"two_phase"`
	Conflicting        *Boolean `json:"conflicting" db:"conflicting"`
	InvalidationReason *Text    `json:"invalidation_reason" db:"invalidation_reason"`
	Failover           *Boolean `json:"failover" db:"failover"` // PG 17+
	Synced             *Boolean `json:"synced" db:"synced"`     // PG 17+
}

type PgSettingsRow struct {
	Name           Text     `json:"name" db:"name"`
	Setting        Text     `json:"setting" db:"setting"`
	Unit           *Text    `json:"unit" db:"unit"`
	Category       Text     `json:"category" db:"category"`
	ShortDesc      Text     `json:"short_desc" db:"short_desc"`
	ExtraDesc      *Text    `json:"extra_desc" db:"extra_desc"`
	Context        Text     `json:"context" db:"context"`
	Vartype        Text     `json:"vartype" db:"vartype"`
	Source         Text     `json:"source" db:"source"`
	MinVal         *Text    `json:"min_val" db:"min_val"`
	MaxVal         *Text    `json:"max_val" db:"max_val"`
	EnumVals       []Text   `json:"enumvals" db:"enumvals"`
	BootVal        *Text    `json:"boot_val" db:"boot_val"`
	ResetVal       *Text    `json:"reset_val" db:"reset_val"`
	Sourcefile     *Text    `json:"sourcefile" db:"sourcefile"`
	Sourceline     *Integer `json:"sourceline" db:"sourceline"`
	PendingRestart Boolean  `json:"pending_restart" db:"pending_restart"`
}

type PgStatActivityRow struct {
	DatID           *Oid         `json:"datid" db:"datid"`
	DatName         *Name        `json:"datname" db:"datname"`
	PID             *Integer     `json:"pid" db:"pid"`
	LeaderPID       *Integer     `json:"leader_pid" db:"leader_pid"`
	UseSysID        *Oid         `json:"usesysid" db:"usesysid"`
	UseName         *Name        `json:"usename" db:"usename"`
	ApplicationName *Text        `json:"application_name" db:"application_name"`
	ClientAddr      *Inet        `json:"client_addr" db:"client_addr"`
	ClientHostname  *Text        `json:"client_hostname" db:"client_hostname"`
	ClientPort      *Integer     `json:"client_port" db:"client_port"`
	BackendStart    *TimestampTZ `json:"backend_start" db:"backend_start"`
	XactStart       *TimestampTZ `json:"xact_start" db:"xact_start"`
	QueryStart      *TimestampTZ `json:"query_start" db:"query_start"`
	StateChange     *TimestampTZ `json:"state_change" db:"state_change"`
	WaitEventType   *Text        `json:"wait_event_type" db:"wait_event_type"`
	WaitEvent       *Text        `json:"wait_event" db:"wait_event"`
	State           *Text        `json:"state" db:"state"`
	BackendXID      *Xid         `json:"backend_xid" db:"backend_xid"`
	BackendXIDAge   *Bigint      `json:"backend_xid_age" db:"backend_xid_age"`
	BackendXmin     *Xid         `json:"backend_xmin" db:"backend_xmin"`
	BackendXminAge  *Bigint      `json:"backend_xmin_age" db:"backend_xmin_age"`
	QueryID         *Text        `json:"query_id" db:"query_id"` // PG 14+: composite queryid_usesysid_datid (matches pg_stat_statements key)
	BackendType     *Text        `json:"backend_type" db:"backend_type"`
}

type PgStatArchiverRow struct {
	ArchivedCount    *Bigint      `json:"archived_count" db:"archived_count"`
	LastArchivedWal  *Text        `json:"last_archived_wal" db:"last_archived_wal"`
	LastArchivedTime *TimestampTZ `json:"last_archived_time" db:"last_archived_time"`
	FailedCount      *Bigint      `json:"failed_count" db:"failed_count"`
	LastFailedWal    *Text        `json:"last_failed_wal" db:"last_failed_wal"`
	LastFailedTime   *TimestampTZ `json:"last_failed_time" db:"last_failed_time"`
	StatsReset       *TimestampTZ `json:"stats_reset" db:"stats_reset"`
}

type PgStatBgwriterRow struct {
	CheckpointsTimed    *Bigint          `json:"checkpoints_timed" db:"checkpoints_timed"`
	CheckpointsReq      *Bigint          `json:"checkpoints_req" db:"checkpoints_req"`
	CheckpointWriteTime *DoublePrecision `json:"checkpoint_write_time" db:"checkpoint_write_time"`
	CheckpointSyncTime  *DoublePrecision `json:"checkpoint_sync_time" db:"checkpoint_sync_time"`
	BuffersCheckpoint   *Bigint          `json:"buffers_checkpoint" db:"buffers_checkpoint"`
	BuffersClean        *Bigint          `json:"buffers_clean" db:"buffers_clean"`
	MaxwrittenClean     *Bigint          `json:"maxwritten_clean" db:"maxwritten_clean"`
	BuffersBackend      *Bigint          `json:"buffers_backend" db:"buffers_backend"`
	BuffersBackendFsync *Bigint          `json:"buffers_backend_fsync" db:"buffers_backend_fsync"`
	BuffersAlloc        *Bigint          `json:"buffers_alloc" db:"buffers_alloc"`
	StatsReset          *TimestampTZ     `json:"stats_reset" db:"stats_reset"`
}

type PgStatCheckpointerRow struct {
	NumTimed           *Bigint          `json:"num_timed" db:"num_timed"`
	NumRequested       *Bigint          `json:"num_requested" db:"num_requested"`
	RestartpointsTimed *Bigint          `json:"restartpoints_timed" db:"restartpoints_timed"`
	RestartpointsReq   *Bigint          `json:"restartpoints_req" db:"restartpoints_req"`
	RestartpointsDone  *Bigint          `json:"restartpoints_done" db:"restartpoints_done"`
	WriteTime          *DoublePrecision `json:"write_time" db:"write_time"`
	SyncTime           *DoublePrecision `json:"sync_time" db:"sync_time"`
	BuffersWritten     *Bigint          `json:"buffers_written" db:"buffers_written"`
	StatsReset         *TimestampTZ     `json:"stats_reset" db:"stats_reset"`
	SlruWritten        *Bigint          `json:"slru_written" db:"slru_written"`
}

type PgStatDatabaseConflictsRow struct {
	DatID            *Oid    `json:"datid" db:"datid"`
	DatName          *Name   `json:"datname" db:"datname"`
	ConflTablespace  *Bigint `json:"confl_tablespace" db:"confl_tablespace"`
	ConflLock        *Bigint `json:"confl_lock" db:"confl_lock"`
	ConflSnapshot    *Bigint `json:"confl_snapshot" db:"confl_snapshot"`
	ConflBufferpin   *Bigint `json:"confl_bufferpin" db:"confl_bufferpin"`
	ConflDeadlock    *Bigint `json:"confl_deadlock" db:"confl_deadlock"`
	ConflLogicalSlot *Bigint `json:"confl_active_logicalslot" db:"confl_active_logicalslot"`
}

type PgStatDatabaseRow struct {
	DatID                 *Oid             `json:"datid" db:"datid"`
	DatName               *Name            `json:"datname" db:"datname"`
	NumBackends           *Integer         `json:"numbackends" db:"numbackends"`
	XactCommit            *Bigint          `json:"xact_commit" db:"xact_commit"`
	XactRollback          *Bigint          `json:"xact_rollback" db:"xact_rollback"`
	BlksRead              *Bigint          `json:"blks_read" db:"blks_read"`
	BlksHit               *Bigint          `json:"blks_hit" db:"blks_hit"`
	TupReturned           *Bigint          `json:"tup_returned" db:"tup_returned"`
	TupFetched            *Bigint          `json:"tup_fetched" db:"tup_fetched"`
	TupInserted           *Bigint          `json:"tup_inserted" db:"tup_inserted"`
	TupUpdated            *Bigint          `json:"tup_updated" db:"tup_updated"`
	TupDeleted            *Bigint          `json:"tup_deleted" db:"tup_deleted"`
	Conflicts             *Bigint          `json:"conflicts" db:"conflicts"`
	TempFiles             *Bigint          `json:"temp_files" db:"temp_files"`
	TempBytes             *Bigint          `json:"temp_bytes" db:"temp_bytes"`
	Deadlocks             *Bigint          `json:"deadlocks" db:"deadlocks"`
	ChecksumFailures      *Bigint          `json:"checksum_failures" db:"checksum_failures"`
	ChecksumLastFailure   *TimestampTZ     `json:"checksum_last_failure" db:"checksum_last_failure"`
	BlkReadTime           *DoublePrecision `json:"blk_read_time" db:"blk_read_time"`
	BlkWriteTime          *DoublePrecision `json:"blk_write_time" db:"blk_write_time"`
	SessionTime           *DoublePrecision `json:"session_time" db:"session_time"`
	ActiveTime            *DoublePrecision `json:"active_time" db:"active_time"`
	IdleInTransactionTime *DoublePrecision `json:"idle_in_transaction_time" db:"idle_in_transaction_time"`
	Sessions              *Bigint          `json:"sessions" db:"sessions"`
	SessionsAbandoned     *Bigint          `json:"sessions_abandoned" db:"sessions_abandoned"`
	SessionsFatal         *Bigint          `json:"sessions_fatal" db:"sessions_fatal"`
	SessionsKilled        *Bigint          `json:"sessions_killed" db:"sessions_killed"`
	StatsReset            *TimestampTZ     `json:"stats_reset" db:"stats_reset"`
	ParallelWorkers       *Bigint          `json:"parallel_workers" db:"parallel_workers"`
	TempBytesRead         *Bigint          `json:"temp_bytes_read" db:"temp_bytes_read"`
	TempBytesWritten      *Bigint          `json:"temp_bytes_written" db:"temp_bytes_written"`
	TempFilesRead         *Bigint          `json:"temp_files_read" db:"temp_files_read"`
	TempFilesWritten      *Bigint          `json:"temp_files_written" db:"temp_files_written"`
}

type PgStatIORow struct {
	BackendType   *Text            `json:"backend_type" db:"backend_type"`
	Object        *Text            `json:"object" db:"object"`
	Context       *Text            `json:"context" db:"context"`
	Reads         *Bigint          `json:"reads" db:"reads"`
	ReadTime      *DoublePrecision `json:"read_time" db:"read_time"`
	Writes        *Bigint          `json:"writes" db:"writes"`
	WriteTime     *DoublePrecision `json:"write_time" db:"write_time"`
	Writebacks    *Bigint          `json:"writebacks" db:"writebacks"`
	WritebackTime *DoublePrecision `json:"writeback_time" db:"writeback_time"`
	Extends       *Bigint          `json:"extends" db:"extends"`
	ExtendTime    *DoublePrecision `json:"extend_time" db:"extend_time"`
	OpBytes       *Bigint          `json:"op_bytes" db:"op_bytes"`
	Hits          *Bigint          `json:"hits" db:"hits"`
	Evictions     *Bigint          `json:"evictions" db:"evictions"`
	Reuses        *Bigint          `json:"reuses" db:"reuses"`
	Fsyncs        *Bigint          `json:"fsyncs" db:"fsyncs"`
	FsyncTime     *DoublePrecision `json:"fsync_time" db:"fsync_time"`
	StatsReset    *TimestampTZ     `json:"stats_reset" db:"stats_reset"`
}

type PgStatProgressAnalyzeRow struct {
	PID                    *Integer `json:"pid" db:"pid"`
	DatID                  *Oid     `json:"datid" db:"datid"`
	DatName                *Name    `json:"datname" db:"datname"`
	RelID                  *Oid     `json:"relid" db:"relid"`
	Phase                  *Text    `json:"phase" db:"phase"`
	SampleBlksTotal        *Bigint  `json:"sample_blks_total" db:"sample_blks_total"`
	SampleBlksScanned      *Bigint  `json:"sample_blks_scanned" db:"sample_blks_scanned"`
	ExtStatsTotal          *Bigint  `json:"ext_stats_total" db:"ext_stats_total"`
	ExtStatsComputed       *Bigint  `json:"ext_stats_computed" db:"ext_stats_computed"`
	ChildTablesTotal       *Bigint  `json:"child_tables_total" db:"child_tables_total"`
	ChildTablesDone        *Bigint  `json:"child_tables_done" db:"child_tables_done"`
	CurrentChildTableRelID *Oid     `json:"current_child_table_relid" db:"current_child_table_relid"`
}

type PgStatProgressCreateIndexRow struct {
	PID              *Integer `json:"pid" db:"pid"`
	DatID            *Oid     `json:"datid" db:"datid"`
	DatName          *Name    `json:"datname" db:"datname"`
	RelID            *Oid     `json:"relid" db:"relid"`
	IndexRelID       *Oid     `json:"index_relid" db:"index_relid"`
	Command          *Text    `json:"command" db:"command"`
	Phase            *Text    `json:"phase" db:"phase"`
	LockersTotal     *Bigint  `json:"lockers_total" db:"lockers_total"`
	LockersDone      *Bigint  `json:"lockers_done" db:"lockers_done"`
	CurrentLockerPID *Bigint  `json:"current_locker_pid" db:"current_locker_pid"`
	BlocksTotal      *Bigint  `json:"blocks_total" db:"blocks_total"`
	BlocksDone       *Bigint  `json:"blocks_done" db:"blocks_done"`
	TuplesTotal      *Bigint  `json:"tuples_total" db:"tuples_total"`
	TuplesDone       *Bigint  `json:"tuples_done" db:"tuples_done"`
	PartitionsTotal  *Bigint  `json:"partitions_total" db:"partitions_total"`
	PartitionsDone   *Bigint  `json:"partitions_done" db:"partitions_done"`
}

type PgStatProgressVacuumRow struct {
	PID              *Integer `json:"pid" db:"pid"`
	DatID            *Oid     `json:"datid" db:"datid"`
	DatName          *Name    `json:"datname" db:"datname"`
	RelID            *Oid     `json:"relid" db:"relid"`
	Phase            *Text    `json:"phase" db:"phase"`
	HeapBlksTotal    *Bigint  `json:"heap_blks_total" db:"heap_blks_total"`
	HeapBlksScanned  *Bigint  `json:"heap_blks_scanned" db:"heap_blks_scanned"`
	HeapBlksVacuumed *Bigint  `json:"heap_blks_vacuumed" db:"heap_blks_vacuumed"`
	IndexVacuumCount *Bigint  `json:"index_vacuum_count" db:"index_vacuum_count"`
	MaxDeadTuples    *Bigint  `json:"max_dead_tuples" db:"max_dead_tuples"`
	NumDeadTuples    *Bigint  `json:"num_dead_tuples" db:"num_dead_tuples"`
}

type PgStatRecoveryPrefetchRow struct {
	StatsReset    *TimestampTZ `json:"stats_reset" db:"stats_reset"`
	Prefetch      *Bigint      `json:"prefetch" db:"prefetch"`
	Hit           *Bigint      `json:"hit" db:"hit"`
	SkipInit      *Bigint      `json:"skip_init" db:"skip_init"`
	SkipNew       *Bigint      `json:"skip_new" db:"skip_new"`
	SkipFpw       *Bigint      `json:"skip_fpw" db:"skip_fpw"`
	SkipRep       *Bigint      `json:"skip_rep" db:"skip_rep"`
	WalDistance   *Integer     `json:"wal_distance" db:"wal_distance"`
	BlockDistance *Integer     `json:"block_distance" db:"block_distance"`
	IoDepth       *Integer     `json:"io_depth" db:"io_depth"`
}

type PgStatReplicationRow struct {
	PID             *Integer     `json:"pid" db:"pid"`
	UseSysID        *Oid         `json:"usesysid" db:"usesysid"`
	UseName         *Name        `json:"usename" db:"usename"`
	ApplicationName *Text        `json:"application_name" db:"application_name"`
	ClientAddr      *Inet        `json:"client_addr" db:"client_addr"`
	ClientHostname  *Text        `json:"client_hostname" db:"client_hostname"`
	ClientPort      *Integer     `json:"client_port" db:"client_port"`
	BackendStart    *TimestampTZ `json:"backend_start" db:"backend_start"`
	BackendXmin     *Xid         `json:"backend_xmin" db:"backend_xmin"`
	BackendXminAge  *Bigint      `json:"backend_xmin_age" db:"backend_xmin_age"`
	State           *Text        `json:"state" db:"state"`
	SentLsn         *PgLsn       `json:"sent_lsn" db:"sent_lsn"`
	WriteLsn        *PgLsn       `json:"write_lsn" db:"write_lsn"`
	FlushLsn        *PgLsn       `json:"flush_lsn" db:"flush_lsn"`
	ReplayLsn       *PgLsn       `json:"replay_lsn" db:"replay_lsn"`
	WriteLag        *Interval    `json:"write_lag" db:"write_lag"`
	FlushLag        *Interval    `json:"flush_lag" db:"flush_lag"`
	ReplayLag       *Interval    `json:"replay_lag" db:"replay_lag"`
	SyncPriority    *Integer     `json:"sync_priority" db:"sync_priority"`
	SyncState       *Text        `json:"sync_state" db:"sync_state"`
	ReplyTime       *TimestampTZ `json:"reply_time" db:"reply_time"`
}

type PgStatReplicationSlotsRow struct {
	SlotName    *Name        `json:"slot_name" db:"slot_name"`
	SpillTxns   *Bigint      `json:"spill_txns" db:"spill_txns"`
	SpillCount  *Bigint      `json:"spill_count" db:"spill_count"`
	SpillBytes  *Bigint      `json:"spill_bytes" db:"spill_bytes"`
	StreamTxns  *Bigint      `json:"stream_txns" db:"stream_txns"`
	StreamCount *Bigint      `json:"stream_count" db:"stream_count"`
	StreamBytes *Bigint      `json:"stream_bytes" db:"stream_bytes"`
	TotalTxns   *Bigint      `json:"total_txns" db:"total_txns"`
	TotalBytes  *Bigint      `json:"total_bytes" db:"total_bytes"`
	StatsReset  *TimestampTZ `json:"stats_reset" db:"stats_reset"`
}

type PgStatSlruRow struct {
	Name        *Text        `json:"name" db:"name"`
	BlksZeroed  *Bigint      `json:"blks_zeroed" db:"blks_zeroed"`
	BlksHit     *Bigint      `json:"blks_hit" db:"blks_hit"`
	BlksRead    *Bigint      `json:"blks_read" db:"blks_read"`
	BlksWritten *Bigint      `json:"blks_written" db:"blks_written"`
	BlksExists  *Bigint      `json:"blks_exists" db:"blks_exists"`
	Flushes     *Bigint      `json:"flushes" db:"flushes"`
	Truncates   *Bigint      `json:"truncates" db:"truncates"`
	StatsReset  *TimestampTZ `json:"stats_reset" db:"stats_reset"`
}

type PgStatStatementsConfig struct {
	DiffLimit          int  `config:"diff_limit" default:"500" min:"0" max:"500"`
	IncludeQueries     bool `config:"include_queries" default:"true"`
	MaxQueryTextLength int  `config:"max_query_text_length" default:"8192" min:"0" max:"8192"`
}

type PgStatStatementsDelta struct {
	UserID  *Oid    `json:"userid" db:"userid"`
	DbID    *Oid    `json:"dbid" db:"dbid"`
	QueryID *Bigint `json:"queryid" db:"queryid"`

	Calls         *Bigint          `json:"calls" db:"calls"`
	TotalExecTime *DoublePrecision `json:"total_exec_time" db:"total_exec_time"`
}

type PgStatStatementsExtVersion struct {
	Major int
	Minor int
}

type PgStatStatementsPayload struct {
	CollectedAt         time.Time               `json:"collected_at"`
	Rows                []PgStatStatementsRow   `json:"rows"`
	Deltas              []PgStatStatementsDelta `json:"deltas,omitempty"`
	DeltaCount          int                     `json:"delta_count"`
	AverageQueryRuntime float64                 `json:"average_query_runtime"`
}

type PgStatStatementsRow struct {
	// Identifiers
	UserID  *Oid    `json:"userid" db:"userid"`
	DbID    *Oid    `json:"dbid" db:"dbid"`
	QueryID *Bigint `json:"queryid" db:"queryid"`

	// Query text
	Query    *Text   `json:"query,omitempty" db:"query"`
	QueryLen *Bigint `json:"query_len,omitempty" db:"query_len"`

	// Core counters (all versions)
	Calls          *Bigint          `json:"calls" db:"calls"`
	TotalExecTime  *DoublePrecision `json:"total_exec_time" db:"total_exec_time"`
	MinExecTime    *DoublePrecision `json:"min_exec_time" db:"min_exec_time"`
	MaxExecTime    *DoublePrecision `json:"max_exec_time" db:"max_exec_time"`
	MeanExecTime   *DoublePrecision `json:"mean_exec_time" db:"mean_exec_time"`
	StddevExecTime *DoublePrecision `json:"stddev_exec_time" db:"stddev_exec_time"`
	Rows           *Bigint          `json:"rows" db:"rows"`

	// Block I/O (all versions)
	SharedBlksHit     *Bigint `json:"shared_blks_hit" db:"shared_blks_hit"`
	SharedBlksRead    *Bigint `json:"shared_blks_read" db:"shared_blks_read"`
	SharedBlksDirtied *Bigint `json:"shared_blks_dirtied" db:"shared_blks_dirtied"`
	SharedBlksWritten *Bigint `json:"shared_blks_written" db:"shared_blks_written"`
	LocalBlksHit      *Bigint `json:"local_blks_hit" db:"local_blks_hit"`
	LocalBlksRead     *Bigint `json:"local_blks_read" db:"local_blks_read"`
	LocalBlksDirtied  *Bigint `json:"local_blks_dirtied" db:"local_blks_dirtied"`
	LocalBlksWritten  *Bigint `json:"local_blks_written" db:"local_blks_written"`
	TempBlksRead      *Bigint `json:"temp_blks_read" db:"temp_blks_read"`
	TempBlksWritten   *Bigint `json:"temp_blks_written" db:"temp_blks_written"`

	// Block I/O timing — PG17 renamed blk_read/write_time to shared_blk_read/write_time.
	SharedBlkReadTime  *DoublePrecision `json:"shared_blk_read_time" db:"shared_blk_read_time"`
	SharedBlkWriteTime *DoublePrecision `json:"shared_blk_write_time" db:"shared_blk_write_time"`

	// PG17+: local block I/O timing
	LocalBlkReadTime  *DoublePrecision `json:"local_blk_read_time,omitempty" db:"local_blk_read_time"`
	LocalBlkWriteTime *DoublePrecision `json:"local_blk_write_time,omitempty" db:"local_blk_write_time"`

	// PG13+
	Plans          *Bigint          `json:"plans" db:"plans"`
	TotalPlanTime  *DoublePrecision `json:"total_plan_time" db:"total_plan_time"`
	MinPlanTime    *DoublePrecision `json:"min_plan_time" db:"min_plan_time"`
	MaxPlanTime    *DoublePrecision `json:"max_plan_time" db:"max_plan_time"`
	MeanPlanTime   *DoublePrecision `json:"mean_plan_time" db:"mean_plan_time"`
	StddevPlanTime *DoublePrecision `json:"stddev_plan_time" db:"stddev_plan_time"`
	WalRecords     *Bigint          `json:"wal_records" db:"wal_records"`
	WalFpi         *Bigint          `json:"wal_fpi" db:"wal_fpi"`
	WalBytes       *Bigint          `json:"wal_bytes" db:"wal_bytes"`

	// PG14+
	TopLevel *Boolean `json:"toplevel" db:"toplevel"`

	// PG15+
	TempBlkReadTime  *DoublePrecision `json:"temp_blk_read_time" db:"temp_blk_read_time"`
	TempBlkWriteTime *DoublePrecision `json:"temp_blk_write_time" db:"temp_blk_write_time"`

	JitFunctions         *Bigint          `json:"jit_functions" db:"jit_functions"`
	JitGenerationTime    *DoublePrecision `json:"jit_generation_time" db:"jit_generation_time"`
	JitInliningCount     *Bigint          `json:"jit_inlining_count" db:"jit_inlining_count"`
	JitInliningTime      *DoublePrecision `json:"jit_inlining_time" db:"jit_inlining_time"`
	JitOptimizationCount *Bigint          `json:"jit_optimization_count" db:"jit_optimization_count"`
	JitOptimizationTime  *DoublePrecision `json:"jit_optimization_time" db:"jit_optimization_time"`
	JitEmissionCount     *Bigint          `json:"jit_emission_count" db:"jit_emission_count"`
	JitEmissionTime      *DoublePrecision `json:"jit_emission_time" db:"jit_emission_time"`
}

type PgStatSubscriptionRow struct {
	SubID              *Oid         `json:"subid" db:"subid"`
	SubName            *Name        `json:"subname" db:"subname"`
	PID                *Integer     `json:"pid" db:"pid"`
	LeaderPID          *Integer     `json:"leader_pid" db:"leader_pid"`
	RelID              *Oid         `json:"relid" db:"relid"`
	ReceivedLsn        *PgLsn       `json:"received_lsn" db:"received_lsn"`
	LastMsgSendTime    *TimestampTZ `json:"last_msg_send_time" db:"last_msg_send_time"`
	LastMsgReceiptTime *TimestampTZ `json:"last_msg_receipt_time" db:"last_msg_receipt_time"`
	LatestEndLsn       *PgLsn       `json:"latest_end_lsn" db:"latest_end_lsn"`
	LatestEndTime      *TimestampTZ `json:"latest_end_time" db:"latest_end_time"`
	WorkerType         *Text        `json:"worker_type" db:"worker_type"`
}

type PgStatSubscriptionStatsRow struct {
	SubID           *Oid         `json:"subid" db:"subid"`
	SubName         *Name        `json:"subname" db:"subname"`
	ApplyErrorCount *Bigint      `json:"apply_error_count" db:"apply_error_count"`
	SyncErrorCount  *Bigint      `json:"sync_error_count" db:"sync_error_count"`
	StatsReset      *TimestampTZ `json:"stats_reset" db:"stats_reset"`
}

type PgStatUserFunctionsRow struct {
	FuncID     *Oid             `json:"funcid" db:"funcid"`
	SchemaName *Name            `json:"schemaname" db:"schemaname"`
	FuncName   *Name            `json:"funcname" db:"funcname"`
	Calls      *Bigint          `json:"calls" db:"calls"`
	TotalTime  *DoublePrecision `json:"total_time" db:"total_time"`
	SelfTime   *DoublePrecision `json:"self_time" db:"self_time"`
}

type PgStatUserIndexesConfig struct {
	CategoryLimit int `config:"category_limit" default:"200" min:"0"`
}

type PgStatUserIndexesRow struct {
	RelID        *Oid         `json:"relid" db:"relid"`
	IndexRelID   *Oid         `json:"indexrelid" db:"indexrelid"`
	SchemaName   *Name        `json:"schemaname" db:"schemaname"`
	RelName      *Name        `json:"relname" db:"relname"`
	IndexRelName *Name        `json:"indexrelname" db:"indexrelname"`
	IdxScan      *Bigint      `json:"idx_scan" db:"idx_scan"`
	LastIdxScan  *TimestampTZ `json:"last_idx_scan" db:"last_idx_scan"`
	IdxTupRead   *Bigint      `json:"idx_tup_read" db:"idx_tup_read"`
	IdxTupFetch  *Bigint      `json:"idx_tup_fetch" db:"idx_tup_fetch"`
}

type PgStatUserTableRow struct {
	RelID                *Oid             `json:"relid" db:"relid"`
	SchemaName           Name             `json:"schemaname" db:"schemaname"`
	RelName              Name             `json:"relname" db:"relname"`
	SeqScan              *Bigint          `json:"seq_scan" db:"seq_scan"`
	LastSeqScan          *TimestampTZ     `json:"last_seq_scan" db:"last_seq_scan"`
	SeqTupRead           *Bigint          `json:"seq_tup_read" db:"seq_tup_read"`
	IdxScan              *Bigint          `json:"idx_scan" db:"idx_scan"`
	LastIdxScan          *TimestampTZ     `json:"last_idx_scan" db:"last_idx_scan"`
	IdxTupFetch          *Bigint          `json:"idx_tup_fetch" db:"idx_tup_fetch"`
	NTupIns              *Bigint          `json:"n_tup_ins" db:"n_tup_ins"`
	NTupUpd              *Bigint          `json:"n_tup_upd" db:"n_tup_upd"`
	NTupDel              *Bigint          `json:"n_tup_del" db:"n_tup_del"`
	NTupHotUpd           *Bigint          `json:"n_tup_hot_upd" db:"n_tup_hot_upd"`
	NTupNewpageUpd       *Bigint          `json:"n_tup_newpage_upd" db:"n_tup_newpage_upd"`
	NLiveTup             *Bigint          `json:"n_live_tup" db:"n_live_tup"`
	NDeadTup             *Bigint          `json:"n_dead_tup" db:"n_dead_tup"`
	NModSinceAnalyze     *Bigint          `json:"n_mod_since_analyze" db:"n_mod_since_analyze"`
	NInsSinceVacuum      *Bigint          `json:"n_ins_since_vacuum" db:"n_ins_since_vacuum"`
	LastVacuum           *TimestampTZ     `json:"last_vacuum" db:"last_vacuum"`
	LastAutovacuum       *TimestampTZ     `json:"last_autovacuum" db:"last_autovacuum"`
	LastAnalyze          *TimestampTZ     `json:"last_analyze" db:"last_analyze"`
	LastAutoanalyze      *TimestampTZ     `json:"last_autoanalyze" db:"last_autoanalyze"`
	VacuumCount          *Bigint          `json:"vacuum_count" db:"vacuum_count"`
	AutovacuumCount      *Bigint          `json:"autovacuum_count" db:"autovacuum_count"`
	AnalyzeCount         *Bigint          `json:"analyze_count" db:"analyze_count"`
	AutoanalyzeCount     *Bigint          `json:"autoanalyze_count" db:"autoanalyze_count"`
	TotalVacuumTime      *DoublePrecision `json:"total_vacuum_time" db:"total_vacuum_time"`
	TotalAutovacuumTime  *DoublePrecision `json:"total_autovacuum_time" db:"total_autovacuum_time"`
	TotalAnalyzeTime     *DoublePrecision `json:"total_analyze_time" db:"total_analyze_time"`
	TotalAutoanalyzeTime *DoublePrecision `json:"total_autoanalyze_time" db:"total_autoanalyze_time"`
}

type PgStatUserTablesConfig struct {
	CategoryLimit int `config:"category_limit" default:"200" min:"0"`
}

type PgStatWalReceiverRow struct {
	PID                *Integer     `json:"pid" db:"pid"`
	Status             *Text        `json:"status" db:"status"`
	ReceiveStartLsn    *PgLsn       `json:"receive_start_lsn" db:"receive_start_lsn"`
	ReceiveStartTli    *Integer     `json:"receive_start_tli" db:"receive_start_tli"`
	WrittenLsn         *PgLsn       `json:"written_lsn" db:"written_lsn"`
	FlushedLsn         *PgLsn       `json:"flushed_lsn" db:"flushed_lsn"`
	ReceivedTli        *Integer     `json:"received_tli" db:"received_tli"`
	LastMsgSendTime    *TimestampTZ `json:"last_msg_send_time" db:"last_msg_send_time"`
	LastMsgReceiptTime *TimestampTZ `json:"last_msg_receipt_time" db:"last_msg_receipt_time"`
	LatestEndLsn       *PgLsn       `json:"latest_end_lsn" db:"latest_end_lsn"`
	LatestEndTime      *TimestampTZ `json:"latest_end_time" db:"latest_end_time"`
	SlotName           *Text        `json:"slot_name" db:"slot_name"`
	SenderHost         *Text        `json:"sender_host" db:"sender_host"`
	SenderPort         *Integer     `json:"sender_port" db:"sender_port"`
}

type PgStatWalRow struct {
	WalRecords     *Bigint          `json:"wal_records" db:"wal_records"`
	WalFpi         *Bigint          `json:"wal_fpi" db:"wal_fpi"`
	WalBytes       *Bigint          `json:"wal_bytes" db:"wal_bytes"` // pg numeric, but int64 suffices (~9.2 EB max)
	WalBuffersFull *Bigint          `json:"wal_buffers_full" db:"wal_buffers_full"`
	WalWrite       *Bigint          `json:"wal_write" db:"wal_write"`
	WalSync        *Bigint          `json:"wal_sync" db:"wal_sync"`
	WalWriteTime   *DoublePrecision `json:"wal_write_time" db:"wal_write_time"`
	WalSyncTime    *DoublePrecision `json:"wal_sync_time" db:"wal_sync_time"`
	StatsReset     *TimestampTZ     `json:"stats_reset" db:"stats_reset"`
}

type PgStatioUserIndexesConfig struct {
	BackfillBatchSize int `config:"backfill_batch_size" default:"2000" min:"0"`
}

type PgStatioUserIndexesRow struct {
	RelID        *Oid    `json:"relid" db:"relid"`
	IndexRelID   *Oid    `json:"indexrelid" db:"indexrelid"`
	SchemaName   *Name   `json:"schemaname" db:"schemaname"`
	RelName      *Name   `json:"relname" db:"relname"`
	IndexRelName *Name   `json:"indexrelname" db:"indexrelname"`
	IdxBlksRead  *Bigint `json:"idx_blks_read" db:"idx_blks_read"`
	IdxBlksHit   *Bigint `json:"idx_blks_hit" db:"idx_blks_hit"`
}

type PgStatioUserTablesRow struct {
	RelID         *Oid    `json:"relid" db:"relid"`
	SchemaName    *Name   `json:"schemaname" db:"schemaname"`
	RelName       *Name   `json:"relname" db:"relname"`
	HeapBlksRead  *Bigint `json:"heap_blks_read" db:"heap_blks_read"`
	HeapBlksHit   *Bigint `json:"heap_blks_hit" db:"heap_blks_hit"`
	IdxBlksRead   *Bigint `json:"idx_blks_read" db:"idx_blks_read"`
	IdxBlksHit    *Bigint `json:"idx_blks_hit" db:"idx_blks_hit"`
	ToastBlksRead *Bigint `json:"toast_blks_read" db:"toast_blks_read"`
	ToastBlksHit  *Bigint `json:"toast_blks_hit" db:"toast_blks_hit"`
	TidxBlksRead  *Bigint `json:"tidx_blks_read" db:"tidx_blks_read"`
	TidxBlksHit   *Bigint `json:"tidx_blks_hit" db:"tidx_blks_hit"`
}

type PgStatsConfig struct {
	BackfillBatchSize int  `config:"backfill_batch_size" default:"200" min:"0"`
	IncludeTableData  bool `config:"include_table_data"`
}

type PgStatsRow struct {
	SchemaName          Name        `json:"schemaname"`
	TableName           Name        `json:"tablename"`
	AttName             Name        `json:"attname"`
	Inherited           Boolean     `json:"inherited"`
	NullFrac            *Real       `json:"null_frac"`
	AvgWidth            *Integer    `json:"avg_width"`
	NDistinct           *Real       `json:"n_distinct"`
	MostCommonVals      Anyarray    `json:"most_common_vals"`
	MostCommonFreqs     Float4Array `json:"most_common_freqs"`
	HistogramBounds     Anyarray    `json:"histogram_bounds"`
	Correlation         *Real       `json:"correlation"`
	MostCommonElems     Anyarray    `json:"most_common_elems"`
	MostCommonElemFreqs Float4Array `json:"most_common_elem_freqs"`
	ElemCountHistogram  Float4Array `json:"elem_count_histogram"`
}

type PgTypeRow struct {
	Oid          *Oid      `json:"oid" db:"oid"`
	TypName      *Name     `json:"typname" db:"typname"`
	TypNamespace *Oid      `json:"typnamespace" db:"typnamespace"`
	TypLen       *Smallint `json:"typlen" db:"typlen"`
	TypByVal     *Boolean  `json:"typbyval" db:"typbyval"`
	TypAlign     *Text     `json:"typalign" db:"typalign"`
	TypStorage   *Text     `json:"typstorage" db:"typstorage"`
	TypCategory  *Text     `json:"typcategory" db:"typcategory"`
	TypType      *Text     `json:"typtype" db:"typtype"`
	TypBaseType  *Oid      `json:"typbasetype" db:"typbasetype"`
	TypElem      *Oid      `json:"typelem" db:"typelem"`
	TypRelID     *Oid      `json:"typrelid" db:"typrelid"`
}

type PrepareCtx func(ctx context.Context) (context.Context, error)

type Real float64 // pg: real / float4

type SeqParams struct {
	Name      string
	DataType  string
	Start     int64
	Increment int64
	MinValue  int64
	MaxValue  int64
	Cache     int64
	Cycle     bool
}

type Smallint int64 // pg: smallint / int2

type Text string // pg: text — variable-length string

type TimestampTZ time.Time

type TransactionCommitsRow struct {
	XactCommit int64   `json:"xact_commit"`
	TPS        float64 `json:"tps,omitempty"`
}

type UptimeMinutesRow struct {
	UptimeMinutes DoublePrecision `json:"uptime_minutes" db:"uptime_minutes"`
}

type WaitEventRow struct {
	WaitEventType Text   `json:"wait_event_type" db:"wait_event_type"`
	CurrentCount  Bigint `json:"current_count" db:"current_count"`
}

type Xid string