execution

Documentation

Index

• type ExecutionStats
• type Options
  • func DefaultOptions() Options
  • func FromEnv(base Options) (Options, error)
  • func (o Options) Normalize() Options
  • func (o Options) Validate() error

Types

type ExecutionStats

type ExecutionStats struct {
	TotalFilesProcessed    int
	TotalBytesProcessed    int64
	WorkersUsed            int
	ContainerAppendCount   int64
	FsyncCount             int64
	ContainerOpenCount     int64
	ContainerCloseCount    int64
	BytesWritten           int64
	BytesRead              int64
	SnapshotMetadataWrites int64
}

ExecutionStats captures aggregated execution diagnostics for one run. This shape is intentionally aggregate-only so it remains stable for benchmarks and CI output.

type Options

type Options struct {
	StoreFolderWorkers int
	PipelineDepth      int
	Deterministic      bool
}

Options defines execution policy knobs used by command flows.

func DefaultOptions

func DefaultOptions() Options

DefaultOptions returns v1.6-equivalent execution behavior.

func FromEnv

func FromEnv(base Options) (Options, error)

FromEnv applies supported environment overrides to base options. Invalid values are rejected to avoid silently enabling risky behavior.

func (Options) Normalize

func (o Options) Normalize() Options

Normalize clamps invalid or unset numeric values to safe defaults.

func (Options) Validate

func (o Options) Validate() error

Validate ensures options are explicitly valid.