trace

type GetPayload struct {
	ColumnFamilyID uint32
	Key            []byte
}

type Header struct {
	Magic   uint64
	Version uint32
}

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

type Record struct {
	Timestamp time.Time
	Type      RecordType
	Payload   []byte
}

type RecordType uint8

type ReplayHandler interface {
	// HandleWrite handles a write operation
	HandleWrite(cfID uint32, batchData []byte) error
	// HandleGet handles a get operation
	HandleGet(cfID uint32, key []byte) error
	// HandleIterSeek handles an iterator seek operation
	HandleIterSeek(cfID uint32, key []byte) error
	// HandleFlush handles a flush operation
	HandleFlush() error
	// HandleCompaction handles a compaction operation
	HandleCompaction() error
}

type ReplayHandlerV2 interface {
	ReplayHandler
	// HandleWriteWithSeqno handles a write operation with its assigned sequence number.
	// seqno is the sequence number assigned by the DB after the write completed.
	// For version 1 traces, seqno will be 0.
	HandleWriteWithSeqno(cfID uint32, seqno uint64, batchData []byte) error
}

type ReplayStats struct {
	TotalRecords    uint64
	SuccessfulOps   uint64
	FailedOps       uint64
	Duration        time.Duration
	OperationCounts map[RecordType]uint64
}

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

type ReplayerOptions struct {
	// PreserveTiming delays operations to match original timing
	PreserveTiming bool

	// SpeedMultiplier speeds up or slows down replay (1.0 = original speed)
	SpeedMultiplier float64
}

type TraceStats struct {
	TotalRecords uint64
	Duration     int64 // nanoseconds between first and last record
	RecordCounts map[RecordType]uint64
}

type WritePayload struct {
	ColumnFamilyID uint32
	SequenceNumber uint64 // Seqno assigned by DB after Write() - for seqno-prefix verification
	Data           []byte // WriteBatch data
}

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

type WriterOption func(*Writer)