菜单
Use when instrumenting liteorm with metrics, tracing, or audit around every executed statement — the Observer seam (liteorm.WithObserver + QueryEvent). Distinct from slog statement logging (the logging skill), which rides the same seam.
用 Codex 或 Claude 帮你安装 复制这段 Prompt，粘贴到 Codex、Claude 或其他助手里，让它检查 Skill 页面并帮你完成安装。
基于 SOC 职业分类
| name | observability |
| description | Use when instrumenting liteorm with metrics, tracing, or audit around every executed statement — the Observer seam (liteorm.WithObserver + QueryEvent). Distinct from slog statement logging (the logging skill), which rides the same seam. |
LiteORM invokes an observer around every statement, on a *liteorm.DB and on any transaction started from it. Its own slog statement logging rides the same event, so an observer sees exactly what the logger sees: the SQL, bind args, elapsed time, rows affected, and error. This is the hook for Prometheus metrics, OpenTelemetry traces, or an audit sink.
type Observer interface {
BeforeQuery(ctx context.Context, ev *liteorm.QueryEvent) context.Context
AfterQuery(ctx context.Context, ev *liteorm.QueryEvent)
}
BeforeQuery runs before the statement and may return a derived context carrying per-statement state (an open span, a start marker); LiteORM threads it into the execution and back to AfterQuery, which runs after with Duration/Rows/Err filled in. Register at construction — observers compose as an onion (before in order, after in reverse):
db, _ := sqlite.Open("app.db", liteorm.WithObserver(metrics, tracing))
WithObserver(o ...Observer) works with every backend's Open. QueryEvent carries Op (liteorm.MsgQuery for a SELECT / RETURNING read-back, liteorm.MsgExec for INSERT/UPDATE/DELETE/DDL), SQL, Args, Start, Duration, Rows (rows-affected for an exec; -1 for a query), and Err.
BeforeQuery returns ctx unchanged; count and time in AfterQuery. Label by ev.Op only — it's one of two constants, so low-cardinality.
func (m metrics) BeforeQuery(ctx context.Context, _ *liteorm.QueryEvent) context.Context { return ctx }
func (m metrics) AfterQuery(_ context.Context, ev *liteorm.QueryEvent) {
status := "ok"
if ev.Err != nil { status = "error" }
m.count.WithLabelValues(ev.Op, status).Inc()
m.latency.WithLabelValues(ev.Op).Observe(ev.Duration.Seconds())
}
Open a span in BeforeQuery, return the span-bearing context, end it in AfterQuery (trace.SpanFromContext recovers it). Because the span lives on the threaded context, the DB span nests under the incoming request span automatically.
func (t tracing) BeforeQuery(ctx context.Context, ev *liteorm.QueryEvent) context.Context {
ctx, _ = t.tracer.Start(ctx, "db."+ev.Op, trace.WithSpanKind(trace.SpanKindClient))
return ctx
}
func (t tracing) AfterQuery(ctx context.Context, ev *liteorm.QueryEvent) {
span := trace.SpanFromContext(ctx)
if ev.Err != nil { span.RecordError(ev.Err) }
span.End()
}
ev.Args is NEVER redacted for observers. WithSQLArgs(false) redacts the log only; an observer always gets the real bind values. Redact in the observer before forwarding to a metrics/trace/audit sink. See the security guide.ev.SQL or ev.Args — unbounded cardinality. ev.Op is the only safe label.Observer, QueryEvent, WithObserver). Guide: docs/guides/observability.md.Use when storing large or growing binary content (files, uploads, blobs) in SQLite as streamed io.ReaderAt/io.WriterAt instead of loading whole []byte — the orm.LOB field + liteorm.org/dialect/sqlite/lob.
Use when working with liteorm's declarative orm front-end — model structs and tags, AutoMigrate, the orm.Repo, associations (Load/Attach), hooks, or soft delete.
Use when liteorm code behaves unexpectedly, or proactively before writing it, to avoid the common gotchas around loading, soft delete, types, and dialect-gated operators.
Use when migrating a gorm codebase to liteorm — running models on gorm tags as-is, rewriting them to native orm tags, and adjusting for what differs.
Use when adding vector (sqlite-vec), full-text (FTS5), or hybrid RRF search to liteorm's SQLite backend.
Use when capturing, applying, inverting, or concatenating SQLite changesets (the SESSION extension) for audit logs, one-way replication, or undo — the liteorm.org/dialect/sqlite/changeset package. SQLite backend only.