asteros

Nov 20, 2025

Changes in this version

+ var ErrPoolRequired = errors.New("pool is required")

+ var ErrRoomNotFound = errors.New("room not found")

type AsterOS

+ func (os *AsterOS) Pool() *core.Pool

+ func (os *AsterOS) RegisterRoom(id string, r *core.Room) error

type BaseInterface

+ func (i *BaseInterface) OnRoomRegistered(room *core.Room) error

type Interface

+ OnRoomRegistered func(room *core.Room) error

type Options

+ Pool *core.Pool

type Registry

+ func (r *Registry) GetRoom(id string) (*core.Room, bool)

+ func (r *Registry) ListRooms() []string

+ func (r *Registry) RegisterRoom(id string, room *core.Room) error

+ func (r *Registry) UnregisterRoom(id string) error

type ResourceType

+ const ResourceTypeRoom

+ type RoomJoinRequest struct

+ AgentID string

+ Name string

+ type RoomLeaveRequest struct

+ Name string

+ type RoomSayRequest struct

+ From string

+ Text string

Nov 19, 2025

Changes in this version

+ var ErrAgentNotFound = errors.New("agent not found")

+ var ErrAlreadyRunning = errors.New("asteros is already running")

+ var ErrCosmosRequired = errors.New("cosmos is required")

+ var ErrInterfaceExists = errors.New("interface already exists")

+ var ErrInterfaceNotFound = errors.New("interface not found")

+ var ErrInvalidPort = errors.New("invalid port number")

+ var ErrNotRunning = errors.New("asteros is not running")

+ var ErrResourceExists = errors.New("resource already exists")

+ var ErrStarsNotFound = errors.New("stars not found")

+ var ErrWorkflowNotFound = errors.New("workflow not found")

+ type AgentRunRequest struct

+ Context map[string]interface{}

+ Message string

+ Stream bool

+ type AsterOS struct

+ func New(opts *Options) (*AsterOS, error)

+ func (os *AsterOS) AddInterface(iface Interface) error

+ func (os *AsterOS) Cosmos() *cosmos.Cosmos

+ func (os *AsterOS) IsRunning() bool

+ func (os *AsterOS) Name() string

+ func (os *AsterOS) RegisterAgent(id string, ag *agent.Agent) error

+ func (os *AsterOS) RegisterStars(id string, s *stars.Stars) error

+ func (os *AsterOS) RegisterWorkflow(id string, wf workflow.Agent) error

+ func (os *AsterOS) Registry() *Registry

+ func (os *AsterOS) RemoveInterface(name string) error

+ func (os *AsterOS) Router() *gin.Engine

+ func (os *AsterOS) Serve() error

+ func (os *AsterOS) Shutdown() error

+ type BaseInterface struct

+ func NewBaseInterface(name string, typ InterfaceType) *BaseInterface

+ func (i *BaseInterface) Name() string

+ func (i *BaseInterface) OnAgentRegistered(agent *agent.Agent) error

+ func (i *BaseInterface) OnStarsRegistered(stars *stars.Stars) error

+ func (i *BaseInterface) OnWorkflowRegistered(wf workflow.Agent) error

+ func (i *BaseInterface) Start(ctx context.Context, os *AsterOS) error

+ func (i *BaseInterface) Stop(ctx context.Context) error

+ func (i *BaseInterface) Type() InterfaceType

+ type Interface interface

+ Name func() string

+ OnAgentRegistered func(agent *agent.Agent) error

+ OnStarsRegistered func(stars *stars.Stars) error

+ OnWorkflowRegistered func(wf workflow.Agent) error

+ Start func(ctx context.Context, os *AsterOS) error

+ Stop func(ctx context.Context) error

+ Type func() InterfaceType

+ type InterfaceType string

+ const InterfaceTypeA2A

+ const InterfaceTypeAGUI

+ const InterfaceTypeHTTP

+ const InterfaceTypeSlack

+ type Options struct

+ APIKey string

+ APIPrefix string

+ AutoDiscover bool

+ Cosmos *cosmos.Cosmos

+ EnableAuth bool

+ EnableCORS bool

+ EnableHealth bool

+ EnableLogging bool

+ EnableMetrics bool

+ LogLevel string

+ Name string

+ Port int

+ func DefaultOptions() *Options

+ func (o *Options) Validate() error

+ type Registry struct

+ func NewRegistry() *Registry

+ func (r *Registry) Clear()

+ func (r *Registry) GetAgent(id string) (*agent.Agent, bool)

+ func (r *Registry) GetStars(id string) (*stars.Stars, bool)

+ func (r *Registry) GetWorkflow(id string) (workflow.Agent, bool)

+ func (r *Registry) ListAgents() []string

+ func (r *Registry) ListAll() []Resource

+ func (r *Registry) ListStars() []string

+ func (r *Registry) ListWorkflows() []string

+ func (r *Registry) RegisterAgent(id string, ag *agent.Agent) error

+ func (r *Registry) RegisterStars(id string, s *stars.Stars) error

+ func (r *Registry) RegisterWorkflow(id string, wf workflow.Agent) error

+ func (r *Registry) UnregisterAgent(id string) error

+ func (r *Registry) UnregisterStars(id string) error

+ func (r *Registry) UnregisterWorkflow(id string) error

+ type Resource struct

+ Data interface{}

+ ID string

+ Name string

+ Type ResourceType

+ type ResourceType string

+ const ResourceTypeAgent

+ const ResourceTypeStars

+ const ResourceTypeWorkflow

+ type StarsJoinRequest struct

+ AgentID string

+ Role string

+ type StarsLeaveRequest struct

+ AgentID string

+ type StarsRunRequest struct

+ Context map[string]interface{}

+ Task string

+ type WorkflowExecuteRequest struct

+ Context map[string]interface{}

+ Message string