workload

type Event struct {
	// Time is the trace timestamp in nanoseconds.
	Time int64
	// Goroutine is the emitting goroutine. GoScript reports one goroutine for
	// every event, so replay orders by Time and correlates by Record IDs.
	Goroutine int64
	// Record is the logical operation.
	Record Record
}

type Op string

type OrderedJournal interface {
	// AppendJournalOrdered journals reference graph changes with write
	// ordering only.
	AppendJournalOrdered(ctx context.Context, adds, removes []block_gc.RefEdge) error
}

type Record struct {
	// Op names the operation.
	Op Op
	// ID identifies the transaction, iterator, read scope, or batch.
	ID uint64
	// Parent identifies the transaction that owns an iterator.
	Parent uint64
	// Size is the operation's length, count, or result, as its Op documents.
	Size int64
	// Key is the key, key prefix, or binary block reference.
	Key []byte
}

type Replay struct {

	// Ordered commits every key-value commit that writes no shared object head,
	// and every journal append, with write ordering only, so only block Sync
	// and head commits flush.
	Ordered bool
	// contains filtered or unexported fields
}

type Result struct {
	// Ops is the number of records replayed.
	Ops int
	// Wall is the replay's elapsed time.
	Wall time.Duration
	// Latency holds each timed operation's latencies in replay order: commit,
	// sync, put, put-batch, get-block, journal-append, and journal-replay.
	Latency map[Op][]time.Duration
	// CommitErrors counts commits the target rejected. A replay that commits
	// transactions the recording interleaved may conflict where it did not.
	CommitErrors int
	// OrderedCommits counts commits and journal appends made with write
	// ordering only.
	OrderedCommits int
	// BlockBytes is the payload written by block puts.
	BlockBytes int64
	// ValueBytes is the payload written by key-value sets.
	ValueBytes int64
}

type Target interface {
	kvtx.Store
	block.StoreOps
	// AppendJournal durably journals reference graph changes.
	AppendJournal(ctx context.Context, adds, removes []block_gc.RefEdge) error
	// ReplayJournal passes every journaled change to apply, then removes it.
	ReplayJournal(ctx context.Context, apply func(adds, removes []block_gc.RefEdge) error) error
}