journal

type BranchJournal interface {
	Get(ctx context.Context, runID, sourceNode string) ([]BranchRecord, bool, error)
	Put(ctx context.Context, runID, sourceNode string, records []BranchRecord) error
}

type BranchRecord struct {
	RunID       string       `json:"run_id"`
	SourceNode  string       `json:"source_node"`
	From        string       `json:"from"`
	To          string       `json:"to"`
	When        string       `json:"when,omitempty"`
	Otherwise   bool         `json:"otherwise,omitempty"`
	Status      BranchStatus `json:"status"`
	Reason      string       `json:"reason"`
	DecisionSeq int          `json:"decision_seq"`
	CreatedAt   time.Time    `json:"created_at"`
}

type BranchStatus string

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

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