sqlstats

Aug 14, 2026

Changes in this version

+ type CommentTagPolicy string

+ const CommentTagsOff

+ const CommentTagsOn

+ const EnvCommentTags

+ func ResolveCommentTagPolicy(getenv func(string) string) (CommentTagPolicy, string)

Aug 7, 2026

Changes in this version

+ type EventObserver interface

+ SQLCancel func(time.Time, any)

+ SQLFinish func(time.Time, any, string, time.Duration, bool)

+ SQLStart func(time.Time) any

type GenerationCollector

+ func (c *GenerationCollector) SetEventObserver(observer EventObserver)

type Store

+ func (s *Store) SetEventObserver(observer EventObserver)

Aug 5, 2026

Changes in this version

+ const MaxTargets

+ const RotateDrainBudget

+ const SectionName

+ var ErrDriverFailed = errors.New("isutools: database driver failed")

+ var ErrDuplicatePurpose = errors.New("isutools: purpose already registered")

+ var ErrDuplicateTarget = errors.New("isutools: target id already in use")

+ var ErrExecNotAllowed = errors.New("isutools: exec statement not allowed")

+ var ErrForeignHandle = errors.New("sqlstats: generation handle belongs to another collector")

+ var ErrHandleReleased = errors.New("sqlstats: generation handle was released")

+ var ErrInspectorTargetMismatch = errors.New("isutools: inspector credential points at a different target")

+ var ErrInvalidPurpose = errors.New("isutools: invalid purpose")

+ var ErrInvalidTargetID = errors.New("isutools: invalid target id")

+ var ErrNotDrained = errors.New("sqlstats: generation was not drained")

+ var ErrPurposeNotRegistered = errors.New("isutools: purpose not registered")

+ var ErrTooManyTargets = errors.New("isutools: too many db targets")

+ var ErrUnknownDriver = errors.New("isutools: driver is not registered")

+ var ErrUnknownTarget = errors.New("isutools: unknown target id")

+ var ErrUnparsedDSN = errors.New("isutools: dsn could not be parsed")

+ var ErrUnsupportedDSNForm = errors.New("isutools: dsn form does not support inspector connection hygiene")

+ func CloseDBInspectors()

+ func Inspect(ctx context.Context, id string, purpose Purpose, ...) error

+ func Notes() []string

+ func RegisterDBInspector(targetID string, purpose Purpose, driverName, dsn string) error

+ func RegisterDBTarget(id, driverName, dsn string) error

+ func TargetIDForDSN(driverName, dsn string) (string, bool)

+ type DSNFeatures struct

+ InterpolateParams bool

+ MultiStatements bool

+ ParseTime bool

+ func Features(id string) (DSNFeatures, bool)

type Frozen

+ CutShort bool

+ type GenerationCollector struct

+ func NewGenerationCollector(store *Store) *GenerationCollector

+ func (c *GenerationCollector) BeginBoundary(ctx context.Context, runID string, ep runctl.Epoch) (runctl.BoundaryResult, error)

+ func (c *GenerationCollector) Collect(h runctl.GenerationHandle) (any, error)

+ func (c *GenerationCollector) Drain(ctx context.Context, h runctl.GenerationHandle) error

+ func (c *GenerationCollector) Freeze(ctx context.Context, runID string, ep runctl.Epoch) (runctl.BoundaryResult, error)

+ func (c *GenerationCollector) Name() string

+ func (c *GenerationCollector) Release(h runctl.GenerationHandle)

+ type Purpose string

+ const PurposeApp

+ const PurposeExplain

+ const PurposeStats

+ type Querier interface

+ ExecContext func(ctx context.Context, query string, args ...any) (sql.Result, error)

+ QueryContext func(ctx context.Context, query string, args ...any) (Rows, error)

+ QueryRowContext func(ctx context.Context, query string, args ...any) Row

+ type Row interface

+ Err func() error

+ Scan func(dest ...any) error

+ type Rows interface

+ Close func() error

+ Columns func() ([]string, error)

+ Err func() error

+ Next func() bool

+ Scan func(dest ...any) error

type Store

+ func (s *Store) RotateContext(ctx context.Context) Frozen

+ func (s *Store) SetRotateDrainBudget(budget time.Duration)

+ type TargetInfo struct

+ Display string

+ Driver string

+ ID string

+ Purposes []Purpose

+ Schema string

+ func Target(id string) (TargetInfo, bool)

+ func Targets() []TargetInfo

Aug 3, 2026

Changes in this version

+ func FirstConn() (driverName, dsn string, ok bool)

+ type Frozen struct

+ Entries []agg.Entry

+ Generation int64

+ type Store struct

+ func NewStore(maxKeys int) *Store

+ func (s *Store) CurrentGeneration() int64

+ func (s *Store) Observe(query string, duration time.Duration)

+ func (s *Store) ObserveResult(query string, duration time.Duration, failed bool)

+ func (s *Store) Reset()

+ func (s *Store) Rotate() Frozen

+ func (s *Store) Snapshot() []agg.Entry

Aug 3, 2026

Changes in this version

+ const DriverSuffix

+ var Default = agg.NewTable(agg.DefaultMaxKeys)

+ func Register(names ...string) error