flow

type CompiledFlow struct {
	Name       string
	Priority   int
	Predicates []*schema.Predicate
	Program    *Program
	FactPaths  []string
	SourceFile string
}

type Compiler struct{}

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

type ExecutorOption func(*Executor)

type Program struct {
	Tag         ProgramTag
	Pure        interface{}
	Effect      effectus.Effect
	Transaction *TransactionInfo
	Continue    func(interface{}) *Program
}

type ProgramTag int

type Spec struct {
	Name         string
	Flows        []*CompiledFlow
	FactPaths    []string
	SagaEnabled  bool                         // Whether to use saga execution
	SagaStore    schema.SagaStore             // Saga store for transaction management
	CapSystem    *capability.CapabilitySystem // Capability system for locking
	VerbRegistry common.VerbRegistry          // Verb registry for execution
}

type TransactionInfo struct {
	SagaID       string   // Unique saga identifier
	Name         string   // Human-readable transaction name
	Compensation string   // Inverse verb for compensation
	Program      *Program // The program to execute within the transaction
	IsAtomic     bool     // Whether this transaction should be atomic
}