services

package

Go to main page

Versions in this module

v1

v1.24.0

Apr 30, 2026

v1.23.1

Apr 28, 2026

Changes in this version

type SessionService

+ func (s *SessionService) SetHistoryLinker(hl *session.HistoryLinker)

v1.23.0

Apr 27, 2026

Changes in this version

+ type ProjectService struct

+ func NewProjectService(storage *session.Storage) *ProjectService

+ func (s *ProjectService) AssignSessionsToProject(ctx context.Context, ...) (*connect.Response[sessionv1.AssignSessionsToProjectResponse], error)

+ func (s *ProjectService) CreateProject(ctx context.Context, req *connect.Request[sessionv1.CreateProjectRequest]) (*connect.Response[sessionv1.CreateProjectResponse], error)

+ func (s *ProjectService) DeleteProject(ctx context.Context, req *connect.Request[sessionv1.DeleteProjectRequest]) (*connect.Response[sessionv1.DeleteProjectResponse], error)

+ func (s *ProjectService) ListProjects(ctx context.Context, req *connect.Request[sessionv1.ListProjectsRequest]) (*connect.Response[sessionv1.ListProjectsResponse], error)

+ func (s *ProjectService) UpdateProject(ctx context.Context, req *connect.Request[sessionv1.UpdateProjectRequest]) (*connect.Response[sessionv1.UpdateProjectResponse], error)

type SessionService

+ func (s *SessionService) AssignSessionsToProject(ctx context.Context, ...) (*connect.Response[sessionv1.AssignSessionsToProjectResponse], error)

+ func (s *SessionService) BatchCreateSessions(ctx context.Context, ...) (*connect.Response[sessionv1.BatchCreateSessionsResponse], error)

+ func (s *SessionService) CreateProject(ctx context.Context, req *connect.Request[sessionv1.CreateProjectRequest]) (*connect.Response[sessionv1.CreateProjectResponse], error)

+ func (s *SessionService) DeleteProject(ctx context.Context, req *connect.Request[sessionv1.DeleteProjectRequest]) (*connect.Response[sessionv1.DeleteProjectResponse], error)

+ func (s *SessionService) DeletePromptHistory(ctx context.Context, ...) (*connect.Response[sessionv1.DeletePromptHistoryResponse], error)

+ func (s *SessionService) ListProjects(ctx context.Context, req *connect.Request[sessionv1.ListProjectsRequest]) (*connect.Response[sessionv1.ListProjectsResponse], error)

+ func (s *SessionService) ListPromptHistory(ctx context.Context, req *connect.Request[sessionv1.ListPromptHistoryRequest]) (*connect.Response[sessionv1.ListPromptHistoryResponse], error)

+ func (s *SessionService) RunOneShot(ctx context.Context, req *connect.Request[sessionv1.RunOneShotRequest]) (*connect.Response[sessionv1.RunOneShotResponse], error)

+ func (s *SessionService) UpdateProject(ctx context.Context, req *connect.Request[sessionv1.UpdateProjectRequest]) (*connect.Response[sessionv1.UpdateProjectResponse], error)

v1.22.0

Apr 26, 2026

Changes in this version

+ type UnfinishedWorkService struct

+ func NewUnfinishedWorkService(scanner *unfinished.Scanner, stateStore *unfinished.StateStore, ...) *UnfinishedWorkService

+ func (s *UnfinishedWorkService) DismissWorktree(_ context.Context, req *connect.Request[sessionv1.DismissWorktreeRequest]) (*connect.Response[sessionv1.DismissWorktreeResponse], error)

+ func (s *UnfinishedWorkService) GetUnfinishedWorkConfig(_ context.Context, ...) (*connect.Response[sessionv1.GetUnfinishedWorkConfigResponse], error)

+ func (s *UnfinishedWorkService) GetWorktreeAISummary(ctx context.Context, ...) (*connect.Response[sessionv1.GetWorktreeAISummaryResponse], error)

+ func (s *UnfinishedWorkService) ListUnfinishedWork(_ context.Context, _ *connect.Request[sessionv1.ListUnfinishedWorkRequest]) (*connect.Response[sessionv1.ListUnfinishedWorkResponse], error)

+ func (s *UnfinishedWorkService) QuickCommitPush(_ context.Context, req *connect.Request[sessionv1.QuickCommitPushRequest]) (*connect.Response[sessionv1.QuickCommitPushResponse], error)

+ func (s *UnfinishedWorkService) ScanUnfinishedWork(_ context.Context, _ *connect.Request[sessionv1.ScanUnfinishedWorkRequest]) (*connect.Response[sessionv1.ScanUnfinishedWorkResponse], error)

+ func (s *UnfinishedWorkService) SnoozeWorktree(_ context.Context, req *connect.Request[sessionv1.SnoozeWorktreeRequest]) (*connect.Response[sessionv1.SnoozeWorktreeResponse], error)

+ func (s *UnfinishedWorkService) UndismissWorktree(_ context.Context, req *connect.Request[sessionv1.UndismissWorktreeRequest]) (*connect.Response[sessionv1.UndismissWorktreeResponse], error)

+ func (s *UnfinishedWorkService) UpdateUnfinishedWorkConfig(_ context.Context, ...) (*connect.Response[sessionv1.UpdateUnfinishedWorkConfigResponse], error)

+ func (s *UnfinishedWorkService) WatchUnfinishedWork(ctx context.Context, _ *connect.Request[sessionv1.WatchUnfinishedWorkRequest], ...) error

v1.21.0

Apr 26, 2026

v1.20.1

Apr 25, 2026

v1.20.0

Apr 24, 2026

v1.19.0

Apr 23, 2026

v1.18.0

Apr 23, 2026

Changes in this version

type SessionService

+ func (s *SessionService) FindLiveInstance(id string) *session.Instance

+ func (s *SessionService) RemoveFromAllPollers(id string)

v1.17.0

Apr 21, 2026

Changes in this version

+ func InjectHooksConfig(rootDir, sessionTitle string, hooks []HookName) error

+ func InjectMCPConfig(rootDir, binaryPath string) error

+ func RemoveMCPConfig(rootDir string) error

+ type HookName string

+ const HookPermissionApproval

+ const HookPostToolLogging

+ const HookPreToolLogging

+ const HookPromptSubmit

+ const HookStopNotification

+ type HookReceiver struct

+ func NewHookReceiver() *HookReceiver

+ func (h *HookReceiver) HandlePostToolUse(w http.ResponseWriter, r *http.Request)

+ func (h *HookReceiver) HandlePreToolUse(w http.ResponseWriter, r *http.Request)

+ func (h *HookReceiver) HandlePromptSubmit(w http.ResponseWriter, r *http.Request)

+ func (h *HookReceiver) HandleStop(w http.ResponseWriter, r *http.Request)

+ func (h *HookReceiver) RegisterRoutes(mux *http.ServeMux)

+ type ImageUploadHandler struct

+ func NewImageUploadHandler(dir string) *ImageUploadHandler

+ func (h *ImageUploadHandler) HandleUpload(w http.ResponseWriter, r *http.Request)

type SessionService

+ func (s *SessionService) ListBranches(ctx context.Context, req *connect.Request[sessionv1.ListBranchesRequest]) (*connect.Response[sessionv1.ListBranchesResponse], error)

+ func (s *SessionService) SetMCPServerURL(url string)

v1.16.0

Apr 21, 2026

Changes in this version

type PushNotification

+ Renotify bool

v1.15.0

Apr 21, 2026

Changes in this version

+ type SessionStreamer interface

+ StartControlMode func() error

+ StopControlMode func() error

+ SubscribeControlModeUpdates func() (string, <-chan []byte)

+ UnsubscribeControlModeUpdates func(id string)

v1.14.0

Apr 17, 2026

Changes in this version

type SessionService

+ func (s *SessionService) GetTerminalSnapshot(ctx context.Context, ...) (*connect.Response[sessionv1.GetTerminalSnapshotResponse], error)

v1.13.3

Apr 16, 2026

v1.13.2

Apr 16, 2026

v1.13.1

Apr 16, 2026

v1.13.0

Apr 16, 2026

Changes in this version

+ type DirCache struct

+ func NewDirCache(maxSize int, ttl time.Duration) *DirCache

+ func (c *DirCache) Get(path string) ([]os.DirEntry, bool)

+ func (c *DirCache) Put(path string, entries []os.DirEntry, dirMtime time.Time)

v1.12.1

Apr 15, 2026

v1.12.0

Apr 14, 2026

Changes in this version

+ var ErrSettingsNotFound = fmt.Errorf("settings file not found")

+ type DefaultsService struct

+ func NewDefaultsService() *DefaultsService

+ func (d *DefaultsService) DeleteDirectoryRule(ctx context.Context, ...) (*connect.Response[sessionv1.DeleteDirectoryRuleResponse], error)

+ func (d *DefaultsService) DeleteProfile(ctx context.Context, req *connect.Request[sessionv1.DeleteProfileRequest]) (*connect.Response[sessionv1.DeleteProfileResponse], error)

+ func (d *DefaultsService) GetSessionDefaults(ctx context.Context, req *connect.Request[sessionv1.GetSessionDefaultsRequest]) (*connect.Response[sessionv1.GetSessionDefaultsResponse], error)

+ func (d *DefaultsService) ResolveDefaults(ctx context.Context, req *connect.Request[sessionv1.ResolveDefaultsRequest]) (*connect.Response[sessionv1.ResolveDefaultsResponse], error)

+ func (d *DefaultsService) UpdateGlobalDefaults(ctx context.Context, ...) (*connect.Response[sessionv1.UpdateGlobalDefaultsResponse], error)

+ func (d *DefaultsService) UpsertDirectoryRule(ctx context.Context, ...) (*connect.Response[sessionv1.UpsertDirectoryRuleResponse], error)

+ func (d *DefaultsService) UpsertProfile(ctx context.Context, req *connect.Request[sessionv1.UpsertProfileRequest]) (*connect.Response[sessionv1.UpsertProfileResponse], error)

type FileService

+ func (fs *FileService) SearchFiles(ctx context.Context, req *connect.Request[sessionv1.SearchFilesRequest]) (*connect.Response[sessionv1.SearchFilesResponse], error)

type PathCompletionService

+ func (p *PathCompletionService) ListWorktrees(ctx context.Context, req *connect.Request[sessionv1.ListWorktreesRequest]) (*connect.Response[sessionv1.ListWorktreesResponse], error)

+ type PushHandler struct

+ func NewPushHandler(pushService *PushService) *PushHandler

+ func (h *PushHandler) RegisterRoutes(mux *http.ServeMux)

+ type PushNotification struct

+ Body string

+ Data map[string]interface{}

+ Icon string

+ RequireInteraction bool

+ Tag string

+ Title string

+ type PushService struct

+ func NewPushService(configDir string) *PushService

+ func (ps *PushService) GetSubscriptions() []PushSubscription

+ func (ps *PushService) GetVapidPublicKey() string

+ func (ps *PushService) SendNotification(notif PushNotification) int

+ func (ps *PushService) Subscribe(sub PushSubscription) string

+ func (ps *PushService) Unsubscribe(endpoint string) bool

+ type PushSubscription struct

+ Endpoint string

+ Keys struct{ ... }

type RuleSpec

+ ToolCategory string

type SessionService

+ func (s *SessionService) DeleteDirectoryRule(ctx context.Context, ...) (*connect.Response[sessionv1.DeleteDirectoryRuleResponse], error)

+ func (s *SessionService) DeleteProfile(ctx context.Context, req *connect.Request[sessionv1.DeleteProfileRequest]) (*connect.Response[sessionv1.DeleteProfileResponse], error)

+ func (s *SessionService) GetSessionDefaults(ctx context.Context, req *connect.Request[sessionv1.GetSessionDefaultsRequest]) (*connect.Response[sessionv1.GetSessionDefaultsResponse], error)

+ func (s *SessionService) ListWorktrees(ctx context.Context, req *connect.Request[sessionv1.ListWorktreesRequest]) (*connect.Response[sessionv1.ListWorktreesResponse], error)

+ func (s *SessionService) ResolveDefaults(ctx context.Context, req *connect.Request[sessionv1.ResolveDefaultsRequest]) (*connect.Response[sessionv1.ResolveDefaultsResponse], error)

+ func (s *SessionService) SearchFiles(ctx context.Context, req *connect.Request[sessionv1.SearchFilesRequest]) (*connect.Response[sessionv1.SearchFilesResponse], error)

+ func (s *SessionService) UpdateGlobalDefaults(ctx context.Context, ...) (*connect.Response[sessionv1.UpdateGlobalDefaultsResponse], error)

+ func (s *SessionService) UpsertDirectoryRule(ctx context.Context, ...) (*connect.Response[sessionv1.UpsertDirectoryRuleResponse], error)

+ func (s *SessionService) UpsertProfile(ctx context.Context, req *connect.Request[sessionv1.UpsertProfileRequest]) (*connect.Response[sessionv1.UpsertProfileResponse], error)

+ type WorkspaceProvider interface

+ GetWorkspace func(sessionID string) (session.Workspace, error)

type WorkspaceService

+ func (ws *WorkspaceService) GetWorkspace(sessionID string) (session.Workspace, error)

v1.11.1

Apr 10, 2026

v1.11.0

Apr 9, 2026

Changes in this version

+ type FileService struct

+ func NewFileService(storage *session.Storage) *FileService

+ func (fs *FileService) GetFileContent(ctx context.Context, req *connect.Request[sessionv1.GetFileContentRequest]) (*connect.Response[sessionv1.GetFileContentResponse], error)

+ func (fs *FileService) ListFiles(ctx context.Context, req *connect.Request[sessionv1.ListFilesRequest]) (*connect.Response[sessionv1.ListFilesResponse], error)

type SessionService

+ func (s *SessionService) GetFileContent(ctx context.Context, req *connect.Request[sessionv1.GetFileContentRequest]) (*connect.Response[sessionv1.GetFileContentResponse], error)

+ func (s *SessionService) ListFiles(ctx context.Context, req *connect.Request[sessionv1.ListFilesRequest]) (*connect.Response[sessionv1.ListFilesResponse], error)

v1.10.0

Apr 9, 2026

Changes in this version

+ type PathCompletionService struct

+ func NewPathCompletionService() *PathCompletionService

+ func (p *PathCompletionService) ListPathCompletions(ctx context.Context, ...) (*connect.Response[sessionv1.ListPathCompletionsResponse], error)

type SessionService

+ func (s *SessionService) ListPathCompletions(ctx context.Context, ...) (*connect.Response[sessionv1.ListPathCompletionsResponse], error)

v1.9.0

Apr 9, 2026

v1.8.1

Apr 9, 2026

v1.8.0

Apr 9, 2026

v1.7.3

Apr 9, 2026

v1.7.2

Apr 9, 2026

v1.7.1

Apr 8, 2026

v1.7.0

Apr 8, 2026

v1.1.6

Apr 8, 2026

v1.1.5

Apr 8, 2026

v1.1.4

Apr 8, 2026

v1.1.3

Apr 8, 2026

v1.1.2

Apr 8, 2026

Changes in this version

+ func ExpandPath(arg string) string

type ParsedCommand

+ ExpandedArgs []string

+ type PathClassification uint

+ const PathCwd

+ const PathGitRepo

+ const PathHome

+ const PathRoot

+ const PathSystemDir

+ const PathTempDir

+ func ClassifyPath(path string, ctx ClassificationContext) PathClassification

+ type PathMatcher struct

+ ArgIndex int

+ MatchIf PathClassification

+ RejectIf PathClassification

+ func (pm *PathMatcher) Matches(expandedArgs []string, ctx ClassificationContext) bool

type Rule

+ PathMatcher *PathMatcher

v1.1.1

Apr 8, 2026

v1.1.0

Apr 8, 2026

Changes in this version

type SessionService

+ func (s *SessionService) GetInstanceStore() session.InstanceStore

v1.0.12

Apr 7, 2026

v1.0.0

Apr 7, 2026

Changes in this version

+ const ToolCategoryAny

+ const ToolCategoryBuiltin

+ const ToolCategoryBuiltinAgent

+ const ToolCategoryMCP

+ const ToolCategoryMCPRead

+ const ToolCategoryMCPWrite

+ func CategorizeToolName(name string) string

+ func ExtractDomainsFromCommand(cmd string) []string

+ func FormatSecretDenyMessage(patternName string) string

+ func InjectHookConfig(rootDir, sessionTitle string) error

+ func StartExpirationCleanup(ctx context.Context, store *ApprovalStore)

+ func WriteSnapshot(snap *DebugSnapshot, dir string) (string, error)

+ type AnalyticsEntry struct

+ Alternative string

+ ApprovalID string

+ CommandCategory string

+ CommandPreview string

+ CommandProgram string

+ CommandSubcategory string

+ Cwd string

+ Decision string

+ DurationMs int64

+ ID string

+ PythonImports []string

+ Reason string

+ RiskLevel string

+ RuleID string

+ RuleName string

+ SessionID string

+ Timestamp time.Time

+ ToolName string

+ func ReclassifyGaps(entries []AnalyticsEntry, c Classifier) []AnalyticsEntry

+ type AnalyticsStore struct

+ func NewAnalyticsStore(filePath string) *AnalyticsStore

+ func (s *AnalyticsStore) DroppedCount() int64

+ func (s *AnalyticsStore) LoadWindow(since time.Time) ([]AnalyticsEntry, error)

+ func (s *AnalyticsStore) Record(entry AnalyticsEntry)

+ func (s *AnalyticsStore) RecordFromResult(payload PermissionRequestPayload, result ClassificationResult, ...)

+ func (s *AnalyticsStore) RecordManualDecision(approvalID, sessionID, toolName, cwd, decision string)

+ func (s *AnalyticsStore) Start(ctx interface{ ... })

+ type AnalyticsSummary struct

+ AutoApproveRate float64

+ CommandSubcommandStats []SubcommandStat

+ CoverageGapCount int

+ CoverageGapRate float64

+ DecisionCounts map[string]int

+ ManualReviewRate float64

+ TopCommandPrograms []ProgramStat

+ TopDeniedCommands []CommandStat

+ TopPythonImports []ImportStat

+ TopTools []ToolStat

+ TopTriggeredRules []RuleStat

+ TopUncoveredPrograms []ProgramStat

+ TopUncoveredTools []ToolStat

+ TotalDecisions int

+ WindowEnd time.Time

+ WindowStart time.Time

+ func ComputeSummary(entries []AnalyticsEntry) AnalyticsSummary

+ type ApprovalDecision struct

+ Behavior string

+ Message string

+ type ApprovalDetail struct

+ ClaudeSessionID string

+ CreatedAt time.Time

+ Cwd string

+ ExpiresAt time.Time

+ ID string

+ PermissionMode string

+ SessionID string

+ ToolInput map[string]interface{}

+ ToolName string

+ type ApprovalHandler struct

+ func NewApprovalHandler(store *ApprovalStore, storage *session.Storage, eventBus *events.EventBus) *ApprovalHandler

+ func (h *ApprovalHandler) HandlePermissionRequest(w http.ResponseWriter, r *http.Request)

+ func (h *ApprovalHandler) SetAnalyticsStore(a *AnalyticsStore)

+ func (h *ApprovalHandler) SetClassifier(c *RuleBasedClassifier)

+ func (h *ApprovalHandler) SetDomainChecker(d *DomainAgeChecker)

+ func (h *ApprovalHandler) SetNotificationStamper(s approvalNotificationStamper)

+ func (h *ApprovalHandler) SetQueueChecker(checker ReviewQueueChecker)

+ type ApprovalService struct

+ func NewApprovalService(store *ApprovalStore) *ApprovalService

+ func (as *ApprovalService) ListPendingApprovals(ctx context.Context, ...) (*connect.Response[sessionv1.ListPendingApprovalsResponse], error)

+ func (as *ApprovalService) ResolveApproval(ctx context.Context, req *connect.Request[sessionv1.ResolveApprovalRequest]) (*connect.Response[sessionv1.ResolveApprovalResponse], error)

+ func (as *ApprovalService) SetNotificationStore(store notificationMetadataStore)

+ type ApprovalSnapshot struct

+ Pending []ApprovalDetail

+ PendingCount int

+ type ApprovalStore struct

+ func NewApprovalStore(filePath string) *ApprovalStore

+ func (s *ApprovalStore) CancelSession(sessionID string) []string

+ func (s *ApprovalStore) CleanupExpired() []string

+ func (s *ApprovalStore) Create(a *PendingApproval) error

+ func (s *ApprovalStore) Get(id string) (*PendingApproval, bool)

+ func (s *ApprovalStore) GetApprovalMetadataBySession(sessionID string) []session.ApprovalMetadata

+ func (s *ApprovalStore) GetBySession(sessionID string) []*PendingApproval

+ func (s *ApprovalStore) GetFilePath() string

+ func (s *ApprovalStore) ListAll() []*PendingApproval

+ func (s *ApprovalStore) Remove(id string)

+ func (s *ApprovalStore) Resolve(id string, decision ApprovalDecision) error

+ type CircuitBreakerHandler struct

+ func NewCircuitBreakerHandler() *CircuitBreakerHandler

+ func (h *CircuitBreakerHandler) HandleCircuitBreakers(w http.ResponseWriter, r *http.Request)

+ func (h *CircuitBreakerHandler) RegisterRoutes(mux *http.ServeMux)

+ type ClassificationContext struct

+ Cwd string

+ IsGitRepo bool

+ IsWorktree bool

+ RepoRoot string

+ type ClassificationDecision int

+ const AutoAllow

+ const AutoDeny

+ const Escalate

+ type ClassificationResult struct

+ Alternative string

+ Decision ClassificationDecision

+ Reason string

+ RiskLevel RiskLevel

+ RuleID string

+ RuleName string

+ type Classifier interface

+ BuildContext func(cwd string) ClassificationContext

+ Classify func(payload PermissionRequestPayload, ctx ClassificationContext) ClassificationResult

+ type ClaudePermissions struct

+ Allow []string

+ Deny []string

+ func ParseClaudeSettings(path string) (*ClaudePermissions, error)

+ type CommandCriteria struct

+ BlockedSubcommands []string

+ ForbiddenFlags []string

+ Programs []string

+ PythonModes []string

+ RequiredFlagPrefixes []string

+ RequiredFlags []string

+ Subcommands []string

+ func (cc *CommandCriteria) Matches(pc ParsedCommand) bool

+ type CommandInfo struct

+ AllPrograms []string

+ Category string

+ Program string

+ Subcommand string

+ func ParseBashCommand(command string) CommandInfo

+ type CommandStat struct

+ Count int

+ Preview string

+ ToolName string

+ type ConfigService struct

+ func NewConfigService() *ConfigService

+ func (cs *ConfigService) GetClaudeConfig(ctx context.Context, req *connect.Request[sessionv1.GetClaudeConfigRequest]) (*connect.Response[sessionv1.GetClaudeConfigResponse], error)

+ func (cs *ConfigService) ListClaudeConfigs(ctx context.Context, req *connect.Request[sessionv1.ListClaudeConfigsRequest]) (*connect.Response[sessionv1.ListClaudeConfigsResponse], error)

+ func (cs *ConfigService) UpdateClaudeConfig(ctx context.Context, req *connect.Request[sessionv1.UpdateClaudeConfigRequest]) (*connect.Response[sessionv1.UpdateClaudeConfigResponse], error)

+ type ConnectRPCWebSocketHandler struct

+ func NewConnectRPCWebSocketHandler(sessionService *SessionService, ...) *ConnectRPCWebSocketHandler

+ func (h *ConnectRPCWebSocketHandler) HandleWebSocket(w http.ResponseWriter, r *http.Request)

+ func (h *ConnectRPCWebSocketHandler) SetExternalSessionSupport(discovery *session.ExternalSessionDiscovery)

+ type DailyBucket struct

+ AutoAllow int

+ AutoDeny int

+ Date string

+ Escalate int

+ ManualAllow int

+ ManualDeny int

+ Total int

+ func ComputeDailyBuckets(entries []AnalyticsEntry) []DailyBucket

+ func (b DailyBucket) AutoApproveRate() float64

+ type DatabaseService struct

+ func NewDatabaseService() *DatabaseService

+ func (ds *DatabaseService) GetCurrentDatabase(ctx context.Context, req *connect.Request[sessionv1.GetCurrentDatabaseRequest]) (*connect.Response[sessionv1.GetCurrentDatabaseResponse], error)

+ func (ds *DatabaseService) ListDatabases(ctx context.Context, req *connect.Request[sessionv1.ListDatabasesRequest]) (*connect.Response[sessionv1.ListDatabasesResponse], error)

+ func (ds *DatabaseService) MergeDatabase(ctx context.Context, req *connect.Request[sessionv1.MergeDatabaseRequest]) (*connect.Response[sessionv1.MergeDatabaseResponse], error)

+ func (ds *DatabaseService) SwitchDatabase(ctx context.Context, req *connect.Request[sessionv1.SwitchDatabaseRequest]) (*connect.Response[sessionv1.SwitchDatabaseResponse], error)

+ type DebugSnapshot struct

+ Approvals ApprovalSnapshot

+ Errors []string

+ Note string

+ RecentLogs RecentLogsSnapshot

+ Server ServerInfo

+ Sessions []SessionSnapshot

+ Timestamp time.Time

+ Tmux TmuxSnapshot

+ Version int

+ func CollectSnapshot(ctx context.Context, note string, instances []*session.Instance, ...) *DebugSnapshot

+ type DomainAgeChecker struct

+ func NewDomainAgeChecker(enabled bool) *DomainAgeChecker

+ func (d *DomainAgeChecker) IsNewlyRegistered(ctx context.Context, domain string) (bool, error)

+ func (d *DomainAgeChecker) NewDomainThreshold() time.Duration

+ type EscapeCodeHandler struct

+ func NewEscapeCodeHandler() *EscapeCodeHandler

+ func (h *EscapeCodeHandler) HandleClear(w http.ResponseWriter, r *http.Request)

+ func (h *EscapeCodeHandler) HandleExport(w http.ResponseWriter, r *http.Request)

+ func (h *EscapeCodeHandler) HandleGetAll(w http.ResponseWriter, r *http.Request)

+ func (h *EscapeCodeHandler) HandleGetByCategory(w http.ResponseWriter, r *http.Request)

+ func (h *EscapeCodeHandler) HandleGetBySession(w http.ResponseWriter, r *http.Request)

+ func (h *EscapeCodeHandler) HandleGetStats(w http.ResponseWriter, r *http.Request)

+ func (h *EscapeCodeHandler) HandleStatus(w http.ResponseWriter, r *http.Request)

+ func (h *EscapeCodeHandler) HandleToggle(w http.ResponseWriter, r *http.Request)

+ func (h *EscapeCodeHandler) RegisterRoutes(mux *http.ServeMux)

+ type ExternalWebSocketHandler struct

+ func NewExternalWebSocketHandler(discovery *session.ExternalSessionDiscovery, ...) *ExternalWebSocketHandler

+ func (h *ExternalWebSocketHandler) HandleApprovalResponse(w http.ResponseWriter, r *http.Request)

+ func (h *ExternalWebSocketHandler) HandleApprovals(w http.ResponseWriter, r *http.Request)

+ type GitHubService struct

+ func NewGitHubService(storage *session.Storage) *GitHubService

+ func (gs *GitHubService) ClosePR(ctx context.Context, req *connect.Request[sessionv1.ClosePRRequest]) (*connect.Response[sessionv1.ClosePRResponse], error)

+ func (gs *GitHubService) GetPRComments(ctx context.Context, req *connect.Request[sessionv1.GetPRCommentsRequest]) (*connect.Response[sessionv1.GetPRCommentsResponse], error)

+ func (gs *GitHubService) GetPRInfo(ctx context.Context, req *connect.Request[sessionv1.GetPRInfoRequest]) (*connect.Response[sessionv1.GetPRInfoResponse], error)

+ func (gs *GitHubService) MergePR(ctx context.Context, req *connect.Request[sessionv1.MergePRRequest]) (*connect.Response[sessionv1.MergePRResponse], error)

+ func (gs *GitHubService) PostPRComment(ctx context.Context, req *connect.Request[sessionv1.PostPRCommentRequest]) (*connect.Response[sessionv1.PostPRCommentResponse], error)

+ type ImportStat struct

+ Count int

+ Module string

+ type NotificationRateLimiter struct

+ func NewNotificationRateLimiter(r float64, b int) *NotificationRateLimiter

+ func (rl *NotificationRateLimiter) Allow(sessionID string) bool

+ func (rl *NotificationRateLimiter) Cleanup(activeSessions []string)

+ func (rl *NotificationRateLimiter) Count() int

+ func (rl *NotificationRateLimiter) Reset(sessionID string)

+ type NotificationService struct

+ func NewNotificationService(rateLimiter *NotificationRateLimiter, eventBus *events.EventBus) *NotificationService

+ func (ns *NotificationService) ClearNotificationHistory(ctx context.Context, ...) (*connect.Response[sessionv1.ClearNotificationHistoryResponse], error)

+ func (ns *NotificationService) GetNotificationHistory(ctx context.Context, ...) (*connect.Response[sessionv1.GetNotificationHistoryResponse], error)

+ func (ns *NotificationService) GetNotificationStore() *notifications.NotificationHistoryStore

+ func (ns *NotificationService) MarkNotificationRead(ctx context.Context, ...) (*connect.Response[sessionv1.MarkNotificationReadResponse], error)

+ func (ns *NotificationService) SendNotification(ctx context.Context, req *connect.Request[sessionv1.SendNotificationRequest]) (*connect.Response[sessionv1.SendNotificationResponse], error)

+ func (ns *NotificationService) SetNotificationStore(store *notifications.NotificationHistoryStore)

+ func (ns *NotificationService) SetReviewQueuePoller(poller *session.ReviewQueuePoller)

+ type ParsedCommand struct

+ Args []string

+ Program string

+ Raw string

+ func ExtractAllCommands(cmd string) []ParsedCommand

+ type PendingApproval struct

+ ClaudeSessionID string

+ CreatedAt time.Time

+ Cwd string

+ ExpiresAt time.Time

+ ID string

+ Orphaned bool

+ PermissionMode string

+ SessionID string

+ ToolInput map[string]interface{}

+ ToolName string

+ type PermissionRequestPayload struct

+ Cwd string

+ HookEventName string

+ PermissionMode string

+ SessionID string

+ ToolInput map[string]interface{}

+ ToolName string

+ TranscriptPath string

+ type PersistedApproval struct

+ ClaudeSessionID string

+ CreatedAt time.Time

+ Cwd string

+ ExpiresAt time.Time

+ ID string

+ Orphaned bool

+ PermissionMode string

+ SessionID string

+ ToolInput map[string]interface{}

+ ToolName string

+ type ProgramStat struct

+ Category string

+ Count int

+ Program string

+ type PythonInfo struct

+ Imports []string

+ IsInline bool

+ func ParsePythonCommand(command string) PythonInfo

+ type ReactiveQueueManager interface

+ AddStreamClient func(ctx context.Context, filters interface{}) (<-chan *sessionv1.ReviewQueueEvent, string)

+ RemoveStreamClient func(clientID string)

+ type RecentLogsSnapshot struct

+ LineCount int

+ Lines []string

+ LogFilePath string

+ type ReviewQueueChecker interface

+ CheckSession func(inst *session.Instance)

+ FindInstance func(sessionID string) *session.Instance

+ type ReviewQueueService struct

+ func NewReviewQueueService(reviewQueue *session.ReviewQueue, storage *session.Storage, ...) *ReviewQueueService

+ func (rqs *ReviewQueueService) AcknowledgeSession(ctx context.Context, req *connect.Request[sessionv1.AcknowledgeSessionRequest]) (*connect.Response[sessionv1.AcknowledgeSessionResponse], error)

+ func (rqs *ReviewQueueService) GetQueue() *session.ReviewQueue

+ func (rqs *ReviewQueueService) GetReviewQueue(ctx context.Context, req *connect.Request[sessionv1.GetReviewQueueRequest]) (*connect.Response[sessionv1.GetReviewQueueResponse], error)

+ func (rqs *ReviewQueueService) LogUserInteraction(ctx context.Context, req *connect.Request[sessionv1.LogUserInteractionRequest]) (*connect.Response[sessionv1.LogUserInteractionResponse], error)

+ func (rqs *ReviewQueueService) SetApprovalStore(store *ApprovalStore)

+ func (rqs *ReviewQueueService) SetReactiveQueueManager(mgr ReactiveQueueManager)

+ func (rqs *ReviewQueueService) SetReviewQueuePoller(poller *session.ReviewQueuePoller)

+ func (rqs *ReviewQueueService) WatchReviewQueue(ctx context.Context, req *connect.Request[sessionv1.WatchReviewQueueRequest], ...) error

+ type RiskLevel int

+ const RiskCritical

+ const RiskHigh

+ const RiskLow

+ const RiskMedium

+ type Rule struct

+ Alternative string

+ CommandPattern *regexp.Regexp

+ Criteria *CommandCriteria

+ Decision ClassificationDecision

+ Enabled bool

+ FilePattern *regexp.Regexp

+ ID string

+ Name string

+ Priority int

+ Reason string

+ RiskLevel RiskLevel

+ Source string

+ ToolCategory string

+ ToolName string

+ ToolPattern *regexp.Regexp

+ func LoadClaudeSettingsRules(projectDir string) []Rule

+ func SeedRules() []Rule

+ type RuleBasedClassifier struct

+ func NewRuleBasedClassifier() *RuleBasedClassifier

+ func (c *RuleBasedClassifier) AddRules(rules []Rule)

+ func (c *RuleBasedClassifier) BuildContext(cwd string) ClassificationContext

+ func (c *RuleBasedClassifier) Classify(payload PermissionRequestPayload, ctx ClassificationContext) ClassificationResult

+ func (c *RuleBasedClassifier) ReplaceRules(rules []Rule)

+ func (c *RuleBasedClassifier) Rules() []Rule

+ type RuleSpec struct

+ Alternative string

+ CommandPattern string

+ CreatedAt time.Time

+ Decision string

+ Enabled bool

+ FilePattern string

+ ID string

+ Name string

+ Priority int

+ Reason string

+ RiskLevel string

+ Source string

+ ToolName string

+ ToolPattern string

+ type RuleStat struct

+ Count int

+ RuleID string

+ RuleName string

+ type RulesFile struct

+ Rules []RuleSpec

+ Version int

+ type RulesService struct

+ func NewRulesService(rulesStore *RulesStore, analyticsStore *AnalyticsStore, ...) *RulesService

+ func (rs *RulesService) DeleteApprovalRule(ctx context.Context, req *connect.Request[sessionv1.DeleteApprovalRuleRequest]) (*connect.Response[sessionv1.DeleteApprovalRuleResponse], error)

+ func (rs *RulesService) GetApprovalAnalytics(ctx context.Context, ...) (*connect.Response[sessionv1.GetApprovalAnalyticsResponse], error)

+ func (rs *RulesService) ListApprovalRules(ctx context.Context, req *connect.Request[sessionv1.ListApprovalRulesRequest]) (*connect.Response[sessionv1.ListApprovalRulesResponse], error)

+ func (rs *RulesService) UpsertApprovalRule(ctx context.Context, req *connect.Request[sessionv1.UpsertApprovalRuleRequest]) (*connect.Response[sessionv1.UpsertApprovalRuleResponse], error)

+ type RulesStore struct

+ func NewRulesStore(filePath string) (*RulesStore, error)

+ func (s *RulesStore) All() []RuleSpec

+ func (s *RulesStore) Delete(id string) error

+ func (s *RulesStore) ToRules() []Rule

+ func (s *RulesStore) Upsert(spec RuleSpec) (RuleSpec, error)

+ func (s *RulesStore) WatchAndReload(ctx context.Context)

+ type SearchService struct

+ func NewSearchService(searchEngine *search.SearchEngine, snippetGenerator *search.SnippetGenerator, ...) *SearchService

+ func (ss *SearchService) GetClaudeHistoryDetail(ctx context.Context, ...) (*connect.Response[sessionv1.GetClaudeHistoryDetailResponse], error)

+ func (ss *SearchService) GetClaudeHistoryMessages(ctx context.Context, ...) (*connect.Response[sessionv1.GetClaudeHistoryMessagesResponse], error)

+ func (ss *SearchService) ListClaudeHistory(ctx context.Context, req *connect.Request[sessionv1.ListClaudeHistoryRequest]) (*connect.Response[sessionv1.ListClaudeHistoryResponse], error)

+ func (ss *SearchService) SearchClaudeHistory(ctx context.Context, ...) (*connect.Response[sessionv1.SearchClaudeHistoryResponse], error)

+ type SecretScanResult struct

+ Found bool

+ PatternName string

+ func ScanForSecrets(text string) SecretScanResult

+ type ServerInfo struct

+ Arch string

+ GoVersion string

+ OS string

+ PID int

+ UptimeSeconds int64

+ type SessionService struct

+ func NewSessionService(storage *session.Storage, eventBus *events.EventBus) *SessionService

+ func NewSessionServiceFromConfig() (*SessionService, error)

+ func (s *SessionService) AcknowledgeSession(ctx context.Context, req *connect.Request[sessionv1.AcknowledgeSessionRequest]) (*connect.Response[sessionv1.AcknowledgeSessionResponse], error)

+ func (s *SessionService) ClearNotificationHistory(ctx context.Context, ...) (*connect.Response[sessionv1.ClearNotificationHistoryResponse], error)

+ func (s *SessionService) ClosePR(ctx context.Context, req *connect.Request[sessionv1.ClosePRRequest]) (*connect.Response[sessionv1.ClosePRResponse], error)

+ func (s *SessionService) CreateCheckpoint(ctx context.Context, req *connect.Request[sessionv1.CreateCheckpointRequest]) (*connect.Response[sessionv1.CreateCheckpointResponse], error)

+ func (s *SessionService) CreateDebugSnapshot(ctx context.Context, ...) (*connect.Response[sessionv1.CreateDebugSnapshotResponse], error)

+ func (s *SessionService) CreateSession(ctx context.Context, req *connect.Request[sessionv1.CreateSessionRequest]) (*connect.Response[sessionv1.CreateSessionResponse], error)

+ func (s *SessionService) DeleteApprovalRule(ctx context.Context, req *connect.Request[sessionv1.DeleteApprovalRuleRequest]) (*connect.Response[sessionv1.DeleteApprovalRuleResponse], error)

+ func (s *SessionService) DeleteSession(ctx context.Context, req *connect.Request[sessionv1.DeleteSessionRequest]) (*connect.Response[sessionv1.DeleteSessionResponse], error)

+ func (s *SessionService) FocusWindow(ctx context.Context, req *connect.Request[sessionv1.FocusWindowRequest]) (*connect.Response[sessionv1.FocusWindowResponse], error)

+ func (s *SessionService) ForkSession(ctx context.Context, req *connect.Request[sessionv1.ForkSessionRequest]) (*connect.Response[sessionv1.ForkSessionResponse], error)

+ func (s *SessionService) GetAnalyticsStore() *AnalyticsStore

+ func (s *SessionService) GetApprovalAnalytics(ctx context.Context, ...) (*connect.Response[sessionv1.GetApprovalAnalyticsResponse], error)

+ func (s *SessionService) GetApprovalStore() *ApprovalStore

+ func (s *SessionService) GetClassifier() *RuleBasedClassifier

+ func (s *SessionService) GetClaudeConfig(ctx context.Context, req *connect.Request[sessionv1.GetClaudeConfigRequest]) (*connect.Response[sessionv1.GetClaudeConfigResponse], error)

+ func (s *SessionService) GetClaudeHistoryDetail(ctx context.Context, ...) (*connect.Response[sessionv1.GetClaudeHistoryDetailResponse], error)

+ func (s *SessionService) GetClaudeHistoryMessages(ctx context.Context, ...) (*connect.Response[sessionv1.GetClaudeHistoryMessagesResponse], error)

+ func (s *SessionService) GetCurrentDatabase(ctx context.Context, req *connect.Request[sessionv1.GetCurrentDatabaseRequest]) (*connect.Response[sessionv1.GetCurrentDatabaseResponse], error)

+ func (s *SessionService) GetEventBus() *events.EventBus

+ func (s *SessionService) GetLogs(ctx context.Context, req *connect.Request[sessionv1.GetLogsRequest]) (*connect.Response[sessionv1.GetLogsResponse], error)

+ func (s *SessionService) GetNotificationHistory(ctx context.Context, ...) (*connect.Response[sessionv1.GetNotificationHistoryResponse], error)

+ func (s *SessionService) GetNotificationStore() *notifications.NotificationHistoryStore

+ func (s *SessionService) GetPRComments(ctx context.Context, req *connect.Request[sessionv1.GetPRCommentsRequest]) (*connect.Response[sessionv1.GetPRCommentsResponse], error)

+ func (s *SessionService) GetPRInfo(ctx context.Context, req *connect.Request[sessionv1.GetPRInfoRequest]) (*connect.Response[sessionv1.GetPRInfoResponse], error)

+ func (s *SessionService) GetReviewQueue(ctx context.Context, req *connect.Request[sessionv1.GetReviewQueueRequest]) (*connect.Response[sessionv1.GetReviewQueueResponse], error)

+ func (s *SessionService) GetReviewQueueInstance() *session.ReviewQueue

+ func (s *SessionService) GetSession(ctx context.Context, req *connect.Request[sessionv1.GetSessionRequest]) (*connect.Response[sessionv1.GetSessionResponse], error)

+ func (s *SessionService) GetSessionDiff(ctx context.Context, req *connect.Request[sessionv1.GetSessionDiffRequest]) (*connect.Response[sessionv1.GetSessionDiffResponse], error)

+ func (s *SessionService) GetStorage() *session.Storage

+ func (s *SessionService) GetVCSStatus(ctx context.Context, req *connect.Request[sessionv1.GetVCSStatusRequest]) (*connect.Response[sessionv1.GetVCSStatusResponse], error)

+ func (s *SessionService) GetWorkspaceInfo(ctx context.Context, req *connect.Request[sessionv1.GetWorkspaceInfoRequest]) (*connect.Response[sessionv1.GetWorkspaceInfoResponse], error)

+ func (s *SessionService) ListApprovalRules(ctx context.Context, req *connect.Request[sessionv1.ListApprovalRulesRequest]) (*connect.Response[sessionv1.ListApprovalRulesResponse], error)

+ func (s *SessionService) ListCheckpoints(ctx context.Context, req *connect.Request[sessionv1.ListCheckpointsRequest]) (*connect.Response[sessionv1.ListCheckpointsResponse], error)

+ func (s *SessionService) ListClaudeConfigs(ctx context.Context, req *connect.Request[sessionv1.ListClaudeConfigsRequest]) (*connect.Response[sessionv1.ListClaudeConfigsResponse], error)

+ func (s *SessionService) ListClaudeHistory(ctx context.Context, req *connect.Request[sessionv1.ListClaudeHistoryRequest]) (*connect.Response[sessionv1.ListClaudeHistoryResponse], error)

+ func (s *SessionService) ListDatabases(ctx context.Context, req *connect.Request[sessionv1.ListDatabasesRequest]) (*connect.Response[sessionv1.ListDatabasesResponse], error)

+ func (s *SessionService) ListPendingApprovals(ctx context.Context, ...) (*connect.Response[sessionv1.ListPendingApprovalsResponse], error)

+ func (s *SessionService) ListSessions(ctx context.Context, req *connect.Request[sessionv1.ListSessionsRequest]) (*connect.Response[sessionv1.ListSessionsResponse], error)

+ func (s *SessionService) ListWorkspaceTargets(ctx context.Context, ...) (*connect.Response[sessionv1.ListWorkspaceTargetsResponse], error)

+ func (s *SessionService) LogUserInteraction(ctx context.Context, req *connect.Request[sessionv1.LogUserInteractionRequest]) (*connect.Response[sessionv1.LogUserInteractionResponse], error)

+ func (s *SessionService) MarkNotificationRead(ctx context.Context, ...) (*connect.Response[sessionv1.MarkNotificationReadResponse], error)

+ func (s *SessionService) MergeDatabase(ctx context.Context, req *connect.Request[sessionv1.MergeDatabaseRequest]) (*connect.Response[sessionv1.MergeDatabaseResponse], error)

+ func (s *SessionService) MergePR(ctx context.Context, req *connect.Request[sessionv1.MergePRRequest]) (*connect.Response[sessionv1.MergePRResponse], error)

+ func (s *SessionService) PostPRComment(ctx context.Context, req *connect.Request[sessionv1.PostPRCommentRequest]) (*connect.Response[sessionv1.PostPRCommentResponse], error)

+ func (s *SessionService) RenameSession(ctx context.Context, req *connect.Request[sessionv1.RenameSessionRequest]) (*connect.Response[sessionv1.RenameSessionResponse], error)

+ func (s *SessionService) ResolveApproval(ctx context.Context, req *connect.Request[sessionv1.ResolveApprovalRequest]) (*connect.Response[sessionv1.ResolveApprovalResponse], error)

+ func (s *SessionService) RestartSession(ctx context.Context, req *connect.Request[sessionv1.RestartSessionRequest]) (*connect.Response[sessionv1.RestartSessionResponse], error)

+ func (s *SessionService) SearchClaudeHistory(ctx context.Context, ...) (*connect.Response[sessionv1.SearchClaudeHistoryResponse], error)

+ func (s *SessionService) SendNotification(ctx context.Context, req *connect.Request[sessionv1.SendNotificationRequest]) (*connect.Response[sessionv1.SendNotificationResponse], error)

+ func (s *SessionService) SetConfigService(svc *ConfigService)

+ func (s *SessionService) SetExternalDiscovery(discovery *session.ExternalSessionDiscovery)

+ func (s *SessionService) SetNotificationStore(store *notifications.NotificationHistoryStore)

+ func (s *SessionService) SetReactiveQueueManager(mgr ReactiveQueueManager)

+ func (s *SessionService) SetReviewQueuePoller(poller *session.ReviewQueuePoller)

+ func (s *SessionService) SetScrollbackManager(mgr scrollbackSequencer)

+ func (s *SessionService) SetStatusManager(mgr *session.InstanceStatusManager)

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

+ func (s *SessionService) SwitchDatabase(ctx context.Context, req *connect.Request[sessionv1.SwitchDatabaseRequest]) (*connect.Response[sessionv1.SwitchDatabaseResponse], error)

+ func (s *SessionService) SwitchWorkspace(ctx context.Context, req *connect.Request[sessionv1.SwitchWorkspaceRequest]) (*connect.Response[sessionv1.SwitchWorkspaceResponse], error)

+ func (s *SessionService) UpdateClaudeConfig(ctx context.Context, req *connect.Request[sessionv1.UpdateClaudeConfigRequest]) (*connect.Response[sessionv1.UpdateClaudeConfigResponse], error)

+ func (s *SessionService) UpdateSession(ctx context.Context, req *connect.Request[sessionv1.UpdateSessionRequest]) (*connect.Response[sessionv1.UpdateSessionResponse], error)

+ func (s *SessionService) UpsertApprovalRule(ctx context.Context, req *connect.Request[sessionv1.UpsertApprovalRuleRequest]) (*connect.Response[sessionv1.UpsertApprovalRuleResponse], error)

+ func (s *SessionService) WatchReviewQueue(ctx context.Context, req *connect.Request[sessionv1.WatchReviewQueueRequest], ...) error

+ func (s *SessionService) WatchSessions(ctx context.Context, req *connect.Request[sessionv1.WatchSessionsRequest], ...) error

+ type SessionSnapshot struct

+ Branch string

+ Category string

+ CreatedAt time.Time

+ GitHubPRNumber int

+ InstanceType string

+ LastMeaningfulOutput time.Time

+ LastOutputSignature string

+ LastTerminalUpdate time.Time

+ PaneContent string

+ PaneContentRaw string

+ PaneContentTruncated bool

+ Path string

+ Program string

+ SessionType string

+ Status string

+ Tags []string

+ Title string

+ UpdatedAt time.Time

+ type SubcommandStat struct

+ Category string

+ Count int

+ Program string

+ Subcommand string

+ type TerminalWebSocketHandler struct

+ func NewTerminalWebSocketHandler(storage session.Storage, eventBus *events.EventBus) *TerminalWebSocketHandler

+ func (h *TerminalWebSocketHandler) HandleWebSocket(w http.ResponseWriter, r *http.Request)

+ type TmuxSessionDetail struct

+ ListPanesOutput string

+ PaneContent string

+ TmuxSessionName string

+ type TmuxSnapshot struct

+ ListSessionsOutput string

+ PerSession []TmuxSessionDetail

+ type ToolStat struct

+ Count int

+ ToolName string

+ type UtilityService struct

+ func NewUtilityService(approvalStore *ApprovalStore) *UtilityService

+ func (us *UtilityService) CreateDebugSnapshot(ctx context.Context, ...) (*connect.Response[sessionv1.CreateDebugSnapshotResponse], error)

+ func (us *UtilityService) FocusWindow(ctx context.Context, req *connect.Request[sessionv1.FocusWindowRequest]) (*connect.Response[sessionv1.FocusWindowResponse], error)

+ func (us *UtilityService) GetLogs(ctx context.Context, req *connect.Request[sessionv1.GetLogsRequest]) (*connect.Response[sessionv1.GetLogsResponse], error)

+ func (us *UtilityService) SetReviewQueuePoller(poller *session.ReviewQueuePoller)

+ type WatchReviewQueueFilters struct

+ IncludeStatistics bool

+ InitialSnapshot bool

+ PriorityFilter []session.Priority

+ ReasonFilter []session.AttentionReason

+ SessionIDs []string

+ func (f *WatchReviewQueueFilters) GetIncludeStatistics() bool

+ func (f *WatchReviewQueueFilters) GetInitialSnapshot() bool

+ func (f *WatchReviewQueueFilters) GetPriorityFilter() []session.Priority

+ func (f *WatchReviewQueueFilters) GetReasonFilter() []session.AttentionReason

+ func (f *WatchReviewQueueFilters) GetSessionIDs() []string

+ type WorkspaceService struct

+ func NewWorkspaceService(storage *session.Storage, eventBus *events.EventBus) *WorkspaceService

+ func (ws *WorkspaceService) GetVCSStatus(ctx context.Context, req *connect.Request[sessionv1.GetVCSStatusRequest]) (*connect.Response[sessionv1.GetVCSStatusResponse], error)

+ func (ws *WorkspaceService) GetWorkspaceInfo(ctx context.Context, req *connect.Request[sessionv1.GetWorkspaceInfoRequest]) (*connect.Response[sessionv1.GetWorkspaceInfoResponse], error)

+ func (ws *WorkspaceService) ListWorkspaceTargets(ctx context.Context, ...) (*connect.Response[sessionv1.ListWorkspaceTargetsResponse], error)

+ func (ws *WorkspaceService) SwitchWorkspace(ctx context.Context, req *connect.Request[sessionv1.SwitchWorkspaceRequest]) (*connect.Response[sessionv1.SwitchWorkspaceResponse], error)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL