Versions in this module Expand all Collapse all v0 v0.2.0 Jul 14, 2026 Changes in this version + var ErrTeamNotFound = db.ErrTeamNotFound + func FormatIncoming(msg mailbox.Message) string + type AgentToolFactory func(agentID string) []tool.Tool + type Dispatcher struct + func NewDispatcher(registry *agent.ProfileRegistry, mb mailbox.Mailbox) *Dispatcher + func (d *Dispatcher) Assign(ctx context.Context, fromID, role, teamID, subject, body string) error + func (d *Dispatcher) Broadcast(ctx context.Context, fromID, teamID, subject, body string) error + func (d *Dispatcher) Reply(ctx context.Context, fromID, toID, replyToID, subject, body string) error + func (d *Dispatcher) Send(ctx context.Context, fromID, toID, subject, body string) error + type ErrNoAgentForRole struct + Role string + TeamID string + func (e *ErrNoAgentForRole) Error() string + type MessageHandler func(ctx context.Context, profile agent.AgentProfile, msg mailbox.Message) + func NewSessionHandler(eng *engine.Engine, toolFactory AgentToolFactory, ...) MessageHandler + type Team struct + CreatedAt time.Time + Description string + ID string + Metadata map[string]string + Name string + UpdatedAt time.Time + func NewTeam(name, description string) Team + type TeamBus struct + func NewTeamBus(registry *agent.ProfileRegistry, mb mailbox.Mailbox, handler MessageHandler, ...) *TeamBus + func (b *TeamBus) Start(ctx context.Context) error + func (b *TeamBus) Stop() + type TeamRegistry struct + func NewTeamRegistry(database *db.DB, profiles *agent.ProfileRegistry) *TeamRegistry + func (r *TeamRegistry) AddMember(ctx context.Context, teamID, agentID string) error + func (r *TeamRegistry) Create(ctx context.Context, t Team) error + func (r *TeamRegistry) Delete(ctx context.Context, id string) error + func (r *TeamRegistry) Get(ctx context.Context, id string) (Team, error) + func (r *TeamRegistry) GetByName(ctx context.Context, name string) (Team, error) + func (r *TeamRegistry) List(ctx context.Context) ([]Team, error) + func (r *TeamRegistry) Members(ctx context.Context, teamID string) ([]agent.AgentProfile, error) + func (r *TeamRegistry) RemoveMember(ctx context.Context, agentID string) error + func (r *TeamRegistry) Update(ctx context.Context, t Team) error
Go to main page