protocol

Nov 2, 2026

Changes in this version

type InboundMessage

+ ExternalMCPMetadata map[string]string

Oct 31, 2026

Changes in this version

type InboundMessage

+ OriginHeader string

type ScheduledMessageState

+ Origin string

Oct 22, 2026

Changes in this version

type Conversation

+ Run *CronRun

+ type CronRun struct

+ At time.Time

+ OneOff bool

+ Path string

Oct 20, 2026

Changes in this version

+ const InboundPrincipalEmailMetadataKey

+ const InboundPrincipalNameMetadataKey

Oct 19, 2026

Changes in this version

type Conversation

+ Space string

type CronjobMessage

+ Space string

Oct 18, 2026

Changes in this version

type OneOffCronjob

+ Space string

Oct 17, 2026

Changes in this version

+ const InboundSenderActionMetadataKey

+ const InboundSenderAgentMetadataKey

+ const InboundSenderSessionMetadataKey

+ const SenderActionStopped

Oct 13, 2026

Changes in this version

type OutboundAttachment

+ ConversationID string

+ type ShadowBinding struct

+ ChildConversationID string

+ ParentAgent string

+ ParentConversationID string

+ ShadowAgent string

+ Turns []ShadowTurn

+ type ShadowTurn struct

+ ChildTurnID string

+ Order int64

+ ParentSourceConversationID string

+ ParentTurnID string

+ Revision string

+ Running bool

+ Terminal Terminal

Oct 10, 2026

Changes in this version

type OutboundMessage

+ Terminal Terminal

type PrimaryTextRouter

+ MentionThread func(target TextConversationTarget) (recorded, report bool, err error)

+ SubmitMention func(ctx context.Context, agent string, target TextConversationTarget, ...) (bool, error)

+ WebURL func(ctx context.Context, conversationID string) (string, error)

Oct 8, 2026

Changes in this version

+ type BackgroundJob struct

+ Hidden bool

+ ID string

+ Kind string

+ Label string

+ Note string

+ State string

+ StoppedBy string

+ SubagentKey string

+ ToolCallID string

Oct 7, 2026

Changes in this version

type StartNewThreadRequest

+ CreatedBy string

Oct 6, 2026

Changes in this version

+ var ErrBridgeStopped = errors.New("bridge stopped")

+ func ReplyStepKey(turnID string) string

type OutboundMessage

+ ReplyState json.RawMessage

type ThreadQueueItem

+ Inbound *InboundMessage

Oct 5, 2026

Changes in this version

+ type AttachmentPresence string

+ const AttachmentPresenceImages

+ const AttachmentPresenceNone

+ const AttachmentPresenceUnsupported

+ type ConversationChange struct

+ ConversationID string

+ Revision string

+ type GoalAction string

+ const GoalActionContinue

+ const GoalActionKickoff

+ const GoalActionNone

type InboundContent

+ AttachmentPresence AttachmentPresence

type InboundMessage

+ AttachmentPresence AttachmentPresence

+ GoalAction GoalAction

+ PreserveWhitespace bool

Oct 2, 2026

Changes in this version

type OutboundMessage

+ ConsumedHeader string

Sep 29, 2026

Changes in this version

type OutboundMessage

+ ConsumedRawText string

+ ConsumedSource Source

Sep 28, 2026

Changes in this version

type OutboundMessage

+ Model string

+ ReasoningEffort *string

+ SourceConversationID string

Sep 24, 2026

Changes in this version

+ const InboundRawTextMetadataKey

+ func Clone[T any](p *T) *T

+ func NormalizeMIMEType(mimeType string) string

+ type Conversation struct

+ Agent string

+ CreatedBy string

+ ID string

+ Settled bool

type CronRunResult

+ ConversationID string

+ type Event struct

+ Acknowledgement chan error

+ Message *OutboundMessage

type InboundKind

+ const InboundKindCancel

+ const InboundKindEnqueue

+ const InboundKindHeld

+ const InboundKindSteer

type InboundMessage

+ Cronjob *CronjobMessage

+ RequireOutputDecision bool

+ SyncDestination string

type OneOffCronjob

+ ConversationID string

type OutboundAttachment

+ ID string

+ OriginalUnverified bool

+ Size int64

type OutboundMessage

+ ConsumedID string

+ ConsumedText string

type PrimaryTextRouter

+ PromoteThreadQueueItem func(ctx context.Context, target TextConversationTarget, id string) (bool, error)

+ SkillDescriptions func(agent string) ([]SkillDescription, error)

+ type SessionSummary struct

+ ConversationID string

+ LastMessage string

+ LastUpdated time.Time

+ type SkillDescription struct

+ Description string

+ Name string

type Source

+ const SourceWeb

type ThreadQueueItem

+ Content InboundContent

+ Kind InboundKind

+ SlackReply *SlackReplyTarget

+ Source Source

Sep 1, 2026

Changes in this version

+ const GoalCommandHelp

+ const InboundAllowedAgentsMetadataKey

+ const InboundMediaMetadataKey

+ const InboundOriginMetadataKey

+ const InboundPrincipalMetadataKey

+ const InboundStartNewThreadDisabledMetadataKey

+ const MaxInboundTextAttachmentBytes

+ var ErrGoalAlreadyActive = errors.New("goal already active")

+ func AttachmentNamesSpeech(attachments []OutboundAttachment) string

+ func IsTextAttachment(name, mimeType string) bool

+ func OnDemandCronTarget(text string, prefixes ...string) (string, bool)

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

+ func SlackThreadConversationID(channelID, threadTS string) string

+ func SlackThreadTarget(conversationID string) (channelID, threadTS string, ok bool)

+ func StartNewThreadRootText(title, prompt string) string

+ func StaticGoalCheckWord(word *syntax.Word) (string, error)

+ type ActivationHook func(context.Context, *InboundMessage) error

+ type AgentUpdate struct

+ Activity string

+ CallID string

+ Label string

+ PhaseID string

+ type AskUserQuestionAnswer struct

+ Custom string

+ Selected []string

+ Source Source

+ type AskUserQuestionOption struct

+ Description string

+ Label string

+ Value string

+ type AskUserQuestionRequest struct

+ Bridge BridgeID

+ ConversationID string

+ Details string

+ ID string

+ Multiple bool

+ Options []AskUserQuestionOption

+ Question string

+ SlackReply *SlackReplyTarget

+ Source Source

+ 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

+ func NewChannels() Channels

+ type CronProgress struct

+ Message func(context.Context, string) error

+ Thinking func(context.Context, string) error

+ type CronRunResult struct

+ Attachments []OutboundAttachment

+ Text string

+ VerbatimMessage string

+ type CronjobMessage struct

+ Agent string

+ RanAt string

+ RelativePath string

+ type ExternalMCPRelay struct

+ Agent string

+ Attachments []OutboundAttachment

+ ConversationID string

+ ExternalConversationID string

+ Text string

+ type GoalRequest struct

+ CheckScript string

+ MaxTurns int

+ Objective string

+ func ParseGoalRequest(text string) (goal GoalRequest, rejection string)

+ type InboundAttachment struct

+ Data []byte

+ MIMEType string

+ Name string

+ type InboundContent struct

+ AttachmentWarnings []string

+ Attachments []InboundAttachment

+ HadAttachments bool

+ HadNonImageAttachments bool

+ Text string

+ TextAttachments []string

+ type InboundKind string

+ const InboundKindInternalize

+ const InboundKindPrompt

+ type InboundMessage struct

+ AttachmentWarnings []string

+ Attachments []InboundAttachment

+ Bridge BridgeID

+ ConversationID string

+ GoalTurn bool

+ HadAttachments bool

+ HadNonImageAttachments bool

+ Human bool

+ Kind InboundKind

+ Label string

+ Metadata map[string]string

+ Response chan Response

+ SlackReply *SlackReplyTarget

+ Source Source

+ Text string

+ VerbatimAttachments []OutboundAttachment

+ VerbatimMessage string

+ Workflow *WorkflowInvocation

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

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

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

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

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

+ type InboundResponse struct

+ Attachments []OutboundAttachment

+ Err error

+ Text string

+ type LaterWorkKind string

+ const LaterWorkQueued

+ const LaterWorkScheduled

+ type LaterWorkRow struct

+ Kind LaterWorkKind

+ Queue ThreadQueueItem

+ Scheduled ScheduledMessageState

+ ScheduledID string

+ func MixedLaterWork(queue []ThreadQueueItem, scheduled map[string]ScheduledMessageState) []LaterWorkRow

+ type LintFinding struct

+ Code string

+ Message string

+ Path string

+ Severity string

+ type LintRequest struct

+ Context OverlayContext

+ type LintResult struct

+ Findings []LintFinding

+ type OneOffCronjob struct

+ Agent string

+ Prompt string

+ RelativePath string

+ TextChannel string

+ type OutboundAttachment struct

+ Data []byte

+ MIMEType string

+ Name string

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

+ type OutboundMessage struct

+ Agent string

+ Attachments []OutboundAttachment

+ Bridge BridgeID

+ Complete bool

+ ConversationID string

+ Cronjob *CronjobMessage

+ ExternalConversationID string

+ GoalActive bool

+ GoalComplete bool

+ GoalMaxTurns int

+ GoalTurn bool

+ GoalTurnNumber int

+ PostProgressText bool

+ ProgressText string

+ Response chan Response

+ Sequence int

+ SessionEntryID int64

+ SlackReply *SlackReplyTarget

+ Source Source

+ Targets []OutputTarget

+ Text string

+ TurnID string

+ WorkflowAgent *AgentUpdate

+ WorkflowPhase *PhaseUpdate

+ WorkflowTerminal Terminal

+ func CloneOutboundMessage(message *OutboundMessage) *OutboundMessage

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

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

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

+ type OutboundPublisher interface

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

+ type OutputTarget string

+ const OutputTargetSlack

+ type OverlayContext struct

+ BaseOverlay string

+ Files []OverlayFile

+ type OverlayFile struct

+ Content string

+ Path string

+ type OverlaySpec struct

+ Spec string

+ type PendingSteer struct

+ Principal string

+ SlackChannel string

+ SlackTS string

+ SlackThreadTS string

+ Text string

+ type PendingSteersSink struct

+ Set func(conversationID string, steers []PendingSteer) error

+ func (s PendingSteersSink) Persist(conversationID string, steers []PendingSteer)

+ type PhaseStatus string

+ const PhaseComplete

+ const PhaseError

+ const PhaseInProgress

+ const PhasePending

+ const PhaseSkipped

+ type PhaseUpdate struct

+ Complete int

+ Details string

+ Name string

+ PhaseID string

+ Running int

+ Scheduled int

+ Status PhaseStatus

+ type PrimaryTextRouter interface

+ DeleteThreadQueueItem func(ctx context.Context, target TextConversationTarget, id string) error

+ InterruptConversation func(conversationID string) *InboundMessage

+ InterruptThread func(target TextConversationTarget) (*InboundMessage, error)

+ PickQueuedWork func(ctx context.Context, target TextConversationTarget) error

+ RegisterCronThread func(ctx context.Context, target TextConversationTarget, agent string) error

+ RegisterThread func(target TextConversationTarget, agent string) (created bool, err error)

+ ReserveWorkflowTurn func(target TextConversationTarget) (release func(), reserved bool, err error)

+ ScheduledMessages func(ctx context.Context, target TextConversationTarget) (map[string]ScheduledMessageState, error)

+ StartGoalInThread func(ctx context.Context, agent, objective, checkScript string, maxTurns int, ...) error

+ StartThread func(ctx context.Context, agent string, target TextConversationTarget, ...) error

+ StartWorkflowInThread func(ctx context.Context, agent, name, args string, target TextConversationTarget, ...) error

+ StashThreadQueueItem func(ctx context.Context, target TextConversationTarget, item *ThreadQueueItem) error

+ SubmitThreadReply func(ctx context.Context, target TextConversationTarget, inbound *InboundMessage) (bool, error)

+ SubmitWhenActive func(ctx context.Context, target TextConversationTarget, inbound *InboundMessage, ...) (bool, error)

+ SwitchThreadAgent func(target TextConversationTarget, agent string) (bool, error)

+ ThreadAgent func(target TextConversationTarget) (agent string, handled bool, err error)

+ ThreadBusy func(target TextConversationTarget) bool

+ ThreadQueueItems func(ctx context.Context, target TextConversationTarget) ([]ThreadQueueItem, error)

+ WorkflowDescriptions func() ([]WorkflowDescription, error)

+ type ReloadRequest struct

+ Reason string

+ type Response struct

+ Err error

+ Payload ResponsePayload

+ type ResponseKind string

+ const ResponseInteraction

+ const ResponseProgress

+ const ResponseResult

+ type ResponsePayload interface

+ ResponseKind func() ResponseKind

+ type RestartRequest struct

+ Reason string

+ type ScheduledMessageState struct

+ Agent string

+ ConversationID string

+ DueAt time.Time

+ Interval time.Duration

+ Message string

+ Recurring bool

+ type SideAskRequest struct

+ Agent string

+ ConversationID string

+ Message func(context.Context, string) error

+ Question string

+ SessionEntryID int64

+ Thinking func(context.Context, string) error

+ type SlackReplyTarget struct

+ ChannelID string

+ MessageTS string

+ RecipientTeamID string

+ RecipientUserID string

+ ThreadTS string

+ type Source string

+ const SourceExternalMCP

+ const SourceSlack

+ const SourceSystem

+ type StartNewThreadRequest struct

+ Agent string

+ AllowedAgents []string

+ Bridge BridgeID

+ CurrentAgent string

+ Prompt string

+ Response chan Response

+ SlackReply *SlackReplyTarget

+ Source Source

+ SourceConversationID string

+ Title string

+ type StartNewThreadResponse struct

+ Err chan error

+ Request *StartNewThreadRequest

+ Root chan StartNewThreadRootResult

+ func (StartNewThreadResponse) ResponseKind() ResponseKind

+ type StartNewThreadResult struct

+ ConversationID string

+ URL string

+ type StartNewThreadRootResult struct

+ Target TextConversationTarget

+ URL string

+ type Terminal string

+ const TerminalComplete

+ const TerminalFailed

+ const TerminalStopped

+ type TextConversationTarget struct

+ ChannelID string

+ MessageID string

+ ThreadID string

+ type TextResponse struct

+ Kind ResponseKind

+ Message *OutboundMessage

+ func (r *TextResponse) ResponseKind() ResponseKind

+ type ThreadQueueItem struct

+ ConversationID string

+ ID string

+ Message string

+ ParkAfter string

+ Position int

+ Principal string

+ SlackChannel string

+ SlackTS string

+ StashAt time.Time

+ type TryTurnRequest struct

+ Agent string

+ Context OverlayContext

+ ConversationID string

+ Prompt string

+ type TryTurnResult struct

+ Answer string

+ ConversationID string

+ Thinking string

+ 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

+ type WorkflowDescription struct

+ Description string

+ Name string

+ type WorkflowInvocation struct

+ Args string

+ Name string

+ RunID string