wal

package

v1.0.4 Latest Latest Go to latest Published: Mar 12, 2026 License: MIT Imports: 9 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

WAL Write-Ahead Log实现

func NewWAL(path string) (*WAL, error)

NewWAL 创建新的WAL

func (w *WAL) Close() error

Close 关闭WAL

func (w *WAL) Recover() ([]*types.Vector, []string, error)

Recover 从WAL恢复数据

func (w *WAL) Truncate() error

Truncate 清空WAL文件

func (w *WAL) WriteBatch(vectors []*types.Vector, ids []string) error

WriteBatch 写入批量操作记录

func (w *WAL) WriteCheckpoint() error

WriteCheckpoint 写入检查点记录

func (w *WAL) WriteDelete(id string) error

WriteDelete 写入删除记录

func (w *WAL) WriteInsert(vec *types.Vector) error

WriteInsert 写入插入记录

type WALRecord struct {
	Type      WALRecordType
	Timestamp int64
	Data      []byte
}

WALRecord WAL记录

type WALRecordType uint8

WALRecordType WAL记录类型

const (
	WALInsert WALRecordType = iota + 1
	WALDelete
	WALBatch
	WALCheckpoint
)