compactioncontinuity

type BarrierConfig struct {
	Timeout time.Duration
}

type CapsuleConfig struct {
	MaxTokens int
	MaxBytes  int
}

type Config struct {
	Preserve  PreserveConfig
	Extractor ExtractorConfig
	Worker    WorkerConfig
	Barrier   BarrierConfig
	Capsule   CapsuleConfig
	Source    SourceConfig
	Result    ResultConfig
	Failure   FailureConfig

	// Flattened aliases retain the D18 operator-facing names and make retention
	// policy explicit to callers. Normalize keeps aliases equal to their group.
	BarrierTimeout   time.Duration
	PendingResultTTL time.Duration
	MaxCapsuleTokens int
	SourceTTL        time.Duration
	FailureMode      string
	BranchTTL        time.Duration
	MaxBranchEntries int
}

type ExtractorConfig struct {
	Enabled         bool
	Route           string
	Inherit         bool
	Timeout         time.Duration
	MaxInputTokens  int
	MaxOutputTokens int
	// These aliases mirror the original D18 shape. Worker is the canonical
	// composition group; both views are kept equal after normalization.
	MaxConcurrency int
	QueueCapacity  int
}

type FailureConfig struct {
	Mode string
}

type InjectionTarget struct {
	BoundaryKey     string
	CapsuleRevision uint64
}

type InjectionWatermark struct {
	BranchBinding   string
	BoundaryKey     string
	CapsuleRevision uint64
}

type ParentBranch struct {
	Binding string
	TraceID string
	ALegID  string
	BLegID  string
}

type ParentPort interface {
	Capture(context.Context, lipapi.Call, compaction.PreservationMeta) (ParentBranch, error)
	CaptureMeta(context.Context, compaction.PreservationMeta) (ParentBranch, error)
	Snapshot(context.Context, ParentBranch) (ParentState, error)
	CommitSource(context.Context, ParentBranch, uint64, []byte, string) (ParentState, error)
	CommitCapsule(context.Context, ParentBranch, uint64, []byte, [32]byte, string) (ParentState, error)
	RecordPendingJob(context.Context, ParentBranch, auxiliary.JobID, uint64) (ParentState, error)
	ValidatePendingJob(context.Context, ParentBranch, auxiliary.JobID) (ParentState, error)
	CommitCapsuleForJob(context.Context, ParentBranch, auxiliary.JobID, string, uint64, []byte, [32]byte, string) (ParentState, error)
	RecordPreviewIntent(context.Context, ParentBranch, PreviewIntent) (ParentState, error)
	BindPreviewIntent(context.Context, ParentBranch, string, string) (ParentState, error)
	SetPendingInjection(context.Context, ParentBranch, InjectionTarget) (ParentState, error)
	ValidateInjection(context.Context, ParentBranch, InjectionTarget) (ParentState, error)
	CommitReleasedInjection(context.Context, ParentBranch, InjectionWatermark) (ParentState, error)
}

type ParentState struct {
	Revision                  uint64
	CapsuleJSON               []byte
	CapsuleDigest             [32]byte
	SourceJSON                []byte
	SourceHighWatermark       string
	PendingJobID              auxiliary.JobID
	PendingJobTargetRevision  uint64
	PendingJobBranchBinding   string
	PendingPreviewIntent      *PreviewIntent
	PendingInjection          *InjectionTarget
	LastReleasedInjection     *InjectionWatermark
	LastCompactionTransaction string
}

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

type Prerequisites struct {
	DetectorPreview   bool
	DetectorCommit    bool
	BranchCoordinator bool
	BackgroundAux     bool
}

type PreserveConfig struct {
	Plan                 bool `yaml:"plan"`
	UserDecisions        bool `yaml:"user_decisions"`
	Constraints          bool `yaml:"constraints"`
	Rationale            bool `yaml:"rationale"`
	RejectedAlternatives bool `yaml:"rejected_alternatives"`
}

type PreviewIntent struct {
	Key                  string
	TargetSourceRevision uint64
}

type ResultConfig struct {
	TTL      time.Duration
	MaxBytes int
	MaxCount int
}

type SourceConfig struct {
	TTL      time.Duration
	MaxBytes int
}

type WorkerConfig struct {
	MaxConcurrency int
	QueueCapacity  int
}