ledger

type AtomicAdmissionStore interface {
	ExecutionLedger
	AdmitExecutionAtomic(context.Context, DurableAdmission) (ExecutionRecord, bool, error)
}

type DurableAdmission struct {
	Artifact        ExecutionArtifact
	Execution       ExecutionRecord
	FactApplication FactApplication
	Plans           []ExecutionPlanRecord
	Sagas           []workflow.CreateSagaRequest
	InitialSteps    []workflow.EnqueueStepRequest
}

type ExecutionArtifact struct {
	GenerationDigest string
	IRDigest         string
	IRBytes          []byte
	Environment      json.RawMessage
	ExecutorManifest json.RawMessage
	FunctionManifest json.RawMessage
	SourceDigest     string
	CompilerMetadata json.RawMessage
	CreatedAt        time.Time
}

type ExecutionLease struct {
	ExecutionID string
	Owner       string
	Token       string
	Deadline    time.Time
	Revision    uint64
}

type ExecutionLedger interface {
	PutArtifact(context.Context, ExecutionArtifact) error
	GetArtifact(context.Context, string) (ExecutionArtifact, error)
	AdmitExecution(context.Context, DurableAdmission) (ExecutionRecord, bool, error)
	GetExecution(context.Context, string) (ExecutionRecord, error)
	GetExecutionByAdmission(context.Context, string) (ExecutionRecord, error)
	SetExecutionState(context.Context, string, uint64, ExecutionState, string) (ExecutionRecord, error)
	LeaseExecutions(context.Context, string, int, time.Duration) ([]ExecutionLease, error)
	FinishExecutionLease(context.Context, ExecutionLease, ExecutionState, string) error
}

type ExecutionPlanRecord struct {
	ExecutionID string
	PlanID      string
	SagaID      string
	Ordinal     int
	State       string
}

type ExecutionRecord struct {
	ExecutionID       string
	AdmissionIdentity string
	RequestHash       string
	Ruleset           string
	Version           string
	TenantNamespace   string
	MergePolicy       string
	GenerationDigest  string
	EffectiveFacts    json.RawMessage
	State             ExecutionState
	Revision          uint64
	RecoveryOwner     string
	RecoveryToken     string
	RecoveryDeadline  time.Time
	LastError         string
	CreatedAt         time.Time
	UpdatedAt         time.Time
	Plans             []ExecutionPlanRecord
}

type ExecutionState string

type FactApplication struct {
	ExecutionID     string
	FactEventID     string
	MergePolicy     string
	Facts           json.RawMessage
	AppliedRevision uint64
}

type RecoveryStats struct {
	Nonterminal       int64
	Blocked           int64
	OldestNonterminal time.Time
	OldestOutbox      time.Time
}

type RecoveryStatsReader interface {
	RecoveryStats(context.Context) (RecoveryStats, error)
}