backend

Nov 3, 2026

Changes in this version

type Runtime

+ func (r *Runtime) SandboxError() string

Nov 2, 2026

Changes in this version

type Runtime

+ CronJobs runtimeRefresher

type SessionService

+ func (s *SessionService) SaveTopShelf(ctx context.Context, username string, shelf []byte) error

+ func (s *SessionService) TopShelf(ctx context.Context, username string) ([]byte, error)

Oct 31, 2026

Changes in this version

+ func EasyUploadDir(cfg *config.Config, conversationID string) string

type Config

+ Secrets config.SecretFetcher

type GoalState

+ Origin string

type SessionService

+ func (s *SessionService) CronRunRecorded(path string) (bool, error)

Oct 31, 2026

Changes in this version

+ type BoardLane struct

+ Chats []SidebarChat

+ Total int

type Runtime

+ func (r *Runtime) JustBashInstallError() string

type SessionService

+ func (s *SessionService) Board(ctx context.Context, username, spaceID string, dashboards [][]string, ...) ([][]BoardLane, error)

type SidebarSession

+ ArrivedAt time.Time

+ External bool

+ Queued bool

+ StateSince time.Time

+ Work WorkState

+ type WorkState string

+ const WorkIdle

+ const WorkNeedsYou

+ const WorkQueued

+ const WorkRunning

Oct 29, 2026

Changes in this version

type SidebarSession

+ Asking bool

Oct 28, 2026

Changes in this version

type TabState

+ SharedOrder []string

Oct 27, 2026

Changes in this version

type SessionService

+ func (s *SessionService) EditSharedSearch(ctx context.Context, space, path string, base, search []byte) (bool, error)

type SharedTab

+ Search []byte

type Tab

+ Search []byte

Oct 25, 2026

Changes in this version

type Page

+ Conversation string

+ Space string

type Runtime

+ func (r *Runtime) OpenCodeMCP() http.Handler

Oct 25, 2026

Changes in this version

+ func TabConversation(path string) string

type SessionService

+ func (s *SessionService) MuteTab(ctx context.Context, username, path string, until *time.Time) error

+ func (s *SessionService) ShareTab(ctx context.Context, space, path string) error

+ func (s *SessionService) SharedTabs(ctx context.Context) ([]SharedTab, error)

+ func (s *SessionService) SwapSharedTabs(ctx context.Context, space, path, with string) error

+ func (s *SessionService) TabMutes(ctx context.Context, username string) ([]TabMute, error)

+ func (s *SessionService) UnmuteTab(ctx context.Context, username, path string) error

+ func (s *SessionService) UnshareTab(ctx context.Context, space, path string) error

+ type SharedTab struct

+ Path string

+ Space string

+ type TabMute struct

+ Path string

+ Until *time.Time

Oct 24, 2026

Changes in this version

type SessionService

+ func (s *SessionService) ForkOpenCodeSession(ctx context.Context, name string, server config.OpenCodeConfig, ...) (string, error)

Oct 23, 2026

Changes in this version

type SessionService

+ func (s *SessionService) LegacyTabStates(ctx context.Context) (map[string][]byte, error)

+ func (s *SessionService) ViewSession(ctx context.Context, username, conversationID string) error

type SidebarSession

+ UnreadAt time.Time

+ type Tab struct

+ Group string

+ Path string

+ Pinned bool

+ Preview bool

+ Space string

+ type TabGroup struct

+ Collapsed bool

+ Color string

+ ID string

+ Name string

+ type TabState struct

+ Groups []TabGroup

+ Last map[string]string

+ Placement string

+ Space string

+ Tabs []Tab

Oct 22, 2026

Changes in this version

+ var ErrInvalidRevertMessage = errors.New("invalid revert message ID")

+ var ErrRemoteSession = errors.New("a remote OpenCode session's history stays on its server")

+ var ErrRevertMessageGone = errors.New("revert message is no longer in the session")

type ChatOriginFacts

+ Run *protocol.CronRun

+ type ConversationKind string

+ const KindCronRun

+ const KindExternalMCPRun

+ const KindOneOffCronRun

+ const KindRemote

+ const KindReview

+ const KindShadow

+ const KindSlackThread

+ const KindSubagent

+ const KindWebChat

type CronRunSource

+ Run protocol.CronRun

+ type Delegation struct

+ CallID string

+ ID string

+ Kind ConversationKind

+ Legacy bool

+ Parent string

type ExternalMCPSessionState

+ Thread protocol.SlackReplyTarget

type HistorySnapshot

+ Floor string

+ Lineage []SidebarSession

+ Reviews []string

type RawRunProgress

+ Run *protocol.CronRun

type Runtime

+ func (r *Runtime) ContinueRun(ctx context.Context, run, conversationID string) error

type SessionService

+ func (s *SessionService) ConversationKind(ctx context.Context, id string) (kind ConversationKind, found bool, err error)

+ func (s *SessionService) CronRun(ctx context.Context, conversationID string) (path string, run bool, err error)

+ func (s *SessionService) SlackThread(ctx context.Context, conversationID string) (channelID, threadTS string, err error)

type SidebarSession

+ CronPath string

+ Kind ConversationKind

+ Origin ChatOriginFacts

+ RemoteSession string

+ SlackChannel string

+ func (row *SidebarSession) Label() string

Oct 22, 2026

Changes in this version

type Runtime

+ func (r *Runtime) EditQueueItem(ctx context.Context, conversationID, id, text string) (bool, error)

Oct 21, 2026

Changes in this version

+ type SearchScope int

+ const SearchFields

+ const SearchFilters

+ const SearchMessages

Oct 20, 2026

Changes in this version

type SidebarSession

+ Background bool

+ Model string

Oct 20, 2026

Changes in this version

type GoalState

+ PrincipalEmail string

+ PrincipalName string

Oct 19, 2026

Changes in this version

type SidebarSession

+ Reply string

Oct 19, 2026

Changes in this version

+ var ErrSpaceRejected = errors.New("another space has that name, or it is the last space")

type SessionService

+ func (s *SessionService) CreateSpace(ctx context.Context, name string) error

+ func (s *SessionService) DeleteSpace(ctx context.Context, id string) error

+ func (s *SessionService) RenameSpace(ctx context.Context, id, name string) error

+ func (s *SessionService) SaveTabState(ctx context.Context, username string, state []byte, revision int64) (bool, error)

+ func (s *SessionService) Spaces(ctx context.Context) ([]Space, error)

+ func (s *SessionService) TabState(ctx context.Context, username string) (state []byte, revision int64, err error)

type SidebarSession

+ SpaceID string

+ type Space struct

+ ID string

+ Name string

Oct 19, 2026

Changes in this version

+ type Page struct

+ Agent string

+ Body []byte

+ ContentType string

+ Kind PageKind

+ Name string

+ Size int

+ UpdatedAt time.Time

+ type PageKind string

+ const PageData

+ const PageFile

type SessionService

+ func (s *SessionService) DeletePage(ctx context.Context, agent string, kind PageKind, name string) (bool, error)

+ func (s *SessionService) Page(ctx context.Context, agent string, kind PageKind, name string) (Page, bool, error)

+ func (s *SessionService) Pages(ctx context.Context, agent string) ([]Page, error)

+ func (s *SessionService) PutPage(ctx context.Context, page *Page) error

Oct 18, 2026

Changes in this version

+ var ErrTagNotAllowed = errors.New("the session's agent does not allow this tag")

+ func AgentTags(agents rocketcode.Agents) map[string][]string

type SessionService

+ func (s *SessionService) CreateOpenCodeSession(ctx context.Context, name string, server config.OpenCodeConfig, ...) (string, error)

+ func (s *SessionService) SyncOpenCode(ctx context.Context, servers map[string]config.OpenCodeConfig)

+ func (s *SessionService) ToggleManualTag(ctx context.Context, agents rocketcode.Agents, id, tag string) error

type SidebarSession

+ Directory string

+ Offline bool

+ Server string

Oct 17, 2026

Changes in this version

type Bridge

+ func (b *Bridge) AppendChildEntry(ctx context.Context, key string, entry *rocketcode.SessionEntry) error

+ func (b *Bridge) AwaitSubagent(ctx context.Context, key, callKey string) (string, rocketcode.ReplayAttribution, error)

+ func (b *Bridge) WriteSubagent(ctx context.Context, write *rocketcode.SubagentWrite) (bool, error)

Oct 17, 2026

Changes in this version

+ func PromptPrincipal(header string) string

type SessionSearch

+ Principals []string

Oct 15, 2026

Changes in this version

type Runtime

+ ExternalMCPAgents externalMCPAgents

Oct 14, 2026

Changes in this version

type SessionService

+ func (s *SessionService) ResetVoiceConversation(ctx context.Context, username, conversationID string) error

+ func (s *SessionService) StartVoiceConversation(ctx context.Context, username, conversationID, agent string) error

+ func (s *SessionService) UpdateVoiceSettings(ctx context.Context, username string, agent, voice *string, transcript *bool) error

+ func (s *SessionService) VoiceSettings(ctx context.Context, username string) (VoiceSettings, error)

+ type VoiceSettings struct

+ Agent string

+ ConversationID string

+ Transcript bool

+ Voice string

Oct 13, 2026

Changes in this version

type Bridge

+ func (b *Bridge) Drain(ctx context.Context, phase rocketcode.TurnPhase, applied []string) ([]rocketcode.PromptInput, error)

type HistoryInventory

+ Shadows string

type HistorySnapshot

+ Shadows []protocol.ShadowBinding

type SessionService

+ func (s *SessionService) ShadowParent(ctx context.Context, id string) (string, error)

Oct 13, 2026

Changes in this version

type SessionService

+ func (s *SessionService) TurnAttachments(ctx context.Context, conversationID, turnID string) ([]protocol.OutboundAttachment, error)

Oct 10, 2026

Changes in this version

+ func DecideOrigin(facts *ChatOriginFacts) (origin any, text string)

+ func MentionedIDs(hits []MessageSearchHit, mentions map[string]string) []string

+ type CronRun struct

+ At time.Time

+ Stem string

+ func ParseCronRun(source string) (CronRun, bool)

+ type CronRunSource struct

+ ConversationID string

+ SourceConversationID string

+ type QuestionNotPendingError struct

+ ConversationID string

+ QuestionID string

+ func (e *QuestionNotPendingError) Error() string

type Runtime

+ func (r *Runtime) AnswerQuestion(ctx context.Context, conversationID, questionID string, ...) error

+ func (r *Runtime) PendingQuestions(ctx context.Context, conversationID string) ([]protocol.AskUserQuestionRequest, error)

+ type SearchKey string

+ type SearchTerm struct

+ End int

+ Key SearchKey

+ Start int

+ Text string

+ Value string

+ type SessionField string

+ type SessionMatch struct

+ Chat SidebarChat

+ Field SessionField

+ Text string

+ type SessionSearch struct

+ Hits []MessageSearchHit

+ IndexComplete bool

+ Matches []SessionMatch

+ MentionIDs []string

+ Needle string

+ SummariesComplete bool

+ Terms []SearchTerm

+ Text string

type SessionService

+ func (s *SessionService) CronRunSources(ctx context.Context) ([]CronRunSource, error)

+ func (s *SessionService) SearchMessagesMentioning(ctx context.Context, needle string, slack slackLookup) (hits []MessageSearchHit, mentions map[string]string, complete bool, err error)

+ func (s *SessionService) SearchSessions(ctx context.Context, query string, messages bool, slack slackLookup) (*SessionSearch, error)

+ func (s *SessionService) SidebarChats(ctx context.Context, slack slackLookup) iter.Seq2[SidebarChat, error]

+ type SidebarChat struct

+ Cron bool

+ CronName string

+ Origin string

+ Room string

+ RoomAgents []string

+ Session SidebarSession

type SlackFrontend

+ EditCronjobRootFooter func(ctx context.Context, msg *protocol.OutboundMessage, ...) error

+ SidebarChannelAgentChoices func(context.Context, string) (string, []string, error)

+ SlackTagsMatching func(context.Context, string) []string

Oct 8, 2026

Changes in this version

+ type MessageSearchHit struct

+ ConversationID string

+ MessageID string

+ Role string

+ Text string

type SessionService

+ func (s *SessionService) InputAttachments(ctx context.Context, producer, text string) (string, []protocol.OutboundAttachment, error)

+ func (s *SessionService) SearchMessages(ctx context.Context, needle string, tagPrefixes []string) (hits []MessageSearchHit, complete bool, err error)

Oct 8, 2026

Changes in this version

type Runtime

+ func (r *Runtime) BackgroundJobs(ctx context.Context, conversationID string) ([]protocol.BackgroundJob, bool, error)

+ func (r *Runtime) CompletionNotes(ctx context.Context, history string, jobIDs []string) ([]protocol.BackgroundJob, error)

+ func (r *Runtime) MoveToBackground(conversationID string) (bool, error)

+ func (r *Runtime) StopBackgroundJob(ctx context.Context, conversationID, jobID string) (bool, error)

Oct 7, 2026

Changes in this version

+ type HistoryInventory struct

+ ConversationID string

+ Entries map[string]string

+ From int64

+ Marker string

+ Oldest int64

+ Source string

+ type HistorySnapshot struct

+ Delegations []string

+ Eligible bool

+ Entries []ObservedSessionEntry

+ Inventory HistoryInventory

+ Predecessor string

+ Reset bool

type Runtime

+ func (r *Runtime) ClearRevert(ctx context.Context, conversationID string) error

+ func (r *Runtime) StageRevert(ctx context.Context, conversationID, before string) (marker, prompt string, err error)

type SessionService

+ func (s *SessionService) ObserveHistory(ctx context.Context, id, source string, from, before int64, limit int, ...) (view HistorySnapshot, err error)

+ func (s *SessionService) RevertAttachmentMetadata(ctx context.Context, conversationID, id string) (protocol.OutboundAttachment, error)

+ func (s *SessionService) RevertState(ctx context.Context, conversationID string) (marker string, eligible bool, predecessor string, err error)

Oct 6, 2026

Changes in this version

type Bridge

+ func (b *Bridge) Run(ctx context.Context) error

+ type ChatOriginFacts struct

+ Binding ExternalMCPSessionState

+ ConversationID string

+ CreatedBy ThreadCreator

+ CreatingSource string

+ ExternalConversationID string

+ ProducerAgent string

type ExternalMCPSessionState

+ OriginPairs map[string]string

type SessionService

+ func (s *SessionService) ChatOriginFacts(ctx context.Context) iter.Seq2[ChatOriginFacts, error]

+ func (s *SessionService) HasActiveTurn(ctx context.Context, conversationID string) (bool, error)

+ func (s *SessionService) LoadTurnStep(ctx context.Context, conversationID, key string) (value json.RawMessage, found bool, err error)

+ func (s *SessionService) SaveTurnStep(ctx context.Context, conversationID, key string, value json.RawMessage) error

type SlackFrontend

+ SendCronjobRoot func(context.Context, *protocol.OutboundMessage) (protocol.TextConversationTarget, error)

Oct 5, 2026

Changes in this version

type ActiveTurnState

+ Terminal protocol.Terminal

type ObservedSessionEntry

+ Active bool

+ Key string

+ Revision string

+ Terminal protocol.Terminal

type Runtime

+ func (r *Runtime) StartGoal(ctx context.Context, inbound *protocol.InboundMessage, ...) error

+ func (r *Runtime) WorkflowDescriptions() (descriptions []protocol.WorkflowDescription, err error)

type SessionService

+ func (s *SessionService) Changes(ctx context.Context, conversationID string) iter.Seq2[protocol.ConversationChange, error]

+ func (s *SessionService) ObserveTranscript(ctx context.Context, conversationID string, from, before int64, ...) ([]ObservedSessionEntry, error)

+ func (s *SessionService) OriginPairs(ctx context.Context, conversationID string) (map[string]string, error)

+ func (s *SessionService) SetActiveTurnTerminal(ctx context.Context, turnID string, terminal protocol.Terminal) error

+ func (s *SessionService) TranscriptPage(ctx context.Context, conversationID string, before int64, limit int) (start, oldest int64, err error)

type SidebarSession

+ Tags []string

Oct 2, 2026

Changes in this version

type SessionService

+ func (s *SessionService) Delegations(ctx context.Context, producers []string) ([]string, error)

Sep 28, 2026

Changes in this version

+ func GenerateHandoff(ctx context.Context, cfg *config.Config, agent, transcript string) (document string, err error)

type SessionService

+ func (s *SessionService) ForkConversation(ctx context.Context, source string, destination protocol.Conversation, ...) (string, error)

type SidebarSession

+ ForkedFrom string

Sep 26, 2026

Changes in this version

type SidebarSession

+ SnoozedUntil *time.Time

Sep 24, 2026

Changes in this version

+ func OriginPairsFromEntry(entry *rocketcode.SessionEntry) (map[string]string, bool)

+ func ReplayDeliveryText(items []responses.ResponseInputItemUnionParam) (string, error)

+ func ReplayInputMessageRoleText(item *responses.ResponseInputItemUnionParam, raw json.RawMessage) (role, text string, ok bool, err error)

+ type FrontendAssembler interface

+ Assemble func(*Runtime) (SlackFrontend, <-chan struct{}, []func(context.Context) error, error)

+ ValidateAssets func(*config.Config, string, []string) error

type ObservedSessionEntry

+ SourceConversationID string

+ Synced bool

type RawRunProgress

+ Cronjob *protocol.CronjobMessage

+ SyncDestination string

type Runtime

+ func (r *Runtime) CreateConversation(ctx context.Context, conversation protocol.Conversation) error

+ func (r *Runtime) DeleteQueueItem(ctx context.Context, conversationID, id string) (bool, error)

+ func (r *Runtime) ListConversations(ctx context.Context) (conversations []protocol.Conversation, err error)

+ func (r *Runtime) PopQueueItem(ctx context.Context, conversationID, id string) (bool, error)

+ func (r *Runtime) PromoteQueueItem(ctx context.Context, conversationID, id string) (bool, error)

+ func (r *Runtime) PublishOutbound(ctx context.Context, message *protocol.OutboundMessage) error

+ func (r *Runtime) QueueItems(conversationID string) ([]protocol.ThreadQueueItem, error)

+ func (r *Runtime) ReorderQueueItems(conversationID string, ids []string) error

+ func (r *Runtime) RunTurn(ctx context.Context, inbound *protocol.InboundMessage) error

+ func (r *Runtime) StashQueueItem(ctx context.Context, conversationID string, item *protocol.ThreadQueueItem) error

+ func (r *Runtime) Subscribe(ctx context.Context) iter.Seq[protocol.Event]

+ func (r *Runtime) SwitchConversationAgent(conversationID, agent string) (bool, error)

+ func (r *Runtime) SyncConversation(ctx context.Context, source, destination string) error

type SessionService

+ func (s *SessionService) AttachmentMetadata(ctx context.Context, conversationID, id string, uploadOnly bool) (protocol.OutboundAttachment, error)

+ func (s *SessionService) ChannelFact(ctx context.Context, workspaceID, channelID string) (name string, found bool, err error)

+ func (s *SessionService) DeleteSession(ctx context.Context, conversationID string) (int64, error)

+ func (s *SessionService) ListSessions(ctx context.Context, conversationIDs []string) ([]protocol.SessionSummary, error)

+ func (s *SessionService) LoadAttachment(ctx context.Context, conversationID, id string, uploadOnly bool) (protocol.OutboundAttachment, error)

+ func (s *SessionService) RecordChannelFact(ctx context.Context, workspaceID, channelID, name string, observedAt time.Time) error

+ func (s *SessionService) ReplayAttachments(ctx context.Context, conversationID string, root *os.Root, raw json.RawMessage, ...) ([]protocol.OutboundAttachment, error)

+ func (s *SessionService) SaveAttachment(ctx context.Context, conversationID string, ...) error

+ func (s *SessionService) SetConversationSettled(ctx context.Context, conversationID string, settled bool) (bool, error)

+ func (s *SessionService) SidebarSessions(ctx context.Context, autoSettleBefore time.Time) iter.Seq2[SidebarSession, error]

+ func (s *SessionService) SlackChannelIDs(ctx context.Context) ([]string, error)

+ func (s *SessionService) UpdateConversationDetails(ctx context.Context, conversationID string, pinned *bool, name *string) (bool, error)

+ type SidebarSession struct

+ Conversation protocol.Conversation

+ Name string

+ Pinned bool

+ Running bool

+ Summary *protocol.SessionSummary

type ThreadState

+ Settled bool

Sep 1, 2026

Changes in this version

+ const GoalStatusActive

+ const GoalStatusBlocked

+ const GoalStatusBudgetExhausted

+ const GoalStatusComplete

+ const GoalStatusProgress

+ const GoalStatusStopped

+ const RawRunExposedToolName

+ var ErrRestartRequested = errors.New("restart requested")

+ func DeleteSessionIn(ctx context.Context, databaseURL, conversationID string) (int64, error)

+ func ExternalMCPAgentsIn(cfg *config.Config, runtimeDir string) ([]string, error)

+ func IsBridgeStopped(err error) bool

+ func LintTry(workspace, runtimeDir string, overlays []string, baseOverlay string, ...) (protocol.LintResult, error)

+ func LoadRuntimeDefinitions(cfg *config.Config, runtimeDir string) (rocketcode.Agents, rocketcode.Skills, error)

+ func NoopActivationHook(_ context.Context, _ *protocol.InboundMessage) error

+ func OverlayContextFromSkel(got skel.OverlayContext) protocol.OverlayContext

+ func Run(ctx context.Context, cfg *config.Config, configPath string, ...) error

+ func RunTryTurn(ctx context.Context, workspace, runtimeDir string, overlays []string, ...) (thinking, answer string, err error)

+ func ValidateGoalCheckScriptStart(cfg *config.Config, agentName, script string) error

+ func ValidateRuntimeDefinitions(workspace, runtimeDir string, channels []string) error

+ type ActiveTurnState struct

+ Checkpoint harness.ActiveTurnCheckpoint

+ CreatedAt time.Time

+ PendingSteers []protocol.PendingSteer

+ SourceMetadata map[string]string

+ UpdatedAt time.Time

+ type Bridge struct

+ func NewConversation(cfg *config.Config, publisher protocol.OutboundPublisher, bridgeCfg *Config, ...) *Bridge

+ func (b *Bridge) InterruptActiveTurn() *protocol.InboundMessage

+ func (b *Bridge) PickLaterWork(ctx context.Context) error

+ func (b *Bridge) RecoverActiveTurn(ctx context.Context, turn *ActiveTurnState) error

+ func (b *Bridge) ResetScheduledMessages() error

+ func (b *Bridge) ScheduleMessage(delay time.Duration, message string, recurring bool) error

+ func (b *Bridge) Start(ctx context.Context) error

+ func (b *Bridge) Stop() error

+ func (b *Bridge) Submit(ctx context.Context, msg *protocol.InboundMessage) error

+ func (b *Bridge) SubmitWhenActive(ctx context.Context, msg *protocol.InboundMessage, ...) error

+ func (b *Bridge) SwitchAgent(agent string)

+ type Config struct

+ Agent string

+ AgentAfterRecovery string

+ ConversationID string

+ EnqueueActivation EnqueueActivation

+ ExternalConversationID string

+ ManagedConversationID string

+ OutputTargets []protocol.OutputTarget

+ RecoveringActiveTurn bool

+ RequestReload func(context.Context, string) (string, error)

+ RequestRestart func(context.Context, string) (string, error)

+ SessionService *SessionService

+ StartNewThread func(context.Context, *protocol.StartNewThreadRequest) (protocol.StartNewThreadResult, error)

+ SteerDrain rocketcode.SteerDrain

+ UserQuestionAsker protocol.UserQuestionAsker

+ type CronScheduleRun struct

+ DueAt time.Time

+ RelativePath string

+ ScheduleID string

+ type CronScheduleState struct

+ NextDue time.Time

+ RelativePath string

+ ScheduleID string

+ type DevelopmentChat struct

+ type DevelopmentTurnResult struct

+ Answer string

+ Thinking string

+ func RunDevelopmentTurn(ctx context.Context, cfg *config.Config, runtimeDir, agent, prompt string, ...) (DevelopmentTurnResult, error)

+ type EnqueueActivation struct

+ Fn func(context.Context, *protocol.ThreadQueueItem, *protocol.InboundMessage) error

+ func (a EnqueueActivation) Activate(ctx context.Context, item *protocol.ThreadQueueItem, ...) error

+ type ExternalMCPSessionState struct

+ Agent string

+ ManagedConversationID string

+ PrivateConversationID string

+ SlackChannel string

+ type GoalState struct

+ CheckScript string

+ CreatedAt time.Time

+ MaxTurns int

+ Note string

+ Objective string

+ SlackRecipientTeamID string

+ SlackRecipientUserID string

+ Status string

+ TurnsUsed int

+ UpdatedAt time.Time

+ type KeyedConversationLocks struct

+ func NewKeyedConversationLocks() *KeyedConversationLocks

+ func (l *KeyedConversationLocks) Lock(key string) func()

+ type Manager struct

+ func New(workspace, runtimeDir string, channels []string, ...) *Manager

+ func (m *Manager) ListCronjobs(channel string) ([]string, error)

+ func (m *Manager) LoadOneOffCronjob(target string) (protocol.OneOffCronjob, error)

+ func (m *Manager) RunOneOffCronjob(ctx context.Context, job protocol.OneOffCronjob, ...)

+ func (m *Manager) Start(ctx context.Context) error

+ func (m *Manager) Stop(ctx context.Context) error

+ type ObservedSessionEntry struct

+ Entry harness.SessionEntry

+ ID int64

+ func ObserveSessionEntries(ctx context.Context, databaseURL, conversationID string, lastID int64) ([]ObservedSessionEntry, error)

+ type PruneStateStats struct

+ ExternalMCPSessions int

+ SessionRows int64

+ Threads int

+ type RawRunProgress struct

+ ConversationID string

+ Message func(context.Context, string) error

+ RequestReload func(context.Context, string) (string, error)

+ RequestRestart func(context.Context, string) (string, error)

+ SessionService *SessionService

+ StartNewThread func(context.Context, *protocol.StartNewThreadRequest) (protocol.StartNewThreadResult, error)

+ TextChannel string

+ Thinking func(context.Context, string) error

+ type RawRunResult struct

+ Attachments []protocol.OutboundAttachment

+ Text string

+ VerbatimMessage string

+ func RunRawWithProgress(ctx context.Context, cfg *config.Config, agent, prompt string, ...) (result RawRunResult, err error)

+ type RunFunc func(context.Context, string, string, *slog.Logger, *RawRunProgress) (protocol.CronRunResult, error)

+ type Runtime struct

+ CannotResume []cannotResumeItem

+ Cfg *config.Config

+ Channels protocol.Channels

+ ConfigPath string

+ Cron *Manager

+ ExternalMCPUsers map[string]string

+ Log *slog.Logger

+ OverlayMu *sync.Mutex

+ RecoveredTurns []ActiveTurnState

+ RefreshExternalMCPAgents *func() error

+ Reload func(context.Context, string) (string, error)

+ Restart func(context.Context, string) (string, error)

+ RunCtx context.Context

+ Sessions *SessionService

+ TextRouter protocol.PrimaryTextRouter

+ func (r *Runtime) AttachSlack(slack SlackFrontend)

+ func (r *Runtime) SubmitExternalMCP(ctx context.Context, agent, conversationID string, ...) error

+ type SessionListOptions struct

+ Limit int

+ Since time.Time

+ Until time.Time

+ type SessionService struct

+ func NewSessionServiceIn(databaseURL string, logger *slog.Logger) (*SessionService, error)

+ func (s *SessionService) AccountGoalTurn(conversationID string) (GoalState, bool, error)

+ func (s *SessionService) ActiveGoalThreads() (map[string]ThreadState, error)

+ func (s *SessionService) ActiveGoals() (map[string]GoalState, error)

+ func (s *SessionService) ActiveTurn(ctx context.Context, turnID string) (ActiveTurnState, bool, error)

+ func (s *SessionService) AppendEntryID(ctx context.Context, conversationID string, entry *harness.SessionEntry) (int64, error)

+ func (s *SessionService) ApplyPendingRestartNotifications(ctx context.Context) error

+ func (s *SessionService) BeginGoal(conversationID, objective, checkScript string, maxTurns int, ...) error

+ func (s *SessionService) ClaimCronSchedule(due CronScheduleState, nextDue, now time.Time) (CronScheduleRun, bool, error)

+ func (s *SessionService) ClaimScheduledMessage(id, conversationID string, dueAt, now time.Time) (message protocol.ScheduledMessageState, claimed bool, err error)

+ func (s *SessionService) ClearActiveTurn(ctx context.Context, turnID string) error

+ func (s *SessionService) CompleteCronRun(relativePath string, now time.Time) error

+ func (s *SessionService) DeleteScheduledMessage(id string) error

+ func (s *SessionService) DeleteThreadQueueItem(id string) error

+ func (s *SessionService) DueCronSchedules(now time.Time, limit int) ([]CronScheduleState, error)

+ func (s *SessionService) ExternalMCPSession(externalConversationID string) (ExternalMCPSessionState, bool, error)

+ func (s *SessionService) ExternalMCPSessionByConversationID(conversationID string) (externalConversationID string, session ExternalMCPSessionState, ok bool, ...)

+ func (s *SessionService) Goal(conversationID string) (GoalState, bool, error)

+ func (s *SessionService) MarkRestartRequester(ctx context.Context, conversationID string) error

+ func (s *SessionService) ObserveEntries(ctx context.Context, conversationID string, lastID int64) ([]ObservedSessionEntry, error)

+ func (s *SessionService) PairBusy(pairID string) bool

+ func (s *SessionService) PairBusyFor(pairID, conversationID string) bool

+ func (s *SessionService) PruneStateBefore(ctx context.Context, cutoff time.Time) (PruneStateStats, error)

+ func (s *SessionService) PutMCPWaiter(id string, inbound *protocol.InboundMessage)

+ func (s *SessionService) PutScheduledMessage(id string, message *protocol.ScheduledMessageState) error

+ func (s *SessionService) PutThreadQueueItem(id string, item *protocol.ThreadQueueItem) error

+ func (s *SessionService) RecoverableActiveTurns(ctx context.Context) ([]ActiveTurnState, error)

+ func (s *SessionService) RegisterExternalMCPConversation(externalConversationID, managedAgent string, session *ExternalMCPSessionState) error

+ func (s *SessionService) ReleaseExternalMCPRecovery(conversationID string) error

+ func (s *SessionService) RemoveExternalMCPConversation(externalConversationID string) error

+ func (s *SessionService) ReserveExternalMCPRecovery(conversationID string) error

+ func (s *SessionService) ReserveWorkflowTurn(conversationID string) (release func(), reserved bool, err error)

+ func (s *SessionService) ResetCronSchedules() error

+ func (s *SessionService) ResetScheduledMessages(conversationID string) error

+ func (s *SessionService) ScheduledMessages() (map[string]protocol.ScheduledMessageState, error)

+ func (s *SessionService) ScheduledMessagesForConversation(conversationID string) (map[string]protocol.ScheduledMessageState, error)

+ func (s *SessionService) SetPendingSteers(conversationID string, steers []protocol.PendingSteer) error

+ func (s *SessionService) SetThreadAgentIfExists(conversationID, agent string) (bool, error)

+ func (s *SessionService) StartActiveTurn(ctx context.Context, checkpoint *harness.ActiveTurnCheckpoint) error

+ func (s *SessionService) Stop(context.Context) error

+ func (s *SessionService) StopGoal(conversationID string) error

+ func (s *SessionService) SyncCronSchedules(schedules []CronScheduleState, now time.Time) error

+ func (s *SessionService) TakeMCPWaiter(id string) *protocol.InboundMessage

+ func (s *SessionService) Thread(conversationID string) (ThreadState, bool, error)

+ func (s *SessionService) ThreadQueueForConversation(conversationID string) ([]protocol.ThreadQueueItem, error)

+ func (s *SessionService) UpdateGoalStatus(conversationID, status, note string) (GoalState, error)

+ func (s *SessionService) UpsertActiveTurn(ctx context.Context, checkpoint *harness.ActiveTurnCheckpoint, ...) error

+ func (s *SessionService) UpsertExternalMCPSession(externalConversationID string, session *ExternalMCPSessionState) error

+ func (s *SessionService) UpsertThread(conversationID string, thread ThreadState) error

+ type SessionSummary struct

+ ConversationID string

+ LastAssistantMessage string

+ LastUpdated time.Time

+ LastUserMessage string

+ Turns int

+ func ListSessionsInOptions(ctx context.Context, databaseURL string, options SessionListOptions) ([]SessionSummary, error)

+ type SideAskRunner struct

+ Config *config.Config

+ Logger *slog.Logger

+ Sessions *SessionService

+ func (r SideAskRunner) Run(ctx context.Context, req protocol.SideAskRequest) error

+ type SlackFrontend interface

+ AbortResponse func(*protocol.OutboundMessage)

+ ActivateEnqueue func(context.Context, *protocol.ThreadQueueItem, *protocol.InboundMessage) error

+ AskUserQuestion func(context.Context, *protocol.AskUserQuestionRequest) (protocol.AskUserQuestionAnswer, error)

+ DiscardPendingSteers func(context.Context, []protocol.PendingSteer)

+ DrainSteers func(context.Context, string) []string

+ HandleBroadcast func(context.Context, *protocol.Broadcast) protocol.BroadcastAcknowledgement

+ RestorePendingSteers func(string, []protocol.PendingSteer)

+ SendResponse func(context.Context, *protocol.OutboundMessage) error

+ SetPendingSteersSink func(protocol.PendingSteersSink)

+ Start func(context.Context) error

+ StartNewThreadRoot func(context.Context, *protocol.StartNewThreadRequest) (protocol.StartNewThreadRootResult, error)

+ Stop func(context.Context) error

+ type ThreadCreator string

+ const ThreadCreatedByCron

+ type ThreadState struct

+ Agent string

+ CreatedBy ThreadCreator