dispatch

type BuildOptions ¶ added in v0.6.0

type BuildOptions struct {
	PlanPath string
	TaskIDs  map[string]string // slot name → existing task ID (caller-supplied)
}

BuildOptions configures BuildManifest.

type Manifest ¶ added in v0.6.0

type Manifest struct {
	SchemaVersion int       `json:"schema_version"`
	PlanPath      string    `json:"plan_path"`
	PlanSHA256    string    `json:"plan_sha256"`
	CreatedAt     time.Time `json:"created_at"`
	CurrentWave   int       `json:"current_wave"`
	Waves         []Wave    `json:"waves"`
}

Manifest is the dispatch contract written by `bones swarm dispatch` and consumed by harness-specific orchestrator skills.

func Advance(root string, isClosed TaskClosed) (Manifest, error)

func BuildManifest(opts BuildOptions) (Manifest, error)

func Read(root string) (Manifest, error)

type PresenceProbe ¶ added in v0.2.0

type PresenceProbe func(ctx context.Context) ([]string, error)

PresenceProbe returns the agent IDs currently present in the substrate. Used by WaitWorkerAbsent to poll for worker dropout without depending on a particular substrate's Presence type.

The standard binding is `coord.Coord.PresentAgentIDs`; tests can pass a closure backed by an in-memory slice.

type ResultKind ¶

type ResultKind string

const (
	ResultSuccess ResultKind = "success"
	ResultFork    ResultKind = "fork"
	ResultFail    ResultKind = "fail"
)

type ResultMessage ¶

type ResultMessage struct {
	Kind           ResultKind
	Summary        string
	Branch         string
	Rev            string
	SubstrateError string
	SubstrateFault string
}

ResultMessage is the dispatch payload posted on the task thread when a swarm slot closes. Kind + Summary are agent intent; Branch + Rev describe a fork outcome. SubstrateError and SubstrateFault are substrate-level signals — populated when bones (not the agent) observed a failure on the close path, so a downstream orchestrator can distinguish "agent didn't accomplish X" from "the substrate blocked the agent from accomplishing X" (#159).

SubstrateError is a free-text message (e.g. "swarm commit failed: nats: no responders"). SubstrateFault is a short category tag (e.g. "commit-failed", "hub-unreachable") for orchestrator-side branching without parsing free text.

func ParseResult(body string) (ResultMessage, bool)

type SlotEntry ¶ added in v0.6.0

type SlotEntry struct {
	Slot           string   `json:"slot"`
	TaskID         string   `json:"task_id"`
	Title          string   `json:"title"`
	Files          []string `json:"files"`
	SubagentPrompt string   `json:"subagent_prompt"`
}

SlotEntry is one slot's task assignment within a wave.

type Spec ¶

type Spec struct {
	TaskID        string
	Title         string
	Files         []string
	Thread        string
	ParentAgentID string
	WorkerAgentID string
	WorkspaceDir  string
}

Spec is the parent-resolved description of a task ready to dispatch to a worker process. Pure data; no substrate references. The CLI adapter that produced the Task value is the only thing that knows about coord.

func BuildSpec(parentAgentID, workspaceDir string, task Task) (Spec, error)

type Task ¶ added in v0.2.0

type Task interface {
	// ID returns the task identifier as a plain string. Whatever
	// coord-side type wraps the ID is converted at the adapter
	// boundary; dispatch carries it as a string.
	ID() string

	// Title is the human-readable title.
	Title() string

	// Files lists the absolute workspace paths the task scopes its
	// work to. The returned slice may be the task's own copy;
	// BuildSpec takes a copy if it needs to mutate.
	Files() []string
}

Task is the dispatch-local view of a coord task record. Defined here (rather than imported from coord) so dispatch can be tested with minimal in-memory fakes and so a future migration to a different task source — a different substrate, a different storage shape — does not ripple through dispatch.

Coord's task type satisfies this structurally via a small adapter at the CLI layer; dispatch never imports coord.Task directly.

type TaskClosed ¶ added in v0.6.0

type TaskClosed func(taskID string) (bool, error)

TaskClosed reports whether the task with the given ID is in Closed status. Implemented by the caller (typically a thin shim over internal/tasks).

type TaskCloser ¶ added in v0.6.0

type TaskCloser func(taskID string, reason string) error

TaskCloser closes a task with a reason string (e.g. "dispatch-canceled"). Implemented by the caller (typically a thin shim over internal/tasks).

type Wave ¶ added in v0.6.0

type Wave struct {
	Wave             int         `json:"wave"`
	BlockedUntilWave int         `json:"blocked_until_wave,omitempty"`
	Slots            []SlotEntry `json:"slots"`
}

Wave is one parallelizable set of slots, blocked until prior waves complete.