Documentation
¶
Index ¶
- Constants
- func ExecutableRunStatuses() []taskpkg.RunStatus
- func HealthySession(info *session.Info, workspaceID string, now time.Time) bool
- func IsExecutableRunStatus(status taskpkg.RunStatus) bool
- func Lineage(now time.Time, cfg aghconfig.CoordinatorConfig, ...) *store.SessionLineage
- func OperationalMessageKinds() []string
- func PermissionPolicy(channelIDs ...string) store.SessionPermissionPolicy
- func PromptOverlay(input PromptInput) string
- func SpawnRoleAllowed(role string) bool
- func ToolAllowed(tool string) bool
- func ToolAllowlist() []string
- type Decision
- type PromptInput
Constants ¶
const ( ReasonRunEnqueued = "task_run_enqueued" ReasonRecovery = "recovery" ReasonCoordinatorStopped = "coordinator_stopped" DecisionBootstrap = "bootstrap" DecisionDisabled = "disabled" DecisionGlobalScope = "global_scope" DecisionMissingWorkspace = "missing_workspace" DecisionMissingChannel = "missing_coordination_channel" DecisionNonExecutableRun = "non_executable_run" DecisionTaskRunMismatch = "task_run_mismatch" DecisionExisting = "existing_coordinator" DecisionDenied = "denied" DecisionFailed = "failed" )
Variables ¶
This section is empty.
Functions ¶
func ExecutableRunStatuses ¶
ExecutableRunStatuses returns every open run state considered by recovery.
func HealthySession ¶
HealthySession reports whether a session snapshot is an active coordinator for the workspace.
func IsExecutableRunStatus ¶
IsExecutableRunStatus reports whether a run still represents executable work that may need coordinator orchestration.
func Lineage ¶
func Lineage( now time.Time, cfg aghconfig.CoordinatorConfig, policy store.SessionPermissionPolicy, ) *store.SessionLineage
Lineage builds root lineage metadata for a managed coordinator session.
func OperationalMessageKinds ¶
func OperationalMessageKinds() []string
OperationalMessageKinds returns the coordination-channel message kinds a coordinator may use for worker conversation.
func PermissionPolicy ¶
func PermissionPolicy(channelIDs ...string) store.SessionPermissionPolicy
PermissionPolicy returns the restricted coordinator root permission policy.
func PromptOverlay ¶
func PromptOverlay(input PromptInput) string
PromptOverlay assembles the coordinator's first-run situation and available public API surface.
func SpawnRoleAllowed ¶
SpawnRoleAllowed reports whether a coordinator may request the given child role through the public safe-spawn API.
func ToolAllowed ¶
ToolAllowed reports whether a concrete tool/action is coordinator-safe.
func ToolAllowlist ¶
func ToolAllowlist() []string
ToolAllowlist returns the orchestration-safe tool surface granted to coordinator sessions.
Types ¶
type Decision ¶
type Decision struct {
ShouldBootstrap bool
Reason string
WorkspaceID string
TaskID string
RunID string
WorkflowID string
CoordinationChannelID string
}
Decision describes whether a task run is eligible to bootstrap a workspace coordinator.
func DecideBootstrap ¶
DecideBootstrap evaluates the mechanical coordinator bootstrap rules. It does not check for already-running coordinator sessions; that singleton check belongs to the daemon runtime.
Source Files