reflowstate

type BarrierOutcome uint8

type CollisionKind string

type Config struct {
	Path string

	// ElideRawExecSavepoints is an experimental default-off switch: when true,
	// the write coordinator omits SAVEPOINT/RELEASE around raw writer.exec
	// (SQL statement) mutations. execTx paths always keep savepoints so designed
	// request-local refusals still work. Product default remains false — this is
	// not a recommended production setting. Optional measure-only override:
	// GONIMBUS_REFLOW_ELIDE_RAW_EXEC_SAVEPOINTS=1 (or "true") also enables this
	// when Config does not already set it true. Leave unset for normal use.
	ElideRawExecSavepoints bool
}

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

type UpsertItemParams struct {
	UnitKey        string
	SourceURI      string
	DestURI        string
	SourceKey      string
	DestKey        string
	SourceETag     string
	SourceSize     int64
	Status         string
	Bytes          int64
	Reason         string
	ErrorCode      string
	ErrorMessage   string
	UpdatedAtRFC33 string
}

type WriterStats struct {
	// MaxBatch is the coordinator's admission/coalesce bound (also the exec
	// channel capacity).
	MaxBatch int

	// QueueDepthSamples is how many successful exec admissions contributed a
	// depth sample. QueueDepthSum / QueueDepthSamples is the mean sample.
	// QueueDepthPeak is the maximum sample observed (approximate occupancy).
	QueueDepthSamples int64
	QueueDepthSum     int64
	QueueDepthPeak    int64

	// Admissions counts successful exec-channel enqueues. AdmissionWaitNanos
	// is the sum of admission-select wall times for those enqueues;
	// AdmissionWaitMaxNanos is the max single wait. AdmissionBlocked counts
	// admits whose pre-send depth sample equaled MaxBatch (channel full /
	// backpressured at sample time).
	Admissions            int64
	AdmissionWaitNanos    int64
	AdmissionWaitMaxNanos int64
	AdmissionBlocked      int64

	// Barrier* cover post-enqueue-to-result waits for exec requests only
	// (reads are not counted). Outcome counters partition Barriers.
	Barriers            int64
	BarrierWaitNanos    int64
	BarrierWaitMaxNanos int64
	BarrierOK           int64
	BarrierRefusal      int64
	BarrierWriterFailed int64
	BarrierWriterClosed int64
	BarrierCanceled     int64

	// Batches is the number of write transactions assembled. BatchSizeSum /
	// Batches is mean size in request units (not SQL statements).
	// BatchSizeMax is the largest coalesced batch. Coarse histogram buckets:
	// 1 | 2–8 | 9–32 | 33–128 | 129+.
	Batches          int64
	BatchSizeSum     int64
	BatchSizeMax     int64
	BatchSize1       int64
	BatchSize2To8    int64
	BatchSize9To32   int64
	BatchSize33To128 int64
	BatchSize129Plus int64

	// Commits counts batch write attempts (success and fatal).
	// BatchDuration* is wall time of the full batch write path inside
	// c.commit(batch): BeginTx, per-request SQL/savepoints, and tx.Commit().
	// It is NOT storage COMMIT alone; bind rules must not treat it as
	// SQLite COMMIT sensitivity. CommitFatals counts terminal batch failures.
	// RequestRefusals counts per-request logical refusals on successfully
	// committed batches (distinct from CommitFatals).
	Commits               int64
	BatchDurationNanos    int64
	BatchDurationMaxNanos int64
	CommitFatals          int64
	RequestRefusals       int64

	// SavepointsCreated counts SAVEPOINT statements issued in commit.
	// SavepointsElided counts raw-exec requests that skipped SAVEPOINT/RELEASE
	// when ElideRawExecSavepoints is enabled (experimental).
	SavepointsCreated int64
	SavepointsElided  int64
}