flowstore

package

Go to main page

Versions in this module

v0

v0.10.8

Aug 26, 2026

Changes in this version

+ var ErrEpicProgressionActivationChanged = errors.New("epic progression activation changed")

+ var ErrFlowUntrackedOwned = errors.New("flow worktree is owned by a phase-untracked launch")

+ var ErrUntrackedOwnerChanged = errors.New("phase-untracked Flow owner changed")

+ func EffectiveAutoMerge(record FlowRecord, global bool) bool

+ type AutoMergeUpdate struct

+ Enabled *bool

+ FlowID string

type EpicProgressionHaltUpdate

+ ExpectedActivation time.Time

type EpicProgressionSuccessorUpdate

+ ExpectedActivation time.Time

type EpicProgressionUpdate

+ ExpectedActivation time.Time

type FlowRecord

+ AutoMerge *bool

+ UntrackedOwner *UntrackedOwner

type PhaseLaunchFence

+ OwnerPhaseID string

type PhaseLaunchUpdate

+ AutoMerge bool

+ GlobalAutoMerge bool

type Store

+ func (s *Store) ActivateUntrackedOwner(update UntrackedOwnerActivation) (FlowRecord, error)

+ func (s *Store) ClaimUntrackedOwner(update UntrackedOwnerClaim) (FlowRecord, error)

+ func (s *Store) PrepareUntrackedOwnerTransport(update UntrackedOwnerActivation) (FlowRecord, error)

+ func (s *Store) ReleaseUntrackedOwner(update UntrackedOwnerRelease) (FlowRecord, error)

+ func (s *Store) ReplaceUntrackedOwner(update UntrackedOwnerReplacement) (FlowRecord, error)

+ func (s *Store) SetAutoMerge(update AutoMergeUpdate) (FlowRecord, error)

+ type UntrackedOwner struct

+ ActivatedAt time.Time

+ EndedAt time.Time

+ LaunchID string

+ LauncherPID int

+ LauncherToken string

+ ReservedAt time.Time

+ Role UntrackedOwnerRole

+ State UntrackedOwnerState

+ Transport UntrackedOwnerTransport

+ type UntrackedOwnerActivation struct

+ FlowID string

+ LaunchID string

+ LauncherHandoffComplete bool

+ Transport UntrackedOwnerTransport

+ type UntrackedOwnerClaim struct

+ FlowID string

+ Owner UntrackedOwner

+ type UntrackedOwnerRelease struct

+ FlowID string

+ LaunchID string

+ type UntrackedOwnerReplacement struct

+ ExpectedLaunchID string

+ FlowID string

+ Owner UntrackedOwner

+ type UntrackedOwnerRole string

+ const UntrackedOwnerAutofix

+ const UntrackedOwnerRepair

+ const UntrackedOwnerWorktreeAgent

+ type UntrackedOwnerState string

+ const UntrackedOwnerEnded

+ const UntrackedOwnerLive

+ const UntrackedOwnerReserved

+ type UntrackedOwnerTransport struct

+ Kind UntrackedTransportKind

+ PID int

+ ProcessToken string

+ Session string

+ Socket string

+ Window string

+ type UntrackedTransportKind string

+ const UntrackedTransportDirect

+ const UntrackedTransportEmbeddedTmux

+ const UntrackedTransportLauncher

+ const UntrackedTransportRepoTmux

v0.10.7

Aug 23, 2026

Changes in this version

+ const OutcomePhaseResultMissing

+ const OutcomePhaseResultStale

type ChildPhaseUpdate

+ Fence PhaseLaunchFence

type FlowPhase

+ Reconciliation *PhaseReconciliation

+ RecoveredLaunchIDs []string

type IssueUpdate

+ Fence PhaseLaunchFence

type MergeUpdate

+ Fence PhaseLaunchFence

type PRUpdate

+ Fence PhaseLaunchFence

type PhaseAgentSettingsUpdate

+ Fence PhaseLaunchFence

+ type PhaseKind string

+ type PhaseLaunchFence struct

+ LaunchID string

+ type PhaseReconciliation struct

+ LaunchID string

+ Reason string

+ type PhaseRecoveryUpdate struct

+ ExpectedLaunchID string

+ ExpectedOutcome string

+ ExpectedStatus PhaseStatus

+ ExpectedUpdatedAt time.Time

+ Fence PhaseLaunchFence

+ FlowID string

+ PhaseID string

type PhaseResetUpdate

+ Fence PhaseLaunchFence

type PhaseRestartUpdate

+ Fence PhaseLaunchFence

+ type PhaseStatus string

type PhaseUpdate

+ Fence PhaseLaunchFence

type PlanLinkUpdate

+ Fence PhaseLaunchFence

+ type ReconciliationDemotionUpdate struct

+ LaunchID string

+ Reason string

type Store

+ func (s *Store) DemoteReconciledPhase(update ReconciliationDemotionUpdate) (FlowRecord, error)

+ func (s *Store) RecoverReconciledPhase(update PhaseRecoveryUpdate) (FlowRecord, error)

v0.10.6

Aug 20, 2026

Changes in this version

+ var ErrBeadFlowActive = errors.New("bead already has an active flow")

+ var ErrBeadFlowUnreadable = errors.New("bead may have an unreadable flow")

+ var ErrDatabaseGenerationChanged = errors.New("flow database changed generation underneath this handle")

+ var ErrMigrationBlockedByOwners = errors.New("flow database migration blocked by a live owner")

+ var ErrRestoreBackupUnusable = errors.New("flow database backup is not usable")

+ var ErrRestoreBlockedByOwners = errors.New("flow database restore blocked by a live owner")

+ var ErrRestoreGenerationMismatch = errors.New("flow database backup is from a different generation")

+ func BeadFlowSlotOccupied(record FlowRecord) bool

+ func IsBeadFlowActive(err error) bool

+ func IsBeadFlowRefusal(err error) bool

+ func IsBeadFlowUnreadable(err error) bool

+ func IsMigrationBlockedByOwners(err error) bool

+ func IsSchemaCompatibilityRefusal(err error) bool

+ type BeadFlowActiveError struct

+ BeadID string

+ Existing FlowRecord

+ RepoPath string

+ func (e *BeadFlowActiveError) Error() string

+ func (e *BeadFlowActiveError) Unwrap() error

+ type BeadFlowUnreadableError struct

+ BeadID string

+ Err error

+ FlowID string

+ RepoPath string

+ func (e *BeadFlowUnreadableError) Error() string

+ func (e *BeadFlowUnreadableError) Unwrap() error

type FlowRecord

+ func ActiveBeadFlow(err error) (FlowRecord, bool)

+ type InspectOwner struct

+ BuildVersion string

+ Commit string

+ Executable string

+ PID int

+ SchemaVersion int

+ StartedAt string

+ Verified bool

type InspectReport

+ FirstCompatibleRelease *string

+ Owners []InspectOwner

+ type RestoreOptions struct

+ BackupPath string

+ Force bool

+ LockTimeout time.Duration

+ Root string

+ type RestoreResult struct

+ Forced bool

+ GenerationID string

+ Path string

+ PreRestoreBackup string

+ RestoredFrom string

+ SchemaVersion int64

+ UserVersion int64

+ func Restore(opts RestoreOptions) (RestoreResult, error)

type Store

+ func (s *Store) Revalidate() error

+ func (s *Store) Root() string

type StoreOptions

+ OwnerNonce string

v0.10.5

Aug 18, 2026

Changes in this version

+ const TierHeader

+ const TierMalformed

+ const TierMissing

+ const TierNotADatabase

+ const TierNotWritable

+ const TierOpen

+ func DatabaseSchemaVersion() int

+ type EpicProgressionHaltUpdate struct

+ Halt EpicProgressionHalt

+ Key EpicProgressionKey

+ type InspectExecutable struct

+ BuildVersion string

+ Path string

+ Schema int

+ type InspectMigrationOwner struct

+ PID int

+ Verified bool

+ type InspectReport struct

+ CheckpointedUserVersion *int64

+ DirectoryMode *string

+ Executable InspectExecutable

+ GenerationID *string

+ JournalMode *string

+ MigrationOwner *InspectMigrationOwner

+ MinReaderGeneration *int64

+ MinWriterGeneration *int64

+ NextAction *string

+ Path string

+ Readable bool

+ Reason *string

+ SchemaVersion int64

+ SidecarStale *bool

+ Tier string

+ UserVersion *int64

+ WAL InspectWAL

+ Warnings []string

+ func Inspect(root string) (InspectReport, error)

+ type InspectWAL struct

+ Dirty bool

+ Present bool

+ ShmPresent bool

+ type OpenDiagnostics struct

+ DirectoryMode os.FileMode

+ JournalMode string

+ SidecarStale bool

+ Warnings []string

+ type Role int

+ const RoleMigrator

+ const RoleReader

+ const RoleWriter

+ func (r Role) String() string

type Store

+ func (s *Store) HaltEpicProgression(update EpicProgressionHaltUpdate) (EpicProgression, error)

+ func (s *Store) OpenDiagnostics() OpenDiagnostics

type StoreOptions

+ AllowDevLiveMigration bool

+ BackupDir string

+ Role Role

+ RootExplicit bool

v0.10.4

Aug 16, 2026

v0.10.3

Aug 16, 2026

Changes in this version

+ var ErrPreparationReservation = errors.New("flow preparation reservation is unavailable")

+ func IsPreparationReservation(err error) bool

+ func PhaseGraphLaunchEligible(record FlowRecord, orderedIndex int) bool

+ func PreparationLaunchBlocked(record FlowRecord) bool

+ func SamePreparationIdentity(a, b FlowRecord) bool

type FlowRecord

+ PreparationNonce string

type PreparationFinalizer

+ Compensate func(notes string) (FlowRecord, error)

+ CompensateUnderReservation func(notes string) (FlowRecord, error)

v0.10.2

Aug 15, 2026

Changes in this version

+ var ErrPreparationIncomplete = errors.New("flow preparation is incomplete")

+ var ErrPreparationStale = errors.New("flow preparation generation is stale")

+ var ErrPreparationUnknown = errors.New("flow preparation outcome is unknown")

+ func IsPreparationIncomplete(err error) bool

+ func IsPreparationStale(err error) bool

+ func IsPreparationUnknown(err error) bool

+ func IsPreparedEpicProgressionCommitUnknown(err error) bool

+ type EpicProgression struct

+ CreatedAt time.Time

+ Done bool

+ Enabled bool

+ EpicID string

+ Halt *EpicProgressionHalt

+ RepoPath string

+ SchemaVersion int

+ UpdatedAt time.Time

+ type EpicProgressionHalt struct

+ ChildBeadID string

+ Message string

+ Status string

+ type EpicProgressionKey struct

+ EpicID string

+ RepoPath string

+ type EpicProgressionSuccessorOutcome string

+ const EpicProgressionSuccessorAccepted

+ const EpicProgressionSuccessorInactive

+ const EpicProgressionSuccessorOwnedObstruction

+ const EpicProgressionSuccessorReleased

+ const EpicProgressionSuccessorRetryable

+ type EpicProgressionSuccessorResult struct

+ Flow FlowRecord

+ Outcome EpicProgressionSuccessorOutcome

+ Progression EpicProgression

+ type EpicProgressionSuccessorUpdate struct

+ Bead BeadLink

+ FlowID string

+ Key EpicProgressionKey

+ type EpicProgressionUpdate struct

+ Done bool

+ Enabled bool

+ Key EpicProgressionKey

type FlowRecord

+ PreparationGeneration string

+ PreparedAt *time.Time

+ ProgressionClaim bool

+ type PreparationFinalizer interface

+ Finalize func(func() error) (FlowRecord, error)

+ type PreparedEpicProgressionUpdate struct

+ Bead BeadLink

+ FlowID string

+ Key EpicProgressionKey

type Store

+ func (s *Store) AllocateID(title string) (string, error)

+ func (s *Store) CreatePreparation(record FlowRecord, opts CreateOptions) (FlowRecord, PreparationFinalizer, error)

+ func (s *Store) EnableEpicProgressionForPreparedFlow(update PreparedEpicProgressionUpdate) (EpicProgression, FlowRecord, error)

+ func (s *Store) ReadEpicProgression(key EpicProgressionKey) (EpicProgression, bool, error)

+ func (s *Store) ReconcileEpicProgressionSuccessor(update EpicProgressionSuccessorUpdate) (EpicProgressionSuccessorResult, error)

+ func (s *Store) ReserveEpicProgressionSuccessor(flowID string) (func(), error)

+ func (s *Store) SetEpicProgression(update EpicProgressionUpdate) (EpicProgression, error)

v0.10.1

Aug 14, 2026

Changes in this version

+ const StatusClosed

+ var ErrAutoLaunchOutdated = errors.New("auto launch outdated")

+ var ErrFlowClosed = errors.New("flow is closed")

+ var ErrFlowNotFound = errors.New("flow not found")

+ func FlowClosed(record FlowRecord) bool

+ func IsFlowClosed(err error) bool

+ func PhaseIsActionable(phase FlowPhase) bool

+ func ResolvePhaseAgentSettings(prefs agent.Preferences, raw PhaseAgentSettings) (agent.Settings, error)

+ type BeadLink struct

+ EpicID string

+ ID string

+ func (link *BeadLink) UnmarshalJSON(data []byte) error

+ type Closure struct

+ ClosedAt *time.Time

+ Reason string

+ type ClosureUpdate struct

+ FlowID string

+ Reason string

type CreateOptions

+ PhaseAgent PhaseAgentSettings

type FlowPhase

+ Agent string

+ Model string

+ ReasoningEffort string

+ func NextActionablePhase(record FlowRecord) (FlowPhase, bool)

+ func (p FlowPhase) AgentSettings() PhaseAgentSettings

type FlowRecord

+ Bead BeadLink

+ Closed Closure

+ type PartialListEntry struct

+ Cause error

+ FlowID string

+ func (e PartialListEntry) DiagnosticFlowID() string

+ type PartialListError struct

+ Entries []PartialListEntry

+ func AsPartialList(err error) (*PartialListError, bool)

+ func (e *PartialListError) Error() string

+ func (e *PartialListError) Unwrap() []error

+ type PhaseAgentSettings struct

+ Agent string

+ Model string

+ ReasoningEffort string

+ func PhaseAgentSettingsFrom(settings agent.Settings) PhaseAgentSettings

+ func (s PhaseAgentSettings) IsZero() bool

+ func (s PhaseAgentSettings) Normalize() PhaseAgentSettings

+ func (s PhaseAgentSettings) Validate() error

+ type PhaseAgentSettingsUpdate struct

+ FlowID string

+ PhaseID string

+ Settings PhaseAgentSettings

type Store

+ func (s *Store) CloseFlow(update ClosureUpdate) (FlowRecord, error)

+ func (s *Store) ReopenFlow(flowID string) (FlowRecord, error)

+ func (s *Store) ReserveAgentLaunch(flowID string) (FlowRecord, func(), error)

+ func (s *Store) ReserveRepairLaunch(flowID string) (FlowRecord, func(), error)

+ func (s *Store) SetPhaseAgentSettings(update PhaseAgentSettingsUpdate) (FlowRecord, error)

v0.10.0

Aug 11, 2026

Changes in this version

type CreateOptions

+ Headless *bool

type FlowRecord

+ Headless bool

+ type HeadlessUpdate struct

+ Enabled bool

+ FlowID string

type Store

+ func (s *Store) Close() error

+ func (s *Store) SetHeadless(update HeadlessUpdate) (FlowRecord, error)

v0.9.1

Aug 8, 2026

v0.9.0

Aug 8, 2026

Changes in this version

+ const GraphRecoveryMissingEdgesUnresolved

+ const GraphRecoveryPresetEdgesRestored

+ const KindAutoreview

+ const KindImplementation

+ const KindImplementationChild

+ const KindMerge

+ const KindPRCreation

+ const KindPlan

+ const KindPlanReview

+ const KindReviewLoop

+ const MergeBlocked

+ const MergeMerged

+ const MergePending

+ const OutcomeApproved

+ const OutcomeApprovedWithConcerns

+ const OutcomeBlocked

+ const OutcomeChangesRequested

+ const PhaseBlocked

+ const PhaseCompleted

+ const PhaseNeedsAttention

+ const PhasePending

+ const PhaseReady

+ const PhaseResetReasonAwaitSession

+ const PhaseResetReasonEndedSession

+ const PhaseRunning

+ const PhaseSkipped

+ const StatusAbandoned

+ const StatusBlocked

+ const StatusCompleted

+ const StatusInProgress

+ const StatusMerged

+ const StatusNeedsAttention

+ const StatusPending

+ func AgentSettablePhaseStatuses() []string

+ func AllowedNextPhaseStatuses(current string) []string

+ func DefaultRoot() (string, error)

+ func DeriveStatus(record FlowRecord) string

+ func HasIssueTarget(issue Issue) bool

+ func HasPRTarget(pr PullRequest) bool

+ func IsAutoLaunchOutdated(err error) bool

+ func IsNotFound(err error) bool

+ func LatestPhaseLaunchID(phase FlowPhase) string

+ func PhaseAwaitingSession(phase FlowPhase) bool

+ func PhaseGateSatisfied(record FlowRecord, phase FlowPhase) bool

+ func PhaseLatestLaunchEnded(phase FlowPhase) bool

+ func PhaseLaunchEligible(record FlowRecord, orderedIndex int) bool

+ func PhasePredecessorsSatisfied(record FlowRecord, phaseID string) bool

+ func PhaseSessionLaunchMismatch(phase FlowPhase) bool

+ func PhaseStatusTerminal(status string) bool

+ func RecoverableRunningPhaseResetReason(phase FlowPhase) (string, bool)

+ func SemanticKind(phase FlowPhase) string

+ func ValidatePreset(preset Preset) error

+ type AutoModeUpdate struct

+ Enabled bool

+ FlowID string

+ type ChildPhaseUpdate struct

+ FlowID string

+ Order int

+ ParentPhaseID string

+ PhaseID string

+ Title string

+ type CreateOptions struct

+ Preset *Preset

+ type FlowFilter struct

+ RepoPath string

+ type FlowPhase struct

+ CreatedAt time.Time

+ DependsOn []string

+ Kind string

+ LaunchIDs []string

+ Notes string

+ Order int

+ Outcome string

+ ParentPhaseID string

+ PhaseID string

+ Sessions []Session

+ Status string

+ Summary string

+ Title string

+ UpdatedAt time.Time

+ func FindPhaseByKind(record FlowRecord, kind string) (FlowPhase, bool)

+ func FirstLaunchablePhase(record FlowRecord) (FlowPhase, int, bool)

+ func OrderedPhases(phases []FlowPhase) []FlowPhase

+ type FlowRecord struct

+ AutoMode bool

+ BaseRef string

+ Branch string

+ Commit string

+ CreatedAt time.Time

+ FlowID string

+ GraphRecovery GraphRecoveryState

+ Instructions string

+ Issue Issue

+ Merge Merge

+ PR PullRequest

+ Phases []FlowPhase

+ PlanID string

+ PlanPath string

+ PresetName string

+ RepoPath string

+ SchemaVersion int

+ Status string

+ Title string

+ UpdatedAt time.Time

+ WorktreePath string

+ type GraphRecoveryState struct

+ Status string

+ type Issue struct

+ Number int

+ Provider string

+ URL string

+ type IssueUpdate struct

+ FlowID string

+ Number int

+ Provider string

+ URL string

+ type ManualMergeUpdate struct

+ Commit string

+ FlowID string

+ MergedAt time.Time

+ PRNumber int

+ PRURL string

+ Summary string

+ type Merge struct

+ Commit string

+ MergedAt *time.Time

+ Status string

+ type MergeUpdate struct

+ Commit string

+ FlowID string

+ MergedAt time.Time

+ Status string

+ type PRUpdate struct

+ BaseBranch string

+ FlowID string

+ HeadBranch string

+ Number int

+ Provider string

+ Status string

+ URL string

+ type PhaseLaunchEndUpdate struct

+ EndedAt time.Time

+ FlowID string

+ LaunchID string

+ PhaseID string

+ type PhaseLaunchUpdate struct

+ AutoLaunch bool

+ FlowID string

+ LaunchID string

+ PhaseID string

+ Resume bool

+ type PhaseResetUpdate struct

+ FlowID string

+ PhaseID string

+ type PhaseRestartUpdate struct

+ FlowID string

+ Notes string

+ PhaseID string

+ type PhaseSpec struct

+ DependsOn []string

+ ID string

+ Kind string

+ Title string

+ type PhaseUpdate struct

+ FlowID string

+ Notes string

+ Outcome string

+ PhaseID string

+ Status string

+ Summary string

+ type PlanLinkUpdate struct

+ FlowID string

+ PlanID string

+ PlanPath string

+ type Preset struct

+ Name string

+ Phases []PhaseSpec

+ func DefaultPreset() Preset

+ type PullRequest struct

+ BaseBranch string

+ HeadBranch string

+ Number int

+ Provider string

+ Status string

+ URL string

+ type Session struct

+ EndedAt time.Time

+ LaunchID string

+ Provider string

+ SessionID string

+ StartedAt time.Time

+ Status string

+ TranscriptPath string

+ func LatestPhaseSession(phase FlowPhase, requireSessionID bool) (Session, bool)

+ type SessionAttachUpdate struct

+ FlowID string

+ PhaseID string

+ Session Session

+ type StartMetadataUpdate struct

+ BaseRef string

+ Branch string

+ Commit string

+ FlowID string

+ PlanID string

+ PlanPath string

+ WorktreePath string

+ type Store struct

+ func NewStore(opts StoreOptions) (*Store, error)

+ func (s *Store) AddChildPhase(update ChildPhaseUpdate) (FlowRecord, error)

+ func (s *Store) AddPhaseLaunchID(update PhaseLaunchUpdate) (FlowRecord, error)

+ func (s *Store) AttachSession(update SessionAttachUpdate) (FlowRecord, error)

+ func (s *Store) Create(record FlowRecord) (FlowRecord, error)

+ func (s *Store) CreateWithOptions(record FlowRecord, opts CreateOptions) (FlowRecord, error)

+ func (s *Store) Delete(flowID string) error

+ func (s *Store) List(filter FlowFilter) ([]FlowRecord, error)

+ func (s *Store) MarkManualMerge(update ManualMergeUpdate) (FlowRecord, error)

+ func (s *Store) MarkPhaseLaunchEnded(update PhaseLaunchEndUpdate) (FlowRecord, error)

+ func (s *Store) Read(flowID string) (FlowRecord, error)

+ func (s *Store) ResetAwaitingSessionPhase(update PhaseResetUpdate) (FlowRecord, error)

+ func (s *Store) ResetRecoverableRunningPhase(update PhaseResetUpdate) (FlowRecord, error)

+ func (s *Store) RestartPhase(update PhaseRestartUpdate) (FlowRecord, error)

+ func (s *Store) SetAutoMode(update AutoModeUpdate) (FlowRecord, error)

+ func (s *Store) SetIssue(update IssueUpdate) (FlowRecord, error)

+ func (s *Store) SetMerge(update MergeUpdate) (FlowRecord, error)

+ func (s *Store) SetPR(update PRUpdate) (FlowRecord, error)

+ func (s *Store) SetPhase(update PhaseUpdate) (FlowRecord, error)

+ func (s *Store) SetPlanLink(update PlanLinkUpdate) (FlowRecord, error)

+ func (s *Store) SetStartMetadata(update StartMetadataUpdate) (FlowRecord, error)

+ type StoreOptions struct

+ LockTimeout time.Duration

+ Now func() time.Time

+ Presets []Preset

+ Root string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL