server

package

Go to main page

Versions in this module

v0

v0.0.51

Oct 26, 2026

v0.0.50

Oct 23, 2026

Changes in this version

+ const FeatureRefusedModeRecovery

+ const FeatureSessionPermissionModes

+ var ErrIdentityBrokerUnavailable = errors.New("server: identity broker unavailable")

type Config

+ EnforcingCheckerConfigured bool

+ IdentityBroker identitybroker.Service

+ MaxAllowedMode session.PermissionMode

+ ProjectTrusted *bool

+ SubagentAskReviewer *string

+ type ModeScopedWorkspace interface

+ ForPermissionMode func(mode session.PermissionMode) tool.Workspace

type Service

+ func (s *Service) AdmittedModes() []session.PermissionMode

+ func (s *Service) EndScheduledRun(ctx context.Context, sess *session.Session)

v0.0.49

Oct 20, 2026

Changes in this version

+ const FeatureSessionAgentDefinitions

+ func AgentDefSessionRootFromContext(ctx context.Context) string

+ func ContextWithAgentDefSessionRoot(ctx context.Context, root string) context.Context

+ type AgentDefSessionEngineFactory func(ctx context.Context, sel ProviderSelector, profile SessionProfile, ...) (SessionEngineResult, error)

+ type AgentDefSessionSelection struct

+ Limits session.Limits

+ Name string

+ func AgentDefSessionSelectionFromContext(ctx context.Context) (AgentDefSessionSelection, bool)

type Config

+ AgentDefSessionEngine AgentDefSessionEngineFactory

type CreateSessionOption

+ func WithAgentDefinitionName(name string) CreateSessionOption

type Service

+ func (s *Service) ScheduleFirePlacement(ctx context.Context, spec port.ScheduleSpec, fireID session.SessionID) (PlacementBinding, error)

type SessionEngineResult

+ AgentDefinitionName string

+ Authority session.Authority

+ BrokerRegistrationKeys []string

+ Limits *session.Limits

+ NonBrokerRegistrationKeys []string

+ type WorkspaceEnrollmentCollisionError struct

+ Key string

+ func (*WorkspaceEnrollmentCollisionError) Unwrap() error

+ func (e *WorkspaceEnrollmentCollisionError) Error() string

v0.0.48

Oct 13, 2026

Changes in this version

+ const FeatureExecutionTemplates

+ const FeatureSkillFiles

+ var ErrExecutionTemplatesDisabled = errors.New("execution templates disabled")

+ var ErrSkillFileNotText = errors.New("server: skill file is not valid text")

+ var ErrSkillFileTooLarge = errors.New("server: skill file is too large to read")

type Config

+ ExecutionTemplateAllowed func(*session.Principal, string, string) bool

+ SkillSourceFor func(context.Context) tool.SkillSource

type CreateSessionOption

+ func WithExecutionSelection(e ExecutionSelection) CreateSessionOption

+ type ExecutionSelection struct

+ ID string

+ Kind PlacementSelectorKind

+ Revision string

+ type ExecutionTemplateCatalog interface

+ ListExecutionTemplates func(context.Context, *session.Principal) ([]ExecutionTemplateInfo, string, error)

+ type ExecutionTemplateInfo struct

+ DeclaredBuiltInShell bool

+ DeclaredExecutionFiles bool

+ Description string

+ DisplayToken string

+ Extensions map[string]string

+ ID string

+ Name string

+ Revision string

type HarnessServer

+ func (h *HarnessServer) ListExecutionTemplates(ctx context.Context, _ *mecatlv1.ListExecutionTemplatesRequest) (*mecatlv1.ListExecutionTemplatesResponse, error)

+ func (h *HarnessServer) ListSkillFiles(ctx context.Context, req *mecatlv1.ListSkillFilesRequest) (*mecatlv1.ListSkillFilesResponse, error)

+ func (h *HarnessServer) ReadSkillFile(ctx context.Context, req *mecatlv1.ReadSkillFileRequest) (*mecatlv1.ReadSkillFileResponse, error)

type PlacementSelector

+ Revision string

+ func SelectTemplate(id, revision string) PlacementSelector

+ func (s PlacementSelector) IsTemplate() bool

type PlacementSelectorKind

+ const PlacementSelectorTemplate

type Service

+ func (s *Service) ListExecutionTemplates(ctx context.Context) ([]ExecutionTemplateInfo, string, error)

+ func (s *Service) ListSkillFiles(ctx context.Context, name string) ([]*mecatlv1.SkillFileInfo, error)

+ func (s *Service) ReadSkillFile(ctx context.Context, name, file string) (string, error)

v0.0.47

Oct 8, 2026

v0.0.46

Oct 7, 2026

v0.0.45

Oct 7, 2026

Changes in this version

type ReflectionReceipt

+ Usage session.AuxiliaryUsage

v0.0.44

Oct 1, 2026

v0.0.43

Sep 30, 2026

v0.0.42

Sep 29, 2026

Changes in this version

+ var ErrEnvironmentLogicalRootUnavailable = fmt.Errorf("%w: Guest could not attach the prepared repository worktree", ...)

+ func NewPlacementReadinessError(stage, category, cause string) error

+ func PlacementGovernanceRoot(binding PlacementBinding) (string, error)

type Config

+ ExecutionAccess ExecutionAccess

+ ReferenceIntents ReferenceIntentLifecycle

+ type ExecutionAccess interface

+ AcquireRun func(context.Context, ExecutionRunRequest) (ExecutionRunHandle, error)

+ Applies func(session.EnvironmentRef) bool

+ type ExecutionRunHandle interface

+ Environment func() tool.Environment

+ Release func(context.Context) error

+ Renew func(context.Context) error

+ type ExecutionRunRequest struct

+ BindingID session.SessionID

+ Principal *session.Principal

+ Ref session.EnvironmentRef

+ RunID string

type PlacementBindRequest

+ BindingID session.SessionID

type PlacementBinding

+ Commit func(context.Context) error

+ GovernanceRoot string

+ Rollback func() error

+ type PlacementDeleteRequest struct

+ Principal *session.Principal

+ Ref session.EnvironmentRef

+ Scope PlacementScope

+ type PlacementDeleteResult struct

+ Retained bool

+ type PlacementDeleter interface

+ DeletePlacement func(context.Context, PlacementDeleteRequest) (PlacementDeleteResult, error)

type PlacementReattachRequest

+ BindingID session.SessionID

+ type PlacementSuccessorRequest struct

+ DestinationBindingID session.SessionID

+ Principal *session.Principal

+ Ref session.EnvironmentRef

+ SourceBindingID session.SessionID

+ type PlacementSuccessorReservoir interface

+ ReserveSuccessor func(context.Context, PlacementSuccessorRequest) (PlacementBinding, error)

+ type PlacementValidator interface

+ ValidatePlacement func(context.Context) error

+ type ReferenceDeleteHandle interface

+ Cancel func(context.Context) error

+ Confirm func(context.Context) error

+ type ReferenceIntent struct

+ BindingID session.SessionID

+ OperationID string

+ PendingDelete bool

+ Principal *session.Principal

+ Ref session.EnvironmentRef

+ SourceBindingID session.SessionID

+ type ReferenceIntentLifecycle interface

+ CancelReferenceIntentDelete func(context.Context, ReferenceIntent) error

+ CommitReferenceIntent func(context.Context, ReferenceIntent) error

+ ConfirmReferenceIntentDelete func(context.Context, ReferenceIntent) error

+ ListReferenceIntents func(context.Context, int) ([]ReferenceIntent, error)

+ type ReferenceLifecycle interface

+ Applies func(session.EnvironmentRef) bool

+ PrepareReferenceDelete func(context.Context, PlacementSuccessorRequest) (ReferenceDeleteHandle, error)

type Service

+ func (s *Service) ReattachPlacementForBinding(ctx context.Context, ref session.EnvironmentRef, bindingID session.SessionID) (PlacementBinding, error)

+ func (s *Service) ReconcileReferenceIntents(ctx context.Context)

v0.0.41

Sep 25, 2026

Changes in this version

+ const FeatureExactPlanAskControl

+ var ErrCommandBindingRetired = errors.New("harness command binding is retired")

+ type CommandSourceBinding interface

+ type CommandSourceResolver interface

+ Activate func(context.Context, session.SessionID, *session.Principal, string) error

+ Borrow func(context.Context, session.SessionID, *session.Principal, string) (CommandSourceBinding, func(), error)

+ Retire func(session.SessionID)

type Config

+ GuardrailCoverage func(*session.Session) GuardrailCoverage

+ MCPRefresh func(ctx context.Context) (MCPRefreshSnapshot, error)

+ MCPStatus func() MCPSourceStatus

+ MemberEngineForOperation func(context.Context) MemberEngineFactory

+ OperationPin func(context.Context) (context.Context, func(), error)

+ OperationRevision func(context.Context) (uint64, bool)

+ ReviewDetails *ReviewDetailRegistry

+ RootAuthorityForOperation func(context.Context, session.SessionKind) session.Authority

+ SessionCleared func(session.SessionID)

+ SessionContextEngine SessionContextEngineFactory

+ SharedEngineRevision uint64

+ type ExecutionWorkspaceAcquirer func(context.Context) (tool.Workspace, func() error, error)

type FeatureScope

+ ExactPlanAskControl bool

+ type GuardrailCoverage struct

+ CheckerModelID string

+ CheckerProviderID string

+ Enabled bool

+ Entries []GuardrailCoverageEntry

+ type GuardrailCoverageEntry struct

+ Inspection string

+ Job string

+ Mode string

+ Phase string

+ Reason string

+ RuleID string

+ RuleOrigin string

+ Tool string

+ type GuardrailReviewDetail struct

+ Concern string

+ NextAction string

+ ReviewID string

+ SourceDisplay string

type HarnessServer

+ func (h *HarnessServer) GetGuardrailReviewDetail(ctx context.Context, req *mecatlv1.GetGuardrailReviewDetailRequest) (*mecatlv1.GetGuardrailReviewDetailResponse, error)

+ func (h *HarnessServer) ListGuardrailCoverage(ctx context.Context, req *mecatlv1.ListGuardrailCoverageRequest) (*mecatlv1.ListGuardrailCoverageResponse, error)

+ func (h *HarnessServer) RefreshMcpSources(ctx context.Context, req *mecatlv1.RefreshMcpSourcesRequest) (*mecatlv1.RefreshMcpSourcesResponse, error)

+ func (h *HarnessServer) ResolvePlanAsk(ctx context.Context, req *mecatlv1.ResolvePlanAskRequest) (*mecatlv1.ResolvePlanAskResponse, error)

+ type MCPRefreshResult struct

+ Changed bool

+ Revision uint64

+ type MCPRefreshSnapshot struct

+ Changed bool

+ Revision uint64

+ ToolNames []string

+ type MCPSourceStatus struct

+ Reconciling bool

+ Revision uint64

+ Sources []source.SourceInfo

+ Stale bool

type ModelInventory

+ CurrentModelSnapshot func() ModelSnapshot

+ type ModelSnapshot struct

+ Models []*mecatlv1.ModelInfo

+ ProviderStatus []*mecatlv1.ProviderStatus

+ type ReviewDetailRegistry struct

+ func NewReviewDetailRegistry() *ReviewDetailRegistry

+ func (r *ReviewDetailRegistry) PublishReviewDetail(_ context.Context, detail agent.ReviewDetail)

type ScheduleManagerConfig

+ ModelInventory ModelInventory

type Service

+ func (s *Service) GetGuardrailReviewDetail(ctx context.Context, ref session.SessionID, reviewID string) (GuardrailReviewDetail, error)

+ func (s *Service) ListGuardrailCoverage(ctx context.Context, id session.SessionID) (GuardrailCoverage, error)

+ func (s *Service) ListModelSnapshot(ctx context.Context) ModelSnapshot

+ func (s *Service) RefreshMcpSources(ctx context.Context, id session.SessionID) (MCPRefreshResult, error)

+ func (s *Service) ResolveApprovalRun(ctx context.Context, id session.SessionID, resolution agent.ApprovalResolution, ...) (*agent.Run, error)

+ func (s *Service) ResolvePlanAsk(ctx context.Context, id session.SessionID, expectedRunID, askID string, ...) (RunAskAcknowledgement, error)

+ func (s *Service) ResolveScopedRunAsk(ctx context.Context, id session.SessionID, expectedRunID string, ...) (RunAskAcknowledgement, error)

+ func (s *Service) StartInteractiveRunContentWithPlanContinuation(ctx context.Context, id session.SessionID, text string, ...) (*agent.Run, error)

+ type SessionContextEngineFactory func(context.Context, session.SessionID, *session.Principal, ...) (SessionEngineResult, error)

type SessionEngineResult

+ RuntimeRevision uint64

v0.0.40

Sep 23, 2026

Changes in this version

type Config

+ ResolveSessionModel func(ProviderSelector, session.PermissionMode) ResolvedModel

v0.0.39

Sep 21, 2026

Changes in this version

+ const FeaturePromptFreeControls

+ var ErrAskNotPending = errors.New("server: permission ask is not pending")

+ var ErrPlanResolutionRequired = errors.New("server: plan ask requires plan resolution")

type HarnessServer

+ func (h *HarnessServer) CancelRun(ctx context.Context, req *mecatlv1.CancelRunRequest) (*mecatlv1.CancelRunResponse, error)

+ func (h *HarnessServer) CancelRunSteer(ctx context.Context, req *mecatlv1.CancelRunSteerRequest) (*mecatlv1.CancelRunSteerResponse, error)

+ func (h *HarnessServer) ResolveRunAsk(ctx context.Context, req *mecatlv1.ResolveRunAskRequest) (*mecatlv1.ResolveRunAskResponse, error)

+ func (h *HarnessServer) SteerRun(ctx context.Context, req *mecatlv1.SteerRunRequest) (*mecatlv1.SteerRunResponse, error)

+ type RunAskAcknowledgement struct

+ AskID string

+ RunID string

+ type RunControlAcknowledgement struct

+ RunID string

+ type RunSteerAcknowledgement struct

+ MessageID string

+ Outcome agent.SteerOutcome

+ RunID string

type Service

+ func (s *Service) CancelRun(ctx context.Context, id session.SessionID, expectedRunID string) (RunControlAcknowledgement, error)

+ func (s *Service) CancelRunSteer(ctx context.Context, id session.SessionID, expectedRunID, messageID string) (RunSteerAcknowledgement, error)

+ func (s *Service) ResolveRunAsk(ctx context.Context, id session.SessionID, expectedRunID, askID string, ...) (RunAskAcknowledgement, error)

+ func (s *Service) SteerRun(ctx context.Context, id session.SessionID, expectedRunID, text string, ...) (RunSteerAcknowledgement, error)

type SessionEngineResult

+ MountedClientMCPTools []string

v0.0.38

Sep 15, 2026

v0.0.37

Sep 15, 2026

Changes in this version

+ var ErrContextWindowUnavailable = errors.New("server: context window unavailable")

type Config

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

v0.0.36

Sep 14, 2026

Changes in this version

+ const FeatureSessionActivityInventory

type Config

+ ResolveCapabilities func(providerID, modelID string, mode session.PermissionMode) port.ProviderCapabilities

type FeatureScope

+ SessionActivityInventory bool

type Service

+ func (s *Service) LostOwnershipCandidates(ctx context.Context) ([]session.SessionID, error)

+ func (s *Service) ReconcileLeaseLossTombstone(ctx context.Context, id session.SessionID) (bool, error)

type SessionSummary

+ Activity session.ActivityState

v0.0.35

Sep 11, 2026

Changes in this version

+ const FeatureHTTPSteer

v0.0.34

Sep 11, 2026

Changes in this version

type Config

+ MCPConnectorInspector brokercontract.ConnectorInspector

type HarnessServer

+ func (h *HarnessServer) ListSessionMcpConnectors(ctx context.Context, req *mecatlv1.ListSessionMcpConnectorsRequest) (*mecatlv1.ListSessionMcpConnectorsResponse, error)

type Service

+ func (s *Service) ListSessionMcpConnectors(ctx context.Context, id session.SessionID) (brokercontract.ConnectorInventory, error)

v0.0.33

Sep 10, 2026

v0.0.32

Sep 10, 2026

v0.0.31

Sep 10, 2026

v0.0.30

Sep 10, 2026

v0.0.29

Sep 10, 2026

v0.0.28

Sep 9, 2026

v0.0.27

Sep 8, 2026

v0.0.26

Sep 8, 2026

Changes in this version

+ var ErrBrokerBindingMismatch = errors.New("MCP broker binding mismatch")

+ var ErrReflectionCancelled = errors.New("server: reflection cancelled")

+ var ErrReflectionDeadline = errors.New("server: reflection timed out")

+ var ErrReflectionFailed = errors.New("server: reflection service failed")

+ var ErrReflectionQueueFull = errors.New("server: reflection queue is full")

+ func NewProtectedResourceHandler(profile ProtectedResourceProfile) http.Handler

+ func WellKnownProtectedResourceURL(resource string) string

+ func WithProtectedResourceMetadata(profile ProtectedResourceProfile, next http.Handler) http.Handler

+ type AuthorizationTimer interface

+ Stop func() bool

+ type AuthorizationTimerFactory func(time.Duration, func()) AuthorizationTimer

type Config

+ AuthorizationTimer AuthorizationTimerFactory

+ MCPBroker brokercontract.Service

+ ModelInventory ModelInventory

+ ProposalManifest ProposalManifestLoader

+ SessionEngineWithTools SessionEngineWithToolsFactory

+ SessionLoadFailureMetric func(port.SessionLoadFailureClass)

+ TitleGenerationEligible func(ProviderSelector) bool

+ TitleGenerator SessionTitleGenerator

+ TitleGeneratorForSession func(ProviderSelector) SessionTitleGenerator

+ WorkspaceEnrollment bool

type HarnessServer

+ func (h *HarnessServer) CancelMcpAuthorization(...) error

+ func (h *HarnessServer) CancelWorkspaceEnrollment(ctx context.Context, req *mecatlv1.WorkspaceEnrollmentControlRequest) (*mecatlv1.WorkspaceEnrollment, error)

+ func (h *HarnessServer) ConnectWorkspaceServices(ctx context.Context, req *mecatlv1.WorkspaceEnrollmentConnectRequest) (*mecatlv1.WorkspaceEnrollment, error)

+ func (h *HarnessServer) GetMcpAuthorizationPresentation(ctx context.Context, req *mecatlv1.GetMcpAuthorizationPresentationRequest) (*mecatlv1.GetMcpAuthorizationPresentationResponse, error)

+ func (h *HarnessServer) RecheckMcpAuthorization(...) error

+ func (h *HarnessServer) RetryWorkspaceEnrollment(ctx context.Context, req *mecatlv1.WorkspaceEnrollmentControlRequest) (*mecatlv1.WorkspaceEnrollment, error)

+ type LocalSessionContextServer struct

+ func NewLocalSessionContextServer(svc *Service) *LocalSessionContextServer

+ func (s *LocalSessionContextServer) GetLocalSessionContext(ctx context.Context, req *mecatlv1.GetLocalSessionContextRequest) (*mecatlv1.GetLocalSessionContextResponse, error)

+ type MCPAuthorizationControl struct

+ AuthorizationID string

+ SessionID session.SessionID

+ type MCPAuthorizationResult struct

+ Event session.Event

+ Run *agent.Run

+ Status session.AuthorizationStatus

+ type ModelInventory interface

+ CurrentModels func() []*mecatlv1.ModelInfo

+ SetModels func([]*mecatlv1.ModelInfo)

+ type ProposalManifestLoader func(context.Context, learning.ProposalPartition, learning.ProposalID) (learning.MaterializationManifest, bool, error)

+ type ProtectedResourceProfile struct

+ Audience string

+ ClientID string

+ Issuer string

+ Resource string

+ Scopes []string

type ReflectionReceipt

+ Reason string

type Service

+ func (s *Service) CancelMCPAuthorization(ctx context.Context, id session.SessionID, control MCPAuthorizationControl) (MCPAuthorizationResult, error)

+ func (s *Service) CancelWorkspaceEnrollment(ctx context.Context, id session.SessionID, ...) (WorkspaceEnrollmentProjection, error)

+ func (s *Service) ConnectWorkspaceServices(ctx context.Context, id session.SessionID) (WorkspaceEnrollmentProjection, error)

+ func (s *Service) MCPAuthorizationPresentation(ctx context.Context, id session.SessionID, control MCPAuthorizationControl) (string, error)

+ func (s *Service) RecheckMCPAuthorization(ctx context.Context, id session.SessionID, control MCPAuthorizationControl) (MCPAuthorizationResult, error)

+ func (s *Service) RetryWorkspaceEnrollment(ctx context.Context, id session.SessionID, ...) (WorkspaceEnrollmentProjection, error)

+ func (s *Service) StartInteractiveRunContent(ctx context.Context, id session.SessionID, text string, ...) (*agent.Run, error)

+ type SessionEngineWithToolsFactory func(ctx context.Context, sel ProviderSelector, specs []mcp.ServerConfig, ...) (SessionEngineResult, error)

type SessionSummary

+ TitleMetadata session.TitlePayload

+ TokenUsage map[session.UsageKind]session.TokenUsage

+ type SessionTitleGenerator interface

+ Generate func(context.Context, []string) TitleGenerationResult

+ func NewSessionTitleGenerator(provider port.LLMProvider, model string) (SessionTitleGenerator, error)

+ func NewSessionTitleGeneratorWithAttribution(provider port.LLMProvider, providerID, model string) (SessionTitleGenerator, error)

+ type TitleGenerationResult struct

+ Err error

+ FailureClass titleFailureClass

+ FailureStage titleFailureStage

+ ModelID string

+ Outcome session.TitleAttemptOutcome

+ ProviderID string

+ Retryable bool

+ Title string

+ Usage session.Usage

+ type WorkspaceEnrollmentProjection struct

+ Ref brokercontract.WorkspaceEnrollmentRef

+ Status brokercontract.WorkspaceEnrollmentStatus

+ URL string

v0.0.25

Sep 5, 2026

Changes in this version

type Config

+ SessionReadLedger func(session.SessionID) tool.ReadLedger

v0.0.24

Sep 4, 2026

Changes in this version

+ var ErrAttemptLiveClaimConflict = errors.New("server: learning attempt has a live claim")

+ var ErrAttemptTerminalConflict = errors.New("server: learning attempt terminal conflict")

+ var ErrAttemptVersionConflict = errors.New("server: learning attempt version conflict")

+ var ErrInvalidPlacementBinding = errors.New("server: invalid placement binding")

+ var ErrInvalidPlacementSelection = errors.New("server: invalid placement selection")

+ var ErrPlacementChanged = errors.New("server: placement changed during bind")

+ var ErrPlacementNotFound = errors.New("server: placement selector not found")

+ var ErrPlacementStale = errors.New("server: placement selector is stale")

+ var ErrPlacementUnavailable = errors.New("server: placement unavailable")

+ type ACPEnvironmentOverlay func(session.SessionID, tool.Environment) (tool.Environment, error)

type Config

+ AttemptPrincipal func(*session.Principal) string

+ Attempts learning.AttemptRepository

+ MutationCapability *SessionMutationCapability

+ PlacementProvider PlacementProvider

+ PlacementScope PlacementScope

+ SharedEngineRoot string

type CreateSessionOption

+ func WithPlacementBinding(binding PlacementBinding) CreateSessionOption

+ type ForkSuccessorRequest struct

+ ModelID string

+ Placement SuccessorPlacement

+ ProviderID string

+ ReasoningEffort string

+ Source session.SessionID

+ Title string

type HarnessServer

+ func (h *HarnessServer) AbandonLearningAttempt(ctx context.Context, req *mecatlv1.MutateLearningAttemptRequest) (*mecatlv1.MutateLearningAttemptResponse, error)

+ func (h *HarnessServer) ClearSession(ctx context.Context, req *mecatlv1.ClearSessionRequest) (*mecatlv1.ClearSessionResponse, error)

+ func (h *HarnessServer) GetLearningAttempt(ctx context.Context, req *mecatlv1.GetLearningAttemptRequest) (*mecatlv1.GetLearningAttemptResponse, error)

+ func (h *HarnessServer) ListLearningAttempts(ctx context.Context, req *mecatlv1.ListLearningAttemptsRequest) (*mecatlv1.ListLearningAttemptsResponse, error)

+ func (h *HarnessServer) RetryLearningAttempt(ctx context.Context, req *mecatlv1.MutateLearningAttemptRequest) (*mecatlv1.MutateLearningAttemptResponse, error)

+ type PlacementBindRequest struct

+ Operation PlacementOperation

+ Principal *session.Principal

+ Scope PlacementScope

+ Selector PlacementSelector

+ type PlacementBinder struct

+ func NewPlacementBinder(provider PlacementProvider) (*PlacementBinder, error)

+ func (b *PlacementBinder) Bind(ctx context.Context, req PlacementBindRequest) (PlacementBinding, error)

+ func (b *PlacementBinder) Reattach(ctx context.Context, req PlacementReattachRequest) (PlacementBinding, error)

+ type PlacementBinding struct

+ Close func() error

+ Environment tool.Environment

+ Metadata PlacementMetadata

+ Ref session.EnvironmentRef

+ type PlacementDiscoverer interface

+ ListWorktrees func(context.Context, PlacementDiscoveryRequest) ([]ScopedWorktree, error)

+ type PlacementDiscoveryRequest struct

+ Principal *session.Principal

+ Scope PlacementScope

+ Source session.SessionID

+ SourceRef session.EnvironmentRef

+ type PlacementMetadata struct

+ Branch string

+ Kind string

+ Label string

+ Revision string

+ type PlacementOperation string

+ const PlacementOperationCreate

+ const PlacementOperationSuccessor

+ type PlacementProvider interface

+ Bind func(context.Context, PlacementBindRequest) (PlacementBinding, error)

+ type PlacementReattachRequest struct

+ Principal *session.Principal

+ Ref session.EnvironmentRef

+ Scope PlacementScope

+ type PlacementReattacher interface

+ Reattach func(context.Context, PlacementReattachRequest) (PlacementBinding, error)

+ type PlacementScope string

+ type PlacementSelector struct

+ ID string

+ Kind PlacementSelectorKind

+ Source session.SessionID

+ SourceRef session.EnvironmentRef

+ func DefaultPlacement() PlacementSelector

+ func NoFSPlacement() PlacementSelector

+ func SelectWorktree(source session.SessionID, ref session.EnvironmentRef, token string) PlacementSelector

+ func (s PlacementSelector) IsDefault() bool

+ func (s PlacementSelector) IsNoFS() bool

+ func (s PlacementSelector) IsWorktree() bool

+ func (s PlacementSelector) Valid() bool

+ type PlacementSelectorKind string

+ const PlacementSelectorDefault

+ const PlacementSelectorNoFS

+ const PlacementSelectorWorktree

+ type ScopedWorktree struct

+ Bare bool

+ Branch string

+ Label string

+ Revision string

+ Selector string

type Service

+ func NewServiceContext(ctx context.Context, cfg Config) (*Service, error)

+ func (s *Service) AbandonLearningAttempt(ctx context.Context, id, expectedVersion string) (*mecatlv1.LearningAttempt, error)

+ func (s *Service) BindPlacement(ctx context.Context, selector PlacementSelector, operation PlacementOperation) (PlacementBinding, error)

+ func (s *Service) ClearSessionSuccessor(ctx context.Context, source session.SessionID, placement SuccessorPlacement) (session.SessionID, error)

+ func (s *Service) CreateACPSession(ctx context.Context, cwd string, mode session.PermissionMode, ...) (*session.Session, error)

+ func (s *Service) CreateTeamForSession(ctx context.Context, source session.SessionID, name, goal string, ...) (string, []team.Member, error)

+ func (s *Service) CreateTeamOnDefaultPlacement(ctx context.Context, name, goal string, maxTeamTokens int, ...) (string, []team.Member, error)

+ func (s *Service) ForkSessionSuccessor(ctx context.Context, req ForkSuccessorRequest) (session.SessionID, error)

+ func (s *Service) GetLearningAttempt(ctx context.Context, id string) (*mecatlv1.LearningAttempt, error)

+ func (s *Service) GracefulDrain(ctx context.Context) error

+ func (s *Service) ListCommandsForSession(ctx context.Context, id session.SessionID) ([]Command, error)

+ func (s *Service) ListLearningAttempts(ctx context.Context, stateValue, cursor string, limit int) (*mecatlv1.ListLearningAttemptsResponse, error)

+ func (s *Service) ListWorktreesForSession(ctx context.Context, id session.SessionID) ([]ScopedWorktree, error)

+ func (s *Service) LoadACPSession(ctx context.Context, id session.SessionID, cwd string, ...) (*session.Session, error)

+ func (s *Service) ReattachPlacement(ctx context.Context, ref session.EnvironmentRef) (PlacementBinding, error)

+ func (s *Service) ReattachPlacementInScope(ctx context.Context, ref session.EnvironmentRef, scope string) (PlacementBinding, error)

+ func (s *Service) RetryLearningAttempt(ctx context.Context, id, expectedVersion string) (*mecatlv1.LearningAttempt, error)

+ type SessionMutationCapability struct

+ func NewSessionMutationCapability(enabled bool) *SessionMutationCapability

+ func (c *SessionMutationCapability) Disable()

+ func (c *SessionMutationCapability) Grant(id session.SessionID)

+ func (c *SessionMutationCapability) GuardStore(next port.SessionStore) port.SessionStore

+ func (c *SessionMutationCapability) GuardToolCallRecorder(next port.ToolCallRecorder) port.ToolCallRecorder

+ func (c *SessionMutationCapability) Invalidate(id session.SessionID)

+ func (c *SessionMutationCapability) Remove(id session.SessionID)

+ type SessionMutationClass uint8

+ const SessionMutationComposition

+ const SessionMutationLeaseOwned

+ const SessionMutationLeaseProven

+ const SessionMutationNewFamily

+ const SessionMutationReadOnly

+ type SessionMutationEntry struct

+ Class SessionMutationClass

+ Rationale string

type SessionSummary

+ Placement session.PlacementMetadata

+ type SuccessorPlacement struct

+ Selector string

+ SelectorPresent bool

+ type WorktreeSelectorIssuer struct

+ func NewWorktreeSelectorIssuer(key []byte) (*WorktreeSelectorIssuer, error)

+ func (i *WorktreeSelectorIssuer) Issue(principal *session.Principal, source session.SessionID, choice Worktree) string

+ func (i *WorktreeSelectorIssuer) Match(selector string, principal *session.Principal, source session.SessionID, ...) (Worktree, error)

v0.0.23

Sep 2, 2026

v0.0.22

Sep 1, 2026

Changes in this version

+ const APIMajor

+ const FeatureMCPServersOnCreate

+ const FeatureServerInfo

+ const FeatureWatchSessionEvents

+ const WatchPhaseGap

+ const WatchPhaseLive

+ const WatchPhaseReplay

+ var ErrActivityGap = errors.New("server: a durable event-log append failed; this watch has a delivery gap")

+ var ErrClientMCPUnreachable = errors.New("server: a requested client-provided MCP server could not be connected")

+ var ErrClientMCPUnsupported = errors.New("server: client-provided MCP servers are not accepted on this deployment")

+ var ErrStaleRunControl = errors.New("server: control targets a run that is no longer current")

+ var ErrWatchLagging = errors.New(...)

+ var ErrWatchUnsupported = errors.New("server: the configured event log does not support cursors")

+ type ActivityGapError struct

+ func (*ActivityGapError) Error() string

+ func (*ActivityGapError) Unwrap() error

+ type CORSPolicy struct

+ func NewCORSPolicy(origins []string) (*CORSPolicy, error)

+ func (p *CORSPolicy) AllowedOrigins() []string

+ func (p *CORSPolicy) Middleware(next http.Handler) http.Handler

+ type ClientMCPGrant struct

+ func (g ClientMCPGrant) IsEmpty() bool

type Config

+ BuildID string

+ ClientMCPOnCreate bool

+ DebugMCP bool

+ DebugSessionEngine DebugSessionEngineFactory

+ DeploymentID string

+ ProviderEndpoint func(providerID string) string

+ ServerImplementation string

type CreateSessionOption

+ func WithClientMCP(grant ClientMCPGrant) CreateSessionOption

+ func WithDebugMCP(names []string) CreateSessionOption

+ func WithDebugTarget(id session.SessionID) CreateSessionOption

+ type DebugSessionEngineFactory func(ctx context.Context, sel ProviderSelector, profile SessionProfile, ...) (SessionEngineResult, error)

+ type FeatureScope struct

+ ClientMCPOnCreate bool

type HarnessServer

+ func (h *HarnessServer) CompactSession(ctx context.Context, req *mecatlv1.CompactSessionRequest) (*mecatlv1.CompactSessionResponse, error)

+ func (h *HarnessServer) GetCompatibilityInfo(ctx context.Context, _ *mecatlv1.GetCompatibilityInfoRequest) (*mecatlv1.GetCompatibilityInfoResponse, error)

+ func (h *HarnessServer) GetServerInfo(_ context.Context, req *mecatlv1.GetServerInfoRequest) (*mecatlv1.GetServerInfoResponse, error)

+ func (h *HarnessServer) WatchSessionEvents(req *mecatlv1.WatchSessionEventsRequest, ...) error

+ type RunEventRecorder struct

+ func NewRunEventRecorder(ctx context.Context, svc *Service, id session.SessionID) *RunEventRecorder

+ func (r *RunEventRecorder) Close()

+ func (r *RunEventRecorder) Observe(ev session.Event)

type Service

+ func (s *Service) ClientMCPFromWire(servers []mcp.ClientServer) (ClientMCPGrant, error)

+ func (s *Service) CompactSession(ctx context.Context, id session.SessionID, caller *session.Principal) (agent.ManualCompactionResult, error)

+ func (s *Service) CompatibilityInfo(context.Context) *mecatlv1.GetCompatibilityInfoResponse

+ func (s *Service) WatchSessionEvents(ctx context.Context, id session.SessionID, after port.Cursor, runID string) (iter.Seq2[WatchEnvelope, error], error)

type SessionEngineResult

+ DebugMCPTools []string

+ MountedClientMCP []string

+ type WatchEnvelope struct

+ Cursor port.Cursor

+ Event *session.Event

+ Phase string

v0.0.21

Aug 28, 2026

v0.0.20

Aug 28, 2026

Changes in this version

+ const DefaultSessionInventoryPageSize

+ const MaxSessionInventoryPageSize

+ var ErrChildNotFound = errors.New("server: child agent not found or already finished")

+ var ErrCleanupBackend = errors.New("server: storage maintenance failed")

+ var ErrCleanupPlanStale = errors.New("server: cleanup plan is stale")

+ var ErrCleanupUnsupported = errors.New("server: session cleanup is unsupported")

+ var ErrConfig = errors.New("server: invalid config")

+ var ErrDreamApplyFailed = errors.New("server: dream plan application failed")

+ var ErrDreamCapacity = errors.New("server: dream review capacity exhausted")

+ var ErrDreamConflict = errors.New("server: dream plan has a conflicting decision in progress")

+ var ErrDreamDeadline = errors.New("dream request deadline exceeded")

+ var ErrDreamGenerateFailed = errors.New("server: dream plan generation failed")

+ var ErrDreamInProgress = errors.New("server: dream plan decision is still in progress")

+ var ErrDreamNotFound = errors.New("server: dream plan not found; generate a new plan")

+ var ErrDreamRequestFailed = errors.New("server: dream request failed")

+ var ErrDreamTerminalConflict = errors.New("server: dream plan was already decided differently")

+ var ErrDreamUnavailable = errors.New("server: manual dream unavailable")

+ var ErrFailedPrecondition = errors.New("server: failed precondition")

+ var ErrFailedStepRetryIneligible = fmt.Errorf("%w: failed-step retry is not eligible", ErrFailedPrecondition)

+ var ErrFireNowOverlap = fmt.Errorf("server: fire-now skipped (prior fire still running): %w", ...)

+ var ErrIdentityUnavailable = errors.New("identity provider unavailable")

+ var ErrInternal = errors.New("server: internal error")

+ var ErrInvalidArgument = errors.New("server: invalid argument")

+ var ErrInvalidToken = errors.New("invalid bearer token")

+ var ErrLearningUnavailable = errors.New("server: learning proposals are not configured")

+ var ErrMaintenanceExclusionUnavailable = errors.New("server: storage maintenance exclusion unavailable")

+ var ErrManagementUnauthorized = errors.New("server: management authorization required")

+ var ErrMigrationBackend = errors.New("server: storage maintenance failed")

+ var ErrMigrationConflict = errors.New("server: migration job conflict")

+ var ErrMigrationUnsupported = errors.New("server: session migration is not supported")

+ var ErrNoActiveRun = errors.New("server: no active run for session")

+ var ErrNoEventLog = errors.New("server: no durable event log configured")

+ var ErrNoMCPProvider = errors.New("server: no MCP provider configured")

+ var ErrNoScheduleStore = errors.New("server: scheduled tasks are not supported by the configured store")

+ var ErrNotAwaitingPlan = errors.New("server: session is not awaiting a plan approval")

+ var ErrNotFound = errors.New("server: session not found")

+ var ErrProposalConflict = errors.New("server: proposal conflict")

+ var ErrScheduleDisabled = errors.New("server: schedule is disabled")

+ var ErrScheduleExhausted = errors.New("server: one-shot schedule already fired")

+ var ErrScheduleNotLeader = errors.New("server: not the scheduler leader")

+ var ErrSchedulerNotRunning = errors.New("server: scheduler is not running")

+ var ErrSessionDeleteUnsupported = errors.New("server: session deletion is not supported by the configured store")

+ var ErrSessionLeasedElsewhere = errors.New("server: session is leased by another process")

+ var ErrStorageHealthBackend = errors.New("server: storage health unavailable")

+ var ErrTeamNotFound = errors.New("server: team not found")

+ var ErrTeamNotRunning = errors.New("server: team is not running")

+ var ErrTeamRunning = errors.New("server: team is already running")

+ var ErrTeamsDisabled = errors.New("server: agent teams are not enabled")

+ var ErrTooManySessionEngines = errors.New("server: too many live per-session engines")

+ var ErrTooManyTeams = errors.New("server: too many live teams")

+ var ErrUnavailable = errors.New("server: draining, not accepting new runs")

+ func ClampInt32(v int) int32

+ func ClassifyAllBoundaries() []error

+ func ClassifyCallerStoreBoundaries() []error

+ func ClassifyServiceBoundaries() []error

+ func ClassifySystemBoundaries() []error

+ func DeriveTitle(sess *session.Session) string

+ func NewScheduleManager(cfg ScheduleManagerConfig) *scheduleManager

+ func PlanManualRetention(rows []port.SessionDiscoveryMeta, policy RetentionPolicy, ...) sessionretention.Result

+ func PresentScheduleName(sched port.Schedule) string

+ func ValidateClassifiedNames(surface string, table map[string]ClassificationEntry, boundaries []string) []error

+ type AccessKind int

+ const KindCallerOwned

+ const KindDerived

+ const KindExempt

+ const KindSharedInfrastructure

+ func (k AccessKind) String() string

+ type ActivityReplayStatus struct

+ Authoritative bool

+ Available bool

+ Complete bool

+ type AdoptionBindings struct

+ EnvironmentRef session.EnvironmentRef

+ ModelID string

+ Profile SessionProfile

+ ProviderID string

+ Workspace string

+ type AdoptionPreflight struct

+ Bindings AdoptionBindings

+ Eligible bool

+ Reason AdoptionReason

+ type AdoptionReason string

+ const AdoptionReasonActive

+ const AdoptionReasonAwaiting

+ const AdoptionReasonBindingUnresolved

+ const AdoptionReasonInvalidTranscript

+ const AdoptionReasonLeased

+ const AdoptionReasonNotLegacy

+ const AdoptionReasonProtectedProvenance

+ type AuthenticationRejectionCategorizer interface

+ AuthenticationRejectionCategory func() string

+ type Authenticator struct

+ func NewAuthenticator(cfg SecurityConfig) *Authenticator

+ func (a *Authenticator) Close()

+ func (a *Authenticator) Middleware(next http.Handler) http.Handler

+ func (a *Authenticator) StreamInterceptor() grpc.StreamServerInterceptor

+ func (a *Authenticator) UnaryInterceptor() grpc.UnaryServerInterceptor

+ type CapabilityReason string

+ const CapabilityReasonActiveElsewhere

+ const CapabilityReasonAwaitingApproval

+ const CapabilityReasonInspectOnlyKind

+ const CapabilityReasonStorageUnsupported

+ const CapabilityReasonTranscriptUnavailable

+ const CapabilityReasonUnknown

+ type ClassificationEntry struct

+ Kind AccessKind

+ Rationale string

+ type CleanupCandidate struct

+ EstimatedBytes int64

+ ID session.SessionID

+ Kind session.SessionKind

+ ModifiedAt time.Time

+ Reason string

+ State session.State

+ type CleanupCounts struct

+ ByKind map[string]int

+ ByReason map[string]int

+ ByState map[string]int

+ Total int

+ type CleanupItemError struct

+ ItemHandle string

+ Message string

+ ReasonCode string

+ type CleanupJob struct

+ Deleted int

+ Errors []CleanupItemError

+ Failed int

+ ID string

+ Processed int

+ Skipped int

+ Stale int

+ State string

+ type CleanupPlan struct

+ Available bool

+ Eligible []CleanupCandidate

+ EligibleCounts CleanupCounts

+ EstimatedBytes int64

+ Generation string

+ JobID string

+ PolicyVersion string

+ Protected CleanupCounts

+ Token string

+ UnavailableReason string

+ type CleanupScope struct

+ Kinds []session.SessionKind

+ type Clock func() time.Time

+ type Command struct

+ Description string

+ Name string

+ type CommandLister interface

+ List func(ctx context.Context, root string) ([]Command, error)

+ type Config struct

+ Agents []*mecatlv1.AgentInfo

+ AuthoritativeWorkspace string

+ BeginSkillPublication func() func()

+ CommandRunner tool.CommandRunner

+ CommandRunnerFactory func(root string) tool.CommandRunner

+ Commands CommandLister

+ DefaultCapabilities port.ProviderCapabilities

+ DefaultLimits session.Limits

+ DefaultMode session.PermissionMode

+ DefaultModelPending bool

+ DefaultResolvedModel ResolvedModel

+ DefaultWorkspace string

+ Diagnostics port.Diagnostics

+ DreamCapabilities DreamCapabilities

+ DreamReviewer DreamReviewer

+ Engine *agent.Engine

+ EnvironmentResolver func(context.Context, session.EnvironmentRef) (tool.Environment, error)

+ EventLog port.EventLog

+ Forker tool.EnvironmentForker

+ Interactive bool

+ LearnedSkillNameAvailable func(string) bool

+ LearnedSkills learning.SkillRepository

+ LeaseOwner string

+ LeaseRenewInterval time.Duration

+ LeaseTTL time.Duration

+ LiveSkillGeneration func(learning.SkillPartition) uint64

+ LiveSkills func(context.Context) []*mecatlv1.SkillInfo

+ LocalStorageMaintenanceSingleWriter bool

+ MCPProvider mcp.Provider

+ MCPSourceProber func(ctx context.Context) []source.SourceInfo

+ MCPSources []source.SourceInfo

+ MaxSessionEngines int

+ MaxTeams int

+ MemberEngine MemberEngineFactory

+ ModeNeedsEngine func(mode session.PermissionMode) bool

+ Models []*mecatlv1.ModelInfo

+ NewID IDGenerator

+ Now Clock

+ OnCloseSession func(session.SessionID)

+ OwnershipEnforced bool

+ PlanModeAutoApprove bool

+ Posture string

+ ProjectPromotionAllowed func(project string) bool

+ PromoteProposal ProposalPromoter

+ ProposalActionAvailable func(project string) (bool, string)

+ ProposalPrincipal func(*session.Principal) string

+ Proposals learning.ProposalRepository

+ PublishLearnedSkills func(context.Context, learning.SkillPartition) error

+ ReadOnlyForker tool.EnvironmentForker

+ ReflectSession ExplicitReflector

+ ReplayApprovals func(ctx context.Context, sess *session.Session)

+ ResolveContextWindow func(providerID, modelID string) int64

+ RetentionPolicy RetentionPolicy

+ RevokeLearnedSkill func(learning.SkillPartition, string)

+ RootAuthority func(session.SessionKind) session.Authority

+ ScheduleManager *scheduleManager

+ Scheduler *scheduler.Scheduler

+ SessionEngine SessionEngineFactory

+ SessionLease port.SessionLease

+ SessionLiveness port.SessionLiveness

+ SharedBaseWorkspace func(root string) tool.Workspace

+ SkillActionAvailable func(learning.SkillPartition, string) (bool, string)

+ Skills []*mecatlv1.SkillInfo

+ Soul *mecatlv1.SoulInfo

+ StorageMaintenanceStatus func() StorageMaintenanceStatus

+ StorageMaintenanceUpdate func(StorageMaintenanceEvent)

+ StorageManagementAuthorized func(context.Context) bool

+ Store port.SessionStore

+ TeamGoalUntrusted bool

+ TeamHooks port.HookRunner

+ TeamTokenBudget int

+ UndoProposal ProposalUndoer

+ UserModel UserModelLister

+ WorkspaceAuthority WorkspaceAuthority

+ Workspaces WorkspaceFactory

+ Worktrees WorktreeLister

+ type CreateSessionOption func(*createSessionOpts)

+ func WithOwner(p *session.Principal) CreateSessionOption

+ func WithScheduledRelationship(scheduleName string, origin session.SessionID) CreateSessionOption

+ func WithSessionID(id session.SessionID) CreateSessionOption

+ func WithSourceSession(id session.SessionID) CreateSessionOption

+ type DreamCapabilities struct

+ Decide bool

+ Generate bool

+ Targets map[DreamTarget]DreamTargetCapability

+ UnavailableReason string

+ type DreamDecision string

+ const DreamDecisionApply

+ const DreamDecisionDismiss

+ type DreamOperation struct

+ ExactDuplicateEligible bool

+ Kind string

+ Reason string

+ Replacement DreamReplacement

+ Sources []DreamParticipant

+ Survivor DreamParticipant

+ type DreamParticipant struct

+ Description string

+ Key string

+ Value string

+ type DreamReceipt struct

+ Applied int

+ Conflicted int

+ Disposition DreamDecision

+ Failed int

+ ID string

+ Planned int

+ Skipped int

+ Target DreamTarget

+ type DreamReplacement struct

+ Description string

+ Value string

+ type DreamReview struct

+ ExpiresAt time.Time

+ ID string

+ Operations []DreamOperation

+ PlannedOperations int

+ PlannedSourceCount int

+ Target DreamTarget

+ type DreamReviewer interface

+ Decide func(context.Context, string, DreamDecision) (DreamReceipt, error)

+ Generate func(context.Context, DreamTarget) (DreamReview, error)

+ type DreamTarget string

+ const DreamTargetProjectMemory

+ const DreamTargetUserModel

+ type DreamTargetCapability struct

+ Decide bool

+ Generate bool

+ UnavailableReason string

+ type ExplicitReflector func(context.Context, *session.Session) (ReflectionReceipt, error)

+ type HTTPHandler struct

+ func NewHTTPHandler(svc *Service) *HTTPHandler

+ func (h *HTTPHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ type HarnessServer struct

+ func NewHarnessServer(svc *Service) *HarnessServer

+ func (h *HarnessServer) ActivateLearnedSkill(ctx context.Context, req *mecatlv1.MutateLearnedSkillRequest) (*mecatlv1.MutateLearnedSkillResponse, error)

+ func (h *HarnessServer) AdoptSession(ctx context.Context, req *mecatlv1.AdoptSessionRequest) (*mecatlv1.AdoptSessionResponse, error)

+ func (h *HarnessServer) ApplySessionCleanup(ctx context.Context, req *mecatlv1.ApplySessionCleanupRequest) (*mecatlv1.CleanupJob, error)

+ func (h *HarnessServer) ApplySessionMigration(ctx context.Context, req *mecatlv1.ApplySessionMigrationRequest) (*mecatlv1.SessionMigrationJob, error)

+ func (h *HarnessServer) ApprovePlan(req *mecatlv1.ApprovePlanRequest, ...) error

+ func (h *HarnessServer) ArchiveLearnedSkill(ctx context.Context, req *mecatlv1.MutateLearnedSkillRequest) (*mecatlv1.MutateLearnedSkillResponse, error)

+ func (h *HarnessServer) CancelSessionCleanup(ctx context.Context, req *mecatlv1.CancelSessionCleanupRequest) (*mecatlv1.CleanupJob, error)

+ func (h *HarnessServer) CancelSessionMigration(ctx context.Context, req *mecatlv1.CancelSessionMigrationRequest) (*mecatlv1.SessionMigrationJob, error)

+ func (h *HarnessServer) CancelTeammate(ctx context.Context, req *mecatlv1.CancelTeammateRequest) (*mecatlv1.CancelTeammateResponse, error)

+ func (h *HarnessServer) CleanupTeam(ctx context.Context, req *mecatlv1.CleanupTeamRequest) (*mecatlv1.CleanupTeamResponse, error)

+ func (h *HarnessServer) CloseSession(ctx context.Context, req *mecatlv1.CloseSessionRequest) (*mecatlv1.CloseSessionResponse, error)

+ func (h *HarnessServer) Converse(stream mecatlv1.HarnessService_ConverseServer) error

+ func (h *HarnessServer) CreateSession(ctx context.Context, req *mecatlv1.CreateSessionRequest) (*mecatlv1.CreateSessionResponse, error)

+ func (h *HarnessServer) CreateTeam(ctx context.Context, req *mecatlv1.CreateTeamRequest) (*mecatlv1.CreateTeamResponse, error)

+ func (h *HarnessServer) DecideDreamPlan(ctx context.Context, req *mecatlv1.DecideDreamPlanRequest) (*mecatlv1.DecideDreamPlanResponse, error)

+ func (h *HarnessServer) DecideLearningProposal(ctx context.Context, req *mecatlv1.DecideLearningProposalRequest) (*mecatlv1.DecideLearningProposalResponse, error)

+ func (h *HarnessServer) DeleteSession(ctx context.Context, req *mecatlv1.DeleteSessionRequest) (*mecatlv1.DeleteSessionResponse, error)

+ func (h *HarnessServer) DiffLearnedSkillVersions(ctx context.Context, req *mecatlv1.DiffLearnedSkillVersionsRequest) (*mecatlv1.DiffLearnedSkillVersionsResponse, error)

+ func (h *HarnessServer) ForkSession(ctx context.Context, req *mecatlv1.ForkSessionRequest) (*mecatlv1.ForkSessionResponse, error)

+ func (h *HarnessServer) GenerateDreamPlan(ctx context.Context, req *mecatlv1.GenerateDreamPlanRequest) (*mecatlv1.GenerateDreamPlanResponse, error)

+ func (h *HarnessServer) GetLearnedSkill(ctx context.Context, req *mecatlv1.GetLearnedSkillRequest) (*mecatlv1.GetLearnedSkillResponse, error)

+ func (h *HarnessServer) GetLearningProposal(ctx context.Context, req *mecatlv1.GetLearningProposalRequest) (*mecatlv1.GetLearningProposalResponse, error)

+ func (h *HarnessServer) GetMcpPrompt(ctx context.Context, req *mecatlv1.GetMcpPromptRequest) (*mecatlv1.GetMcpPromptResponse, error)

+ func (h *HarnessServer) GetSession(ctx context.Context, req *mecatlv1.GetSessionRequest) (*mecatlv1.GetSessionResponse, error)

+ func (h *HarnessServer) GetSessionCleanupJob(ctx context.Context, req *mecatlv1.GetSessionCleanupJobRequest) (*mecatlv1.CleanupJob, error)

+ func (h *HarnessServer) GetSessionMigrationJob(ctx context.Context, req *mecatlv1.GetSessionMigrationJobRequest) (*mecatlv1.SessionMigrationJob, error)

+ func (h *HarnessServer) GetSessionTranscript(ctx context.Context, req *mecatlv1.GetSessionTranscriptRequest) (*mecatlv1.GetSessionTranscriptResponse, error)

+ func (h *HarnessServer) GetSoul(ctx context.Context, _ *mecatlv1.GetSoulRequest) (*mecatlv1.GetSoulResponse, error)

+ func (h *HarnessServer) GetStorageHealth(ctx context.Context, _ *mecatlv1.GetStorageHealthRequest) (*mecatlv1.GetStorageHealthResponse, error)

+ func (h *HarnessServer) GetUserModel(ctx context.Context, req *mecatlv1.GetUserModelRequest) (*mecatlv1.GetUserModelResponse, error)

+ func (h *HarnessServer) ListAgents(ctx context.Context, _ *mecatlv1.ListAgentsRequest) (*mecatlv1.ListAgentsResponse, error)

+ func (h *HarnessServer) ListCommands(ctx context.Context, req *mecatlv1.ListCommandsRequest) (*mecatlv1.ListCommandsResponse, error)

+ func (h *HarnessServer) ListLearnedSkills(ctx context.Context, req *mecatlv1.ListLearnedSkillsRequest) (*mecatlv1.ListLearnedSkillsResponse, error)

+ func (h *HarnessServer) ListLearningProposals(ctx context.Context, req *mecatlv1.ListLearningProposalsRequest) (*mecatlv1.ListLearningProposalsResponse, error)

+ func (h *HarnessServer) ListMcpPrompts(ctx context.Context, req *mecatlv1.ListMcpPromptsRequest) (*mecatlv1.ListMcpPromptsResponse, error)

+ func (h *HarnessServer) ListMcpResources(ctx context.Context, req *mecatlv1.ListMcpResourcesRequest) (*mecatlv1.ListMcpResourcesResponse, error)

+ func (h *HarnessServer) ListMcpSources(ctx context.Context, _ *mecatlv1.ListMcpSourcesRequest) (*mecatlv1.ListMcpSourcesResponse, error)

+ func (h *HarnessServer) ListModels(ctx context.Context, _ *mecatlv1.ListModelsRequest) (*mecatlv1.ListModelsResponse, error)

+ func (h *HarnessServer) ListSessions(ctx context.Context, req *mecatlv1.ListSessionsRequest) (*mecatlv1.ListSessionsResponse, error)

+ func (h *HarnessServer) ListSkillChanges(ctx context.Context, req *mecatlv1.ListSkillChangesRequest) (*mecatlv1.ListSkillChangesResponse, error)

+ func (h *HarnessServer) ListSkills(ctx context.Context, _ *mecatlv1.ListSkillsRequest) (*mecatlv1.ListSkillsResponse, error)

+ func (h *HarnessServer) ListTeam(ctx context.Context, req *mecatlv1.ListTeamRequest) (*mecatlv1.ListTeamResponse, error)

+ func (h *HarnessServer) ListToolHiveGroups(ctx context.Context, _ *mecatlv1.ListToolHiveGroupsRequest) (*mecatlv1.ListToolHiveGroupsResponse, error)

+ func (h *HarnessServer) ListWorktrees(ctx context.Context, req *mecatlv1.ListWorktreesRequest) (*mecatlv1.ListWorktreesResponse, error)

+ func (h *HarnessServer) PlanSessionCleanup(ctx context.Context, req *mecatlv1.PlanSessionCleanupRequest) (*mecatlv1.PlanSessionCleanupResponse, error)

+ func (h *HarnessServer) PlanSessionMigration(ctx context.Context, _ *mecatlv1.PlanSessionMigrationRequest) (*mecatlv1.SessionMigrationPlan, error)

+ func (h *HarnessServer) PreflightSessionAdoption(ctx context.Context, req *mecatlv1.PreflightSessionAdoptionRequest) (*mecatlv1.PreflightSessionAdoptionResponse, error)

+ func (h *HarnessServer) ReadMcpResource(ctx context.Context, req *mecatlv1.ReadMcpResourceRequest) (*mecatlv1.ReadMcpResourceResponse, error)

+ func (h *HarnessServer) ReflectSession(ctx context.Context, req *mecatlv1.ReflectSessionRequest) (*mecatlv1.ReflectSessionResponse, error)

+ func (h *HarnessServer) RejectLearnedSkill(ctx context.Context, req *mecatlv1.MutateLearnedSkillRequest) (*mecatlv1.MutateLearnedSkillResponse, error)

+ func (h *HarnessServer) RenameSession(ctx context.Context, req *mecatlv1.RenameSessionRequest) (*mecatlv1.RenameSessionResponse, error)

+ func (h *HarnessServer) ResumeSessionMigration(ctx context.Context, req *mecatlv1.ResumeSessionMigrationRequest) (*mecatlv1.SessionMigrationJob, error)

+ func (h *HarnessServer) RollbackLearnedSkill(ctx context.Context, req *mecatlv1.RollbackLearnedSkillRequest) (*mecatlv1.MutateLearnedSkillResponse, error)

+ func (h *HarnessServer) RunTeam(req *mecatlv1.RunTeamRequest, stream mecatlv1.HarnessService_RunTeamServer) error

+ func (h *HarnessServer) SendTeammateMessage(ctx context.Context, req *mecatlv1.SendTeammateMessageRequest) (*mecatlv1.SendTeammateMessageResponse, error)

+ func (h *HarnessServer) SetMode(ctx context.Context, req *mecatlv1.SetModeRequest) (*mecatlv1.SetModeResponse, error)

+ func (h *HarnessServer) SpawnTeammate(ctx context.Context, req *mecatlv1.SpawnTeammateRequest) (*mecatlv1.SpawnTeammateResponse, error)

+ func (h *HarnessServer) StreamSessionEvents(req *mecatlv1.StreamSessionEventsRequest, ...) error

+ func (h *HarnessServer) StreamSessionLive(req *mecatlv1.StreamSessionLiveRequest, ...) error

+ func (h *HarnessServer) UndoLearningPromotion(ctx context.Context, req *mecatlv1.UndoLearningPromotionRequest) (*mecatlv1.UndoLearningPromotionResponse, error)

+ type HealthHandler struct

+ func NewHealthHandler(ready ReadyFunc) *HealthHandler

+ func (*HealthHandler) Live(w http.ResponseWriter, _ *http.Request)

+ func (h *HealthHandler) Ready(w http.ResponseWriter, _ *http.Request)

+ func (h *HealthHandler) RegisterHealth(mux *http.ServeMux)

+ type IDGenerator func() session.SessionID

+ type ListSessionsPage struct

+ NextCursor string

+ Sessions []SessionSummary

+ TotalCount int

+ type ListSessionsPageRequest struct

+ Cursor string

+ PageSize int

+ type MemberEngineFactory func(t *team.Team, spec agent.MemberSpec, routedModel string) agent.MemberBuild

+ type MigrationItemError struct

+ ItemHandle string

+ Message string

+ ReasonCode string

+ type MigrationJob struct

+ CurrentBytes int64

+ Errors []MigrationItemError

+ Failed int64

+ ID string

+ InvalidFamilies int64

+ Migrated int64

+ Processed int64

+ ReclaimableBytes int64

+ SkippedFamilies int64

+ State string

+ TemporaryBytes int64

+ V1Families int64

+ V2Families int64

+ type MigrationPlan struct

+ Available bool

+ CurrentBytes int64

+ ID string

+ InvalidFamilies int64

+ ReclaimableBytes int64

+ SkippedFamilies int64

+ TemporaryBytes int64

+ UnavailableReason string

+ V1Families int64

+ V2Families int64

+ type OwnerlessCutoverInventory struct

+ ScheduleCount int

+ ScheduleNames []string

+ ScheduleNamesTruncated bool

+ SchedulesAvailable bool

+ SchedulesUnavailableReason string

+ SessionCount int

+ SessionIDs []string

+ SessionIDsTruncated bool

+ SessionsAvailable bool

+ SessionsUnavailableReason string

+ type PrincipalValidator interface

+ Validate func(ctx context.Context, bearer string) (*session.Principal, error)

+ type ProposalPromoter func(context.Context, learning.ProposalPartition, learning.ProposalID, ...) (learning.ProposalRecord, error)

+ type ProposalUndoer func(context.Context, learning.ProposalPartition, learning.ProposalID, ...) (learning.ProposalRecord, error)

+ type ProviderSelector struct

+ ModelID string

+ ProviderID string

+ ReasoningEffort string

+ type ReadyFunc func() bool

+ type ReflectionReceipt struct

+ Abstained bool

+ Conflicted int

+ Disposition string

+ ID string

+ Promoted int

+ Queued int

+ Staged int

+ type ResolvedModel struct

+ ContextWindow int64

+ ModelID string

+ ProviderID string

+ ReasoningEffort string

+ type RetentionPolicy struct

+ ChildMaxAge time.Duration

+ ChildMaxCount int

+ MainMaxAge time.Duration

+ MainMaxCount int

+ ScheduledMaxAge time.Duration

+ ScheduledMaxCount int

+ SweepCadence time.Duration

+ Version string

+ type ScheduleManagerConfig struct

+ Diagnostics port.Diagnostics

+ Models *atomic.Pointer[[]*mecatlv1.ModelInfo]

+ Now func() time.Time

+ OwnershipEnforced bool

+ ScheduleStore port.ScheduleStore

+ Store port.SessionStore

+ type ScheduleManagerImpl = scheduleManager

+ type ScheduleServer struct

+ func NewScheduleServer(svc *Service) *ScheduleServer

+ func (h *ScheduleServer) CreateSchedule(ctx context.Context, req *mecatlv1.CreateScheduleRequest) (*mecatlv1.CreateScheduleResponse, error)

+ func (h *ScheduleServer) DeleteSchedule(ctx context.Context, req *mecatlv1.DeleteScheduleRequest) (*mecatlv1.DeleteScheduleResponse, error)

+ func (h *ScheduleServer) FireNow(ctx context.Context, req *mecatlv1.FireNowRequest) (*mecatlv1.FireNowResponse, error)

+ func (h *ScheduleServer) GetFire(ctx context.Context, req *mecatlv1.GetFireRequest) (*mecatlv1.GetFireResponse, error)

+ func (h *ScheduleServer) GetSchedule(ctx context.Context, req *mecatlv1.GetScheduleRequest) (*mecatlv1.GetScheduleResponse, error)

+ func (h *ScheduleServer) ListFires(ctx context.Context, req *mecatlv1.ListFiresRequest) (*mecatlv1.ListFiresResponse, error)

+ func (h *ScheduleServer) ListSchedules(ctx context.Context, _ *mecatlv1.ListSchedulesRequest) (*mecatlv1.ListSchedulesResponse, error)

+ func (h *ScheduleServer) PauseSchedule(ctx context.Context, req *mecatlv1.PauseScheduleRequest) (*mecatlv1.PauseScheduleResponse, error)

+ func (h *ScheduleServer) ResumeSchedule(ctx context.Context, req *mecatlv1.ResumeScheduleRequest) (*mecatlv1.ResumeScheduleResponse, error)

+ func (h *ScheduleServer) UpdateSchedule(ctx context.Context, req *mecatlv1.UpdateScheduleRequest) (*mecatlv1.UpdateScheduleResponse, error)

+ type SecurityConfig struct

+ AuthToken string

+ Diagnostics port.Diagnostics

+ RateBurst int

+ RateLimit float64

+ Validator PrincipalValidator

+ type Service struct

+ func NewService(cfg Config) (*Service, error)

+ func (s *Service) ActivateLearnedSkill(ctx context.Context, r *mecatlv1.MutateLearnedSkillRequest) (*mecatlv1.MutateLearnedSkillResponse, error)

+ func (s *Service) ActiveRuns() int

+ func (s *Service) AdoptSession(ctx context.Context, sourceID session.SessionID, idempotencyKey string, ...) (*session.Session, error)

+ func (s *Service) AppendRunEvent(ctx context.Context, id session.SessionID, ev session.Event)

+ func (s *Service) ApplySessionCleanup(ctx context.Context, token string) (CleanupJob, error)

+ func (s *Service) ApplySessionMigration(ctx context.Context, planID string, batchSize int) (MigrationJob, error)

+ func (s *Service) Approve(ctx context.Context, id session.SessionID, askID string, ...) error

+ func (s *Service) ApprovePlan(ctx context.Context, id session.SessionID, targetMode session.PermissionMode, ...) (<-chan session.Event, error)

+ func (s *Service) ApproveRun(ctx context.Context, id session.SessionID, askID string, ...) (*agent.Run, error)

+ func (s *Service) ArchiveLearnedSkill(ctx context.Context, r *mecatlv1.MutateLearnedSkillRequest) (*mecatlv1.MutateLearnedSkillResponse, error)

+ func (s *Service) CanProcessSchedule(sched port.Schedule) bool

+ func (s *Service) Cancel(ctx context.Context, id session.SessionID) error

+ func (s *Service) CancelChild(ctx context.Context, id session.SessionID, childID string) error

+ func (s *Service) CancelSessionCleanup(ctx context.Context, id string) (CleanupJob, error)

+ func (s *Service) CancelSessionMigration(ctx context.Context, id string) (MigrationJob, error)

+ func (s *Service) CancelSteer(ctx context.Context, id session.SessionID) (agent.SteerOutcome, error)

+ func (s *Service) CancelTeammate(ctx context.Context, teamID, member string) error

+ func (s *Service) CleanupTeam(ctx context.Context, teamID string) error

+ func (s *Service) Close()

+ func (s *Service) CloseSession(id session.SessionID)

+ func (s *Service) CreateSchedule(ctx context.Context, spec port.ScheduleSpec) (port.Schedule, error)

+ func (s *Service) CreateSession(ctx context.Context, workspace string, mode session.PermissionMode, ...) (*session.Session, error)

+ func (s *Service) CreateSessionWithMCP(ctx context.Context, workspace string, mode session.PermissionMode, ...) (*session.Session, error)

+ func (s *Service) CreateSessionWithProfile(ctx context.Context, workspace string, mode session.PermissionMode, ...) (*session.Session, error)

+ func (s *Service) CreateSessionWithProvider(ctx context.Context, workspace string, mode session.PermissionMode, ...) (*session.Session, error)

+ func (s *Service) CreateTeam(ctx context.Context, workspace, name, goal string, maxTeamTokens int, ...) (string, []team.Member, error)

+ func (s *Service) DecideDream(ctx context.Context, id string, decision DreamDecision) (DreamReceipt, error)

+ func (s *Service) DecideLearningProposal(ctx context.Context, id, expected, decision, reason, project string) (*mecatlv1.LearningProposal, error)

+ func (s *Service) DeleteSchedule(ctx context.Context, name string) error

+ func (s *Service) DeleteSession(ctx context.Context, id session.SessionID) error

+ func (s *Service) DeleteSessionForRetention(ctx context.Context, id session.SessionID) error

+ func (s *Service) DeleteSessionForRetentionCandidate(ctx context.Context, candidate port.SessionDiscoveryMeta) error

+ func (s *Service) Diagnostics() port.Diagnostics

+ func (s *Service) DiffLearnedSkillVersions(ctx context.Context, request *mecatlv1.DiffLearnedSkillVersionsRequest) (*mecatlv1.DiffLearnedSkillVersionsResponse, error)

+ func (s *Service) Drain()

+ func (s *Service) EmitScheduleEvent(ctx context.Context, payload session.SchedulePayload)

+ func (s *Service) EndSession(ctx context.Context, id session.SessionID) error

+ func (s *Service) FinishRun(id session.SessionID, run *agent.Run)

+ func (s *Service) FireNow(ctx context.Context, name string) (port.ScheduleFire, error)

+ func (s *Service) ForkSession(ctx context.Context, srcID session.SessionID, title, effortOverride string) (session.SessionID, error)

+ func (s *Service) GenerateDream(ctx context.Context, target DreamTarget) (DreamReview, error)

+ func (s *Service) GetFire(ctx context.Context, fireID string) (port.ScheduleFire, error)

+ func (s *Service) GetLearnedSkill(ctx context.Context, request *mecatlv1.GetLearnedSkillRequest) (*mecatlv1.GetLearnedSkillResponse, error)

+ func (s *Service) GetLearningProposal(ctx context.Context, id, project string) (*mecatlv1.LearningProposal, error)

+ func (s *Service) GetMcpPrompt(ctx context.Context, server, name string, args map[string]string) (mcp.PromptResult, error)

+ func (s *Service) GetSchedule(ctx context.Context, name string) (port.Schedule, error)

+ func (s *Service) GetSession(ctx context.Context, id session.SessionID) (*session.Session, error)

+ func (s *Service) GetSoul(_ context.Context) *mecatlv1.SoulInfo

+ func (s *Service) GetTranscript(ctx context.Context, id session.SessionID) (*SessionTranscript, error)

+ func (s *Service) GetUserModel(ctx context.Context) (*mecatlv1.GetUserModelResponse, error)

+ func (s *Service) GetUserModelDetail(ctx context.Context, key string) (*mecatlv1.UserModelDetail, error)

+ func (s *Service) HasScheduler() bool

+ func (s *Service) IsDraining() bool

+ func (s *Service) IsLive(id session.SessionID) bool

+ func (s *Service) LeaseSweepDisabled() bool

+ func (s *Service) ListAgents(_ context.Context) []*mecatlv1.AgentInfo

+ func (s *Service) ListCommands(ctx context.Context, workspace string) ([]Command, error)

+ func (s *Service) ListFires(ctx context.Context, scheduleName string) ([]port.ScheduleFire, error)

+ func (s *Service) ListLearnedSkills(ctx context.Context, request *mecatlv1.ListLearnedSkillsRequest) (*mecatlv1.ListLearnedSkillsResponse, error)

+ func (s *Service) ListLearningProposals(ctx context.Context, statusValue, cursor string, limit int, project string) (*mecatlv1.ListLearningProposalsResponse, error)

+ func (s *Service) ListMcpPrompts(ctx context.Context, server string) ([]mcp.Prompt, error)

+ func (s *Service) ListMcpResources(ctx context.Context, server string) ([]mcp.Resource, error)

+ func (s *Service) ListMcpSources(ctx context.Context) []source.SourceInfo

+ func (s *Service) ListModels(ctx context.Context) []*mecatlv1.ModelInfo

+ func (s *Service) ListSchedules(ctx context.Context) ([]port.Schedule, error)

+ func (s *Service) ListSessionPage(ctx context.Context, request ListSessionsPageRequest) (ListSessionsPage, error)

+ func (s *Service) ListSessions(ctx context.Context) ([]SessionSummary, error)

+ func (s *Service) ListSkillChanges(ctx context.Context, r *mecatlv1.ListSkillChangesRequest) (*mecatlv1.ListSkillChangesResponse, error)

+ func (s *Service) ListSkills(ctx context.Context) []*mecatlv1.SkillInfo

+ func (s *Service) ListTeam(ctx context.Context, teamID string) ([]team.Member, []team.Task, bool, error)

+ func (s *Service) ListToolHiveGroups(ctx context.Context) []string

+ func (s *Service) ListWorktrees(ctx context.Context, workspace string) ([]Worktree, error)

+ func (s *Service) LoadSession(ctx context.Context, id session.SessionID) (*session.Session, error)

+ func (s *Service) LoadSessionWithMCP(ctx context.Context, id session.SessionID, specs []mcp.ServerConfig) (*session.Session, error)

+ func (s *Service) LookupRun(id session.SessionID) (*agent.Run, bool)

+ func (s *Service) LookupSteerMessageID(id session.SessionID) string

+ func (s *Service) MaintenanceMutationAvailable() bool

+ func (s *Service) ManualDreamCapabilities() DreamCapabilities

+ func (s *Service) MaybeAutoApprovePlan(ctx context.Context, id session.SessionID, ev session.Event)

+ func (s *Service) OwnershipEnforced() bool

+ func (s *Service) PauseSchedule(ctx context.Context, name string) error

+ func (s *Service) Persist(ctx context.Context, id session.SessionID)

+ func (s *Service) PlanSessionCleanup(ctx context.Context, scope CleanupScope) (CleanupPlan, error)

+ func (s *Service) PlanSessionMigration(ctx context.Context) (MigrationPlan, error)

+ func (s *Service) PreflightSessionAdoption(ctx context.Context, id session.SessionID, bindings AdoptionBindings) (AdoptionPreflight, error)

+ func (s *Service) ProviderCapabilities() port.ProviderCapabilities

+ func (s *Service) ProviderStatuses() []*mecatlv1.ProviderStatus

+ func (s *Service) PublishSessionEvent(id session.SessionID, ev session.Event)

+ func (s *Service) ReadMcpResource(ctx context.Context, server, uri string) (mcp.ResourceContents, error)

+ func (s *Service) RecoverNotice(id session.SessionID) string

+ func (s *Service) ReflectSession(ctx context.Context, id session.SessionID) (*mecatlv1.ReflectionReceipt, error)

+ func (s *Service) RejectLearnedSkill(ctx context.Context, r *mecatlv1.MutateLearnedSkillRequest) (*mecatlv1.MutateLearnedSkillResponse, error)

+ func (s *Service) RenameSession(ctx context.Context, id session.SessionID, title string) (*session.Session, error)

+ func (s *Service) ResolvedModel(id session.SessionID) ResolvedModel

+ func (s *Service) ResumeSchedule(ctx context.Context, name string) error

+ func (s *Service) ResumeSessionMigration(ctx context.Context, jobID string, batchSize int) (MigrationJob, error)

+ func (s *Service) RetryFailedRun(ctx context.Context, id session.SessionID) (*agent.Run, error)

+ func (s *Service) RollbackLearnedSkill(ctx context.Context, r *mecatlv1.RollbackLearnedSkillRequest) (*mecatlv1.MutateLearnedSkillResponse, error)

+ func (s *Service) RunTeam(ctx context.Context, teamID string, sink func(agent.TeamEvent)) (agent.TeamOutcome, error)

+ func (s *Service) ScheduleManager() port.ScheduleManager

+ func (s *Service) SendTeammateMessage(ctx context.Context, teamID, from, to, body string) error

+ func (s *Service) SessionCapabilities(id session.SessionID) port.ProviderCapabilities

+ func (s *Service) SessionCleanupJob(ctx context.Context, id string) (CleanupJob, error)

+ func (s *Service) SessionMigrationJob(ctx context.Context, id string) (MigrationJob, error)

+ func (s *Service) SessionStale(ctx context.Context, meta port.SessionMeta) bool

+ func (s *Service) SetMode(ctx context.Context, id session.SessionID, mode session.PermissionMode) (*session.Session, error)

+ func (s *Service) SetModels(models []*mecatlv1.ModelInfo)

+ func (s *Service) SetModelsRefresher(fn func(context.Context))

+ func (s *Service) SetProviderStatus(status []*mecatlv1.ProviderStatus)

+ func (s *Service) SetScheduleMinInterval(d time.Duration)

+ func (s *Service) SetScheduler(sch *scheduler.Scheduler)

+ func (s *Service) SetSessionEnvironment(id session.SessionID, env tool.Environment)

+ func (s *Service) SettleIfStale(ctx context.Context, id session.SessionID) (bool, error)

+ func (s *Service) SpawnTeammate(ctx context.Context, teamID string, spec agent.MemberSpec) (team.Member, error)

+ func (s *Service) StaleRunningCandidates(ctx context.Context) ([]port.SessionMeta, error)

+ func (s *Service) StartRun(ctx context.Context, id session.SessionID, text string) (*agent.Run, error)

+ func (s *Service) StartRunContent(ctx context.Context, id session.SessionID, text string, ...) (*agent.Run, error)

+ func (s *Service) StartScheduledRunContent(ctx context.Context, id session.SessionID, text string, ...) (*agent.Run, error)

+ func (s *Service) Steer(ctx context.Context, id session.SessionID, text, messageID string) (agent.SteerOutcome, bool, *agent.Run, error)

+ func (s *Service) StorageHealth(ctx context.Context) (StorageHealth, error)

+ func (s *Service) StorageReady(ctx context.Context) bool

+ func (s *Service) StreamSessionEvents(ctx context.Context, id session.SessionID) (iter.Seq2[session.Event, error], error)

+ func (s *Service) Subscribe(ctx context.Context, id session.SessionID) (<-chan session.Event, func(), error)

+ func (s *Service) UndoLearningPromotion(ctx context.Context, id, expected, project string) (*mecatlv1.LearningProposal, error)

+ func (s *Service) UpdateSchedule(ctx context.Context, spec port.ScheduleSpec) (port.Schedule, error)

+ func (s *Service) WithAuthorizedSession(ctx context.Context, id session.SessionID, effect func(*session.Session) error) (*session.Session, error)

+ type SessionEngineFactory func(ctx context.Context, sel ProviderSelector, specs []mcp.ServerConfig, ...) (SessionEngineResult, error)

+ type SessionEngineResult struct

+ BuiltForMode session.PermissionMode

+ Capabilities port.ProviderCapabilities

+ Close func() error

+ Engine *agent.Engine

+ ModelID string

+ ProviderID string

+ ReasoningEffort string

+ type SessionInventoryActionReasons struct

+ CopyID CapabilityReason

+ Delete CapabilityReason

+ Fork CapabilityReason

+ Inspect CapabilityReason

+ PublicChat CapabilityReason

+ Rename CapabilityReason

+ ViewTranscript CapabilityReason

+ type SessionInventoryCapabilities struct

+ ActivityReplay bool

+ AuthoritativeTranscript bool

+ CopyID bool

+ Delete bool

+ Fork bool

+ Inspect bool

+ PublicChat bool

+ Rename bool

+ ViewTranscript bool

+ type SessionProfile string

+ const ProfileDefault

+ const ProfileNoFS

+ func ParseSessionProfile(s string) (SessionProfile, error)

+ type SessionSummary struct

+ Capabilities SessionInventoryCapabilities

+ CreatedAtUnix int64

+ Kind session.SessionKind

+ ModelID string

+ ModifiedAtUnix int64

+ Owner *session.Principal

+ ReasonCode CapabilityReason

+ Reasons SessionInventoryActionReasons

+ Relationship session.SessionRelationship

+ SessionID string

+ State string

+ Title string

+ TitleProvenance session.TitleProvenance

+ Turns int

+ Workspace string

+ type SessionTranscript struct

+ Activity ActivityReplayStatus

+ Complete bool

+ Kind session.SessionKind

+ Messages []session.Message

+ Relationship session.SessionRelationship

+ SessionID session.SessionID

+ type StorageHealth struct

+ ActiveJob string

+ LastFailure string

+ LastSweep time.Time

+ LastSweepAvailable bool

+ NextSweep time.Time

+ NextSweepAvailable bool

+ Ownerless OwnerlessCutoverInventory

+ Policy RetentionPolicy

+ type StorageMaintenanceEvent struct

+ Failure string

+ Key string

+ Kind string

+ Resumable bool

+ State StorageMaintenanceState

+ type StorageMaintenanceState string

+ const StorageMaintenanceCancelled

+ const StorageMaintenanceCompleted

+ const StorageMaintenanceFailed

+ const StorageMaintenanceProgress

+ const StorageMaintenanceStarted

+ type StorageMaintenanceStatus struct

+ ActiveJob string

+ LastFailure string

+ LastSweep time.Time

+ LastSweepAvailable bool

+ NextSweep time.Time

+ NextSweepAvailable bool

+ type UserModelEntry struct

+ Description string

+ Key string

+ type UserModelInspector interface

+ Inspect func(ctx context.Context, key string) (tool.MemoryRecord, bool, error)

+ type UserModelLister interface

+ List func(ctx context.Context) ([]UserModelEntry, error)

+ type WorkspaceAuthority uint8

+ const WorkspaceAuthorityClientSelected

+ const WorkspaceAuthorityFileless

+ const WorkspaceAuthorityServerAssigned

+ type WorkspaceFactory func(root string) tool.Workspace

+ type Worktree struct

+ Bare bool

+ Branch string

+ Head string

+ Path string

+ type WorktreeLister interface

+ List func(ctx context.Context, root string) ([]Worktree, error)

v0.0.19

Aug 27, 2026

v0.0.18

Aug 27, 2026

v0.0.17

Aug 27, 2026

v0.0.16

Aug 26, 2026

v0.0.15

Aug 3, 2026

v0.0.14

Jul 16, 2026

v0.0.13

Jun 30, 2026

v0.0.12

Jun 30, 2026

v0.0.11

Jun 25, 2026

v0.0.10

Jun 22, 2026

v0.0.9

Jun 21, 2026

v0.0.8

Jun 20, 2026

v0.0.7

Jun 19, 2026

v0.0.6

Jun 19, 2026

v0.0.5

Jun 17, 2026

v0.0.4

Jun 17, 2026

v0.0.3

Jun 16, 2026

v0.0.2

Jun 16, 2026

v0.0.1

Jun 16, 2026

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