events

Aug 22, 2026

Changes in this version

type OutboundMessage

+ GoalActive bool

+ SessionEntryID int64

Aug 11, 2026

Changes in this version

type AskUserQuestionRequest

+ Bridge BridgeID

+ type BridgeID string

+ const BridgeExternalMCP

+ const BridgeSlack

+ type Broadcast struct

+ Acknowledgement chan BroadcastAcknowledgement

+ Delivery *OutboundMessage

+ Message *OutboundMessage

+ Relay *ExternalMCPRelay

+ RelayChannel string

+ RelayCleanup *InboundMessage

+ RelayReply *InboundMessage

+ RelayResponse chan BroadcastReply

+ Sender BridgeID

+ func (b *Broadcast) Clone() Broadcast

+ type BroadcastAcknowledgement struct

+ Err error

+ Status BroadcastStatus

+ type BroadcastPublisher chan<- Broadcast

+ func (p BroadcastPublisher) PublishOutbound(ctx context.Context, message *OutboundMessage) error

+ type BroadcastReply struct

+ Err error

+ Message *InboundMessage

+ type BroadcastStatus string

+ const BroadcastDropped

+ const BroadcastFailed

+ const BroadcastHandled

+ type Channels struct

+ Broadcasts chan Broadcast

+ Requests chan Request

+ func NewChannels() Channels

type InboundMessage

+ Bridge BridgeID

+ Response chan Response

type OutboundMessage

+ Bridge BridgeID

+ Response chan Response

+ func CloneOutboundMessage(message *OutboundMessage) *OutboundMessage

+ type OutboundPublisher interface

+ PublishOutbound func(context.Context, *OutboundMessage) error

+ type Request struct

+ Operation RequestOperation

+ Response chan Response

+ Sender BridgeID

+ type RequestKind string

+ const RequestTextInterruptConversation

+ const RequestTextInterruptThread

+ const RequestTextRegisterCronThread

+ const RequestTextRegisterThread

+ const RequestTextReserveWorkflowTurn

+ const RequestTextStartGoal

+ const RequestTextStartThread

+ const RequestTextStartWorkflow

+ const RequestTextSubmitExternalMCP

+ const RequestTextSubmitThreadReply

+ const RequestTextSwitchThreadAgent

+ const RequestTextThreadAgent

+ const RequestTextWorkflowDescriptions

+ type RequestOperation interface

+ RequestKind func() RequestKind

+ type Response struct

+ Err error

+ Payload ResponsePayload

+ type ResponseKind string

+ const ResponseInteraction

+ const ResponseProgress

+ const ResponseResult

+ type ResponsePayload interface

+ ResponseKind func() ResponseKind

type StartNewThreadRequest

+ Bridge BridgeID

+ Response chan Response

+ type StartNewThreadResponse struct

+ Err chan error

+ Request *StartNewThreadRequest

+ Root chan StartNewThreadRootResult

+ func (StartNewThreadResponse) ResponseKind() ResponseKind

+ type TextRequest struct

+ Agent string

+ Args string

+ CheckScript string

+ ConversationID string

+ Inbound *InboundMessage

+ Kind RequestKind

+ MaxTurns int

+ Name string

+ Objective string

+ Target TextConversationTarget

+ func (r *TextRequest) RequestKind() RequestKind

+ type TextResponse struct

+ Agent string

+ Created bool

+ Descriptions []workflow.Description

+ Handled bool

+ Inbound *InboundMessage

+ Kind ResponseKind

+ Message *OutboundMessage

+ Release chan struct{}

+ Reserved bool

+ func (r *TextResponse) ResponseKind() ResponseKind

+ type UserQuestionAsker struct

+ func InteractiveUserQuestionAsker(...) UserQuestionAsker

+ func NoUserQuestionAsker() UserQuestionAsker

+ func (a UserQuestionAsker) AskUserQuestion(ctx context.Context, req *AskUserQuestionRequest) (AskUserQuestionAnswer, error)

+ func (a UserQuestionAsker) ExposeTool() bool

Aug 5, 2026

Changes in this version

+ type CronjobMessage struct

+ Agent string

+ RanAt string

+ RelativePath string

type OutboundMessage

+ Cronjob *CronjobMessage

Jul 27, 2026

Changes in this version

type InboundMessage

+ Workflow *workflow.RunRequest

type OutboundMessage

+ WorkflowAgent *workflow.AgentUpdate

+ WorkflowPhase *workflow.PhaseUpdate

+ WorkflowTerminal workflow.Terminal

Jul 24, 2026

Changes in this version

type ExternalMCPRelay

+ ConversationID string

Jul 22, 2026

Changes in this version

type SlackReplyTarget

+ RecipientTeamID string

+ RecipientUserID string

Jul 18, 2026

Changes in this version

+ type ExternalMCPRelay struct

+ Agent string

+ Attachments []OutboundAttachment

+ ExternalConversationID string

+ Text string

type InboundMessage

+ func NewInboundMessage(source Source, kind InboundKind, label, text string, human bool) *InboundMessage

+ func NewInboundMessageFromContent(source Source, kind InboundKind, label string, content *InboundContent, ...) *InboundMessage

type OutboundMessage

+ Agent string

+ ExternalConversationID string

+ func NewOutboundMessage(source Source, conversationID, text string, targets ...OutputTarget) *OutboundMessage

type OutputTarget

+ const OutputTargetSlack

Jun 26, 2026

Changes in this version

+ const InboundAllowedAgentsMetadataKey

+ const InboundStartNewThreadDisabledMetadataKey

+ const TerminalCLIEmbeddedClientID

+ func SetInboundAllowedAgents(inbound *InboundMessage, agents []string)

+ func StartNewThreadFirstPrompt(req *StartNewThreadRequest, targetAgent string) string

+ func StartNewThreadRootText(title, prompt string) string

+ type StartNewThreadRequest struct

+ Agent string

+ AllowedAgents []string

+ CurrentAgent string

+ DiscordReply *DiscordReplyTarget

+ Prompt string

+ SlackReply *SlackReplyTarget

+ Source Source

+ SourceConversationID string

+ TerminalClientID string

+ Title string

+ type StartNewThreadResult struct

+ AttachCommand string

+ CMUXOpened bool

+ ConversationID string

+ URL string

+ type StartNewThreadRootResult struct

+ Target TextConversationTarget

+ URL string

Jun 23, 2026

Changes in this version

+ const InboundMediaMetadataKey

+ const InboundOriginMetadataKey

+ const InboundPrincipalMetadataKey

Jun 21, 2026

Changes in this version

+ const TerminalCLIClientIDMetadataKey

+ type AskUserQuestionAnswer struct

+ Custom string

+ Selected []string

+ Source Source

+ type AskUserQuestionOption struct

+ Description string

+ Label string

+ Value string

+ type AskUserQuestionRequest struct

+ ConversationID string

+ Details string

+ DiscordReply *DiscordReplyTarget

+ ID string

+ Multiple bool

+ Options []AskUserQuestionOption

+ Question string

+ SlackReply *SlackReplyTarget

+ Source Source

+ TerminalClientID string

type Bus

+ func (b *Bus) Observe(ctx context.Context) iter.Seq[ObservedMessage]

+ type ObservedMessage struct

+ Inbound *InboundMessage

+ Outbound *OutboundMessage

+ type Observer struct

type OutputTarget

+ const OutputTargetTerminal

type Source

+ const SourceTerminalCLI

Jun 15, 2026

Changes in this version

+ const MaxInboundTextAttachmentBytes

+ func IsTextAttachment(name, mimeType string) bool

+ type InboundContent struct

+ AttachmentWarnings []string

+ Attachments []InboundAttachment

+ HadAttachments bool

+ HadNonImageAttachments bool

+ Text string

+ TextAttachments []string

type InboundMessage

+ GoalTurn bool

+ func NewMainInboundMessageFromContent(source Source, kind InboundKind, label string, content *InboundContent, ...) *InboundMessage

+ func (m *InboundMessage) CompleteResponseWithAttachments(text string, attachments []OutboundAttachment, err error)

type InboundResponse

+ Attachments []OutboundAttachment

type OutboundMessage

+ GoalComplete bool

+ GoalMaxTurns int

+ GoalTurn bool

+ GoalTurnNumber int

+ PostProgressText bool

+ ProgressText string

+ type TextConversationTarget struct

+ ChannelID string

+ MessageID string

+ ThreadID string

Jun 7, 2026

Changes in this version

+ var ErrBusClosed = errors.New("bus closed")

+ func AttachmentNamesSpeech(attachments []OutboundAttachment) string

+ func MainConversationID() string

+ type AudioChunk struct

+ Channels int

+ Data []byte

+ Format string

+ RTPSequence uint16

+ SSRC uint32

+ SampleRate int

+ SessionID string

+ Source Source

+ SpeakerID string

+ Timestamp uint32

+ type Bus struct

+ func New(configs ...Config) *Bus

+ func (b *Bus) Audio(ctx context.Context) iter.Seq[*AudioChunk]

+ func (b *Bus) Close()

+ func (b *Bus) Inbound(ctx context.Context) iter.Seq[*InboundMessage]

+ func (b *Bus) Outbound(ctx context.Context) iter.Seq[*OutboundMessage]

+ func (b *Bus) PublishAudio(ctx context.Context, chunk *AudioChunk) error

+ func (b *Bus) PublishInbound(ctx context.Context, msg *InboundMessage) error

+ func (b *Bus) PublishOutbound(ctx context.Context, msg *OutboundMessage) error

+ func (b *Bus) StopInbound()

+ func (b *Bus) WaitInboundDequeued(ctx context.Context) error

+ func (b *Bus) WaitOutboundIdle(ctx context.Context) error

+ type Config struct

+ MinimumWaitAfterHumanInteraction time.Duration

+ type DiscordReplyTarget struct

+ ChannelID string

+ MessageID string

+ ThreadID string

+ type InboundAttachment struct

+ Data []byte

+ MIMEType string

+ Name string

+ type InboundKind string

+ const InboundKindInternalize

+ const InboundKindPrompt

+ type InboundMessage struct

+ AttachmentWarnings []string

+ Attachments []InboundAttachment

+ ConversationID string

+ DiscordReply *DiscordReplyTarget

+ HadAttachments bool

+ HadNonImageAttachments bool

+ Human bool

+ Kind InboundKind

+ Label string

+ Metadata map[string]string

+ SlackReply *SlackReplyTarget

+ Source Source

+ Text string

+ VerbatimAttachments []OutboundAttachment

+ VerbatimMessage string

+ WebSessionID string

+ func NewMainInboundMessage(source Source, kind InboundKind, label, text string, human bool) *InboundMessage

+ func (m *InboundMessage) CompleteResponse(text string, err error)

+ func (m *InboundMessage) EnableResponseWait() <-chan InboundResponse

+ type InboundResponse struct

+ Err error

+ Text string

+ type OutboundAttachment struct

+ Data []byte

+ MIMEType string

+ Name string

+ func CloneOutboundAttachments(attachments []OutboundAttachment) []OutboundAttachment

+ type OutboundMessage struct

+ Attachments []OutboundAttachment

+ Checkpoint *ResponseCheckpoint

+ Complete bool

+ ConversationID string

+ DiscordReply *DiscordReplyTarget

+ Sequence int

+ SlackPostText bool

+ SlackReply *SlackReplyTarget

+ SlackThinking string

+ Source Source

+ Targets []OutputTarget

+ Text string

+ TurnID string

+ WebSessionID string

+ func NewMainOutboundMessage(source Source, text string, targets ...OutputTarget) *OutboundMessage

+ func (m *OutboundMessage) MarkDelivered(err error)

+ func (m *OutboundMessage) WaitDelivered(ctx context.Context) error

+ type OutputTarget string

+ const OutputTargetDiscord

+ const OutputTargetDiscordText

+ const OutputTargetSlackMain

+ const OutputTargetWebUI

+ func MainOutputTargets() []OutputTarget

+ type ResponseCheckpoint struct

+ AssistantText string

+ ConversationID string

+ Model string

+ ResponseID string

+ SessionEntryID int64

+ type SlackReplyTarget struct

+ ChannelID string

+ MessageTS string

+ ThreadTS string

+ type Source string

+ const SourceDiscordText

+ const SourceDiscordVoice

+ const SourceExternalMCP

+ const SourceSlack

+ const SourceSystem

+ const SourceWebVoice