README
¶
minidb
連載「DBRE への道」第 3 部で作っている、教材用の自作データベース minidb です。本リポジトリは 第 18 回 時点のコードにあたります。
第 18 回時点では、次のところまでを実装しています。
- ページ — 固定長 8KB（PostgreSQL に合わせた
PageSize）のバイト列。 - スロット付きページ — ページ内に可変長レコードを詰め、削除跡を
compactで回収する。 - ディスクマネージャ — ファイルをページ単位で読み書きし、ページ番号で位置を決める。
- ヒープファイルと全件走査 — ページを並べてレコードを溜め、全ページ・全スロットを順にたどる Seq Scan 相当の走査を行う。
- バッファプール — 限られたフレームにページを載せ、ヒットならディスクへ行かずに返す。clock で置換し、書き換えた（dirty な）ページは flush で書き戻す。
- B+tree — キーで RecordID（行の住所、ctid に当たる）を引く索引。ノードを 1 ページとしてバッファプール越しに読み書きする。葉に（キー, RecordID）と次の葉への横ポインタ、内部ノードに仕切りキーと子ページ番号を持つ。挿入で分割（葉は先頭キーを写し上げ、内部は中央キーを押し上げ）、削除で兄弟からの借用・併合・木の縮約を行い、葉の横つながりをたどる順序付き走査もできる。
- MVCC — トランザクション番号（XID）とスナップショットで「いつ何が見えるか」を決める多版同時実行制御。行はバージョンの列として持ち、更新は旧バージョンに削除印（xmax）を付けて新バージョンを足す。Begin 時点で進行中だったトランザクションや未確定の変更は見えず、スナップショット分離を満たす。どの現役トランザクションからも見えなくなった不要タプル（dead version）を数える
DeadVersionsも持ち、これが第 14 回の VACUUM が回収する対象になる。 - クエリ処理 — Volcano モデルのイテレータ（開く・一件出す・閉じるの三つで揃えた処理段）を積み重ね、てっぺんから一件ずつ引く実行器。表を頭から読む
SeqScanは第 12 回の可視性をくぐらせ、見える行だけを返す。条件で振り分けるFilter、要る列だけ残すProjectを上に重ね、Runでてっぺんから尽きるまで引くと、SELECT name FROM users WHERE age > 30が表を一周しながら一件ずつ流れる。途中に全件を抱えないのが基本で、PostgreSQL の EXPLAIN に出るあのインデントされた木と同じ積み方になる。 - VACUUM と番号の周回 — 書き換えや削除で残った古い版を実際に表から取り除く回収。回収してよい境界は、いちばん古い現役のトランザクション（
OldestActive）が決め、それより前に消された版だけをVacuumが捨てて行を詰め直す。古いトランザクションが一本でも開いていると境界がそこで止まり、回収できないまま版が溜まる。あわせて、トランザクション番号が 32 ビットで一周すると過去が未来に見える「周回」を、前後を大小ではなく距離（int32(a-b)の符号）で決めるxidPrecedesの小さなモデルで再現し、古い行の作成番号を特別なFrozenXIDに置き換えるfreeze（凍結）で、一周しても過去のまま見え続けるようにする。PostgreSQL の autovacuum が背後で回している、回収と凍結の二つの仕事に当たる。 - EXPLAIN とプランナ — 同じ等値条件に対する全件走査と索引走査に費用の数字をつけ、安いほうの実行の木を選ぶ費用ベースのプランナ。第 10 回の B+tree を列の値から行 ID への索引にした
IndexScanを足し、全件走査と同じ三つの約束（開く・一件出す・閉じる）で差し替えられるようにする。当たる行数は列の異なり数から見積もり（Stats/estimateRows、一意な列なら一行、二種類しかない列なら半分）、順番読み 1 件を 1.0・索引経由 1 件を 4.0（PostgreSQL のseq_page_costとrandom_page_costの既定比）として費用を比べる。PlanEqualsは一意なidには Index Scan を、二種類しかないcityには索引があっても Seq Scan を選ぶ。索引が使われないのは壊れているからではなく、当たる行が多すぎて拾い読みより全件順読みが安いと見積もりが言うから。PlanのCostとEstRows、Explainの一行は、PostgreSQL のEXPLAINに出る cost と rows そのもの。 - チューニングの原理 — 限られたメモリをバッファプールと接続でどう分けるかを、手元の計測で裏づける回。第 9 回のバッファプールに参照列を流してヒット率を測る
MeasureHitRateと、よく触る一部に参照を集めた偏りのある参照列を作るLocalReferencesで、容量を増やすほどヒット率は上がるが、よく触る一部が収まったあとは伸びが鈍ることを数で見せる（容量 2 で 0.16、10 で 0.65、40 で 0.91、100 で 0.98）。容量を決める基準は、全データ量ではなく、よく触る一部の大きさ。あわせて、接続ごとにプロセスとメモリを持つ PostgreSQL をBackendMemory（メモリは接続数に比例）で、接続プール（PgBouncer 相当）が奥の接続を上限に束ねて総メモリを頭打ちにするさまをPoolingCapsBackends（千接続を五十に、10000 MiB を 500 MiB に）でモデル化する。shared_buffersの効きはpg_stat_databaseのヒット率で測り、work_memは接続数との積で見て、接続は増やす前にプールで絞る、という運用判断につながる。 - 観測（USE と RED） — 測れる値が多すぎる
pg_stat_*を、二つの型に落として読む回。処理は RED（流量・失敗・所要時間）で、実行のたびに所要時間と成否を積むREDStatがCount・ErrorRate・AvgDurationを返す。資源は USE（使用率・飽和・エラー）で、バッファプールをBufferPoolUSE（使用率＝載っているページ数／フレーム数、飽和＝第 16 回のミス率）、表をStorageUSE（飽和＝生きた版に対する不要タプルの割合、第 14 回の回収が止まると上がりVacuumで下がる）で表す。使用率はバッファプールが動けば満杯で 1 に張りつき詰まりを表さないので、見るのは飽和（取りこぼし・待ち・溜まり）。PostgreSQL では RED をpg_stat_statementsのcalls・mean_exec_timeとxact_rollbackに、USE をblks_readの割合・n_dead_tupの比・待ちの数に割り当て、RED で処理の異常に気づいて USE で詰まった資源にたどり着く、という読む順に結びつく。 - 壊れる前提の運用（PITR と SLO） — どれだけ観測しても、いつかは壊れる。壊れたとき何を失い、どれだけで戻すかを、壊れる前に決めておく連載最終回。第 11 回の WAL を先頭からある時点まで適用して止める
RecoverUntil（PITR の骨格）と、いまどこまで進んだかの目印を返すWALLength（PostgreSQL の LSN に当たる）で、誤った上書きの手前まで巻き戻せることを示す。同じログを最後まで適用すれば誤りごと再現し、targetで止めれば手前に戻る。止める場所を変えるだけで間違いの前後を選べるのが PITR。レプリケーションはこれを止めずに standby へ流し続ける同じ WAL 適用の連続版で、PITR が時間の軸で「どこまで」を選ぶのに対し、空間の軸で「どこで」系を分ける。あわせて、守ると約束した可用率から止まってよい時間を出すErrorBudget（99.9% を 30 日で守るなら約 43 分）と、使った停止を引いた残りを返すBudgetRemainingで、信頼性を感覚ではなく残高で語る。PostgreSQL では PITR はベースバックアップと WAL の保管でできて目標時点まで適用し、レプリケーションの遅れはpg_stat_replication（非同期で失いうる量）で見え、失ってよい量（RPO）と戻す時間（RTO）から同期・非同期や standby の温め方を逆算する。バックアップは、戻せて初めてバックアップ。
必要なもの
- Go 1.26 以降
試し方
git clone https://github.com/engineers-hub-ltd-in-house-project/minidb.git
cd minidb
# テスト
go test ./...
# デモ（一時ファイルに 1000 件入れて全件走査する）
go run ./cmd/minidb
コマンドとして手元に入れて試すこともできます。
go install github.com/engineers-hub-ltd-in-house-project/minidb/cmd/minidb@latest
minidb
実際の出力
go test ./... -v の出力:
=== RUN TestBTreeInsertAndSearch
--- PASS: TestBTreeInsertAndSearch (0.74s)
=== RUN TestBTreeScanIsSorted
--- PASS: TestBTreeScanIsSorted (0.44s)
=== RUN TestBTreeDeleteWithMerge
--- PASS: TestBTreeDeleteWithMerge (0.48s)
=== RUN TestBTreeRandomizedAgainstMap
--- PASS: TestBTreeRandomizedAgainstMap (2.30s)
=== RUN TestBufferPoolWriteReadBack
--- PASS: TestBufferPoolWriteReadBack (0.00s)
=== RUN TestBufferPoolEvictionFlushesDirty
--- PASS: TestBufferPoolEvictionFlushesDirty (0.03s)
=== RUN TestBufferPoolAllPinnedReturnsError
--- PASS: TestBufferPoolAllPinnedReturnsError (0.01s)
=== RUN TestSlottedPageInsertGet
--- PASS: TestSlottedPageInsertGet (0.00s)
=== RUN TestSlottedPageDeleteAndReuse
--- PASS: TestSlottedPageDeleteAndReuse (0.00s)
=== RUN TestHeapFileInsert1000AndScan
heap_test.go:111: inserted 1000 records across 2 pages, scan returned 1000
--- PASS: TestHeapFileInsert1000AndScan (1.78s)
=== RUN TestSeqScanVisibility
--- PASS: TestSeqScanVisibility (0.00s)
=== RUN TestFilter
--- PASS: TestFilter (0.00s)
=== RUN TestProjectAndPipeline
--- PASS: TestProjectAndPipeline (0.00s)
=== RUN TestPlannerPicksIndexForSelective
--- PASS: TestPlannerPicksIndexForSelective (0.35s)
=== RUN TestPlannerPicksSeqForNonSelective
--- PASS: TestPlannerPicksSeqForNonSelective (0.36s)
=== RUN TestPlannerFallsBackWithoutIndex
--- PASS: TestPlannerFallsBackWithoutIndex (0.34s)
=== RUN TestPlanExplainShowsChoice
--- PASS: TestPlanExplainShowsChoice (0.34s)
=== RUN TestHitRateRisesWithDiminishingReturns
tuning_test.go:47: hit rate: pool=2 0.159, 10 0.652, 40 0.908, 100 0.980
--- PASS: TestHitRateRisesWithDiminishingReturns (0.33s)
=== RUN TestPoolingCapsBackendMemory
--- PASS: TestPoolingCapsBackendMemory (0.00s)
=== RUN TestREDRecordsRateErrorsDuration
--- PASS: TestREDRecordsRateErrorsDuration (0.00s)
=== RUN TestBufferPoolUSEReflectsFillAndMisses
--- PASS: TestBufferPoolUSEReflectsFillAndMisses (0.33s)
=== RUN TestStorageUSEReflectsDeadTuples
--- PASS: TestStorageUSEReflectsDeadTuples (0.00s)
=== RUN TestPITRRecoversToPointBeforeBadWrite
--- PASS: TestPITRRecoversToPointBeforeBadWrite (0.03s)
=== RUN TestErrorBudget
--- PASS: TestErrorBudget (0.00s)
=== RUN TestVacuumReclaimsDeadVersions
--- PASS: TestVacuumReclaimsDeadVersions (0.00s)
=== RUN TestVacuumBlockedByOldTx
--- PASS: TestVacuumBlockedByOldTx (0.00s)
=== RUN TestXIDWraparoundHidesUnfrozenRow
--- PASS: TestXIDWraparoundHidesUnfrozenRow (0.00s)
=== RUN TestFreezeSurvivesWraparound
--- PASS: TestFreezeSurvivesWraparound (0.00s)
PASS
ok github.com/engineers-hub-ltd-in-house-project/minidb 8.637s
? github.com/engineers-hub-ltd-in-house-project/minidb/cmd/minidb [no test files]
go run ./cmd/minidb の出力:
inserted 1000 records across 2 pages, scan returned 1000
ファイル構成
| ファイル | 役割 |
|---|---|
page.go |
スロット付きページ（ページ内のレコード配置と詰め直し） |
disk.go |
ページの入出力（ファイルをページ単位で読み書き） |
heap.go |
ヒープファイルと全件走査（レコードの置き場所と Seq Scan） |
heap_test.go |
ページ／ヒープファイルのテスト |
buffer.go |
バッファプール（フレーム管理・clock 置換・dirty/flush） |
buffer_test.go |
バッファプールのテスト |
btree.go |
B+tree 索引（探索・挿入・分割・削除・借用・併合・縮約・順序走査） |
btree_test.go |
B+tree のテスト（挿入探索・順序走査・削除併合・ランダム照合） |
mvcc.go |
MVCC（XID・スナップショット・バージョン可視性・dead version の計数） |
mvcc_test.go |
MVCC のテスト（スナップショット分離・自己更新・版分岐・削除可視性・abort・DeadVersions） |
executor.go |
クエリ処理（Volcano モデルのイテレータ：SeqScan・Filter・Project と Run） |
executor_test.go |
クエリ処理のテスト（可視性走査・条件振り分け・三段パイプライン） |
vacuum.go |
VACUUM（不要タプルの回収・OldestActive 境界・32 ビットの周回モデルと凍結） |
vacuum_test.go |
VACUUM のテスト（回収・古い tx による回収停止・周回での消失・凍結での生存） |
planner.go |
EXPLAIN とプランナ（索引走査・異なり数からの行数見積もり・費用比較で安い木を選ぶ） |
planner_test.go |
プランナのテスト（選択性が高い時の索引走査・低い時の全件走査・索引なしの退避・Explain） |
tuning.go |
チューニングの原理（ヒット率の計測・偏りのある参照で容量とヒット率の鈍り・接続に比例するメモリとプールによる頭打ち） |
tuning_test.go |
チューニングのテスト（容量を上げるとヒット率の伸びが鈍る・プールで backend と総メモリが頭打ち） |
metrics.go |
観測（処理を RED／資源を USE で表す・バッファプールの飽和＝ミス率・表の飽和＝不要タプルの割合） |
metrics_test.go |
観測のテスト（RED の積み上げ・プール満杯で使用率 1 と飽和・不要タプルで表の飽和が上下） |
recovery.go |
壊れる前提の運用（WAL をある時点まで適用して止める PITR・目標可用率から止まってよい時間を出すエラーバジェット） |
recovery_test.go |
復旧のテスト（誤上書きの手前まで戻す PITR・目標可用率と期間からエラーバジェットを計算） |
cmd/minidb/main.go |
1000 件入れて全件走査するデモ |
バージョニング
連載の回ごとにタグ（v0.10 のような形）を打って、各回の状態をあとからたどれるようにする方針です。第 18 回時点ではまだタグを打っていません。
注意
これは連載の教材用に、仕組みを追えることを優先した最小実装です。本番用のデータベースではありません。
ライセンス
MIT License. 詳細は LICENSE を参照してください。
Documentation
¶
Index ¶
- Constants
- Variables
- func BackendMemory(connections int, perConnMiB float64) float64
- func BudgetRemaining(objective float64, window, downtime time.Duration) time.Duration
- func ErrorBudget(objective float64, window time.Duration) time.Duration
- func LocalReferences(rng *rand.Rand, total, hot, count int, hotShare float64) []int
- func PoolingCapsBackends(clientConnections, poolSize int) int
- func RecoverInto(walPath string, disk *DiskManager) (int, error)
- func RecoverUntil(walPath string, disk *DiskManager, target int) (int, error)
- func Vacuum(t *MVCCTable, oldestActive XID) int
- func WALLength(walPath string) (int, error)
- type BPlusTree
- type BufferPool
- type DiskManager
- type Filter
- type HeapFile
- type HitStats
- type Index
- type IndexScan
- type MVCCTable
- type Observation
- type Operator
- type Page
- type Plan
- type Planner
- type Project
- type REDStat
- type RecordID
- type SeqScan
- type Snapshot
- type Stats
- type Tuple
- type Tx
- type TxManager
- type USEStat
- type WAL
- type XID
Constants ¶
const FrozenXID = uint32(2)
FrozenXID は、何に対しても過去とみなす特別な番号。 周回の説明のため、64 ビットの XID とは別に、32 ビットの小さなモデルとして閉じてある。
const PageSize = 8192
PageSize は 1 ページの大きさ。PostgreSQL に合わせて 8KB にする。
Variables ¶
var ErrNoFreeFrame = errors.New("no free frame available (all pinned)")
ErrNoFreeFrame は、すべてのフレームが pin されていて、 追い出せるものが一つもないときに返す。
var ErrPageFull = errors.New("page is full")
ErrPageFull はページに空きが足りないときに返す。
var ErrSlotNotFound = errors.New("slot not found")
ErrSlotNotFound は指定したスロットが空、または範囲外のときに返す。
Functions ¶
func BackendMemory ¶
BackendMemory は、接続数と 1 接続あたりのメモリ（MiB）から、見込みの総メモリを返す。 PostgreSQL は接続ごとにプロセスを持つので、メモリは接続数に比例して増える。
func BudgetRemaining ¶
BudgetRemaining は、これまでの停止 downtime を引いた、残りのエラーバジェット。 負になっていたら、約束を破っている。
func ErrorBudget ¶
ErrorBudget は、目標可用率 objective(0 から 1) と期間 window から、許される停止時間を返す。 99.9 パーセントを 30 日で守るなら、許される停止は約 43 分。この 43 分がエラーバジェット。
func LocalReferences ¶
LocalReferences は、偏りのある参照列を作る。 hot 本のページに参照の hotShare を集め、残りを全体へ散らす。 「よく触る一部」と「たまに触る全体」という、現実の偏りの再現。
func PoolingCapsBackends ¶
PoolingCapsBackends は、接続プールを挟んだときの実 backend 接続数を返す。 表側の接続がいくつあっても、backend は poolSize までに収まる。PgBouncer の効き目。
func RecoverInto ¶
func RecoverInto(walPath string, disk *DiskManager) (int, error)
RecoverInto は、ログを先頭から読み、各ページの中身をデータファイルへ書き戻す。 途中で切れた末尾や、壊れたレコードに当たったら、そこで安全に止める。 適用したレコード数を返す。
func RecoverUntil ¶
func RecoverUntil(walPath string, disk *DiskManager, target int) (int, error)
RecoverUntil は、ログを先頭から target 個のレコードまで適用して止める。 target の先にレコードが残っていても、適用しない。ある時点まで進めて、そこで止める。 これが PITR（point-in-time recovery）の骨格。誤った操作の手前まで巻き戻せる。
Types ¶
type BPlusTree ¶
type BPlusTree struct {
// contains filtered or unexported fields
}
BPlusTree は、バッファプールの上に積んだ B+tree の索引。 キー（int64）から RecordID（行の住所、PostgreSQL の ctid に当たる）を引く。
func NewBPlusTree ¶
func NewBPlusTree(bp *BufferPool) (*BPlusTree, error)
NewBPlusTree は空の B+tree を作る。葉だけの根を 1 ページ確保する。 根のページ番号はメモリ上にだけ持つ。再オープン時に引き継ぐための メタページは、まだ作らない（次回以降）。
type BufferPool ¶
type BufferPool struct {
// contains filtered or unexported fields
}
BufferPool は、限られた数のフレームを持ち、ディスクのページをメモリに載せる。 同じページが要るときは、ディスクへ行かずにメモリから返す。
func NewBufferPool ¶
func NewBufferPool(disk *DiskManager, size int) *BufferPool
NewBufferPool は、size 枚のフレームを持つバッファプールを作る。
func (*BufferPool) FetchPage ¶
func (bp *BufferPool) FetchPage(pageID int) (*Page, error)
FetchPage は、ページをメモリに用意して返し、pin する。 すでにメモリにあれば、それを返す（ヒット）。なければディスクから読む（ミス）。
func (*BufferPool) FlushAll ¶
func (bp *BufferPool) FlushAll() error
FlushAll は、書き換えられた全フレームをディスクへ書き戻す。 PostgreSQL のチェックポイントに当たる動き。
func (*BufferPool) FlushPage ¶
func (bp *BufferPool) FlushPage(pageID int) error
FlushPage は、指定ページが書き換えられていれば、ディスクへ書き戻す。
func (*BufferPool) NewPage ¶
func (bp *BufferPool) NewPage() (int, *Page, error)
NewPage は、ディスクに新しいページを足し、それをメモリに載せて返す（pin 済み）。
func (*BufferPool) Unpin ¶
func (bp *BufferPool) Unpin(pageID int, dirty bool)
Unpin は、ページの使用を終える。dirty が true なら、書き換えた印をつける。
type DiskManager ¶
type DiskManager struct {
// contains filtered or unexported fields
}
DiskManager はページ単位でファイルを読み書きする。 ファイルを PageSize ごとに区切り、ページ番号で位置を決める。
func (*DiskManager) AllocatePage ¶
func (d *DiskManager) AllocatePage() (int, error)
AllocatePage は末尾に空のページを足し、その番号を返す。
func (*DiskManager) NumPages ¶
func (d *DiskManager) NumPages() (int, error)
NumPages はファイルが今いくつのページ分あるかを返す。
type Filter ¶
type Filter struct {
// contains filtered or unexported fields
}
Filter は条件で振り分ける段。合うものだけを上へ通す。
type HeapFile ¶
type HeapFile struct {
// contains filtered or unexported fields
}
HeapFile はページを並べてレコードを溜める、いちばん素朴な置き場所。
type HitStats ¶
HitStats は、ページ参照のヒットとミスを数えた結果。
func MeasureHitRate ¶
func MeasureHitRate(disk *DiskManager, size int, refs []int) (HitStats, error)
MeasureHitRate は、ページ参照列 refs を、容量 size のプールに流して、ヒット率を測る。 すでにプールに載っていればヒット、なければディスクから読むのでミス。 各参照はすぐ離す。次の参照で追い出せるようにするため。
func ObserveBuffer ¶
func ObserveBuffer(bp *BufferPool, refs []int) (HitStats, error)
ObserveBuffer は、参照列を bp に流し、ヒット統計を返す。 bp は呼び出し側が保持するので、流したあとの使用率を BufferPoolUSE で読める。
type Index ¶
type Index struct {
// contains filtered or unexported fields
}
Index は、ある列の値から行 ID への索引。第 10 回の B+tree をそのまま使う。 MVCC 表では行のありかは rowID そのものなので、RecordID にはその rowID を入れる。
type IndexScan ¶
type IndexScan struct {
// contains filtered or unexported fields
}
IndexScan は、索引でキーを一点引きし、該当する行だけを返す段。 全件を舐めない。索引が指した行 ID の版だけを、可視性をくぐらせて返す。
func NewIndexScan ¶
NewIndexScan は、表・トランザクション・索引・引くキーを束ねた走査を作る。
type MVCCTable ¶
type MVCCTable struct {
// contains filtered or unexported fields
}
MVCCTable は、行ごとにバージョンの列を持つ表。 書き換えは、古いバージョンを消したことにして、新しいバージョンを足す。
func NewMVCCTable ¶
func NewMVCCTable() *MVCCTable
func (*MVCCTable) DeadVersions ¶
DeadVersions は、どのトランザクションから見ても、もう要らないバージョンの数を返す。 消した番号が、いちばん古い現役のトランザクションより前なら、誰からも見えない。 これが第 14 回の VACUUM が回収する対象、いわゆる不要タプルに当たる。
type Observation ¶
type Observation struct {
Buffer USEStat // 資源：バッファプール
Storage USEStat // 資源：表（不要タプルの溜まり）
Query REDStat // 処理：クエリ
}
Observation は、ある時点の観測をひとまとめにしたもの。 資源は USE、処理は RED。定期的に取れば、状態の移り変わりが読める。
type Page ¶
type Page struct {
// contains filtered or unexported fields
}
Page はスロット付きページ。固定長 PageSize のバイト列として持つ。 レイアウトは、先頭からヘッダ、続いてスロット配列が前へ伸び、 レコード本体がページの末尾から前へ向かって積まれる。
type Plan ¶
type Plan struct {
Node string // "Seq Scan" か "Index Scan"
EstRows int
Cost float64
// contains filtered or unexported fields
}
Plan は、選ばれた計画。走査の種類、見積もり行数、費用、そして実行する段。
type Planner ¶
type Planner struct {
// contains filtered or unexported fields
}
Planner は、表と統計と使える索引を持ち、条件から安い計画を選ぶ。
func NewPlanner ¶
NewPlanner は、表・統計・列ごとの索引を束ねたプランナを作る。
type Project ¶
type Project struct {
// contains filtered or unexported fields
}
Project は列を絞る段。要る列だけを残す。
func NewProject ¶
NewProject は下の段と残す列を束ねた絞り込みの段を作る。
type REDStat ¶
type REDStat struct {
Count int // 流量：処理した数
Errors int // 失敗：失敗した数
TotalTime time.Duration // 所要時間の合計
}
REDStat は、処理（リクエスト）の観測。Rate, Errors, Duration。
func (REDStat) AvgDuration ¶
AvgDuration は、1 件あたりの平均所要時間。
type SeqScan ¶
type SeqScan struct {
// contains filtered or unexported fields
}
SeqScan は表を頭から読む段。第 12 回の可視性をくぐらせ、見える行だけを返す。 PostgreSQL の Seq Scan に当たる。
func NewSeqScan ¶
NewSeqScan は表とトランザクションを束ねた走査の段を作る。
type Snapshot ¶
type Snapshot struct {
// contains filtered or unexported fields
}
Snapshot は、ある時点での「何が見えるか」を固定したもの。 xmax 以上の番号は未来。xip は、その時点で進行中だった番号。どちらも見えない。
type Stats ¶
Stats は、計画を立てるための見積もり材料。表の行数と、列ごとの異なり数。 PostgreSQL では ANALYZE が集めて pg_statistic に貯める情報に当たる。
type Tx ¶
type Tx struct {
// contains filtered or unexported fields
}
Tx は、一つのトランザクション。自分の番号とスナップショットを持つ。
type TxManager ¶
type TxManager struct {
// contains filtered or unexported fields
}
TxManager は、トランザクション番号を配り、各番号の状態を覚える。
func NewTxManager ¶
func NewTxManager() *TxManager
func (*TxManager) OldestActive ¶
OldestActive は、いま回収してよい境界を返す。 いちばん古い現役のトランザクション番号。これより前に消された版は、もう誰からも見えない。 進行中が一つも無ければ、次に配る番号を返す（いま消えている版は全部回収してよい）。
type USEStat ¶
type USEStat struct {
Utilization float64 // 使用率：資源のうち使っている割合。0 から 1
Saturation float64 // 飽和：処理しきれず待たされている度合い
Errors int // エラー：資源が返した失敗の数
}
USEStat は、資源の観測。Utilization, Saturation, Errors。
func BufferPoolUSE ¶
func BufferPoolUSE(bp *BufferPool, s HitStats) USEStat
BufferPoolUSE は、バッファプールを資源として USE で表す。 使用率 = 載っているページ数 / フレーム数。飽和 = ミス率。ミスが多いほど、容量に働きが詰まっている。
func StorageUSE ¶
StorageUSE は、表を資源として USE で表す。 飽和 = 不要タプルの割合。回収が追いつかず溜まっているほど高い。第 14 回の回収の遅れが、ここに出る。
type WAL ¶
type WAL struct {
// contains filtered or unexported fields
}
WAL は、変更を先に記録する追記専用のログ。 データページをディスクに書く前に、まずここへ書いて fsync する。 これが先行書き込み（write-ahead）。落ちても、ログから復旧できる。
func (*WAL) AppendPageImage ¶
AppendPageImage は、ページの新しい中身をログに追記し、fsync する。 1 レコードの形: [payloadLen uint32][crc uint32][pageID int32][image ...] crc を付けるのは、末尾が途中で切れた壊れたレコードを、復旧時に見分けるため。
Source Files
Directories