Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

brain

package

Go to main page

Versions in this module

v0

v0.2.2

Feb 27, 2026

Changes in this version

type CreateInstanceParams

+ AutomationID string

type Server

+ func (s *Server) CreateInstanceDirect(params CreateInstanceParams) error

v0.2.1

Feb 22, 2026

Changes in this version

+ const MethodCompleteTask

+ const MethodCreateInstance

+ const MethodDefineWorkflow

+ const MethodGetBrain

+ const MethodGetWorkflow

+ const MethodInjectMessage

+ const MethodKillInstance

+ const MethodPauseInstance

+ const MethodPing

+ const MethodPollEvents

+ const MethodRemoveAgent

+ const MethodResumeInstance

+ const MethodSendMessage

+ const MethodSubscribe

+ const MethodUnsubscribe

+ const MethodUpdateStatus

+ type ActionRequest struct

+ Params map[string]any

+ ResponseCh chan ActionResponse

+ Type ActionType

+ type ActionResponse struct

+ Data map[string]any

+ Error string

+ OK bool

+ type ActionType string

+ const ActionCreateInstance

+ const ActionInjectMessage

+ const ActionKillInstance

+ const ActionPauseInstance

+ const ActionResumeInstance

+ type AgentStatus struct

+ Feature string

+ Files []string

+ Role string

+ UpdatedAt string

+ type BrainMessage struct

+ Content string

+ From string

+ Timestamp string

+ To string

+ type BrainState struct

+ Agents map[string]*AgentStatus

+ Messages []BrainMessage

+ type Client struct

+ func NewClient(socketPath string) *Client

+ func (c *Client) CompleteTask(repoPath, instanceID, taskID, status, errMsg string) (*WorkflowResult, error)

+ func (c *Client) CreateInstance(repoPath, instanceID string, params CreateInstanceParams) (*CreateInstanceResult, error)

+ func (c *Client) DefineWorkflow(repoPath, instanceID string, tasks []*WorkflowTask) (*WorkflowResult, error)

+ func (c *Client) GetBrain(repoPath, instanceID string) (*BrainState, error)

+ func (c *Client) GetWorkflow(repoPath, instanceID string) (*Workflow, error)

+ func (c *Client) InjectMessage(repoPath, instanceID string, params InjectMessageParams) error

+ func (c *Client) KillInstance(repoPath, instanceID, target string) error

+ func (c *Client) PauseInstance(repoPath, instanceID, target string) error

+ func (c *Client) Ping() error

+ func (c *Client) PollEvents(subscriberID string, timeoutSec int) ([]Event, error)

+ func (c *Client) RemoveAgent(repoPath, instanceID string) error

+ func (c *Client) ResumeInstance(repoPath, instanceID, target string) error

+ func (c *Client) SendMessage(repoPath, from, to, content string) error

+ func (c *Client) Subscribe(repoPath string, filter EventFilter) (string, error)

+ func (c *Client) Unsubscribe(subscriberID string) error

+ func (c *Client) UpdateStatus(repoPath, instanceID, feature string, files []string) (*UpdateStatusResult, error)

+ func (c *Client) UpdateStatusWithRole(repoPath, instanceID, feature string, files []string, role string) (*UpdateStatusResult, error)

+ type CreateInstanceParams struct

+ Program string

+ Prompt string

+ Role string

+ SkipPermissions *bool

+ Title string

+ Topic string

+ type CreateInstanceResult struct

+ Error string

+ Status string

+ Title string

+ type Event struct

+ Data map[string]any

+ RepoPath string

+ Sequence uint64

+ Source string

+ Timestamp time.Time

+ Type EventType

+ type EventBus struct

+ func NewEventBus(maxBuffer int) *EventBus

+ func (eb *EventBus) Emit(event Event)

+ func (eb *EventBus) Poll(subscriberID string, timeout time.Duration) ([]Event, error)

+ func (eb *EventBus) PruneStale(maxAge time.Duration) int

+ func (eb *EventBus) Subscribe(filter EventFilter) string

+ func (eb *EventBus) Unsubscribe(subscriberID string)

+ type EventFilter struct

+ Instances []string

+ ParentTitle string

+ Types []EventType

+ type EventType string

+ const EventAgentRemoved

+ const EventInstanceCreated

+ const EventInstanceKilled

+ const EventInstanceStatusChanged

+ const EventMessageReceived

+ const EventStatusChanged

+ const EventTaskCompleted

+ const EventTaskTriggered

+ const EventWorkflowDefined

+ type InjectMessageParams struct

+ Content string

+ Format string

+ To string

+ type Manager struct

+ func NewManager() *Manager

+ func (m *Manager) CompleteTask(repoPath, taskID string, status TaskStatus, errMsg string) error

+ func (m *Manager) DefineWorkflow(repoPath string, tasks []*WorkflowTask) *WorkflowResult

+ func (m *Manager) EvaluateWorkflow(repoPath string) []string

+ func (m *Manager) GetBrain(repoPath, instanceID string) *BrainState

+ func (m *Manager) GetWorkflow(repoPath string) *Workflow

+ func (m *Manager) GetWorkflowTask(repoPath, taskID string) *WorkflowTask

+ func (m *Manager) RemoveAgent(repoPath, instanceID string)

+ func (m *Manager) SendMessage(repoPath, from, to, content string)

+ func (m *Manager) SetEventCallback(fn func(Event))

+ func (m *Manager) UpdateStatus(repoPath, instanceID, feature string, files []string) *UpdateStatusResult

+ func (m *Manager) UpdateStatusWithRole(repoPath, instanceID, feature string, files []string, role string) *UpdateStatusResult

+ type PollEventsResult struct

+ Events []Event

+ SubscriberID string

+ type Request struct

+ InstanceID string

+ Method string

+ Params map[string]any

+ RepoPath string

+ type Response struct

+ Data json.RawMessage

+ Error string

+ OK bool

+ type Server struct

+ func NewServer(socketPath string) *Server

+ func (s *Server) Actions() <-chan ActionRequest

+ func (s *Server) Manager() *Manager

+ func (s *Server) PushEvent(event Event)

+ func (s *Server) SocketPath() string

+ func (s *Server) Start() error

+ func (s *Server) Stop() error

+ type SubscribeResult struct

+ SubscriberID string

+ type Subscriber struct

+ Filter EventFilter

+ ID string

+ type TaskStatus string

+ const TaskDone

+ const TaskFailed

+ const TaskPending

+ const TaskRunning

+ type UpdateStatusResult struct

+ Conflicts []string

+ type Workflow struct

+ ID string

+ Tasks []*WorkflowTask

+ type WorkflowResult struct

+ Error string

+ Triggered []string

+ WorkflowID string

+ type WorkflowTask struct

+ AssignedTo string

+ DependsOn []string

+ Error string

+ ID string

+ Prompt string

+ Role string

+ Status TaskStatus

+ Title string