goncho

module

Go to main page

Versions in this module

v0

v0.3.2

Jun 6, 2026

v0.3.1

Jun 1, 2026

v0.3.0

May 25, 2026

v0.2.0

May 25, 2026

v0.1.1

May 22, 2026

Changes in this version

+ const MemoryScopeGlobal

+ const MemoryScopeProfile

+ const MemoryScopeSession

+ const MemoryScopeShared

+ const MemoryScopeWorkspace

type ConcludeParams

+ ProfileID string

type ConcludeResult

+ ProfileID string

type ContextParams

+ ProfileID string

type ContextResult

+ ProfileID string

type CreateMessage

+ ProfileID string

+ type MemoryNamespace struct

+ PeerID string

+ ProfileDirectory string

+ ProfileID string

+ Scope string

+ WorkspaceID string

type Observation

+ ProfileID string

type ObservationParams

+ ProfileID string

type ObservationQuery

+ ProfileID string

type ProfileResult

+ ProfileID string

type ReviewQuery

+ RelatedID string

+ SubjectID string

type SearchParams

+ ProfileID string

type SearchResultSet

+ ProfileID string

type Service

+ func (s *Service) ApproveSkillLearningProposal(ctx context.Context, p SkillLearningProposalReviewParams) (SkillLearningProposal, error)

+ func (s *Service) GetSkillLearningProposal(ctx context.Context, proposalID string) (SkillLearningProposal, error)

+ func (s *Service) ListPendingSkillLearningProposals(ctx context.Context, q SkillLearningProposalQuery) (SkillLearningProposalList, error)

+ func (s *Service) ProfileInNamespace(ctx context.Context, ns MemoryNamespace) (ProfileResult, error)

+ func (s *Service) RejectSkillLearningProposal(ctx context.Context, p SkillLearningProposalReviewParams) (SkillLearningProposal, error)

+ func (s *Service) SetProfileInNamespace(ctx context.Context, ns MemoryNamespace, card []string) error

+ func (s *Service) SubmitSkillLearningProposal(ctx context.Context, p SkillLearningProposalCreateParams) (SkillLearningProposalRef, error)

+ type SkillLearningProposal struct

+ CreatedAt time.Time

+ CreatedBy string

+ DraftBody string

+ EvidenceJSON json.RawMessage

+ ID int64

+ ProposalID string

+ ReviewReason string

+ ReviewedAt *time.Time

+ ReviewedBy string

+ SkillName string

+ SourceTask string

+ Status SkillLearningProposalStatus

+ WorkspaceID string

+ func GetSkillLearningProposal(ctx context.Context, db *sql.DB, proposalID string) (SkillLearningProposal, error)

+ type SkillLearningProposalCreateParams struct

+ CreatedAt time.Time

+ CreatedBy string

+ DraftBody string

+ Evidence any

+ SkillName string

+ SourceTask string

+ WorkspaceID string

+ type SkillLearningProposalList struct

+ Count int

+ Items []SkillLearningProposal

+ func ListSkillLearningProposals(ctx context.Context, db *sql.DB, q SkillLearningProposalQuery) (SkillLearningProposalList, error)

+ type SkillLearningProposalQuery struct

+ Limit int

+ Status SkillLearningProposalStatus

+ WorkspaceID string

+ type SkillLearningProposalRef struct

+ ProposalID string

+ SkillName string

+ Status SkillLearningProposalStatus

+ WorkspaceID string

+ func SubmitSkillLearningProposal(ctx context.Context, db *sql.DB, p SkillLearningProposalCreateParams) (SkillLearningProposalRef, error)

+ type SkillLearningProposalReviewParams struct

+ ProposalID string

+ ReviewReason string

+ ReviewedAt time.Time

+ ReviewedBy string

+ type SkillLearningProposalStatus string

+ const SkillLearningProposalApproved

+ const SkillLearningProposalPending

+ const SkillLearningProposalRejected

v0.1.0

May 20, 2026

Changes in this version

+ const CrossChatDecisionAllowed

+ const CrossChatDecisionDegraded

+ const CrossChatDecisionDenied

+ const CrossChatFallbackSameChat

+ const DefaultDeriverWorkers

+ const DefaultDreamCooldown

+ const DefaultDreamIdleTimeout

+ const DefaultDreamMinConclusions

+ const DefaultGetContextMaxTokens

+ const DefaultMaxFileSize

+ const DefaultMaxMessageSize

+ const DefaultObserverPeerID

+ const DefaultRecentMessages

+ const DefaultRepresentationBatchMaxTokens

+ const DefaultWebhookWorkspaceLimit

+ const DefaultWorkspaceID

+ const EvidenceCanonicalUserID

+ const EvidenceCrossPeerOptIn

+ const EvidenceDefaultWorkspace

+ const EvidenceExternalPeerFallback

+ const EvidenceHardIsolation

+ const GlobalWorkspaceID

+ const GonchoAsyncClosed

+ const GonchoAsyncEnqueued

+ const GonchoAsyncFlushFailed

+ const GonchoAsyncFlushed

+ const GonchoAsyncRetry

+ const GonchoAsyncShutdown

+ const GonchoConfigBaseURLInvalid

+ const GonchoConfigLocalBaseURL

+ const GonchoMemoryV1ContractVersion

+ const GonchoMemoryV1MCPToolContract

+ const GonchoMemoryV1MarkdownFormat

+ const GonchoWriteDeferred

+ const GonchoWriteFlushFailed

+ const GonchoWriteFlushed

+ const GonchoWriteQueued

+ const LineageKindCompression

+ const LineageKindFork

+ const LineageKindPrimary

+ const LineageStatusError

+ const LineageStatusLoop

+ const LineageStatusMissing

+ const LineageStatusOK

+ const LineageStatusOrphan

+ const LocalHonchoAPIKeySentinel

+ const MaxWebhookURLLength

+ const RecallBenchmarkCorpusVersion

+ const RecallBenchmarkWarningMissingTrace

+ const RecallBenchmarkWarningNoRelevantIDs

+ const RecallRejectNotSelected

+ const RecallRejectScopeMismatch

+ const RecallRejectTokenBudget

+ const RecallReplayKindCandidate

+ const RecallReplayKindProject

+ const RecallReplayKindQuery

+ const RecallReplayKindRejected

+ const RecallReplayKindSelected

+ const RecallReplayKindWarning

+ const RecallReplayStageQuery

+ const RecallReplayStageWarn

+ const RecallStageGenerate

+ const RecallStageProject

+ const RecallStageScore

+ const RecallStageSelect

+ const RecallWarningDegraded

+ const RecallWarningError

+ const RecallWarningFTSUnavailable

+ const RecallWarningGraphDisabled

+ const RecallWarningInfo

+ const RecallWarningScopeExcludedAllCandidates

+ const RecallWarningSemanticUnavailable

+ const RecallWarningStaleEmbeddingIndex

+ const RecallWarningTokenBudgetTruncated

+ const SearchLineageStatusUnavailable

+ const WriteEvidenceCancelled

+ const WriteEvidenceComplete

+ const WriteEvidenceRelationFailed

+ const WriteEvidenceWriteFailed

+ var ErrAgentIDInvalid = errors.New("goncho: dynamic agent name does not normalize to a valid id")

+ var ErrAgentIDReserved = errors.New("goncho: dynamic agent id reserved by static config")

+ var ErrKeyAdminRequired = errors.New("goncho: scoped key creation requires admin credentials")

+ var ErrKeyAuthDisabled = errors.New("goncho: key creation is disabled when auth is off")

+ var ErrKeyExpired = errors.New("goncho: scoped key expired")

+ var ErrKeyInvalid = errors.New("goncho: invalid scoped key")

+ var ErrKeyScopeRequired = errors.New("goncho: at least one of workspace_id, peer_id, or session_id is required")

+ var ErrKeySecretMissing = errors.New("goncho: jwt secret is required")

+ var ErrObservationConflict = errors.New("goncho: observation conflict")

+ var ErrObservationInvalid = errors.New("goncho: invalid observation")

+ var ErrObservationNotFound = errors.New("goncho: observation not found")

+ var ErrObservationSchemaMissing = errors.New("goncho: observation schema missing")

+ var ErrPeerIdentityRequired = errors.New("goncho: peer identity requires user_id or source/chat_id")

+ var ErrSessionBoundaryRequired = errors.New("goncho: session boundary is required")

+ var ErrUserScopeDenied = errors.New("memory: user scope denied")

+ var ErrWebhookInvalidURL = errors.New("goncho: invalid webhook url")

+ var ErrWebhookLimitReached = errors.New("goncho: maximum webhook endpoints reached for workspace")

+ var ErrWebhookNotFound = errors.New("goncho: webhook endpoint not found")

+ var ErrWebhookSecretMissing = errors.New("goncho: webhook secret is required")

+ var ErrWebhookWorkspaceRequired = errors.New("goncho: workspace_id is required")

+ var ErrWorkspacePerUser = errors.New("goncho: workspace-per-user topology is not allowed")

+ var ErrWorkspaceRequired = errors.New("goncho: hard-isolation workspace is required")

+ var ErrWorkspaceRequiresHardIsolation = errors.New("goncho: explicit workspace requires hard isolation")

+ var QueueTaskTypes = []string

+ var ValidMemoryTiers = []MemoryTier

+ func AcceptProposal(ctx context.Context, db *sql.DB, proposalID, reviewedBy string, ...) error

+ func AgentCanAccessMemory(ctx context.Context, db *sql.DB, memoryID, agentID, workspaceID string, ...) (bool, error)

+ func CanRecallGonchoMemoryV1(ctx context.Context, db *sql.DB) (bool, error)

+ func DefaultDecayCurve(createdAt time.Time, now time.Time) float64

+ func DetectWorkspaceFromPath(start string) (workspaceRoot, marker string)

+ func FormatRecallDiagnosticsReport(report RecallDiagnosticsReport) string

+ func FormatRecallReplay(replay RecallReplay) string

+ func GonchoMemoryV1Checksum(content string) string

+ func GonchoMemoryV1ContractInfo() map[string]any

+ func GrantReadACL(ctx context.Context, db *sql.DB, memoryID, agentID, grantedBy string) error

+ func MemoryEntryRelevance(entry MemoryToolEntry, query string) float64

+ func RejectProposal(ctx context.Context, db *sql.DB, proposalID, reviewedBy string) error

+ func ResolvePluginSessionName(cfg PluginConfig, input SessionNameInput) string

+ func RevokeACL(ctx context.Context, db *sql.DB, memoryID, agentID, permission string) error

+ func RunMigrations(db *sql.DB) error

+ func SanitizePayloadSummary(summary map[string]string) map[string]string

+ func SignWebhookPayload(payload, secret string) (string, error)

+ func ValidDialecticLevel(level string) bool

+ func ValidProposalKind(k string) bool

+ func ValidTier(t string) bool

+ func ValidateGonchoMemoryV1Item(item GonchoMemoryV1Item) error

+ func ValidateTierOrErr(raw string) error

+ func WorkspaceIDForPath(path string) string

+ type ACLQuery struct

+ AgentID string

+ IsParent bool

+ ReadTiers []MemoryTier

+ WorkspaceID string

+ WriteTier MemoryTier

+ func (q ACLQuery) CanRead(tier MemoryTier) bool

+ func (q ACLQuery) CanWrite(tier MemoryTier) bool

+ func (q ACLQuery) ReadScopeSQL() (string, []any)

+ type AgentRecord struct

+ CreatedAt time.Time

+ ID string

+ Name string

+ Persona string

+ type AuditAction string

+ const AuditActionObserve

+ type AuditEvent struct

+ Action AuditAction

+ CreatedAt time.Time

+ ID string

+ Metadata map[string]string

+ PeerID string

+ Reason string

+ SessionKey string

+ TargetID string

+ TargetType AuditTargetType

+ WorkspaceID string

+ type AuditQuery struct

+ Action AuditAction

+ Limit int

+ PeerID string

+ SessionKey string

+ Since time.Time

+ TargetID string

+ TargetType AuditTargetType

+ Until time.Time

+ WorkspaceID string

+ type AuditResult struct

+ Count int

+ Events []AuditEvent

+ func AuditTrail(ctx context.Context, db *sql.DB, q AuditQuery) (AuditResult, error)

+ type AuditTargetType string

+ const AuditTargetObservation

+ type BindingMatch struct

+ Channel string

+ PeerID string

+ PeerKind string

+ ThreadID string

+ type CandidateDetector interface

+ Detect func(ctx context.Context, w MemoryWrite, prior []MemoryWrite) ([]RelationCandidate, error)

+ type ChatCompletionMetadata struct

+ TokensIn int

+ TokensOut int

+ type ChatParams struct

+ Query string

+ ReasoningLevel string

+ SessionID string

+ Stream bool

+ Target string

+ type ChatResult struct

+ Content string

+ type ConcludeParams struct

+ Conclusion string

+ DeleteID int64

+ Peer string

+ Scope string

+ SessionKey string

+ type ConcludeResult struct

+ Deleted bool

+ ID int64

+ Peer string

+ Status string

+ WorkspaceID string

+ type Config struct

+ DeriverWorkers int

+ DialecticDefaultLevel DialecticLevel

+ DreamEnabled bool

+ DreamIdleTimeout time.Duration

+ Enabled bool

+ GetContextMaxTokens int

+ MaxFileSize int

+ MaxMessageSize int

+ ObserverPeerID string

+ PeerCardEnabled bool

+ ReasoningEnabled bool

+ RecentMessages int

+ RepresentationBatchMaxTokens int

+ SessionDirectory SessionDirectory

+ SummaryEnabled bool

+ WorkspaceID string

+ func (c Config) Effective() Config

+ type ConfigEvidence struct

+ Code string

+ Message string

+ Source string

+ type ConflictResolution struct

+ Loser *MemoryEntry

+ Reason string

+ Resolved bool

+ Winner *MemoryEntry

+ func ResolveConflict(existing, incoming *MemoryEntry) ConflictResolution

+ type ContextParams struct

+ IncludeDreamStatus *bool

+ IncludeMostFrequent *bool

+ LimitToSession *bool

+ MaxConclusions *int

+ MaxTokens int

+ Peer string

+ PeerPerspective string

+ PeerTarget string

+ Query string

+ Scope string

+ SearchMaxDistance *float64

+ SearchQuery string

+ SearchTopK *int

+ SessionKey string

+ Sources []string

+ Summary *bool

+ Tokens int

+ type ContextResult struct

+ Conclusions []string

+ ObservedPeerID string

+ ObserverPeerID string

+ Peer string

+ PeerCard []string

+ RecentMessages []MessageSlice

+ Representation string

+ ScopeEvidence *CrossChatRecallEvidence

+ SearchResults []SearchHit

+ SessionKey string

+ StructuredSummary *StructuredSummary

+ Summary *SessionSummary

+ Unavailable []ContextUnavailableEvidence

+ WorkspaceID string

+ type ContextUnavailableEvidence struct

+ Capability string

+ Field string

+ Reason string

+ type CreateAgentOptions struct

+ Name string

+ Persona string

+ ReservedIDs map[string]struct{}

+ type CreateMessage struct

+ Content string

+ CreatedAt time.Time

+ Metadata map[string]any

+ Peer string

+ Role string

+ type CreateMessagesParams struct

+ Messages []CreateMessage

+ SessionKey string

+ type CreateMessagesResult struct

+ Messages []MessageRecord

+ SessionKey string

+ WorkspaceID string

+ type CrossChatRecallEvidence struct

+ CurrentBinding *CrossChatSessionEvidence

+ CurrentChatKey string

+ CurrentSessionID string

+ Decision string

+ FallbackScope string

+ Reason string

+ Scope string

+ Sessions []CrossChatSessionEvidence

+ SessionsConsidered int

+ SourceAllowlist []string

+ UserID string

+ WidenedSessionsConsidered int

+ func DegradedCrossChatRecallEvidence(filter SearchFilter, reason string) CrossChatRecallEvidence

+ func ExplainCrossChatRecall(metas []SessionMetadata, filter SearchFilter) CrossChatRecallEvidence

+ type CrossChatSessionEvidence struct

+ ChatID string

+ ChatKey string

+ Current bool

+ SessionID string

+ Source string

+ type CrossSessionKnowledge struct

+ Memories []MemoryToolEntry

+ Query string

+ Sessions map[string]int

+ Summary string

+ type CrossSessionMemory struct

+ func NewCrossSessionMemory(store MemoryToolStore) *CrossSessionMemory

+ func (csm *CrossSessionMemory) DetectContradictions(ctx context.Context, newEntry MemoryToolEntry) ([]MemoryToolEntry, error)

+ func (csm *CrossSessionMemory) LoadRelevant(ctx context.Context, query string, limit int) ([]MemoryToolEntry, error)

+ func (csm *CrossSessionMemory) QueryKnowledge(ctx context.Context, query string, limit int) (CrossSessionKnowledge, error)

+ type DialecticCaller interface

+ Chat func(ctx context.Context, peer string, systemPrompt string, query string) (string, error)

+ type DialecticLevel string

+ const DialecticLevelHigh

+ const DialecticLevelLow

+ const DialecticLevelMax

+ const DialecticLevelMedium

+ const DialecticLevelMinimal

+ type DivergenceClassification string

+ const DivergenceLocal

+ const DivergenceOwnedExcluded

+ type DivergenceEvidence struct

+ Classification DivergenceClassification

+ Rationale string

+ Replacement string

+ type DreamQueueStatus struct

+ Enabled bool

+ Evidence []DreamStatusEvidence

+ Status string

+ TablePresent bool

+ type DreamScheduleParams struct

+ Manual bool

+ Now time.Time

+ Peer string

+ Reason string

+ type DreamScheduleResult struct

+ Action string

+ Evidence DreamStatusEvidence

+ ID int64

+ LastConclusionID int64

+ MinConclusions int

+ NewConclusions int

+ ObservedPeerID string

+ ObserverPeerID string

+ Status string

+ WorkUnitKey string

+ WorkspaceID string

+ type DreamStatusEvidence struct

+ Code string

+ CooldownUntil int64

+ DreamID int64

+ IdleUntil int64

+ LastActivityAt int64

+ LastConclusionID int64

+ MinConclusions int

+ NewConclusions int

+ ObservedPeerID string

+ ObserverPeerID string

+ Reason string

+ Status string

+ WorkUnitKey string

+ WorkspaceID string

+ type DriftAnchorCheckParams struct

+ Limit int

+ Prompt string

+ type DriftAnchorDetector struct

+ func NewDriftAnchorDetector(store MemoryToolStore) *DriftAnchorDetector

+ func (d *DriftAnchorDetector) Check(ctx context.Context, params DriftAnchorCheckParams) (DriftAnchorWarning, error)

+ type DriftAnchorWarning struct

+ Code string

+ MatchedContent string

+ MatchedMemoryID string

+ Recommendation string

+ SimilarityScore float64

+ Warn bool

+ type DynamicAgentRegistry struct

+ func NewDynamicAgentRegistry(db *sql.DB) (*DynamicAgentRegistry, error)

+ func (r *DynamicAgentRegistry) Bind(ctx context.Context, agentID string, match BindingMatch) error

+ func (r *DynamicAgentRegistry) Create(ctx context.Context, opts CreateAgentOptions) (AgentRecord, error)

+ func (r *DynamicAgentRegistry) Get(ctx context.Context, id string) (AgentRecord, bool, error)

+ func (r *DynamicAgentRegistry) List(ctx context.Context) ([]AgentRecord, error)

+ func (r *DynamicAgentRegistry) Resolve(ctx context.Context, match BindingMatch) (string, bool, error)

+ func (r *DynamicAgentRegistry) Unbind(ctx context.Context, match BindingMatch) error

+ type Event struct

+ AgentID string

+ CacheReadTokens int

+ CacheWriteTokens int

+ Category string

+ Divergence *DivergenceEvidence

+ DurationMs int64

+ EventType string

+ Level int

+ Model string

+ Name string

+ ParentID string

+ PayloadSummary map[string]string

+ PeerID string

+ Provider string

+ QueueItems int

+ ReasoningEffort string

+ ReasoningTokens int

+ RequestCount int

+ RunID string

+ SessionID string

+ Source string

+ TaskType string

+ Timestamp time.Time

+ TokensIn int

+ TokensOut int

+ ToolCalls int

+ ToolErrors int

+ TraceID string

+ TreeNodeID string

+ UpstreamEvent string

+ WorkspaceID string

+ func NewTelemetryEvent(input TelemetryEventInput) Event

+ func NormalizeEvent(event Event, now time.Time) Event

+ type EventMatrixEntry struct

+ Category string

+ Divergence DivergenceEvidence

+ HostedExporterOnly bool

+ LocalEvent string

+ Source string

+ UpstreamEvent string

+ func LookupTelemetryEvent(upstream string) (EventMatrixEntry, bool)

+ type EvidenceItem struct

+ ID string

+ Kind string

+ Metadata map[string]string

+ Note string

+ Score float64

+ Source string

+ type ExternalCompatibility struct

+ ExternalToolNames []string

+ InternalService string

+ func HonchoExternalCompatibility() ExternalCompatibility

+ type FileImportMetadata struct

+ ChunkCharacterRange [2]int

+ ChunkIndex int

+ ContentType string

+ FileID string

+ Filename string

+ OriginalFileSize int64

+ TotalChunks int

+ type FileImportResult struct

+ FileID string

+ Messages []ImportedFileMessage

+ PeerID string

+ SessionKey string

+ Unavailable []ContextUnavailableEvidence

+ WorkspaceID string

+ type ForgetMemoryTool struct

+ func NewForgetMemoryTool(store MemoryToolStore) *ForgetMemoryTool

+ func (t *ForgetMemoryTool) Description() string

+ func (t *ForgetMemoryTool) Execute(ctx context.Context, args json.RawMessage) (json.RawMessage, error)

+ func (t *ForgetMemoryTool) Name() string

+ func (t *ForgetMemoryTool) Schema() json.RawMessage

+ func (t *ForgetMemoryTool) Timeout() time.Duration

+ func (t ForgetMemoryTool) Spec() toolmeta.OperationSpec

+ type GonchoContextTool struct

+ func NewGonchoContextTool(svc *Service) *GonchoContextTool

+ func (t *GonchoContextTool) Description() string

+ func (t *GonchoContextTool) Execute(ctx context.Context, args json.RawMessage) (json.RawMessage, error)

+ func (t *GonchoContextTool) Name() string

+ func (t *GonchoContextTool) Schema() json.RawMessage

+ func (t *GonchoContextTool) Spec() toolmeta.OperationSpec

+ func (t *GonchoContextTool) Timeout() time.Duration

+ type GonchoHandoffTool struct

+ func NewGonchoHandoffTool(store MemoryToolStore) *GonchoHandoffTool

+ func (t *GonchoHandoffTool) Description() string

+ func (t *GonchoHandoffTool) Execute(ctx context.Context, args json.RawMessage) (json.RawMessage, error)

+ func (t *GonchoHandoffTool) Name() string

+ func (t *GonchoHandoffTool) Schema() json.RawMessage

+ func (t *GonchoHandoffTool) Spec() toolmeta.OperationSpec

+ func (t *GonchoHandoffTool) Timeout() time.Duration

+ type GonchoMarkdownStore struct

+ func NewGonchoMarkdownStore(db *sql.DB, cfg GonchoMarkdownStoreConfig) (*GonchoMarkdownStore, error)

+ type GonchoMarkdownStoreConfig struct

+ FilePath string

+ ObserverID string

+ WorkspaceID string

+ type GonchoMemoryV1Document struct

+ ContractVersion string

+ FormatVersion string

+ Items []GonchoMemoryV1Item

+ func ParseGonchoMemoryV1Markdown(raw string) (GonchoMemoryV1Document, error)

+ type GonchoMemoryV1Item struct

+ AgentID string

+ Checksum string

+ Content string

+ CreatedAt string

+ Importance float64

+ MemoryID string

+ PeerID string

+ ProvenanceJSON string

+ Revision int

+ Scope string

+ SessionID string

+ SourceKind string

+ SourceTurnID string

+ State string

+ Tags []string

+ TombstoneReason string

+ TombstonedAt string

+ UpdatedAt string

+ WorkspaceID string

+ type GonchoMemoryV1RecallRequest struct

+ Limit int

+ PeerID string

+ Query string

+ Scope string

+ SessionID string

+ Sources []string

+ WorkspaceID string

+ type GonchoMetaanalysisCoverageInput struct

+ DocsArchitectureKeywords []string

+ LocalOnlyEvaluator string

+ MemoryToolLoopVerified bool

+ ProofMatrix gonchoProofMatrixReport

+ ReviewLoopVerified bool

+ SourceDocumentPath string

+ SourceDocumentSHA256 string

+ type GonchoMetaanalysisCoverageReport struct

+ AllLocalEvaluatorChecksPassed bool

+ CompletionCondition string

+ ContextLayersCovered []string

+ CoreEvaluationsCovered []string

+ CoverageVersion string

+ DeferredFeatures []string

+ DocsArchitectureKeywords []string

+ LifecycleStatesCovered []string

+ LocalFeaturesVerified []string

+ PrinciplesCovered []string

+ PublicToolsVerified []string

+ Service string

+ SourceDocumentPath string

+ SourceDocumentSHA256 string

+ func BuildGonchoMetaanalysisCoverageReport(input GonchoMetaanalysisCoverageInput) GonchoMetaanalysisCoverageReport

+ type GonchoPublicToolsRestartE2EConfig struct

+ DBPath string

+ MarkdownPath string

+ ObserverID string

+ PeerID string

+ SessionKey string

+ WorkspaceID string

+ type GonchoPublicToolsRestartE2EReport struct

+ CompletionCondition string

+ ContextRepresentationAfterRestart string

+ HandoffCountAfterRestart int

+ NetworkRequired bool

+ OllamaRequired bool

+ ReviewWarningAfterResolve bool

+ ReviewWarningBeforeResolve bool

+ SQLiteRestartVerified bool

+ SearchCountAfterRestart int

+ SearchCountBeforeRestart int

+ ToolNames []string

+ func RunGonchoPublicToolsRestartE2E(ctx context.Context, cfg GonchoPublicToolsRestartE2EConfig) (GonchoPublicToolsRestartE2EReport, error)

+ type GonchoRememberTool struct

+ func NewGonchoRememberTool(svc *Service) *GonchoRememberTool

+ func (t *GonchoRememberTool) Description() string

+ func (t *GonchoRememberTool) Execute(ctx context.Context, args json.RawMessage) (json.RawMessage, error)

+ func (t *GonchoRememberTool) Name() string

+ func (t *GonchoRememberTool) Schema() json.RawMessage

+ func (t *GonchoRememberTool) Spec() toolmeta.OperationSpec

+ func (t *GonchoRememberTool) Timeout() time.Duration

+ type GonchoSearchTool struct

+ func NewGonchoSearchTool(svc *Service) *GonchoSearchTool

+ func (t *GonchoSearchTool) Description() string

+ func (t *GonchoSearchTool) Execute(ctx context.Context, args json.RawMessage) (json.RawMessage, error)

+ func (t *GonchoSearchTool) Name() string

+ func (t *GonchoSearchTool) Schema() json.RawMessage

+ func (t *GonchoSearchTool) Spec() toolmeta.OperationSpec

+ func (t *GonchoSearchTool) Timeout() time.Duration

+ type HonchoSDKCompatibilityHarness struct

+ func NewHonchoSDKCompatibilityHarness(service *Service) *HonchoSDKCompatibilityHarness

+ func (h *HonchoSDKCompatibilityHarness) ContextPreview(ctx context.Context, req HonchoSDKContextPreviewRequest) (HonchoSDKContextPreview, error)

+ func (h *HonchoSDKCompatibilityHarness) Search(ctx context.Context, req HonchoSDKSearchRequest) (HonchoSDKSearchResponse, error)

+ func (h *HonchoSDKCompatibilityHarness) SeedSession(ctx context.Context, seed HonchoSDKSessionSeed) (HonchoSDKSeedResult, error)

+ type HonchoSDKConclusion struct

+ ID int64

+ Status string

+ type HonchoSDKContextPreview struct

+ PeerCard []string

+ PeerID string

+ RecentMessages []MessageSlice

+ Representation string

+ SearchResults []HonchoSDKSearchHit

+ SessionID string

+ Summary *HonchoSDKContextSummary

+ Unsupported []HonchoSDKUnsupportedFlow

+ WorkspaceID string

+ type HonchoSDKContextPreviewRequest struct

+ PeerID string

+ Query string

+ SessionID string

+ Tokens int

+ type HonchoSDKContextSummary struct

+ Content string

+ CreatedAt int64

+ MessageID int64

+ TokenCount int

+ Type string

+ type HonchoSDKMessage struct

+ Content string

+ CreatedAt int64

+ ID int64

+ Metadata map[string]any

+ PeerID string

+ Role string

+ Sequence int

+ SessionID string

+ WorkspaceID string

+ type HonchoSDKMessageInput struct

+ Content string

+ CreatedAt time.Time

+ Metadata map[string]any

+ PeerID string

+ Role string

+ type HonchoSDKPeer struct

+ ID string

+ type HonchoSDKSearchHit struct

+ Content string

+ ID int64

+ Lineage *SearchLineage

+ OriginSource string

+ SessionID string

+ Source string

+ type HonchoSDKSearchRequest struct

+ Limit int

+ PeerID string

+ Query string

+ SessionID string

+ type HonchoSDKSearchResponse struct

+ PeerID string

+ Query string

+ Results []HonchoSDKSearchHit

+ WorkspaceID string

+ type HonchoSDKSeedResult struct

+ Conclusions []HonchoSDKConclusion

+ Messages []HonchoSDKMessage

+ Peer HonchoSDKPeer

+ Session HonchoSDKSession

+ Workspace HonchoSDKWorkspace

+ type HonchoSDKSession struct

+ ID string

+ type HonchoSDKSessionSeed struct

+ Conclusions []string

+ Messages []HonchoSDKMessageInput

+ PeerCard []string

+ PeerID string

+ SessionID string

+ type HonchoSDKUnsupportedFlow struct

+ Code string

+ Endpoint string

+ Fields []string

+ Method string

+ func UnsupportedHonchoSDKFlow(method, endpoint string, fields ...string) HonchoSDKUnsupportedFlow

+ type HonchoSDKWorkspace struct

+ ID string

+ type HostConfigDocument struct

+ APIKey string

+ BaseURL string

+ Hosts map[string]HostRuntimeConfig

+ PeerName string

+ Workspace string

+ func ApplyHostConfigPatch(doc HostConfigDocument, host string, patch HostConfigPatch) (HostConfigDocument, error)

+ type HostConfigPatch struct

+ AIPeer *string

+ ObservationMode *string

+ PeerName *string

+ RecallMode *string

+ SessionStrategy *string

+ Workspace *string

+ type HostIntegrationInput struct

+ AIPeer string

+ Branch string

+ CharacterName string

+ ChatInstanceID string

+ Host string

+ HostSessionID string

+ PeerName string

+ RecallMode string

+ Repository string

+ SessionStrategy string

+ WorkingDirectory string

+ Workspace string

+ type HostIntegrationMapping struct

+ AIPeerID string

+ ExposeTools bool

+ ExternalToolNames []string

+ Host string

+ InjectContext bool

+ InternalService string

+ RecallMode string

+ SessionKey string

+ SessionStrategy string

+ Unsupported []UnsupportedHostMapping

+ UserPeerID string

+ WorkspaceID string

+ func MapHostIntegration(input HostIntegrationInput) HostIntegrationMapping

+ type HostRuntimeConfig struct

+ AIPeer string

+ ObservationMode string

+ PeerName string

+ RecallMode string

+ SessionStrategy string

+ Workspace string

+ type ImportFileParams struct

+ Configuration map[string]any

+ Content []byte

+ ContentType string

+ CreatedAt *time.Time

+ Filename string

+ Metadata map[string]any

+ PeerID string

+ SessionKey string

+ type ImportanceScorer struct

+ func NewImportanceScorer() *ImportanceScorer

+ func (s *ImportanceScorer) EffectiveImportance(entry MemoryToolEntry, now time.Time) float64

+ func (s *ImportanceScorer) Rank(entries []MemoryToolEntry, relevanceByID map[string]float64, now time.Time) []ScoredMemory

+ func (s *ImportanceScorer) RankByQuery(entries []MemoryToolEntry, query string, now time.Time) []ScoredMemory

+ func (s *ImportanceScorer) ReviewRetentionCandidates(entries []MemoryToolEntry, policy RetentionPolicy) []RetentionCandidate

+ func (s *ImportanceScorer) Score(entry MemoryToolEntry, relevanceScore float64, now time.Time) float64

+ type ImportedFileMessage struct

+ Configuration map[string]any

+ Content string

+ CreatedAt time.Time

+ File FileImportMetadata

+ ID int64

+ MemorySyncReason string

+ MemorySyncStatus string

+ Metadata map[string]any

+ PeerID string

+ Role string

+ SessionKey string

+ type LocalMarkdownMemoryConfig struct

+ AgentID string

+ ObserverPeerID string

+ Path string

+ PeerID string

+ SessionID string

+ WorkspaceID string

+ type LocalMarkdownMemoryStatus struct

+ Enabled bool

+ Evidence []string

+ LocalFirst bool

+ MCPTools []string

+ MarkdownBacked bool

+ NetworkRequired bool

+ OllamaRequired bool

+ Path string

+ SQLiteBacked bool

+ type LocalMarkdownMemoryStore struct

+ func NewLocalMarkdownMemoryStore(db *sql.DB, cfg LocalMarkdownMemoryConfig) *LocalMarkdownMemoryStore

+ func (s *LocalMarkdownMemoryStore) Forget(ctx context.Context, id string) error

+ func (s *LocalMarkdownMemoryStore) Retrieve(ctx context.Context, query string, limit int) ([]MemoryToolEntry, error)

+ func (s *LocalMarkdownMemoryStore) Status(ctx context.Context) (LocalMarkdownMemoryStatus, error)

+ func (s *LocalMarkdownMemoryStore) Store(ctx context.Context, entry MemoryToolEntry) error

+ func (s *LocalMarkdownMemoryStore) Update(ctx context.Context, id string, content string) error

+ func (s *LocalMarkdownMemoryStore) UpdateImportance(ctx context.Context, id string, importance float64) error

+ type MemoryContradiction struct

+ Existing MemoryToolEntry

+ Incoming MemoryToolEntry

+ Reason string

+ Relation string

+ Subject string

+ func DetectMemoryContradiction(existing, incoming MemoryToolEntry) (MemoryContradiction, bool)

+ type MemoryEntry struct

+ Confidence float64

+ Content string

+ CreatedAt time.Time

+ Durability float64

+ ID string

+ LastUsedAt time.Time

+ Type MemoryType

+ UpdatedAt time.Time

+ type MemoryImportanceUpdater interface

+ UpdateImportance func(ctx context.Context, id string, importance float64) error

+ type MemoryProposal struct

+ ChildAgentID string

+ CommittedMemoryID *string

+ Content string

+ CreatedAt int64

+ EvidenceJSON json.RawMessage

+ ID int64

+ Kind ProposalKind

+ ParentAgentID string

+ ProposalID string

+ ProposedTier MemoryTier

+ ReviewedAt *int64

+ ReviewedBy *string

+ Status ProposalStatus

+ SubtaskID string

+ func GetProposal(ctx context.Context, db *sql.DB, proposalID string) (*MemoryProposal, error)

+ func ListPendingProposals(ctx context.Context, db *sql.DB, parentAgentID string) ([]MemoryProposal, error)

+ type MemoryStore interface

+ Apply func(ctx context.Context, w MemoryWrite) error

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

+ type MemoryTier string

+ const TierDecision

+ const TierGlobal

+ const TierProject

+ const TierTask

+ const TierWorkspace

+ func DefaultTierForSource(sourceKind string) MemoryTier

+ func NormalizeTier(raw string) MemoryTier

+ func TierHierarchy() []MemoryTier

+ func TiersReadableBy(agentTier MemoryTier) []MemoryTier

+ func TiersWritableBy(isParent bool) []MemoryTier

+ type MemoryToolEntry struct

+ Content string

+ CreatedAt time.Time

+ ID string

+ Importance float64

+ Metadata map[string]string

+ SessionID string

+ Tags []string

+ UpdatedAt time.Time

+ func RecentEntries(entries []MemoryToolEntry, now time.Time, maxAge time.Duration) []MemoryToolEntry

+ type MemoryToolStore interface

+ Forget func(ctx context.Context, id string) error

+ Retrieve func(ctx context.Context, query string, limit int) ([]MemoryToolEntry, error)

+ Store func(ctx context.Context, entry MemoryToolEntry) error

+ Update func(ctx context.Context, id string, content string) error

+ type MemoryType string

+ const MemoryTypeEpisode

+ const MemoryTypeGoal

+ const MemoryTypeHabit

+ const MemoryTypeIdentity

+ const MemoryTypePreference

+ const MemoryTypeReflection

+ type MemoryV1ToolContractInfo struct

+ ContractVersion string

+ PrivateAgentMemoryDefault bool

+ PurgePolicy string

+ SelfImprovementPerAgentDefault bool

+ Tools map[string]MemoryV1ToolSpec

+ func MemoryV1ToolContract() MemoryV1ToolContractInfo

+ type MemoryV1ToolSpec struct

+ CreatesRevision bool

+ DeleteSemantics string

+ Idempotent bool

+ Mutating bool

+ Name string

+ RequiresProvenance bool

+ RequiresStableID bool

+ ResultContractVersion string

+ type MemoryV1ToolTranscriptEntry struct

+ Arguments map[string]any

+ Result map[string]any

+ Tool string

+ func DecodeMemoryV1ToolTranscript(body []byte) ([]MemoryV1ToolTranscriptEntry, error)

+ type MemoryWrite struct

+ Content string

+ ID string

+ Tags []string

+ type Message struct

+ Content string

+ Role string

+ type MessageRecord struct

+ Content string

+ CreatedAt int64

+ ID int64

+ Metadata map[string]any

+ Peer string

+ Role string

+ Sequence int

+ SessionKey string

+ WorkspaceID string

+ type MessageSearchHit struct

+ ChatID string

+ Content string

+ Lineage SearchLineage

+ Role string

+ SessionID string

+ Source string

+ TSUnix int64

+ func SearchMessages(ctx context.Context, db *sql.DB, metas []SessionMetadata, filter SearchFilter, ...) ([]MessageSearchHit, error)

+ type MessageSlice struct

+ Content string

+ Role string

+ type Observation struct

+ Checksum string

+ ContextID string

+ ID string

+ Input string

+ InputOriginalBytes int

+ InputTruncated bool

+ Kind ObservationKind

+ Metadata map[string]string

+ ObservedAt time.Time

+ Output string

+ OutputOriginalBytes int

+ OutputTruncated bool

+ PeerID string

+ Redacted bool

+ RedactionCount int

+ SessionKey string

+ Success *bool

+ WorkspaceID string

+ type ObservationDecision struct

+ Evidence []string

+ ObserveMe bool

+ ObserveOthers bool

+ func DefaultObservation(req ObservationRequest) ObservationDecision

+ type ObservationKind string

+ const ObservationKindAssistantResponse

+ const ObservationKindCompact

+ const ObservationKindCustom

+ const ObservationKindSessionEnd

+ const ObservationKindSessionStart

+ const ObservationKindToolCall

+ const ObservationKindToolError

+ const ObservationKindToolResult

+ const ObservationKindUserPrompt

+ type ObservationList struct

+ Count int

+ Observations []Observation

+ func ListObservations(ctx context.Context, db *sql.DB, q ObservationQuery) (ObservationList, error)

+ type ObservationParams struct

+ ContextID string

+ ID string

+ Input string

+ Kind ObservationKind

+ Metadata map[string]string

+ ObservedAt time.Time

+ Output string

+ PeerID string

+ Reason string

+ SessionKey string

+ Success *bool

+ WorkspaceID string

+ type ObservationQuery struct

+ ContextID string

+ Kinds []ObservationKind

+ Limit int

+ PeerID string

+ SessionKey string

+ Since time.Time

+ Success *bool

+ Until time.Time

+ WorkspaceID string

+ type ObservationRequest struct

+ CrossPeerObservation bool

+ Role PeerRole

+ type ObservationResult struct

+ AuditID string

+ Observation Observation

+ Replayed bool

+ func Observe(ctx context.Context, db *sql.DB, p ObservationParams) (ObservationResult, error)

+ type PeerIdentityDecision struct

+ Degraded bool

+ Evidence []string

+ PeerID string

+ func ResolvePeerID(meta SessionMetadata) (PeerIdentityDecision, error)

+ type PeerRole string

+ const PeerRoleDeterministicAssistant

+ const PeerRoleGormesAssistant

+ const PeerRoleHuman

+ const PeerRoleImportHelper

+ const PeerRoleParentAgent

+ const PeerRoleTransportBot

+ type PluginAsyncResult struct

+ Code string

+ Evidence []string

+ Flushed int

+ Pending int

+ func (r PluginAsyncResult) HasEvidence(code string) bool

+ type PluginAsyncWriter struct

+ func NewPluginAsyncWriter(flusher PluginSessionFlusher) *PluginAsyncWriter

+ func (w *PluginAsyncWriter) Cache(session PluginMemorySession)

+ func (w *PluginAsyncWriter) Enqueue(session PluginMemorySession) PluginAsyncResult

+ func (w *PluginAsyncWriter) FlushAll() PluginAsyncResult

+ func (w *PluginAsyncWriter) Shutdown() PluginAsyncResult

+ type PluginConfig struct

+ AIPeer string

+ APIKey string

+ APIKeySource string

+ BaseURL string

+ Enabled bool

+ Environment string

+ Evidence []ConfigEvidence

+ Host string

+ PeerName string

+ PinPeerName bool

+ Raw map[string]any

+ SaveMessages bool

+ SessionPeerPrefix bool

+ SessionStrategy string

+ Sessions map[string]string

+ WorkspaceID string

+ WriteFrequency PluginWriteFrequency

+ func ResolvePluginConfig(input PluginConfigInput) PluginConfig

+ func (c PluginConfig) HasEvidence(code string) bool

+ type PluginConfigInput struct

+ Env map[string]string

+ Host string

+ Raw map[string]any

+ type PluginMemoryMessage struct

+ Content string

+ Role string

+ Synced bool

+ type PluginMemorySession struct

+ AssistantPeerID string

+ HonchoSessionID string

+ Key string

+ Messages []PluginMemoryMessage

+ UserPeerID string

+ type PluginPeerInput struct

+ Config PluginConfig

+ RuntimeUserPeerName string

+ SessionKey string

+ type PluginPeerResolution struct

+ AssistantPeerID string

+ UserPeerID string

+ func ResolvePluginPeerNames(input PluginPeerInput) PluginPeerResolution

+ type PluginSessionFlusher interface

+ FlushPluginSession func(PluginMemorySession) error

+ type PluginSessionFlusherFunc func(PluginMemorySession) error

+ func (f PluginSessionFlusherFunc) FlushPluginSession(session PluginMemorySession) error

+ type PluginWriteFrequency struct

+ Every int

+ Mode WriteFrequencyMode

+ Raw string

+ func ParsePluginWriteFrequency(raw any) PluginWriteFrequency

+ type PluginWriteResult struct

+ Code string

+ Evidence []string

+ type PluginWriteRouter struct

+ func NewPluginWriteRouter(cfg PluginWriteRouterConfig) *PluginWriteRouter

+ func (r *PluginWriteRouter) Save(session PluginMemorySession) PluginWriteResult

+ type PluginWriteRouterConfig struct

+ AsyncWriter *PluginAsyncWriter

+ Flusher PluginSessionFlusher

+ Frequency PluginWriteFrequency

+ type ProfileHint struct

+ Alternatives []string

+ Code string

+ Message string

+ type ProfileResult struct

+ Card []string

+ Hint *ProfileHint

+ ObservedPeerID string

+ ObserverPeerID string

+ Peer string

+ Result string

+ Target string

+ WorkspaceID string

+ type ProposalKind string

+ const KindArtifact

+ const KindDecision

+ const KindFact

+ const KindObservation

+ const KindPreference

+ const KindReport

+ type ProposalRef struct

+ ChildAgentID string

+ ParentAgentID string

+ ProposalID string

+ Status ProposalStatus

+ func SubmitProposal(ctx context.Context, db *sql.DB, ...) (*ProposalRef, error)

+ type ProposalStatus string

+ const StatusAccepted

+ const StatusPending

+ const StatusRejected

+ type QueueEmptyWebhookEventParams struct

+ Observed string

+ Observer string

+ QueueType string

+ SessionID string

+ WorkspaceID string

+ type QueueStatus struct

+ Degraded bool

+ Dream DreamQueueStatus

+ Message string

+ ObservabilityOnly bool

+ Status string

+ WorkUnits map[string]QueueWorkUnitStatus

+ func ReadQueueStatus(ctx context.Context, db *sql.DB, cfgs ...QueueStatusConfig) (QueueStatus, error)

+ func ZeroQueueStatus() QueueStatus

+ type QueueStatusConfig struct

+ DreamEnabled bool

+ DreamIdleTimeout time.Duration

+ Now time.Time

+ ObserverPeerID string

+ WorkspaceID string

+ type QueueWorkUnitStatus struct

+ CompletedWorkUnits int

+ InProgressWorkUnits int

+ PendingWorkUnits int

+ Sessions map[string]QueueWorkUnitStatus

+ TotalWorkUnits int

+ type ReasoningTraceInput struct

+ EventType string

+ FinishedAt time.Time

+ InputTokens int

+ Level int

+ Model string

+ OutputTokens int

+ ParentID string

+ Payload map[string]any

+ Provider string

+ ReasoningEffort string

+ StartedAt time.Time

+ TaskType string

+ ToolCalls []string

+ TraceID string

+ TreeNodeID string

+ type ReasoningTraceRecord struct

+ DurationMs int64

+ EventType string

+ InputTokens int

+ Level int

+ Model string

+ OutputTokens int

+ ParentID string

+ PayloadSummary map[string]string

+ Provider string

+ ReasoningEffort string

+ Redactions []RedactionEvidence

+ TaskType string

+ Timestamp time.Time

+ ToolCalls []string

+ TraceID string

+ TreeNodeID string

+ func NewReasoningTraceRecord(input ReasoningTraceInput) ReasoningTraceRecord

+ func (r ReasoningTraceRecord) TelemetryEvent() Event

+ type RecallBenchmarkCase struct

+ ContextContains []string

+ ID string

+ Latency time.Duration

+ RelevantIDs []string

+ Trace RecallTrace

+ type RecallBenchmarkCaseReport struct

+ CandidateMemoryIDs []string

+ ContextSatisfied bool

+ ID string

+ LatencyMS int

+ PipelineVersion string

+ RecallAt10 float64

+ RecallAt5 float64

+ RelevantIDs []string

+ ScoringConfigVersion string

+ SelectedMemoryIDs []string

+ SelectedTokens int

+ TokenBudget int

+ TokenBudgetWithin bool

+ TraceID string

+ WarningCodes []string

+ type RecallBenchmarkLatency struct

+ MaxMS int

+ MinMS int

+ P50MS int

+ P95MS int

+ type RecallBenchmarkReport struct

+ CaseCount int

+ Cases []RecallBenchmarkCaseReport

+ ContextHitRate float64

+ CorpusVersion string

+ Latency RecallBenchmarkLatency

+ RecallAt10 float64

+ RecallAt5 float64

+ Service string

+ TokenBudgetPassRate float64

+ WarningCount int

+ Warnings []RecallWarning

+ func EvaluateRecallBenchmark(cases []RecallBenchmarkCase) RecallBenchmarkReport

+ type RecallCandidate struct

+ AgentID string

+ Content string

+ CreatedAt time.Time

+ Importance float64

+ MemoryID string

+ Provenance []EvidenceItem

+ ScopeID string

+ SessionID string

+ SourceType string

+ type RecallDiagnosticsCandidate struct

+ AgentID string

+ ContentPreview string

+ FinalScore float64

+ MemoryID string

+ ScopeID string

+ Scores RecallScore

+ SessionID string

+ SourceType string

+ WhySelected []string

+ type RecallDiagnosticsRejection struct

+ AgentID string

+ ContentPreview string

+ FinalScore float64

+ MemoryID string

+ Reason string

+ ScopeID string

+ Scores RecallScore

+ SessionID string

+ SourceType string

+ WhyRejected []string

+ type RecallDiagnosticsReport struct

+ CandidateCount int

+ DegradedPathContract string

+ PipelineVersion string

+ ProjectionInvariant string

+ Query RecallQuery

+ Rejected []RecallDiagnosticsRejection

+ RejectedCount int

+ ScoringConfig RecallScoringConfig

+ Selected []RecallDiagnosticsCandidate

+ SelectedCount int

+ Service string

+ Status string

+ TraceID string

+ WarningCount int

+ Warnings []RecallWarning

+ func BuildRecallDiagnostics(trace RecallTrace) RecallDiagnosticsReport

+ type RecallEngine interface

+ Run func(ctx context.Context, q RecallQuery) (RecallTrace, error)

+ type RecallProjector struct

+ func (p *RecallProjector) ProjectContext(trace RecallTrace) ContextResult

+ func (p *RecallProjector) ProjectSearch(trace RecallTrace) SearchResultSet

+ type RecallQuery struct

+ Limit int

+ MaxTokens int

+ Peer string

+ Query string

+ ScopeID string

+ SessionKey string

+ Sources []string

+ WorkspaceID string

+ type RecallReplay struct

+ EventCount int

+ Events []RecallReplayEvent

+ PipelineVersion string

+ ProjectionInvariant string

+ Query RecallQuery

+ ReplayContract string

+ ScoringConfigVersion string

+ Service string

+ TraceID string

+ func BuildRecallReplay(trace RecallTrace) RecallReplay

+ type RecallReplayEvent struct

+ AgentID string

+ Details []string

+ FinalScore float64

+ Index int

+ Kind string

+ MemoryID string

+ Reason string

+ ScopeID string

+ SessionID string

+ Severity string

+ SourceType string

+ Stage string

+ WarningCode string

+ type RecallScore struct

+ DiversityPenalty float64

+ FinalScore float64

+ GraphScore float64

+ ImportanceScore float64

+ KeywordScore float64

+ RRFScore float64

+ RecencyScore float64

+ ScopeScore float64

+ SemanticScore float64

+ WhySelected []string

+ type RecallScoringConfig struct

+ DiversityKeys []string

+ MMRLambda float64

+ RRFK int

+ TokenBudget int

+ Version string

+ Weights map[string]float64

+ type RecallTrace struct

+ Candidates []ScoredRecallCandidate

+ CreatedAt time.Time

+ PipelineVersion string

+ Query RecallQuery

+ Rejected []RejectedRecallCandidate

+ ScoringConfig RecallScoringConfig

+ Selected []ScoredRecallCandidate

+ TraceID string

+ Warnings []RecallWarning

+ func DecodeRecallTraceJSON(r io.Reader) (RecallTrace, error)

+ func (t RecallTrace) StableJSON() ([]byte, error)

+ type RecallWarning struct

+ Code string

+ Evidence map[string]string

+ Message string

+ Severity string

+ Stage string

+ type RedactionEvidence struct

+ Field string

+ Reason string

+ func SummarizePayload(payload map[string]any) (map[string]string, []RedactionEvidence)

+ type RejectedRecallCandidate struct

+ Candidate RecallCandidate

+ Reason string

+ Score RecallScore

+ WhyRejected []string

+ type RelationCandidate struct

+ From string

+ Note string

+ To string

+ Verb RelationVerb

+ type RelationStore interface

+ SavePending func(ctx context.Context, candidates []RelationCandidate) error

+ type RelationVerb string

+ const RelationCompatible

+ const RelationConflicts

+ const RelationNotConflict

+ const RelationRelated

+ const RelationScoped

+ const RelationSupersedes

+ type RetentionAction string

+ const RetentionActionForget

+ const RetentionActionSummarize

+ type RetentionCandidate struct

+ Action RetentionAction

+ Age time.Duration

+ EffectiveImportance float64

+ Entry MemoryToolEntry

+ Reason string

+ type RetentionPolicy struct

+ Limit int

+ MinAge time.Duration

+ MinEffectiveImportance float64

+ Now time.Time

+ type RetrieveMemoryTool struct

+ func NewRetrieveMemoryTool(store MemoryToolStore) *RetrieveMemoryTool

+ func (t *RetrieveMemoryTool) Description() string

+ func (t *RetrieveMemoryTool) Execute(ctx context.Context, args json.RawMessage) (json.RawMessage, error)

+ func (t *RetrieveMemoryTool) Name() string

+ func (t *RetrieveMemoryTool) Schema() json.RawMessage

+ func (t *RetrieveMemoryTool) Timeout() time.Duration

+ func (t RetrieveMemoryTool) Spec() toolmeta.OperationSpec

+ type ReviewItem struct

+ CreatedAt time.Time

+ EvidenceIDs []string

+ ID string

+ Kind ReviewKind

+ PeerID string

+ Reason string

+ RelatedID string

+ Resolution ReviewResolution

+ ResolutionReason string

+ ResolvedAt *time.Time

+ ResolvedBy string

+ SessionKey string

+ Status ReviewStatus

+ SubjectID string

+ WorkspaceID string

+ func CreateReviewItem(ctx context.Context, db *sql.DB, p ReviewItemCreateParams) (ReviewItem, error)

+ func ResolveReviewItem(ctx context.Context, db *sql.DB, p ReviewResolutionParams) (ReviewItem, error)

+ type ReviewItemCreateParams struct

+ CreatedAt time.Time

+ EvidenceIDs []string

+ Kind ReviewKind

+ PeerID string

+ Reason string

+ RelatedID string

+ SessionKey string

+ SubjectID string

+ WorkspaceID string

+ type ReviewKind string

+ const ReviewKindConflict

+ const ReviewKindStale

+ type ReviewList struct

+ Count int

+ Items []ReviewItem

+ func ListReviewItems(ctx context.Context, db *sql.DB, q ReviewQuery) (ReviewList, error)

+ type ReviewQuery struct

+ Kind ReviewKind

+ Limit int

+ PeerID string

+ SessionKey string

+ Status ReviewStatus

+ WorkspaceID string

+ type ReviewResolution string

+ const ReviewResolutionAccepted

+ const ReviewResolutionRejected

+ const ReviewResolutionSuperseded

+ const ReviewResolutionVerified

+ type ReviewResolutionParams struct

+ ID string

+ Resolution ReviewResolution

+ ResolutionReason string

+ ResolvedAt time.Time

+ ResolvedBy string

+ type ReviewStatus string

+ const ReviewStatusOpen

+ const ReviewStatusResolved

+ type ReviewTool struct

+ func NewReviewTool(svc *Service) *ReviewTool

+ func (t *ReviewTool) Description() string

+ func (t *ReviewTool) Execute(ctx context.Context, args json.RawMessage) (json.RawMessage, error)

+ func (t *ReviewTool) Name() string

+ func (t *ReviewTool) Schema() json.RawMessage

+ func (t *ReviewTool) Spec() toolmeta.OperationSpec

+ func (t *ReviewTool) Timeout() time.Duration

+ type ScopedKeyClaims struct

+ Admin *bool

+ ExpiresAt string

+ PeerID string

+ SessionID string

+ Timestamp string

+ WorkspaceID string

+ func VerifyScopedKey(token, secret string, now time.Time) (ScopedKeyClaims, error)

+ type ScopedKeyParams struct

+ Admin bool

+ AuthEnabled bool

+ ExpiresAt time.Time

+ Now time.Time

+ PeerID string

+ Secret string

+ SessionID string

+ WorkspaceID string

+ type ScopedKeyResult struct

+ Claims ScopedKeyClaims

+ Key string

+ func CreateScopedKey(params ScopedKeyParams) (ScopedKeyResult, error)

+ type ScoredMemory struct

+ EffectiveImportance float64

+ Entry MemoryToolEntry

+ Recency float64

+ Relevance float64

+ Score float64

+ type ScoredRecallCandidate struct

+ Candidate RecallCandidate

+ Score RecallScore

+ type SearchFilter struct

+ CurrentChatKey string

+ CurrentSessionID string

+ Query string

+ Roles []string

+ SessionIDs []string

+ Sources []string

+ UserID string

+ type SearchHit struct

+ Content string

+ ID int64

+ Lineage *SearchLineage

+ OriginSource string

+ SessionKey string

+ Source string

+ type SearchLineage struct

+ ChildSessionIDs []string

+ LineageKind string

+ ParentSessionID string

+ Status string

+ type SearchParams struct

+ Filters map[string]any

+ Limit int

+ MaxTokens int

+ Peer string

+ Query string

+ Scope string

+ SessionKey string

+ Sources []string

+ type SearchResultSet struct

+ Peer string

+ Query string

+ Results []SearchHit

+ ScopeEvidence *CrossChatRecallEvidence

+ WorkspaceID string

+ type Service struct

+ func NewService(db *sql.DB, cfg Config, log *slog.Logger) *Service

+ func (s *Service) AuditTrail(ctx context.Context, q AuditQuery) (AuditResult, error)

+ func (s *Service) Chat(ctx context.Context, peer string, params ChatParams) (ChatResult, error)

+ func (s *Service) Conclude(ctx context.Context, params ConcludeParams) (ConcludeResult, error)

+ func (s *Service) Context(ctx context.Context, params ContextParams) (ContextResult, error)

+ func (s *Service) CreateMessages(ctx context.Context, params CreateMessagesParams) (CreateMessagesResult, error)

+ func (s *Service) CreateReviewItem(ctx context.Context, p ReviewItemCreateParams) (ReviewItem, error)

+ func (s *Service) DeleteSession(ctx context.Context, sessionKey string) (SessionDeletionResult, error)

+ func (s *Service) DeleteWebhookEndpoint(ctx context.Context, workspaceID, endpointID string) error

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

+ func (s *Service) DialecticCaller() DialecticCaller

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

+ func (s *Service) ExecuteDreamFactExtraction(ctx context.Context, sessionKey string) (int, error)

+ func (s *Service) GetOrCreateWebhookEndpoint(ctx context.Context, params WebhookEndpointCreateParams) (WebhookEndpointCreateResult, error)

+ func (s *Service) ImportFile(ctx context.Context, params ImportFileParams) (FileImportResult, error)

+ func (s *Service) ListObservations(ctx context.Context, q ObservationQuery) (ObservationList, error)

+ func (s *Service) ListReviewItems(ctx context.Context, q ReviewQuery) (ReviewList, error)

+ func (s *Service) ListWebhookEndpoints(ctx context.Context, workspaceID string) ([]WebhookEndpoint, error)

+ func (s *Service) NewStreamingChatPersistence(peer string, params ChatParams) (*StreamingChatPersistence, error)

+ func (s *Service) Observe(ctx context.Context, p ObservationParams) (ObservationResult, error)

+ func (s *Service) OnSessionEnd(ctx context.Context, sessionKey string, messages []Message) error

+ func (s *Service) Profile(ctx context.Context, peer string) (ProfileResult, error)

+ func (s *Service) ProfileForTarget(ctx context.Context, peer, target string) (ProfileResult, error)

+ func (s *Service) RecordSkillOutcome(ctx context.Context, outcome SkillOutcome) error

+ func (s *Service) ResolveReviewItem(ctx context.Context, p ReviewResolutionParams) (ReviewItem, error)

+ func (s *Service) ScheduleDream(ctx context.Context, params DreamScheduleParams) (DreamScheduleResult, error)

+ func (s *Service) Search(ctx context.Context, params SearchParams) (SearchResultSet, error)

+ func (s *Service) SearchSkillOutcomes(ctx context.Context, skillName string, limit int) ([]string, error)

+ func (s *Service) SetDialecticCaller(dc DialecticCaller)

+ func (s *Service) SetProfile(ctx context.Context, peer string, card []string) error

+ func (s *Service) SetProfileForTarget(ctx context.Context, peer, target string, card []string) error

+ func (s *Service) VerifiedCodeContext(ctx context.Context, params VerifiedCodeContextParams) (VerifiedCodeContextResult, error)

+ type SessionBoundaryDecision struct

+ Evidence []string

+ Kind SessionBoundaryKind

+ SessionKey string

+ func ResolveSessionBoundary(req SessionBoundaryRequest) (SessionBoundaryDecision, error)

+ type SessionBoundaryKind string

+ const SessionBoundaryChannel

+ const SessionBoundaryDelegatedChildRun

+ const SessionBoundaryImportBatch

+ const SessionBoundaryRepository

+ const SessionBoundaryThread

+ type SessionBoundaryRequest struct

+ Key string

+ Kind SessionBoundaryKind

+ Source string

+ type SessionDeletionResult struct

+ ConclusionsDeleted int64

+ MessagesDeleted int64

+ SessionKey string

+ SummariesDeleted int64

+ WorkspaceID string

+ type SessionDirectory interface

+ ListMetadataByUserID func(ctx context.Context, userID string) ([]SessionMetadata, error)

+ type SessionMemoryDeletionPlan struct

+ CascadeForget []MemoryToolEntry

+ Preserve bool

+ Preserved []MemoryToolEntry

+ SessionID string

+ Unrelated []MemoryToolEntry

+ func PlanSessionMemoryDeletion(entries []MemoryToolEntry, sessionID string, cascade bool) SessionMemoryDeletionPlan

+ type SessionMetadata struct

+ ChatID string

+ CreatedAt int64

+ LineageKind string

+ ParentSessionID string

+ SessionID string

+ Source string

+ Title string

+ UpdatedAt int64

+ UserID string

+ type SessionNameInput struct

+ CWD string

+ GatewaySessionKey string

+ SessionID string

+ Title string

+ type SessionSummary struct

+ Content string

+ CreatedAt int64

+ MessageID int64

+ SummaryType string

+ TokenCount int

+ type SillyTavernIntegrationInput struct

+ CharacterName string

+ ChatInstanceID string

+ CustomSessionName string

+ EnrichmentMode string

+ ExistingCharacterPeerIDs []string

+ ExistingSessionKey string

+ GroupCharacterNames []string

+ MessageCharacterName string

+ PeerMode string

+ PeerName string

+ PersonaName string

+ ResetActiveSession bool

+ SessionNaming string

+ UnsupportedPanelKnobs []string

+ Workspace string

+ type SillyTavernIntegrationMapping struct

+ CharacterPeerIDs []string

+ ExposeTools bool

+ ExternalToolNames []string

+ InjectContext bool

+ LazyAddedCharacterPeerIDs []string

+ OrphanedSessionKey string

+ ReasoningToolName string

+ SessionKey string

+ Unsupported []UnsupportedHostMapping

+ UseReasoning bool

+ UserPeerID string

+ WorkspaceID string

+ func MapSillyTavernIntegration(input SillyTavernIntegrationInput) SillyTavernIntegrationMapping

+ type SkillOutcome struct

+ Lesson string

+ SkillName string

+ Success bool

+ type StoreMemoryTool struct

+ func NewStoreMemoryTool(store MemoryToolStore) *StoreMemoryTool

+ func (t *StoreMemoryTool) Description() string

+ func (t *StoreMemoryTool) Execute(ctx context.Context, args json.RawMessage) (json.RawMessage, error)

+ func (t *StoreMemoryTool) Name() string

+ func (t *StoreMemoryTool) Schema() json.RawMessage

+ func (t *StoreMemoryTool) Timeout() time.Duration

+ func (t StoreMemoryTool) Spec() toolmeta.OperationSpec

+ type StreamingChatPersistence struct

+ func (p *StreamingChatPersistence) AppendChunk(chunk string)

+ func (p *StreamingChatPersistence) Complete(ctx context.Context, meta ChatCompletionMetadata) (ChatResult, error)

+ func (p *StreamingChatPersistence) Interrupt(reason string) ChatResult

+ type StructuredSummary struct

+ DecisionsMade []string

+ FilesModified []string

+ NextSteps []string

+ OpenQuestions []string

+ SkillOutcomes []string

+ type SummarizeMemoryTool struct

+ func NewSummarizeMemoryTool(store MemoryToolStore) *SummarizeMemoryTool

+ func (t *SummarizeMemoryTool) Description() string

+ func (t *SummarizeMemoryTool) Execute(ctx context.Context, args json.RawMessage) (json.RawMessage, error)

+ func (t *SummarizeMemoryTool) Name() string

+ func (t *SummarizeMemoryTool) Schema() json.RawMessage

+ func (t *SummarizeMemoryTool) Timeout() time.Duration

+ func (t SummarizeMemoryTool) Spec() toolmeta.OperationSpec

+ type TelemetryEventInput struct

+ AgentID string

+ Iteration int

+ Metrics TelemetryMetrics

+ Payload map[string]any

+ Peer string

+ ResourceID string

+ RunID string

+ SessionKey string

+ Timestamp time.Time

+ Type string

+ Workspace string

+ type TelemetryMetrics struct

+ CacheReadTokens int

+ CacheWriteTokens int

+ DurationMs int64

+ InputTokens int

+ OutputTokens int

+ QueueItemsProcessed int

+ ReasoningTokens int

+ ToolCallsCount int

+ ToolErrors int

+ type TypedMemoryStore struct

+ func NewTypedMemoryStore() *TypedMemoryStore

+ func (s *TypedMemoryStore) Create(entry *MemoryEntry) error

+ func (s *TypedMemoryStore) Delete(id string) bool

+ func (s *TypedMemoryStore) GetAverageConfidence(memType MemoryType) float64

+ func (s *TypedMemoryStore) GetPruningCandidates(now time.Time) []*MemoryEntry

+ func (s *TypedMemoryStore) GetStats() map[MemoryType]int

+ func (s *TypedMemoryStore) ListAll() []*MemoryEntry

+ func (s *TypedMemoryStore) ListByType(memType MemoryType) []*MemoryEntry

+ func (s *TypedMemoryStore) Prune(now time.Time) int

+ func (s *TypedMemoryStore) Read(id string) (*MemoryEntry, bool)

+ func (s *TypedMemoryStore) Update(id string, updateFn func(*MemoryEntry)) bool

+ func (s *TypedMemoryStore) UpsertWithConflictResolution(entry *MemoryEntry) ConflictResolution

+ type UnsupportedFilterError struct

+ Code string

+ Field string

+ Operator string

+ Reason string

+ func (e *UnsupportedFilterError) Error() string

+ type UnsupportedHostMapping struct

+ Field string

+ Reason string

+ Value string

+ type UpdateMemoryTool struct

+ func NewUpdateMemoryTool(store MemoryToolStore) *UpdateMemoryTool

+ func (t *UpdateMemoryTool) Description() string

+ func (t *UpdateMemoryTool) Execute(ctx context.Context, args json.RawMessage) (json.RawMessage, error)

+ func (t *UpdateMemoryTool) Name() string

+ func (t *UpdateMemoryTool) Schema() json.RawMessage

+ func (t *UpdateMemoryTool) Timeout() time.Duration

+ func (t UpdateMemoryTool) Spec() toolmeta.OperationSpec

+ type VerifiedCodeClaim struct

+ Content string

+ Path string

+ Status string

+ type VerifiedCodeContextParams struct

+ MaxTokens int

+ Peer string

+ Query string

+ RepoRoot string

+ SessionKey string

+ type VerifiedCodeContextResult struct

+ Peer string

+ Representation string

+ SessionKey string

+ StaleClaims []VerifiedCodeClaim

+ Unavailable []ContextUnavailableEvidence

+ VerifiedClaims []VerifiedCodeClaim

+ WorkspaceID string

+ type WebhookClock interface

+ Now func() time.Time

+ type WebhookDeliveryAttempt struct

+ Attempt int

+ EndpointID string

+ Error string

+ ErrorClass WebhookDeliveryErrorClass

+ EventType WebhookEventType

+ Evidence WebhookDeliveryEvidence

+ NextRetryAt *time.Time

+ RecordedAt time.Time

+ Retry bool

+ Status WebhookDeliveryStatus

+ StatusCode int

+ WorkspaceID string

+ type WebhookDeliveryEndpoint struct

+ Disabled bool

+ DisabledReason string

+ ID string

+ URL string

+ WorkspaceID string

+ type WebhookDeliveryErrorClass string

+ const WebhookDeliveryErrorDisabled

+ const WebhookDeliveryErrorHTTPStatus

+ const WebhookDeliveryErrorNetwork

+ const WebhookDeliveryErrorNone

+ const WebhookDeliveryErrorSigning

+ const WebhookDeliveryErrorStore

+ type WebhookDeliveryEvidence struct

+ Attempt int

+ EndpointID string

+ EndpointURL string

+ ErrorClass WebhookDeliveryErrorClass

+ EventType WebhookEventType

+ NextRetryAt *time.Time

+ Status WebhookDeliveryStatus

+ StatusCode int

+ WorkspaceID string

+ type WebhookDeliveryRequest struct

+ Attempt int

+ Event WebhookEvent

+ WorkspaceID string

+ type WebhookDeliveryResult struct

+ Attempt int

+ EndpointID string

+ Error string

+ ErrorClass WebhookDeliveryErrorClass

+ EventType WebhookEventType

+ Evidence WebhookDeliveryEvidence

+ NextRetryAt *time.Time

+ Retry bool

+ Status WebhookDeliveryStatus

+ StatusCode int

+ WorkspaceID string

+ type WebhookDeliveryStatus string

+ const WebhookDeliveryDelivered

+ const WebhookDeliveryEndpointDisabled

+ const WebhookDeliveryFailed

+ const WebhookDeliveryRetryable

+ const WebhookDeliverySkipped

+ type WebhookDeliveryStore interface

+ DisableWebhookDeliveryEndpoint func(ctx context.Context, endpoint WebhookDeliveryEndpoint, reason string, ...) error

+ ListWebhookDeliveryEndpoints func(ctx context.Context, workspaceID string) ([]WebhookDeliveryEndpoint, error)

+ RecordWebhookDelivery func(ctx context.Context, attempt WebhookDeliveryAttempt) error

+ type WebhookDeliveryWorker struct

+ Backoff func(attempt int) time.Duration

+ Client WebhookHTTPClient

+ Clock WebhookClock

+ MaxAttempts int

+ Secret string

+ Store WebhookDeliveryStore

+ func (w WebhookDeliveryWorker) Deliver(ctx context.Context, req WebhookDeliveryRequest) ([]WebhookDeliveryResult, error)

+ type WebhookEndpoint struct

+ CreatedAt time.Time

+ ID string

+ URL string

+ WorkspaceID string

+ type WebhookEndpointCreateParams struct

+ Limit int

+ Now time.Time

+ URL string

+ WorkspaceID string

+ type WebhookEndpointCreateResult struct

+ Created bool

+ Endpoint WebhookEndpoint

+ type WebhookEvent struct

+ Data map[string]any

+ Type WebhookEventType

+ WorkspaceID string

+ func NewQueueEmptyWebhookEvent(params QueueEmptyWebhookEventParams) (WebhookEvent, error)

+ func NewTestWebhookEvent(workspaceID string) (WebhookEvent, error)

+ type WebhookEventType string

+ const WebhookEventQueueEmpty

+ const WebhookEventTest

+ type WebhookHTTPClient interface

+ PostWebhook func(ctx context.Context, req WebhookHTTPRequest) (WebhookHTTPResponse, error)

+ type WebhookHTTPRequest struct

+ Body string

+ Headers map[string]string

+ URL string

+ type WebhookHTTPResponse struct

+ StatusCode int

+ type WorkspaceDecision struct

+ Evidence []string

+ HardIsolation bool

+ WorkspaceID string

+ func ResolveWorkspace(req WorkspaceRequest) (WorkspaceDecision, error)

+ type WorkspaceDeletionResult struct

+ ConclusionsDeleted int64

+ DreamsDeleted int64

+ MessagesDeleted int64

+ PeerCardsDeleted int64

+ SummariesDeleted int64

+ WorkspaceID string

+ type WorkspaceRequest struct

+ Strategy WorkspaceStrategy

+ UserID string

+ WorkspaceID string

+ type WorkspaceStrategy string

+ const WorkspaceStrategyDefault

+ const WorkspaceStrategyHardIsolation

+ const WorkspaceStrategyPerUser

+ type WriteEvidence struct

+ Candidates []RelationCandidate

+ Code string

+ Err error

+ WriteOK bool

+ type WriteFrequencyMode string

+ const WriteFrequencyAsync

+ const WriteFrequencyEvery

+ const WriteFrequencyInvalid

+ const WriteFrequencySession

+ const WriteFrequencyTurn

+ type WriteQueue struct

+ func NewWriteQueue(store MemoryStore, detector CandidateDetector, relations RelationStore) *WriteQueue

+ func (q *WriteQueue) Cancel(id string) bool

+ func (q *WriteQueue) Submit(ctx context.Context, w MemoryWrite) WriteEvidence

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