eventlog

type AuditEvent = statedb.AuditEvent

type AuditFilter = statedb.AuditFilter

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

type ReplayOptions struct {
	FromID  int64               // 0 or 1 = entire history; >1 = only events with id >= FromID
	OnEvent func(ev AuditEvent) // optional per-event callback (e.g. progress)
	StopAt  int64               // 0 = no upper bound; otherwise stop after id == StopAt

	// AllowTruncated permits a replay that starts after a retention prune
	// (Task 20218).
	//
	// Replay rebuilds state by applying every mutation in order, so it is only
	// complete if it starts at the first one. Once a prefix has been pruned,
	// the rows before the boundary live in a sealed archive and not in this
	// database — a replay from "the beginning" would quietly produce a partial
	// database that looks whole. Refusing is the safe default; this opts into
	// the partial rebuild deliberately, which is the right call when the tail
	// is all the operator wanted.
	AllowTruncated bool
}

type ReplayReport struct {
	DestPath     string
	EventsRead   int
	TasksWritten int
	StepsWritten int
	ConfigWrites int
	Skipped      int
	BreakAtID    int64 // first id whose payload could not be applied (0 = none)
	BreakReason  string
	StartedAt    time.Time
	FinishedAt   time.Time

	// Gaps counts the audit.gap rows replayed past, and GapEvents the events
	// they record as never appended (Task 20404). Mutations among those are
	// in no row, so a rebuild across a gap can be missing them.
	Gaps      int
	GapEvents int64

	// Truncated reports that a retention prune removed events older than the
	// replay's starting point, so the rebuild is of the surviving tail rather
	// than of the whole history. Set only when the caller passed
	// AllowTruncated; without it a truncated trail is an error.
	Truncated          bool
	TruncatedThroughID int64
	ArchivePath        string
}

type TailOptions struct {
	FromID    int64         // start streaming events with id >= FromID (1 = beginning)
	Follow    bool          // when true, keep polling for new events; when false, return at head
	Poll      time.Duration // follow-mode polling interval (default 500ms)
	Filter    AuditFilter   // additional filtering (Order/Limit/Offset/FromID are overridden)
	BatchSize int           // events per query (default 200, capped at 5000)
}

type TaskRunStory = statedb.TaskRunStory

type TaskStory = statedb.TaskStory

type VerifyReport = statedb.AuditVerifyReport