mesh

May 26, 2026

Changes in this version

+ func BuiltinTeamConfigs() (map[string]*TeamConfig, error)

+ func IsPTYProvider(provider string) bool

+ func ReadHandoff(bb *Blackboard, fromTeam, toTeam string) (map[string]string, bool)

+ func ReadLatestDirective(bb *Blackboard, teamName string) (string, bool)

+ func ValidateProjectConfig(pc *ProjectConfig) error

+ func ValidateTeamConfig(tc *TeamConfig) error

+ func WriteDirective(bb *Blackboard, toTeam, directive string)

+ func WriteHandoff(bb *Blackboard, fromTeam, toTeam string, data map[string]string)

+ type AgentConfig struct

+ MaxIterations int

+ Model string

+ Name string

+ Provider string

+ Role string

+ SystemPrompt string

+ Tools []string

+ func ParseAgentFlag(s string) (AgentConfig, error)

+ type AgentMesh struct

+ func NewAgentMesh() *AgentMesh

+ func (m *AgentMesh) AddNodeToTeam(ctx context.Context, teamID string, cfg NodeConfig, bb *Blackboard, ...) error

+ func (m *AgentMesh) RemoveNodeFromTeam(teamID, nodeName string, router *Router, bb *Blackboard) error

+ func (m *AgentMesh) SpawnTeam(ctx context.Context, task string, configs []NodeConfig, ...) (*TeamHandle, error)

+ type BBBridge struct

+ func NewBBBridge(agentName, role string, teamMembers []string, workDir string, bb *Blackboard, ...) *BBBridge

+ func (b *BBBridge) FormatPrompt(msg Message) string

+ func (b *BBBridge) ParseResponse(response string) string

+ func (b *BBBridge) Run(ctx context.Context, _ string, _ *Blackboard, inbox <-chan Message, ...) error

+ type Blackboard struct

+ func NewBlackboard() *Blackboard

+ func (b *Blackboard) List(section string) map[string]Entry

+ func (b *Blackboard) ListSections() []string

+ func (b *Blackboard) Read(section, key string) (Entry, bool)

+ func (b *Blackboard) Unwatch(id WatcherID)

+ func (b *Blackboard) Watch(fn func(key string, val Entry)) WatcherID

+ func (b *Blackboard) Write(section, key string, value any, author string) Entry

+ func (b *Blackboard) WriteFromRemote(section, key string, value any, author string, revision int64) Entry

+ type BlackboardListTool struct

+ func (t *BlackboardListTool) Definition() provider.ToolDef

+ func (t *BlackboardListTool) Execute(_ context.Context, args map[string]any) (any, error)

+ func (t *BlackboardListTool) Name() string

+ type BlackboardReadTool struct

+ func (t *BlackboardReadTool) Definition() provider.ToolDef

+ func (t *BlackboardReadTool) Execute(_ context.Context, args map[string]any) (any, error)

+ func (t *BlackboardReadTool) Name() string

+ type BlackboardWriteTool struct

+ func (t *BlackboardWriteTool) Definition() provider.ToolDef

+ func (t *BlackboardWriteTool) Execute(ctx context.Context, args map[string]any) (any, error)

+ func (t *BlackboardWriteTool) Name() string

+ type Entry struct

+ Author string

+ Key string

+ Revision int64

+ Timestamp time.Time

+ Value any

+ type Event struct

+ AgentID string

+ Content string

+ Data map[string]any

+ Type string

+ type LocalNode struct

+ func NewLocalNode(cfg NodeConfig, prov provider.Provider, onEvent func(executor.Event)) *LocalNode

+ func (n *LocalNode) ID() string

+ func (n *LocalNode) Info() NodeInfo

+ func (n *LocalNode) Run(ctx context.Context, task string, bb *Blackboard, inbox <-chan Message, ...) error

+ type Message struct

+ Content string

+ From string

+ ID string

+ Metadata map[string]string

+ Timestamp time.Time

+ To string

+ Type string

+ type Node interface

+ ID func() string

+ Info func() NodeInfo

+ Run func(ctx context.Context, task string, bb *Blackboard, inbox <-chan Message, ...) error

+ type NodeConfig struct

+ AllowedPaths []string

+ ContainerMgr interface{}

+ Location string

+ MaxIterations int

+ Model string

+ Name string

+ Provider string

+ ProviderArgs []string

+ Role string

+ SandboxMode bool

+ SystemPrompt string

+ Tools []string

+ TrustEngine interface{}

+ WorkDir string

+ func ToNodeConfigs(tc *TeamConfig) []NodeConfig

+ type NodeInfo struct

+ Location string

+ Model string

+ Name string

+ Provider string

+ Role string

+ type ProjectBlackboard struct

+ func NewProjectBlackboard() *ProjectBlackboard

+ func (pbb *ProjectBlackboard) Mode(teamName string) string

+ func (pbb *ProjectBlackboard) Root() *Blackboard

+ func (pbb *ProjectBlackboard) TeamBB(teamName, mode string) *Blackboard

+ type ProjectConfig struct

+ Cwd string

+ Paths []string

+ Project string

+ Teams []ProjectTeamConfig

+ WorkDir string

+ func LoadProjectConfig(path string) (*ProjectConfig, error)

+ func ParseProjectConfig(data []byte) (*ProjectConfig, error)

+ func ParseProjectConfigJSON(data []byte) (*ProjectConfig, error)

+ type ProjectStatusSummary struct

+ Completed int

+ InProgress int

+ Name string

+ Pending int

+ ProjectID string

+ Total int

+ type ProjectStatusTool struct

+ func (t *ProjectStatusTool) Definition() provider.ToolDef

+ func (t *ProjectStatusTool) Execute(_ context.Context, args map[string]any) (any, error)

+ func (t *ProjectStatusTool) Name() string

+ type ProjectTeamConfig struct

+ Agents []AgentConfig

+ Blackboard string

+ Name string

+ Timeout string

+ WorkDir string

+ func (ptc *ProjectTeamConfig) ToTeamConfig() *TeamConfig

+ type RemoteNode struct

+ func NewRemoteNode(id, address string, info NodeInfo) *RemoteNode

+ func (n *RemoteNode) ID() string

+ func (n *RemoteNode) Info() NodeInfo

+ func (n *RemoteNode) Run(ctx context.Context, task string, bb *Blackboard, inbox <-chan Message, ...) error

+ type Router struct

+ func NewRouter() *Router

+ func (r *Router) Register(nodeID string) (<-chan Message, error)

+ func (r *Router) Send(msg Message) error

+ func (r *Router) Unregister(nodeID string)

+ type Section struct

+ Entries map[string]Entry

+ type SendMessageTool struct

+ func (t *SendMessageTool) Definition() provider.ToolDef

+ func (t *SendMessageTool) Execute(_ context.Context, args map[string]any) (any, error)

+ func (t *SendMessageTool) Name() string

+ type Task struct

+ AssignedTeam string

+ ClaimedBy string

+ CreatedAt time.Time

+ Description string

+ ID string

+ Notes string

+ Priority int

+ ProjectID string

+ Status string

+ Title string

+ UpdatedAt time.Time

+ type TaskClaimTool struct

+ func (t *TaskClaimTool) Definition() provider.ToolDef

+ func (t *TaskClaimTool) Execute(_ context.Context, args map[string]any) (any, error)

+ func (t *TaskClaimTool) Name() string

+ type TaskCreateTool struct

+ func (t *TaskCreateTool) Definition() provider.ToolDef

+ func (t *TaskCreateTool) Execute(_ context.Context, args map[string]any) (any, error)

+ func (t *TaskCreateTool) Name() string

+ type TaskGetTool struct

+ func (t *TaskGetTool) Definition() provider.ToolDef

+ func (t *TaskGetTool) Execute(_ context.Context, args map[string]any) (any, error)

+ func (t *TaskGetTool) Name() string

+ type TaskListTool struct

+ func (t *TaskListTool) Definition() provider.ToolDef

+ func (t *TaskListTool) Execute(_ context.Context, args map[string]any) (any, error)

+ func (t *TaskListTool) Name() string

+ type TaskUpdateTool struct

+ func (t *TaskUpdateTool) Definition() provider.ToolDef

+ func (t *TaskUpdateTool) Execute(_ context.Context, args map[string]any) (any, error)

+ func (t *TaskUpdateTool) Name() string

+ type TeamConfig struct

+ Agents []AgentConfig

+ AllowedPaths []string

+ Blackboard string

+ MaxReviewRounds int

+ Name string

+ Timeout string

+ WorkDir string

+ func BuildTeamConfigFromFlags(name string, agentFlags []string, orchestrator string, bbMode string) (*TeamConfig, error)

+ func DefaultCodeGenTeamConfig() (*TeamConfig, error)

+ func LoadTeamConfig(path string) (*TeamConfig, error)

+ func LoadTeamConfigs(dir string) ([]TeamConfig, error)

+ func SearchTeamConfig(name, projectDir, homeDir string) (*TeamConfig, error)

+ type TeamHandle struct

+ Cancel func()

+ Done <-chan struct{}

+ Events <-chan Event

+ ID string

+ func (h *TeamHandle) Result() TeamResult

+ type TeamResult struct

+ Artifacts map[string]Entry

+ Errors []error

+ Status string

+ type Tracker struct

+ func NewTracker(db *sql.DB) (*Tracker, error)

+ func (tr *Tracker) ClaimTask(taskID, agentName string) error

+ func (tr *Tracker) CreateProject(name, configPath string) (string, error)

+ func (tr *Tracker) CreateTask(projectID, title, description, assignedTeam string, priority int) (string, error)

+ func (tr *Tracker) GetTask(taskID string) (*Task, error)

+ func (tr *Tracker) ListTasks(projectID, team, status string, limit int) ([]Task, error)

+ func (tr *Tracker) ProjectStatus(projectID string) (*ProjectStatusSummary, error)

+ func (tr *Tracker) UpdateTask(taskID, status, notes string) error

+ type TranscriptLogger struct

+ func NewTranscriptLogger(w io.Writer, bb *Blackboard, _ *Router, teamID string) *TranscriptLogger

+ func (tl *TranscriptLogger) LogComplete(agentCount, _ int)

+ func (tl *TranscriptLogger) LogMessage(msg Message)

+ func (tl *TranscriptLogger) LogStart(task string)

+ func (tl *TranscriptLogger) Stop()

+ func (tl *TranscriptLogger) Writes() int

+ type WatcherID int