engine

package

Go to main page

Versions in this module

v0

v0.4.1

May 2, 2026

Changes in this version

+ const DefaultBudget

+ var ErrLaunchctlTransient = errors.New("transient launchd error (launchctl exit 125)")

+ var ErrNotControllable = errors.New("service is not controllable: kind=observed or kind=external")

+ var ErrServiceNotFound = errors.New("service not found in manifest")

+ func NewProviderCommandContext(ctx context.Context, opts ManagedCommandOpts, binary string, args ...string) *exec.Cmd

type Config

+ DefaultBudget int

+ EnableServiceControl bool

+ EnableSkillExec bool

+ ExcludeSubstrings []string

+ func (c *Config) ContextExcludeSubstrings() []string

+ func (c *Config) EffectiveBudget() int

+ type EnvPolicy string

+ const EnvPolicyInherit

+ const EnvPolicyProviderChild

+ type LaunchctlController = ObserverSupervisor — js/wasm, linux/amd64, windows/amd64

+ type LaunchctlController struct — darwin/amd64

+ func NewLaunchctlController() *LaunchctlController

+ func (c *LaunchctlController) Disable(ctx context.Context, name string, def ServiceDef) (*ServiceStatus, error)

+ func (c *LaunchctlController) Enable(ctx context.Context, name string, def ServiceDef) (*ServiceStatus, error)

+ func (c *LaunchctlController) Restart(ctx context.Context, name string, def ServiceDef) (*ServiceStatus, error)

+ func (c *LaunchctlController) Start(ctx context.Context, name string, def ServiceDef) (*ServiceStatus, error)

+ func (c *LaunchctlController) Status(ctx context.Context, name string, def ServiceDef) (*ServiceStatus, error)

+ func (c *LaunchctlController) Stop(ctx context.Context, name string, def ServiceDef) (*ServiceStatus, error)

+ type ManagedCommandOpts struct

+ Dir string

+ EnvPolicy EnvPolicy

+ ExtraEnv []string

+ type ObserverSupervisor struct

+ func (o *ObserverSupervisor) Disable(_ context.Context, _ string, _ ServiceDef) (*ServiceStatus, error)

+ func (o *ObserverSupervisor) Enable(_ context.Context, _ string, _ ServiceDef) (*ServiceStatus, error)

+ func (o *ObserverSupervisor) Restart(_ context.Context, _ string, _ ServiceDef) (*ServiceStatus, error)

+ func (o *ObserverSupervisor) Start(_ context.Context, _ string, _ ServiceDef) (*ServiceStatus, error)

+ func (o *ObserverSupervisor) Status(_ context.Context, _ string, _ ServiceDef) (*ServiceStatus, error)

+ func (o *ObserverSupervisor) Stop(_ context.Context, _ string, _ ServiceDef) (*ServiceStatus, error)

type Process

+ func (p *Process) NodeManifest() *NodeManifest

type Server

+ func (s *Server) SetServiceSupervisor(sup ServiceSupervisor)

type ServiceDef

+ Kind ServiceKind

+ type ServiceKind string

+ const ServiceKindExternal

+ const ServiceKindManaged

+ const ServiceKindObserved

+ func (k ServiceKind) EffectiveKind() ServiceKind

+ type ServiceStatus struct

+ At time.Time

+ ExitCode int

+ Healthy *bool

+ LaunchctlExitCode int

+ LaunchdRegistered bool

+ PID int

+ Running bool

+ Stopping bool

+ type ServiceSupervisor interface

+ Disable func(ctx context.Context, name string, def ServiceDef) (*ServiceStatus, error)

+ Enable func(ctx context.Context, name string, def ServiceDef) (*ServiceStatus, error)

+ Restart func(ctx context.Context, name string, def ServiceDef) (*ServiceStatus, error)

+ Start func(ctx context.Context, name string, def ServiceDef) (*ServiceStatus, error)

+ Status func(ctx context.Context, name string, def ServiceDef) (*ServiceStatus, error)

+ Stop func(ctx context.Context, name string, def ServiceDef) (*ServiceStatus, error)

+ type SkillExecRequest struct

+ Input string

+ Timeout string

+ type SkillExecResponse = skills.ExecResult

+ type SkillRecord = skills.Record

v0.4.0

May 1, 2026

Changes in this version

+ const BlockHealth

+ const BusTraces

+ const DefaultMaxFovealDocs

+ const DefaultPeerAwarenessBudget

+ const DefaultPeerAwarenessWindow

+ const DefaultSalienceFloor

+ const EvtPeerAwarenessRendered

+ const MaxPeerAwarenessBudget

+ const PeerAwarenessRenderBus

+ var RegisterMCPExtensions func(srv *MCPServer)

+ var RegisterProviders func()

+ var SetProvidersWorkspace func(workspaceRoot string)

+ func ActivityChannelForSid(sid string) string

+ func ComputeSectionHash(content []byte) string

+ func GenerateMemorySectionsYAML(body string) string

+ func MemoryIndex(cogRoot, path string, dryRun bool) (string, error)

+ func MemoryTOC(cogRoot, path string, asYAML bool) (string, error)

+ func NewPeerAwarenessDepsFromServer(s *Server) peerAwarenessDeps

+ func ValidateSid(sid string) error

+ type AgentDispatcher interface

+ DispatchToHarness func(ctx context.Context, req DispatchRequest) (*DispatchBatchResult, error)

type AnthropicProvider

+ func (p *AnthropicProvider) Model() string

type AttentionalField

+ func (f *AttentionalField) AllBaseScores() map[string]float64

+ func (f *AttentionalField) BaseFovea(n int) []FileScore

+ func (f *AttentionalField) ObserverScore(path string) float64

+ type AutonomicConfig struct

+ IdleRecheckIn time.Duration

+ type ChannelSessionRecord struct

+ IDSource string

+ Kinds []string

+ LastSeen time.Time

+ Metadata map[string]any

+ ParticipantID string

+ ParticipantType string

+ PreferredOutputDevice string

+ PreferredVoice string

+ Priority int

+ RegisteredAt time.Time

+ SessionID string

+ type ChannelSessionRegistry struct

+ func NewChannelSessionRegistry() *ChannelSessionRegistry

+ func (r *ChannelSessionRegistry) Delete(id string) bool

+ func (r *ChannelSessionRegistry) Get(id string) (*ChannelSessionRecord, bool)

+ func (r *ChannelSessionRegistry) Len() int

+ func (r *ChannelSessionRegistry) Put(rec ChannelSessionRecord)

+ func (r *ChannelSessionRegistry) Snapshot() []*ChannelSessionRecord

type ClaudeCodeProvider

+ func (p *ClaudeCodeProvider) Model() string

type CodexProvider

+ func (p *CodexProvider) Model() string

type CogBlock

+ Prev []string

+ Sections []Section

type CompletionRequest

+ ExternalTools []ToolDefinition

type Config

+ MaxFovealDocs int

+ Mod3URL string

+ SalienceFloor float64

+ func (c *Config) ContextGating() (maxDocs int, salienceFloor float64)

+ func (c *Config) SetContextGating(maxDocs *int, salienceFloor *float64) (int, float64)

type ContextPackage

+ Budget int

+ CandidateCount int

+ FlexBudgetUsed int

type DebugZoneItem

+ CombinedScore float64

+ type DispatchBatchResult struct

+ Notes []string

+ Results []DispatchResult

+ TotalDurationSec float64

+ func QueryDispatchToHarness(ctx context.Context, ctrl AgentController, req DispatchRequest) (*DispatchBatchResult, error)

+ type DispatchIdentity struct

+ Aud string

+ Claims map[string]interface{}

+ Iss string

+ Sub string

+ type DispatchModel string

+ const DispatchModel26B

+ const DispatchModelE4B

+ type DispatchRequest struct

+ AgentID string

+ Identity DispatchIdentity

+ Model DispatchModel

+ N int

+ Scope string

+ SystemPrompt string

+ Task string

+ Thinking *bool

+ TimeoutSeconds int

+ Tools []string

+ func (r *DispatchRequest) Normalize() error

+ type DispatchResult struct

+ Content string

+ DurationSec float64

+ Error string

+ Index int

+ ModelUsed DispatchModel

+ Success bool

+ ToolCalls []DispatchToolCallSummary

+ Turns int

+ type DispatchToolCallSummary struct

+ ArgsDigest string

+ Error string

+ Name string

+ ResultDigest string

type FovealDoc

+ RawSalience float64

+ Relevance float64

+ type HealthCounts struct

+ Degraded int

+ Healthy int

+ Missing int

+ Suspended int

+ type KernelHandlerSpan struct

+ DurationMS int64

+ Error string

+ Handler string

+ Metadata map[string]string

+ Method string

+ Origin string

+ Path string

+ RequestSize int

+ ResponseSize int

+ SessionID string

+ SpanID string

+ StartedAt time.Time

+ Status int

+ type KernelHealthSnapshot struct

+ Counts HealthCounts

+ Providers map[string]reconcile.ResourceStatus

+ Timestamp time.Time

+ func (s KernelHealthSnapshot) AllGreen() bool

+ func (s KernelHealthSnapshot) HasOperationInProgress() bool

+ func (s KernelHealthSnapshot) HasOutOfSync() bool

type KernelToolRegistry

+ func (r *KernelToolRegistry) Scoped(names []string) (*KernelToolRegistry, error)

+ type LocalHarnessController struct

+ func NewLocalHarnessController(cfg *Config, nucleus *Nucleus, process *Process, mcpSrv *MCPServer) (*LocalHarnessController, error)

+ func NewLocalHarnessControllerWithScope(cfg *Config, nucleus *Nucleus, process *Process, mcpSrv *MCPServer, ...) (*LocalHarnessController, error)

+ func (c *LocalHarnessController) DispatchToHarness(ctx context.Context, req DispatchRequest) (*DispatchBatchResult, error)

+ func (c *LocalHarnessController) GetAgent(_ context.Context, id string, includeTrace bool, traceLimit int) (*AgentSnapshot, error)

+ func (c *LocalHarnessController) ListAgents(_ context.Context, _ bool) ([]AgentSummary, error)

+ func (c *LocalHarnessController) SetBusSessionManager(mgr *BusSessionManager)

+ func (c *LocalHarnessController) Start(ctx context.Context)

+ func (c *LocalHarnessController) TriggerAgent(ctx context.Context, id string, reason string, wait bool) (*AgentTriggerResult, error)

+ type LocalLLMBackend string

+ const LocalLLMBackendOllama

+ const LocalLLMBackendOpenAICompat

+ type LocalLLMTarget struct

+ Backend LocalLLMBackend

+ BaseURL string

+ Models []string

type MCPServer

+ func (m *MCPServer) CallTool(ctx context.Context, name string, argsJSON []byte) (string, bool, error)

+ func (m *MCPServer) IsInternalTool(name string) bool

+ func (m *MCPServer) Server() *mcp.Server

+ func (m *MCPServer) SetChannelSessionBackend(b channelSessionBackend)

+ func (m *MCPServer) ToolDefinitions() []ToolDefinition

+ type MemorySection struct

+ Anchor string

+ EndLine int

+ Level int

+ Line int

+ Size int

+ Title string

+ func ParseMemorySections(body string) []MemorySection

type OllamaProvider

+ func (p *OllamaProvider) Model() string

type OpenAICompatProvider

+ func (p *OpenAICompatProvider) Model() string

+ type PeerAwarenessAttentionSignal struct

+ OccurredAt string

+ ParticipantID string

+ SignalType string

+ TargetURI string

+ type PeerAwarenessRequest struct

+ Budget int

+ IncludePeers bool

+ Now time.Time

+ Sid string

+ Window time.Duration

+ type PeerAwarenessResult struct

+ Notes []string

+ Packet string

+ Sources []PeerAwarenessSource

+ TokenCount int

+ func RenderPeerAwarenessPacket(deps peerAwarenessDeps, req PeerAwarenessRequest) (*PeerAwarenessResult, error)

+ type PeerAwarenessSource struct

+ BusID string

+ EchoRisk bool

+ Ref string

+ Section string

+ Seq int

+ Sid string

+ Ts string

+ Type string

type PiProvider

+ func (p *PiProvider) Model() string

type Process

+ func (p *Process) BlobStore() *BlobStore

+ func (p *Process) SetSessionActivityPublisher(pub SessionActivityPublisher)

type Provider

+ Model func() string

type Router

+ FirstLocalProvider func() (string, bool)

+ ProviderForModel func(model string) (string, bool)

+ ProviderForName func(name string) (string, bool)

+ type Section struct

+ Anchor string

+ Hash string

+ Size int

+ Title string

+ func GenerateSectionIndex(markdown string) []Section

type Server

+ func (s *Server) DeregisterChannelSession(ctx context.Context, sessionID string) (json.RawMessage, int, *channelSessionForwardError)

+ func (s *Server) ListChannelSessions(ctx context.Context) (*channelSessionListResponse, int, *channelSessionForwardError)

+ func (s *Server) RegisterChannelSession(ctx context.Context, req channelSessionRegisterRequest) (*channelSessionResponse, *channelSessionForwardError)

+ type SessionActivityPublisher func(busID, eventType, from string, payload map[string]interface{}) (*BusBlock, error)

type SimpleRouter

+ func (r *SimpleRouter) FirstLocalProvider() (string, bool)

+ func (r *SimpleRouter) ProviderForModel(model string) (string, bool)

+ func (r *SimpleRouter) ProviderForName(name string) (string, bool)

type StubProvider

+ func (s *StubProvider) Model() string

v0.3.0

Apr 22, 2026

Changes in this version

+ const BusBroadcast

+ const BusHandoffs

+ const BusSessions

+ const DefaultAgentID

+ const DefaultKernelLogLimit

+ const DefaultMaxSubscribers

+ const DefaultPromptPreviewCap

+ const DefaultResponsePreviewCap

+ const DefaultRingSize

+ const DefaultSubChanBuffer

+ const EvtHandoffClaim

+ const EvtHandoffClaimRejected

+ const EvtHandoffComplete

+ const EvtHandoffOffer

+ const EvtSessionEnd

+ const EvtSessionHeartbeat

+ const EvtSessionRegister

+ const HandoffStateClaimed

+ const HandoffStateCompleted

+ const HandoffStateOpen

+ const IngestEventType

+ const MaxKernelLogLimit

+ const MaxKernelLogSubstring

+ const ToolOwnershipClient

+ const ToolOwnershipKernel

+ const ToolSourceAnthropic

+ const ToolSourceKernelLoop

+ const ToolSourceMCP

+ const ToolSourceOpenAI

+ const ToolStatusError

+ const ToolStatusPending

+ const ToolStatusRejected

+ const ToolStatusSuccess

+ const ToolStatusTimeout

+ var ErrAfterSeqRequiresSession = errors.New("ledger: after_seq requires session_id")

+ var ErrAgentInvalidInput = &AgentControllerError

+ var ErrAgentNotFound = &AgentControllerError

+ var ErrAgentUnavailable = &AgentControllerError

+ var ErrSessionNotFound = errors.New("ledger: session not found")

+ func BuildMemoryIndex(workspaceRoot, sector string) (any, error)

+ func CheckCoherenceMCP(cfg *Config, nucleus *Nucleus) (any, error)

+ func ClampTraceLimit(n int) (int, error)

+ func ConfigToMap(cfg *Config) map[string]any

+ func DecodePatchBody(data []byte) (map[string]any, error)

+ func DefaultKernelLogPath(workspaceRoot string) string

+ func EmitIngestEvent(cfg *Config, result *IngestResult, cogdocPath string) error

+ func EmitLedgerEvent(cfg *Config, event map[string]any) error

+ func NextTurnIndex(workspaceRoot, sessionID string) int

+ func ParseKernelLogSince(s string, now time.Time) (time.Time, error)

+ func ParseKernelLogUntil(s string, now time.Time) (time.Time, error)

+ func ParseSinceDuration(s string, now time.Time) (time.Time, error)

+ func ParseTraceDurationOrTime(s string, now time.Time) (time.Time, error)

+ func ReadConfigOnDisk(root string) (kc kernelConfig, rawYAML string, exists bool, err error)

+ func ReadIngestionQueueState(workspaceRoot string) ingestionQueueState

+ func RegisterBroker(b *EventBroker)

+ func ReplayHandoffRegistry(mgr *BusSessionManager, reg *HandoffRegistry) error

+ func ReplaySessionRegistry(mgr *BusSessionManager, reg *SessionRegistry) error

+ func RunToolLoop(ctx context.Context, provider Provider, req *CompletionRequest, ...) (*CompletionResponse, []ToolCall, error)

+ func RunToolLoopWithTranscript(ctx context.Context, provider Provider, req *CompletionRequest, ...) (*CompletionResponse, []ToolCall, []ToolCallRecord, error)

+ func SearchMemory(workspaceRoot, query string, limit int, sector string) (any, error)

+ func SetCurrentBroker(b *EventBroker)

+ func UnregisterBroker(b *EventBroker)

+ func ValidateAgentID(id string) error

+ func ValidateKernelLogLevel(s string) (string, error)

+ func ValidateSessionID(id string) error

+ func WriteCogDoc(workspaceRoot string, path string, opts CogDocWriteOpts) (string, error)

+ type AgentActivitySummary struct

+ ClaudeCodeActive int

+ ClaudeCodeEvents int64

+ HottestBus string

+ HottestDelta int64

+ TotalEventDelta int64

+ UserLastEventAgo string

+ UserPresence string

+ type AgentController interface

+ GetAgent func(ctx context.Context, id string, includeTrace bool, traceLimit int) (*AgentSnapshot, error)

+ ListAgents func(ctx context.Context, includeStopped bool) ([]AgentSummary, error)

+ TriggerAgent func(ctx context.Context, id string, reason string, wait bool) (*AgentTriggerResult, error)

+ type AgentControllerError struct

+ Code string

+ Message string

+ func (e *AgentControllerError) Error() string

+ type AgentCycleTrace struct

+ Action string

+ Cycle int64

+ DurationMs int64

+ Observation string

+ Reason string

+ Result string

+ Target string

+ Timestamp string

+ Urgency float64

+ type AgentInboxEnrichItem struct

+ Ago string

+ Connections int

+ Title string

+ type AgentInboxSummary struct

+ EnrichedCount int

+ FailedCount int

+ LastPull string

+ LastPullAgo string

+ NextPullIn string

+ RawCount int

+ RecentEnrichments []AgentInboxEnrichItem

+ TotalCount int

+ type AgentMemoryEntry struct

+ Action string

+ Ago string

+ Cycle int64

+ Sentence string

+ Urgency float64

+ type AgentProposalEntry struct

+ Created string

+ File string

+ Title string

+ Type string

+ Urgency string

+ type AgentSnapshot struct

+ Activity *AgentActivitySummary

+ IdentityRef string

+ Inbox *AgentInboxSummary

+ LastObservation string

+ Memory []AgentMemoryEntry

+ Proposals []AgentProposalEntry

+ Summary AgentSummary

+ Traces []AgentCycleTrace

+ func QueryGetAgent(ctx context.Context, ctrl AgentController, req GetAgentRequest) (*AgentSnapshot, error)

+ type AgentSummary struct

+ AgentID string

+ Alive bool

+ CycleCount int64

+ Identity string

+ Interval string

+ LastAction string

+ LastCycle string

+ LastDurMs int64

+ LastReason string

+ LastUrgency float64

+ Model string

+ Running bool

+ UptimeSec int64

+ type AgentTriggerResult struct

+ Action string

+ AgentID string

+ CycleID string

+ DurationMs int64

+ Message string

+ Reason string

+ TimedOut bool

+ TriggerSeq int64

+ Triggered bool

+ Urgency float64

+ func QueryTriggerAgent(ctx context.Context, ctrl AgentController, req TriggerAgentRequest) (*AgentTriggerResult, error)

+ type AssimilationDecision string

+ const Defer

+ const Discard

+ const Integrate

+ const Quarantine

+ type BackupEntry struct

+ Name string

+ Path string

+ Size int64

+ Timestamp string

+ func ListBackups(dir string) ([]BackupEntry, error)

+ type BusBlock = cogfield.Block

+ type BusEventBroker struct

+ func NewBusEventBroker() *BusEventBroker

+ func (b *BusEventBroker) Publish(busID string, evt *BusBlock)

+ func (b *BusEventBroker) StartReaper(ctx context.Context)

+ func (b *BusEventBroker) Subscribe(busID string, ch chan *BusBlock, ctx context.Context, consumerID string) bool

+ func (b *BusEventBroker) SubscriberCount(busID string) int

+ func (b *BusEventBroker) TouchWrite(busID string, ch chan *BusBlock)

+ func (b *BusEventBroker) Unsubscribe(busID string, ch chan *BusBlock)

+ type BusRegistryEntry = cogfield.BusRegistryEntry

+ type BusSessionManager struct

+ func NewBusSessionManager(workspaceRoot string) *BusSessionManager

+ func (m *BusSessionManager) AddEventHandler(name string, fn func(busID string, block *BusBlock))

+ func (m *BusSessionManager) AppendEvent(busID, eventType, from string, payload map[string]interface{}) (*BusBlock, error)

+ func (m *BusSessionManager) BusesDir() string

+ func (m *BusSessionManager) EnsureBus(busID string) error

+ func (m *BusSessionManager) EventsPath(busID string) string

+ func (m *BusSessionManager) LoadRegistry() []BusRegistryEntry

+ func (m *BusSessionManager) ReadEvents(busID string) ([]BusBlock, error)

+ func (m *BusSessionManager) RegisterBus(busID, sessionID, origin string) error

+ func (m *BusSessionManager) RegistryPath() string

+ func (m *BusSessionManager) RemoveEventHandler(name string)

+ func (m *BusSessionManager) WorkspaceRoot() string

+ type ClaimRejection string

+ const ClaimRejectedAlreadyClaimed

+ const ClaimRejectedOfferNotFound

+ const ClaimRejectedOutOfOrder

+ const ClaimRejectedTTLExpired

+ type ClaimResult struct

+ ConflictingSession string

+ Offer *HandoffState

+ Rejection ClaimRejection

type CogBlock

+ func NormalizeIngestBlock(req *IngestRequest, result *IngestResult) *CogBlock

+ type CogDocService struct

+ func NewCogDocService(cfg *Config, process *Process) *CogDocService

+ func (s *CogDocService) PatchAndSync(uri string, patches cogdocFrontmatterPatch) (*WriteResult, error)

+ func (s *CogDocService) WriteAndSync(path string, opts CogDocWriteOpts) (*WriteResult, error)

+ type CogDocWriteOpts struct

+ Content string

+ DocType string

+ Extra map[string]string

+ Source string

+ SourceID string

+ Status string

+ Tags []string

+ Title string

+ URL string

+ func ApplyMembraneDecision(defaultMemPath string, opts CogDocWriteOpts, decision IngestionResult) (string, CogDocWriteOpts, bool)

type Config

+ BindAddr string

+ KernelLogPath string

+ func DefaultKernelYAML(root string) *Config

+ func ResolveFromKernelConfig(root string, kc kernelConfig) *Config

+ type ConfigDiffEntry struct

+ After any

+ Before any

+ Field string

+ type ConfigViolation struct

+ Field string

+ Got any

+ Rule string

+ type ConsumerCursor struct

+ BusID string

+ ConnectedAt time.Time

+ ConsumerID string

+ LastAckAt time.Time

+ LastAckedSeq int64

+ Stale bool

+ type ConsumerRegistry struct

+ func NewConsumerRegistry(dataDir string) *ConsumerRegistry

+ func (cr *ConsumerRegistry) Ack(busID, consumerID string, seq int64) (*ConsumerCursor, error)

+ func (cr *ConsumerRegistry) GetOrCreate(busID, consumerID string) *ConsumerCursor

+ func (cr *ConsumerRegistry) List(busID string) []*ConsumerCursor

+ func (cr *ConsumerRegistry) LoadFromDisk() error

+ func (cr *ConsumerRegistry) Remove(consumerID string) bool

+ type ContentType string

+ const ContentArticle

+ const ContentDiscussion

+ const ContentPaper

+ const ContentRepo

+ const ContentTool

+ const ContentUnknown

+ const ContentVideo

+ type ConversationQuery struct

+ AfterTurn int

+ BeforeTurn int

+ IncludeFull bool

+ IncludeTools bool

+ Limit int

+ Order string

+ SessionID string

+ Since time.Time

+ type ConversationQueryResult struct

+ Count int

+ NextAfterTurn int

+ SessionID string

+ Truncated bool

+ Turns []ConversationTurn

+ func QueryConversation(workspaceRoot string, q ConversationQuery) (*ConversationQueryResult, error)

+ type ConversationTurn struct

+ BlockID string

+ DurationMs int64

+ Error string

+ LedgerHash string

+ Model string

+ Prompt string

+ PromptTruncated bool

+ Provider string

+ Response string

+ ResponseTruncated bool

+ SessionID string

+ SidecarMissing bool

+ Status string

+ Timestamp string

+ ToolCalls []ToolCallRecord

+ TurnID string

+ TurnIndex int

+ Usage TurnUsage

+ type Decomposer interface

+ CanDecompose func(req *IngestRequest) bool

+ Decompose func(ctx context.Context, req *IngestRequest) (*IngestResult, error)

+ type DedupChecker struct

+ func NewDedupChecker(workspaceRoot string) *DedupChecker

+ func (d *DedupChecker) IsDuplicate(sourceID string) bool

+ type DefaultMembranePolicy struct

+ func (p DefaultMembranePolicy) Evaluate(block *CogBlock) IngestionResult

+ type ErrBrokerClosed struct

+ func (ErrBrokerClosed) Error() string

+ type ErrTooManySubscribers struct

+ Max int

+ func (e ErrTooManySubscribers) Error() string

+ type EventBroker struct

+ func CurrentBroker() *EventBroker

+ func NewEventBroker(opts EventBrokerOptions) *EventBroker

+ func (b *EventBroker) Close() error

+ func (b *EventBroker) Publish(env *EventEnvelope)

+ func (b *EventBroker) RingContainsHash(hash string) bool

+ func (b *EventBroker) RingOldestHash() string

+ func (b *EventBroker) RingReplay(filter EventFilter, since time.Time) []*EventEnvelope

+ func (b *EventBroker) Subscribe(ctx context.Context, filter EventFilter) (*Subscription, error)

+ func (b *EventBroker) SubscriberCount() int

+ type EventBrokerOptions struct

+ ChanBuffer int

+ MaxSubscribers int

+ RingSize int

+ type EventFilter struct

+ EventTypePattern string

+ SessionID string

+ Since time.Time

+ Source string

+ type EventQuery struct

+ EventTypePattern string

+ Limit int

+ Order string

+ SessionID string

+ Since time.Time

+ Source string

+ Until time.Time

+ type EventQueryResult struct

+ Count int

+ Events []LedgerEvent

+ NextBefore string

+ Truncated bool

+ func QueryEvents(workspaceRoot string, q EventQuery) (*EventQueryResult, error)

+ type GetAgentRequest struct

+ AgentID string

+ IncludeTrace bool

+ TraceLimit int

+ func (r *GetAgentRequest) Normalize() error

+ type HandoffRegistry struct

+ func NewHandoffRegistry() *HandoffRegistry

+ func (r *HandoffRegistry) ApplyClaim(id, claimingSession string, now time.Time, appendFn func() error) (ClaimResult, error)

+ func (r *HandoffRegistry) ApplyComplete(id, completingSession, outcome, notes, nextHandoffID string, now time.Time, ...) (*HandoffState, ClaimRejection, error)

+ func (r *HandoffRegistry) ApplyOffer(h HandoffState, now time.Time, appendFn func() error) (*HandoffState, error)

+ func (r *HandoffRegistry) Get(id string) (*HandoffState, bool)

+ func (r *HandoffRegistry) Len() int

+ func (r *HandoffRegistry) Snapshot() []*HandoffState

+ type HandoffState struct

+ ClaimedAt time.Time

+ ClaimingSession string

+ CompletedAt time.Time

+ CompletingSession string

+ CompletionNotes string

+ CompletionOutcome string

+ CreatedAt time.Time

+ ExpiresAt time.Time

+ FromSession string

+ HandoffID string

+ NextHandoffID string

+ OfferPayload map[string]interface{}

+ Reason string

+ State string

+ TTLSeconds int

+ ToSession string

+ func (h *HandoffState) IsExpired(now time.Time) bool

+ type IngestFormat string

+ const FormatConversation

+ const FormatDocument

+ const FormatMessage

+ const FormatURL

+ type IngestPipeline struct

+ func NewIngestPipeline(workspaceRoot string) *IngestPipeline

+ func (p *IngestPipeline) CheckDuplicate(sourceID string) bool

+ func (p *IngestPipeline) Ingest(ctx context.Context, req *IngestRequest) (*IngestResult, error)

+ func (p *IngestPipeline) Register(d Decomposer)

+ type IngestRequest struct

+ Data string

+ Format IngestFormat

+ Metadata map[string]string

+ Source IngestSource

+ type IngestResult struct

+ ContentType ContentType

+ Domain string

+ Fields map[string]string

+ Source IngestSource

+ SourceID string

+ Summary string

+ Tags []string

+ Title string

+ URL string

+ type IngestSource string

+ const SourceChatGPT

+ const SourceClaude

+ const SourceDiscord

+ const SourceFile

+ const SourceGemini

+ const SourceURL

+ type IngestStatus string

+ const StatusEnriched

+ const StatusIntegrated

+ const StatusRaw

+ type IngestionResult struct

+ Block *CogBlock

+ Decision AssimilationDecision

+ Provenance BlockProvenance

+ QuarantineReason string

+ Reason string

+ type KernelLogEntry struct

+ Attrs map[string]any

+ Level string

+ Line json.RawMessage

+ Msg string

+ Time time.Time

+ type KernelLogFile struct

+ Exists bool

+ Path string

+ SizeBytes int64

+ type KernelLogQuery struct

+ Level string

+ Limit int

+ Since time.Time

+ Substring string

+ Until time.Time

+ func BuildKernelLogQueryFromValues(limit, level, substring, since, until string, now time.Time) (KernelLogQuery, error)

+ type KernelLogResult struct

+ Count int

+ Entries []KernelLogEntry

+ File KernelLogFile

+ Truncated bool

+ func QueryKernelLog(path string, q KernelLogQuery) (*KernelLogResult, error)

+ type KernelToolRegistry struct

+ func NewKernelToolRegistry(mcpSrv *MCPServer) *KernelToolRegistry

+ func (r *KernelToolRegistry) Definitions() []ToolDefinition

+ func (r *KernelToolRegistry) Execute(ctx context.Context, name, arguments string) (string, error)

+ func (r *KernelToolRegistry) IsKernelTool(name string) bool

+ type LedgerEvent struct

+ Data map[string]interface{}

+ Hash string

+ PriorHash string

+ Seq int64

+ SessionID string

+ Source string

+ Timestamp string

+ Type string

+ type LedgerQuery struct

+ AfterSeq int64

+ EventType string

+ Limit int

+ SessionID string

+ SinceTimestamp string

+ VerifyChain bool

+ type LedgerQueryResult struct

+ Count int

+ Events []LedgerEvent

+ NextAfterSeq int64

+ Truncated bool

+ Verification LedgerVerification

+ func QueryLedger(workspaceRoot string, q LedgerQuery) (*LedgerQueryResult, error)

+ type LedgerVerification struct

+ Errors []string

+ FirstBrokenSeq int64

+ FirstBrokenSession string

+ Requested bool

+ TotalChecked int

+ Valid bool

+ type ListAgentsRequest struct

+ IncludeStopped bool

+ type ListAgentsResponse struct

+ Agents []AgentSummary

+ Count int

+ func QueryListAgents(ctx context.Context, ctrl AgentController, req ListAgentsRequest) (*ListAgentsResponse, error)

+ type MCPServer struct

+ func NewMCPServer(cfg *Config, nucleus *Nucleus, process *Process) *MCPServer

+ func NewMCPServerWithAgentController(cfg *Config, nucleus *Nucleus, process *Process, ctrl AgentController) *MCPServer

+ func (m *MCPServer) Handler() http.Handler

+ func (m *MCPServer) RunStdio(ctx context.Context) error

+ func (m *MCPServer) SetAgentController(ctrl AgentController)

+ func (m *MCPServer) SetSessionsBackend(bus *BusSessionManager, sessions *SessionRegistry, handoffs *HandoffRegistry)

+ type MembranePolicy interface

+ Evaluate func(block *CogBlock) IngestionResult

type Process

+ func (p *Process) Broker() *EventBroker

+ func (p *Process) EmitEvent(eventType string, data map[string]interface{}, source string) error

+ func (p *Process) RecordTurn(turn *TurnRecord) error

+ func (p *Process) RunPendingToolCallSweeper(ctx context.Context)

+ type ReadConfigResult struct

+ Defaults map[string]any

+ EffectiveConfig map[string]any

+ Exists bool

+ Path string

+ RawYAML string

+ func ReadConfigSnapshot(root string, includeRaw, includeDefaults bool) (ReadConfigResult, error)

+ type RollbackOptions struct

+ Backup string

+ ListOnly bool

+ type RollbackResult struct

+ Backups []BackupEntry

+ Error string

+ Path string

+ RequiresRestart bool

+ Restored bool

+ RestoredFrom string

+ func RollbackConfig(root string, opts RollbackOptions) (RollbackResult, error)

type Server

+ func (s *Server) SetAgentController(ctrl AgentController)

+ type SessionBlock struct

+ Content string

+ Hash string

+ Kind string

+ Score float64

+ Source string

+ Tier string

+ Tokens int

+ type SessionContextState struct

+ BlockCount int

+ Blocks []SessionBlock

+ CacheHits int

+ CoherenceScore float64

+ IrisPressure float64

+ IrisSize int

+ IrisUsed int

+ LastRequestAt time.Time

+ Profile string

+ SessionID string

+ TotalTokens int

+ TurnNumber int

+ type SessionContextStore struct

+ func NewSessionContextStore() *SessionContextStore

+ func (s *SessionContextStore) Get(sessionID string) (*SessionContextState, bool)

+ func (s *SessionContextStore) Record(state *SessionContextState)

+ func (s *SessionContextStore) Snapshot() []*SessionContextState

+ type SessionRegistry struct

+ func NewSessionRegistry() *SessionRegistry

+ func (r *SessionRegistry) ApplyEnd(id, reason, handoffID string, now time.Time, appendFn func() error) (*SessionState, bool, error)

+ func (r *SessionRegistry) ApplyHeartbeat(id string, contextUsage float64, status, currentTask string, now time.Time, ...) (*SessionState, bool, error)

+ func (r *SessionRegistry) ApplyRegister(state SessionState, activeWindow time.Duration, now time.Time, ...) (*SessionState, bool, error)

+ func (r *SessionRegistry) Get(id string) (*SessionState, bool)

+ func (r *SessionRegistry) Len() int

+ func (r *SessionRegistry) Snapshot() []*SessionState

+ type SessionState struct

+ ContextUsage float64

+ CurrentTask string

+ EndHandoffID string

+ EndReason string

+ Ended bool

+ EndedAt time.Time

+ Extras map[string]interface{}

+ Hostname string

+ LastSeen time.Time

+ Model string

+ RegisteredAt time.Time

+ Role string

+ SessionID string

+ Status string

+ Task string

+ Workspace string

+ func (s *SessionState) IsActive(window time.Duration, now time.Time) bool

+ type SourceStatus struct

+ FileExists bool

+ Matched int

+ Name string

+ Scanned int

+ type Subscription struct

+ Cancel func()

+ Dropped func() uint64

+ Events <-chan *EventEnvelope

+ type ToolCallEvent struct

+ Arguments json.RawMessage

+ CallID string

+ InteractionID string

+ Ownership string

+ Provider string

+ SessionID string

+ Source string

+ ToolName string

+ TurnIndex int

+ type ToolCallQuery struct

+ CallID string

+ IncludeArgs bool

+ IncludeOutput bool

+ Limit int

+ Order string

+ Ownership string

+ SessionID string

+ Since time.Time

+ Source string

+ Status string

+ ToolName string

+ Until time.Time

+ type ToolCallQueryResult struct

+ Calls []ToolCallRow

+ Count int

+ SourcesChecked ToolCallSourceCounts

+ Truncated bool

+ func QueryToolCalls(workspaceRoot string, q ToolCallQuery) (*ToolCallQueryResult, error)

+ type ToolCallRecord struct

+ Arguments string

+ DurationMs int64

+ ID string

+ Name string

+ RejectReason string

+ Rejected bool

+ Result string

+ type ToolCallRow struct

+ Arguments json.RawMessage

+ CallID string

+ CalledAt string

+ CompletedAt string

+ DurationMs int

+ InteractionID string

+ OutputLength int

+ OutputSummary string

+ Ownership string

+ Provider string

+ Reason string

+ SessionID string

+ Source string

+ Status string

+ ToolName string

+ TurnIndex int

+ type ToolCallSourceCounts struct

+ Anthropic int

+ KernelLoop int

+ MCP int

+ OpenAI int

+ Other int

+ type ToolCallValidationResult struct

+ Reason string

+ ToolName string

+ Valid bool

+ func ValidateToolCall(tc ToolCall, toolDefs []ToolDefinition) ToolCallValidationResult

+ type ToolResultEvent struct

+ CallID string

+ Duration time.Duration

+ OutputLength int

+ OutputSummary string

+ Reason string

+ SessionID string

+ Source string

+ Status string

+ ToolName string

+ type TraceQuery struct

+ Level string

+ Limit int

+ Order string

+ SessionID string

+ Since time.Time

+ Source TraceSource

+ Substring string

+ Until time.Time

+ type TraceQueryResult struct

+ Count int

+ Results []TraceResult

+ SourcesChecked []SourceStatus

+ Truncated bool

+ func QueryTraces(workspaceRoot string, q TraceQuery) (*TraceQueryResult, error)

+ type TraceResult struct

+ Level string

+ Line json.RawMessage

+ SessionID string

+ Source string

+ Timestamp time.Time

+ type TraceSource string

+ const SourceAll

+ const SourceAttention

+ const SourceInternalRequests

+ const SourceProprioceptive

+ type TriggerAgentRequest struct

+ AgentID string

+ Reason string

+ Wait bool

+ func (r *TriggerAgentRequest) Normalize() error

+ type TurnRecord struct

+ BlockID string

+ DurationMs int64

+ Error string

+ LedgerHash string

+ Model string

+ Prompt string

+ Provider string

+ Response string

+ SessionID string

+ Status string

+ Timestamp time.Time

+ ToolCalls []ToolCallRecord

+ TurnID string

+ TurnIndex int

+ Usage TurnUsage

+ type TurnUsage struct

+ InputTokens int

+ OutputTokens int

+ TotalTokens int

+ type URLDecomposer struct

+ func NewURLDecomposer(workspaceRoot string) *URLDecomposer

+ func (d *URLDecomposer) CanDecompose(req *IngestRequest) bool

+ func (d *URLDecomposer) Decompose(ctx context.Context, req *IngestRequest) (*IngestResult, error)

+ type WriteConfigOptions struct

+ DryRun bool

+ Scope string

+ type WriteConfigResult struct

+ BackupPath string

+ ChangedFields []string

+ Diff []ConfigDiffEntry

+ DryRun bool

+ EffectiveConfig map[string]any

+ Path string

+ RequiresRestart bool

+ Violations []ConfigViolation

+ Written bool

+ func WriteConfigPatch(root string, patch map[string]any, opts WriteConfigOptions) (WriteConfigResult, error)

+ type WriteResult struct

+ Path string

+ URI string

v0.2.0

Apr 20, 2026

Changes in this version

+ const BlockEvents

+ const BlockField

+ const BlockFocus

+ const BlockKnowledge

+ const BlockNode

+ const BlockNucleus

+ const BlockProject

+ var DefaultStability = map[string]int

+ var DefaultTiers = map[string]int

+ var TraceEmitter func(ev trace.CycleEvent)

+ var TraceIdentity = func() string

+ func DefaultManifestPath(workspaceRoot string) string

+ func FieldKeyToURI(workspaceRoot, absPath string) string

+ func PathExistsOnDisk(path string) bool

+ func ResolveToFieldKey(workspaceRoot, pointer string) string

+ type ConsumerEntry struct

+ JSONPath string

+ Key string

+ Match string

+ Path string

+ Replace string

+ Template string

+ Type string

+ type ContextBlock struct

+ Content string

+ Hash string

+ Name string

+ Stability int

+ Tier int

+ Tokens int

+ func NewBlock(name, content string) ContextBlock

+ type ContextFrame struct

+ Anchor string

+ Blocks []ContextBlock

+ Budget int

+ Goal string

+ UsedTokens int

+ func (f *ContextFrame) FitBudget(budget int)

+ func (f *ContextFrame) Render() string

+ type NodeHealth struct

+ func NewNodeHealth() *NodeHealth

+ func (nh *NodeHealth) Counts() (int, int)

+ func (nh *NodeHealth) Names() []string

+ func (nh *NodeHealth) Probe(manifest *NodeManifest, selfPort int)

+ func (nh *NodeHealth) Snapshot() map[string]ServiceHealth

+ func (nh *NodeHealth) Summary() map[string]string

+ type NodeManifest struct

+ APIVersion string

+ Kind string

+ Services map[string]ServiceDef

+ func LoadManifest(path string) (*NodeManifest, error)

+ type PiProvider struct

+ func NewPiProvider(name string, cfg ProviderConfig, procMgr *ProcessManager) *PiProvider

+ func (p *PiProvider) Available(ctx context.Context) bool

+ func (p *PiProvider) Capabilities() ProviderCapabilities

+ func (p *PiProvider) Complete(ctx context.Context, req *CompletionRequest) (*CompletionResponse, error)

+ func (p *PiProvider) Name() string

+ func (p *PiProvider) Ping(ctx context.Context) (time.Duration, error)

+ func (p *PiProvider) Stream(ctx context.Context, req *CompletionRequest) (<-chan StreamChunk, error)

type Process

+ func (p *Process) CurrentCycleID() string

+ func (p *Process) NodeHealth() *NodeHealth

+ func (p *Process) SubmitExternal(evt *GateEvent) bool

+ type ServiceDef struct

+ Binary string

+ Command string

+ Consumers []ConsumerEntry

+ DependsOn []string

+ Health string

+ Launchd string

+ Port int

+ Restart string

+ Venv string

+ Workdir string

+ type ServiceHealth struct

+ At time.Time

+ Port int

+ Status string

v0.1.0

Apr 11, 2026

Changes in this version

+ const DefaultChunkSize

+ const DefaultFileWatcherPollInterval

+ const DefaultOpenClawTailerScanInterval

+ const DefaultSyncWatcherPollInterval

+ var BuildTime = "unknown"

+ var URIRegistry *uriRegistryStub

+ var Version = "dev"

+ func AppendEvent(workspaceRoot, sessionID string, envelope *EventEnvelope) error

+ func ArchivedSessions(workspaceRoot, sessionID string) (map[string]struct{}, error)

+ func CanonicalizeEvent(payload *EventPayload) ([]byte, error)

+ func ChunkDocument(body string, targetSize int) []string

+ func CollectReferencedHashes(workspaceRoot string) (map[string]bool, error)

+ func ContentTypeFromExt(path string) string

+ func ExtractInlineRefs(content string) []string

+ func ExtractReferencedPaths(response string) []string

+ func GetHashAlgorithm(workspaceRoot string) string

+ func GetHotFiles(repoPath, scope string, limit int, threshold float64, daysWindow int, ...) ([]string, error)

+ func HashEvent(canonicalBytes []byte, algorithm string) (string, error)

+ func Main()

+ func MemoryRead(workspaceRoot, path string) (string, error)

+ func MemorySearch(workspaceRoot, query string) ([]string, error)

+ func OllamaEmbed(ctx context.Context, cfg *Config, query string) ([]float32, error)

+ func PathToURI(workspaceRoot, path string) (string, error)

+ func PrintSummary(results []BenchmarkResult)

+ func RunExperiment(ctx context.Context, experimentPath, workspaceRoot string, process *Process, ...) error

+ func RunInit(workspaceRoot string) error

+ func SaveResults(workspaceRoot string, results []BenchmarkResult, model, method string) error

+ func ShouldRedirectToBlob(path string, size int64) bool

+ type AnthropicProvider struct

+ func NewAnthropicProvider(name string, cfg ProviderConfig) *AnthropicProvider

+ func (p *AnthropicProvider) Available(_ context.Context) bool

+ func (p *AnthropicProvider) Capabilities() ProviderCapabilities

+ func (p *AnthropicProvider) Complete(ctx context.Context, req *CompletionRequest) (*CompletionResponse, error)

+ func (p *AnthropicProvider) Name() string

+ func (p *AnthropicProvider) Ping(ctx context.Context) (time.Duration, error)

+ func (p *AnthropicProvider) Stream(ctx context.Context, req *CompletionRequest) (<-chan StreamChunk, error)

+ type AssembleOption func(*assembleOpts)

+ func WithContext(ctx context.Context) AssembleOption

+ func WithConversationID(id string) AssembleOption

+ func WithIrisSignal(signal irisSignal) AssembleOption

+ func WithManifestMode(enabled bool) AssembleOption

+ type AttentionProbe struct

+ DHead int

+ KProj [][]float32

+ OutProj [][]float32

+ QProj [][]float32

+ VProj [][]float32

+ func (ap *AttentionProbe) Apply(context []float32, candidates [][]float32) []float32

+ type AttentionalField struct

+ func NewAttentionalField(cfg *Config) *AttentionalField

+ func (f *AttentionalField) AllScores() map[string]float64

+ func (f *AttentionalField) Boost(path string, delta float64)

+ func (f *AttentionalField) Fovea(n int) []FileScore

+ func (f *AttentionalField) LastUpdated() time.Time

+ func (f *AttentionalField) Len() int

+ func (f *AttentionalField) Score(path string) float64

+ func (f *AttentionalField) Update() error

+ type AttentionalZone string

+ const ZoneFoveal

+ const ZoneMomentum

+ const ZoneNucleus

+ const ZoneParafoveal

+ type BackgroundTaskOpts struct

+ AllowedTools []string

+ CallbackChannel string

+ Effort string

+ Identity string

+ MCPConfig string

+ MaxBudgetUSD float64

+ Model string

+ Prompt string

+ Source string

+ SystemPrompt string

+ Timeout time.Duration

+ WorkDir string

+ type BenchmarkPrompt struct

+ ExpectedDocs []string

+ ExpectedKeywords []string

+ Prompt string

+ func LoadPrompts(path string) ([]BenchmarkPrompt, error)

+ type BenchmarkResult struct

+ AssemblyMs int64

+ ExpectedDocs []string

+ InjectedDocs []string

+ Precision float64

+ Prompt string

+ Recall float64

+ Response string

+ ResponseMs int64

+ TotalTokens int

+ type BenchmarkSuite struct

+ func NewBenchmarkSuite(process *Process, router Router, model string, budget int) *BenchmarkSuite

+ func (b *BenchmarkSuite) Run(ctx context.Context, prompts []BenchmarkPrompt) []BenchmarkResult

+ type BlobEntry struct

+ ContentType string

+ Hash string

+ Refs []string

+ Size int64

+ StoredAt string

+ SyncedTo []string

+ type BlobPointer struct

+ ContentType string

+ Hash string

+ OriginalPath string

+ Size int64

+ func FindBlobPointers(workspaceRoot string) ([]BlobPointer, error)

+ type BlobStore struct

+ func NewBlobStore(workspaceRoot string) *BlobStore

+ func (bs *BlobStore) Exists(hash string) bool

+ func (bs *BlobStore) GC(referencedHashes map[string]bool) (removed int, freed int64, err error)

+ func (bs *BlobStore) Get(hash string) ([]byte, error)

+ func (bs *BlobStore) Init() error

+ func (bs *BlobStore) List() ([]BlobEntry, error)

+ func (bs *BlobStore) PrintBlobList() error

+ func (bs *BlobStore) Size() (int64, int, error)

+ func (bs *BlobStore) Store(content []byte, contentType string, refs ...string) (string, error)

+ func (bs *BlobStore) StoreFile(path string, contentType string, refs ...string) (string, error)

+ func (bs *BlobStore) Verify(workspaceRoot string) (missing []string, err error)

+ func (bs *BlobStore) WritePointer(path string, hash string, size int64, contentType string, originalPath string) error

+ type BlockArtifact struct

+ Kind string

+ Ref string

+ type BlockProvenance struct

+ IngestedAt time.Time

+ NormalizedBy string

+ OriginChannel string

+ OriginSession string

+ type BuildRouterOption func(*buildRouterOpts)

+ func WithProcessManager(pm *ProcessManager) BuildRouterOption

+ type Capability string

+ const CapBatch

+ const CapCaching

+ const CapJSON

+ const CapLongContext

+ const CapStreaming

+ const CapToolCallValidation

+ const CapToolUse

+ const CapVision

+ type ChunkMeta struct

+ ChunkID string

+ ChunkIdx int

+ DocID string

+ Path string

+ SectionTitle string

+ TextPreview string

+ Title string

+ type ClaudeCodeProvider struct

+ func NewClaudeCodeProvider(name string, cfg ProviderConfig, procMgr *ProcessManager) *ClaudeCodeProvider

+ func (p *ClaudeCodeProvider) Available(ctx context.Context) bool

+ func (p *ClaudeCodeProvider) Capabilities() ProviderCapabilities

+ func (p *ClaudeCodeProvider) Complete(ctx context.Context, req *CompletionRequest) (*CompletionResponse, error)

+ func (p *ClaudeCodeProvider) Name() string

+ func (p *ClaudeCodeProvider) Ping(ctx context.Context) (time.Duration, error)

+ func (p *ClaudeCodeProvider) SpawnBackground(opts BackgroundTaskOpts) (string, error)

+ func (p *ClaudeCodeProvider) Stream(ctx context.Context, req *CompletionRequest) (<-chan StreamChunk, error)

+ type ClaudeCodeTailer struct

+ Watcher *FileWatcher

+ func (t *ClaudeCodeTailer) Name() string

+ func (t *ClaudeCodeTailer) Tail(ctx context.Context, path string, out chan<- CogBlock) error

+ type CodexProvider struct

+ func NewCodexProvider(name string, cfg ProviderConfig) *CodexProvider

+ func (p *CodexProvider) Available(ctx context.Context) bool

+ func (p *CodexProvider) Capabilities() ProviderCapabilities

+ func (p *CodexProvider) Complete(ctx context.Context, req *CompletionRequest) (*CompletionResponse, error)

+ func (p *CodexProvider) Name() string

+ func (p *CodexProvider) Ping(ctx context.Context) (time.Duration, error)

+ func (p *CodexProvider) Stream(ctx context.Context, req *CompletionRequest) (<-chan StreamChunk, error)

+ type CogBlock struct

+ Artifacts []BlockArtifact

+ ID string

+ Kind CogBlockKind

+ LedgerRef string

+ Messages []ProviderMessage

+ Provenance BlockProvenance

+ RawPayload json.RawMessage

+ SessionID string

+ SourceChannel string

+ SourceIdentity string

+ SourceTransport string

+ SystemPrompt string

+ TargetIdentity string

+ ThreadID string

+ Timestamp time.Time

+ TrustContext TrustContext

+ WorkspaceID string

+ func NormalizeAnthropicRequest(body []byte, source string) *CogBlock

+ func NormalizeGateEvent(evt *GateEvent) *CogBlock

+ func NormalizeMCPRequest(toolName string, input json.RawMessage) *CogBlock

+ func NormalizeOpenAIRequest(req *oaiChatRequest, rawBody []byte, source string) *CogBlock

+ type CogBlockKind string

+ const BlockAttention

+ const BlockImport

+ const BlockMessage

+ const BlockSystemEvent

+ const BlockToolCall

+ const BlockToolResult

+ type CogDocIndex struct

+ ByStatus map[string][]*IndexedCogdoc

+ ByTag map[string][]*IndexedCogdoc

+ ByType map[string][]*IndexedCogdoc

+ ByURI map[string]*IndexedCogdoc

+ InverseRefs map[string][]string

+ RefGraph map[string][]DocRef

+ func BuildIndex(workspaceRoot string) (*CogDocIndex, error)

+ type CoherenceReport struct

+ Pass bool

+ Results []ValidationResult

+ Timestamp string

+ func RunCoherence(cfg *Config, nucleus *Nucleus, idxArgs ...*CogDocIndex) *CoherenceReport

+ type CompletionRequest struct

+ Context []ContextItem

+ InteractionID string

+ MaxTokens int

+ Messages []ProviderMessage

+ Metadata RequestMetadata

+ ModelOverride string

+ Stop []string

+ SystemPrompt string

+ Temperature *float64

+ ToolChoice string

+ Tools []ToolDefinition

+ TopP *float64

+ type CompletionResponse struct

+ Content string

+ ProviderMeta ProviderMeta

+ StopReason string

+ ToolCalls []ToolCall

+ Usage TokenUsage

+ type Config struct

+ CogDir string

+ ConsolidationInterval int

+ DigestPaths map[string]string

+ HeartbeatInterval int

+ LocalModel string

+ OllamaEmbedEndpoint string

+ OllamaEmbedModel string

+ OutputReserve int

+ Port int

+ SalienceDaysWindow int

+ TRMChunksPath string

+ TRMEmbeddingsPath string

+ TRMWeightsPath string

+ ToolCallValidationEnabled bool

+ WorkspaceRoot string

+ func LoadConfig(workspaceRoot string, port int) (*Config, error)

+ type ConsolidationAction struct

+ MaxEvents int

+ Now func() time.Time

+ WorkspaceRoot string

+ func (a ConsolidationAction) Run() (int, error)

+ type ConstellationBridge interface

+ EmitHeartbeat func(payload KernelHeartbeatPayload) (HeartbeatReceipt, error)

+ Start func(ctx context.Context) error

+ Stop func()

+ TrustSnapshot func() ConstellationTrustSnapshot

+ type ConstellationTrustSnapshot struct

+ ConstellationHealthy bool

+ PeerCount int

+ PeerTrustMean float64

+ SelfCoherencePass bool

+ SelfTrustScore float64

+ Timestamp time.Time

+ TrustedPeerCount int

+ type ContainerConfig struct

+ Command []string

+ Env map[string]string

+ Name string

+ Port int

+ RestartPolicy string

+ WorkspaceRoot string

+ type ContainerRuntime interface

+ Exec func(containerID string, command []string) ([]byte, error)

+ Logs func(containerID string, follow bool) (io.ReadCloser, error)

+ Pull func(image string) error

+ Start func(image string, config ContainerConfig) (containerID string, err error)

+ Status func(containerID string) (ContainerStatus, error)

+ Stop func(containerID string) error

+ type ContainerStatus struct

+ Exists bool

+ Running bool

+ Status string

+ type ContentPart struct

+ ImageURL string

+ Text string

+ Type string

+ type ContextItem struct

+ Content string

+ ID string

+ Salience float64

+ TokenEstimate int

+ Zone AttentionalZone

+ type ContextPackage struct

+ ClientSystem string

+ Conversation []ScoredMessage

+ CurrentMessage *ProviderMessage

+ FovealDocs []FovealDoc

+ InjectedPaths []string

+ NucleusText string

+ OutputReserve int

+ TotalTokens int

+ func (pkg *ContextPackage) FormatForProvider() (string, []ProviderMessage)

+ type Conv1D struct

+ Bias []float32

+ Channels int

+ Kernel int

+ Weight [][][]float32

+ type DaemonHealth struct

+ Identity string

+ State string

+ Status string

+ Version string

+ Workspace string

+ type DaemonState struct

+ Container string

+ Endpoint string

+ Image string

+ Mode string

+ PID *int

+ StartedAt string

+ Workspace string

+ type DebugBudget struct

+ OutputReserve int

+ Remaining int

+ Total int

+ Used int

+ type DebugClientInfo struct

+ HasSystemPrompt bool

+ MessagesCount int

+ ModelRequested string

+ QueryExtracted string

+ type DebugContextView struct

+ Budget DebugBudget

+ Zones []DebugZone

+ type DebugEngineInfo struct

+ Budget int

+ ClientSystemTokens int

+ CogDocsInjected int

+ CogDocsInjectedPaths []string

+ CogDocsScored int

+ ConversationTurnsIn int

+ ConversationTurnsKept int

+ CurrentMessageTokens int

+ FlexBudgetUsed int

+ NucleusTokens int

+ OutputReserve int

+ TotalTokens int

+ type DebugProviderInfo struct

+ LatencyMs int64

+ Model string

+ ResponseTokens int

+ Selected string

+ type DebugSnapshot struct

+ Client DebugClientInfo

+ Context DebugContextView

+ Engine DebugEngineInfo

+ Provider DebugProviderInfo

+ Timestamp time.Time

+ type DebugZone struct

+ ContentPreview string

+ Items []DebugZoneItem

+ Tokens int

+ Zone string

+ type DebugZoneItem struct

+ ID string

+ Preview string

+ Reason string

+ Recency float64

+ Relevance float64

+ Role string

+ Salience float64

+ Title string

+ Tokens int

+ type Diagnostic struct

+ Actual string

+ Expected string

+ Rule string

+ Severity string

+ Suggestion string

+ type DocRef struct

+ Rel string

+ URI string

+ type EmbeddingIndex struct

+ Chunks []ChunkMeta

+ Dim int

+ Embeddings [][]float32

+ func LoadEmbeddingIndex(embPath, chunksPath string) (*EmbeddingIndex, error)

+ func (idx *EmbeddingIndex) CosineTopK(query []float32, k int) []IndexResult

+ func (idx *EmbeddingIndex) CosineTopKIndices(query []float32, k int) ([]int, [][]float32)

+ func (idx *EmbeddingIndex) Size() int

+ type EventEnvelope struct

+ HashedPayload EventPayload

+ Metadata EventMetadata

+ func GetLastEvent(workspaceRoot, sessionID string) (*EventEnvelope, error)

+ func GetLastGlobalEvent(workspaceRoot, currentSessionID string) (*EventEnvelope, error)

+ type EventMetadata struct

+ Hash string

+ Seq int64

+ Source string

+ type EventPayload struct

+ Data map[string]interface{}

+ PriorHash string

+ SessionID string

+ Timestamp string

+ Type string

+ type ExperimentConfig struct

+ Created string

+ Run struct{ ... }

+ Title string

+ Type string

+ type ExperimentDelta struct

+ IsRegression bool

+ PrecisionDelta float64

+ RecallDelta float64

+ type FileScore struct

+ Path string

+ Score float64

+ func RankFilesBySalience(repoPath, scope string, limit, daysWindow int, cfg *SalienceConfig) ([]FileScore, error)

+ type FileWatcher struct

+ PollInterval time.Duration

+ func NewFileWatcher(pollInterval time.Duration) *FileWatcher

+ func (w *FileWatcher) Watch(ctx context.Context, path string, onLine func([]byte) error) error

+ type FovealDoc struct

+ Content string

+ Path string

+ Reason string

+ Salience float64

+ SchemaIssues []string

+ Summary string

+ Title string

+ Tokens int

+ URI string

+ type Gate struct

+ func NewGate(field *AttentionalField, cfg *Config) *Gate

+ func (g *Gate) Process(evt *GateEvent) *GateResult

+ type GateEvent struct

+ Content string

+ Data map[string]interface{}

+ SessionID string

+ Timestamp time.Time

+ Type string

+ func NewGateEventFromBlock(block *CogBlock, eventType, content string) *GateEvent

+ type GateResult struct

+ Accepted bool

+ Elevated []FileScore

+ StateTransition ProcessState

+ type HealthChecker func(endpoint string, timeout time.Duration) (*DaemonHealth, error)

+ type HeartbeatReceipt struct

+ Hash string

+ PeersSent int

+ Timestamp time.Time

+ type IndexResult struct

+ ChunkMeta ChunkMeta

+ Index int

+ Score float32

+ type IndexedCogdoc struct

+ Created string

+ ID string

+ InlineRefs []string

+ Path string

+ Refs []DocRef

+ Status string

+ Tags []string

+ Title string

+ Type string

+ URI string

+ type InferenceEvent struct

+ CostUSD float64

+ Error string

+ Escalated bool

+ Latency time.Duration

+ Model string

+ ProcessState string

+ Provider string

+ RequestID string

+ RoutingDecision *RoutingDecision

+ Source string

+ Success bool

+ Timestamp time.Time

+ Usage TokenUsage

+ type KernelHeartbeatPayload struct

+ CoherenceFingerprint string

+ FieldSize int

+ LedgerHead string

+ NucleusFingerprint string

+ ProcessState string

+ Timestamp time.Time

+ type LayerNorm struct

+ Bias []float32

+ Dim int

+ Eps float32

+ Weight []float32

+ func (ln *LayerNorm) Apply(x []float32) []float32

+ type LightCone struct

+ States []MambaState

+ type LightConeInfo struct

+ CompressedNorm float64

+ ConversationID string

+ LayerNorms []float64

+ NLayers int

+ UpdatedAt time.Time

+ type LightConeManager struct

+ func NewLightConeManager(trm *MambaTRM) *LightConeManager

+ func (m *LightConeManager) Count() int

+ func (m *LightConeManager) Delete(convID string)

+ func (m *LightConeManager) Get(convID string) *LightCone

+ func (m *LightConeManager) List() []LightConeInfo

+ func (m *LightConeManager) Prune(before time.Time) int

+ func (m *LightConeManager) Set(convID string, lc *LightCone)

+ type Linear struct

+ Bias []float32

+ InDim int

+ OutDim int

+ Weight [][]float32

+ func (l *Linear) Apply(x []float32) []float32

+ type MambaBlock struct

+ Conv Conv1D

+ D []float32

+ DInner int

+ DState int

+ InProj [][]float32

+ LogA [][]float32

+ Norm LayerNorm

+ OutProj [][]float32

+ XProj [][]float32

+ func (mb *MambaBlock) Step(x []float32, state *MambaState) ([]float32, *MambaState)

+ type MambaState struct

+ H [][]float32

+ type MambaTRM struct

+ Config TRMConfig

+ FinalNorm LayerNorm

+ Head ScoreHead

+ InputProj Linear

+ Layers []MambaBlock

+ ProbeNorms []LayerNorm

+ Probes []AttentionProbe

+ TypeEmbed [][]float32

+ func LoadTRM(weightsPath string) (*MambaTRM, error)

+ func (m *MambaTRM) GetLightConeNorms(lc *LightCone) ([]float64, float64)

+ func (m *MambaTRM) ScoreCandidates(context []float32, candidates [][]float32) []float32

+ func (m *MambaTRM) Step(event []float32, eventType int, lc *LightCone) ([]float32, *LightCone)

+ type ManagedProcess struct

+ CallbackChannel string

+ Error string

+ FinishedAt *time.Time

+ ID string

+ Identity string

+ Kind ProcessKind

+ Source string

+ StartedAt time.Time

+ Status ProcessStatus

+ Usage *TokenUsage

+ func (p *ManagedProcess) SetError(err error)

+ type ManagedProcessOpts struct

+ CallbackChannel string

+ Cancel func()

+ Identity string

+ Kind ProcessKind

+ Source string

+ type NerdctlRuntime struct

+ func NewNerdctlRuntime() (*NerdctlRuntime, error)

+ func (n *NerdctlRuntime) Exec(containerID string, command []string) ([]byte, error)

+ func (n *NerdctlRuntime) Logs(containerID string, follow bool) (io.ReadCloser, error)

+ func (n *NerdctlRuntime) Pull(image string) error

+ func (n *NerdctlRuntime) Start(image string, config ContainerConfig) (string, error)

+ func (n *NerdctlRuntime) Status(containerID string) (ContainerStatus, error)

+ func (n *NerdctlRuntime) Stop(containerID string) error

+ type NilBridge struct

+ func (NilBridge) EmitHeartbeat(KernelHeartbeatPayload) (HeartbeatReceipt, error)

+ func (NilBridge) Start(context.Context) error

+ func (NilBridge) Stop()

+ func (NilBridge) TrustSnapshot() ConstellationTrustSnapshot

+ type Nucleus struct

+ Card string

+ LoadedAt time.Time

+ Name string

+ Role string

+ WorkspaceRoot string

+ func LoadNucleus(cfg *Config) (*Nucleus, error)

+ func (n *Nucleus) Summary() string

+ type ObserverUpdate struct

+ Cycle int64

+ MeanError float64

+ Prediction []string

+ PredictionError float64

+ Receding []string

+ type OllamaProvider struct

+ func NewOllamaProvider(name string, cfg ProviderConfig) *OllamaProvider

+ func (p *OllamaProvider) Available(ctx context.Context) bool

+ func (p *OllamaProvider) Capabilities() ProviderCapabilities

+ func (p *OllamaProvider) Complete(ctx context.Context, req *CompletionRequest) (*CompletionResponse, error)

+ func (p *OllamaProvider) ContextWindow() int

+ func (p *OllamaProvider) Name() string

+ func (p *OllamaProvider) Ping(ctx context.Context) (time.Duration, error)

+ func (p *OllamaProvider) Stream(ctx context.Context, req *CompletionRequest) (<-chan StreamChunk, error)

+ type OpenAICompatProvider struct

+ func NewOpenAICompatProvider(name string, cfg ProviderConfig) *OpenAICompatProvider

+ func (p *OpenAICompatProvider) Available(ctx context.Context) bool

+ func (p *OpenAICompatProvider) Capabilities() ProviderCapabilities

+ func (p *OpenAICompatProvider) Complete(ctx context.Context, req *CompletionRequest) (*CompletionResponse, error)

+ func (p *OpenAICompatProvider) Name() string

+ func (p *OpenAICompatProvider) Ping(ctx context.Context) (time.Duration, error)

+ func (p *OpenAICompatProvider) Stream(ctx context.Context, req *CompletionRequest) (<-chan StreamChunk, error)

+ type OpenClawTailer struct

+ ScanInterval time.Duration

+ Watcher *FileWatcher

+ func (t *OpenClawTailer) Name() string

+ func (t *OpenClawTailer) Tail(ctx context.Context, path string, out chan<- CogBlock) error

+ type PredictedChunk struct

+ Path string

+ Score float32

+ SectionTitle string

+ type Process struct

+ NodeID string

+ TrustState TrustState

+ func NewProcess(cfg *Config, nucleus *Nucleus) *Process

+ func (p *Process) AssembleContext(query string, messages []ProviderMessage, budget int, opts ...AssembleOption) (*ContextPackage, error)

+ func (p *Process) EmbeddingIndex() *EmbeddingIndex

+ func (p *Process) Field() *AttentionalField

+ func (p *Process) Fingerprint() string

+ func (p *Process) Gate() *Gate

+ func (p *Process) Index() *CogDocIndex

+ func (p *Process) LightCones() *LightConeManager

+ func (p *Process) Observer() *TrajectoryModel

+ func (p *Process) RecordBlock(block *CogBlock) string

+ func (p *Process) Run(ctx context.Context) error

+ func (p *Process) Send(evt *GateEvent) bool

+ func (p *Process) SessionID() string

+ func (p *Process) SetTRM(trm *MambaTRM, idx *EmbeddingIndex)

+ func (p *Process) StartedAt() time.Time

+ func (p *Process) State() ProcessState

+ func (p *Process) TRM() *MambaTRM

+ func (p *Process) TrustSnapshot() TrustState

+ type ProcessKind int

+ const ProcessAgent

+ const ProcessBackground

+ const ProcessForeground

+ func (k ProcessKind) String() string

+ type ProcessManager struct

+ func NewProcessManager(cfg ProcessManagerConfig) *ProcessManager

+ func (pm *ProcessManager) CanSpawn(identity string) error

+ func (pm *ProcessManager) Finish(id string)

+ func (pm *ProcessManager) Kill(id string)

+ func (pm *ProcessManager) KillByIdentity(identity string) int

+ func (pm *ProcessManager) KillBySource(source string) int

+ func (pm *ProcessManager) List() []ProcessSummary

+ func (pm *ProcessManager) Remove(id string)

+ func (pm *ProcessManager) SetOnComplete(fn func(*ManagedProcess))

+ func (pm *ProcessManager) Shutdown(timeout time.Duration)

+ func (pm *ProcessManager) Stats() ProcessStats

+ func (pm *ProcessManager) Track(cmd *exec.Cmd, opts ManagedProcessOpts) *ManagedProcess

+ type ProcessManagerConfig struct

+ MaxGlobal int

+ MaxPerIdentity int

+ type ProcessState int

+ const StateActive

+ const StateConsolidating

+ const StateDormant

+ const StateReceptive

+ func (s ProcessState) String() string

+ type ProcessStats struct

+ ByKind map[string]int

+ BySource map[string]int

+ Cancelled int

+ Completed int

+ Failed int

+ Running int

+ Total int

+ type ProcessStatus int

+ const ProcessCancelled

+ const ProcessCompleted

+ const ProcessFailed

+ const ProcessRunning

+ const ProcessTimedOut

+ func (s ProcessStatus) String() string

+ type ProcessSummary struct

+ CallbackChannel string

+ Duration string

+ Error string

+ ID string

+ Identity string

+ Kind string

+ Source string

+ StartedAt string

+ Status string

+ type Projection struct

+ Base string

+ ExtBase string

+ GlobPat string

+ Pattern string

+ Suffix string

+ type ProprioceptiveEntry struct

+ Actual []string

+ Delta float64

+ Event string

+ Hits int

+ Predicted []PredictedChunk

+ Provider string

+ Query string

+ Reason string

+ ResponseLen int

+ Timestamp string

+ ToolArgs string

+ ToolCallID string

+ ToolName string

+ func ComputeEntry(query string, predicted []PredictedChunk, response string) ProprioceptiveEntry

+ type ProprioceptiveLogger struct

+ func NewProprioceptiveLogger(logPath string) *ProprioceptiveLogger

+ func (p *ProprioceptiveLogger) Log(entry ProprioceptiveEntry)

+ type Provider interface

+ Available func(ctx context.Context) bool

+ Capabilities func() ProviderCapabilities

+ Complete func(ctx context.Context, req *CompletionRequest) (*CompletionResponse, error)

+ Name func() string

+ Ping func(ctx context.Context) (time.Duration, error)

+ Stream func(ctx context.Context, req *CompletionRequest) (<-chan StreamChunk, error)

+ type ProviderCapabilities struct

+ AgenticHarness bool

+ Capabilities []Capability

+ CostPerInputToken float64

+ CostPerOutputToken float64

+ IsLocal bool

+ MaxContextTokens int

+ MaxOutputTokens int

+ ModelsAvailable []string

+ func (pc ProviderCapabilities) HasAllCapabilities(required []Capability) bool

+ func (pc ProviderCapabilities) HasCapability(cap Capability) bool

+ type ProviderConfig struct

+ APIKeyEnv string

+ ContextWindow int

+ Enabled *bool

+ Endpoint string

+ Headers map[string]string

+ MaxTokens int

+ Model string

+ Options map[string]interface{}

+ Timeout int

+ Type string

+ func (pc ProviderConfig) IsEnabled() bool

+ type ProviderMessage struct

+ Content string

+ ContentParts []ContentPart

+ Name string

+ Role string

+ ToolCallID string

+ ToolCalls []ToolCall

+ type ProviderMeta struct

+ Cached bool

+ Latency time.Duration

+ Model string

+ Provider string

+ Region string

+ type ProviderSalienceEntry struct

+ ID string

+ Salience float64

+ Zone AttentionalZone

+ type ProviderSalienceSnapshot struct

+ FocalPoint string

+ MomentumVector []float64

+ TopItems []ProviderSalienceEntry

+ type ProviderScore struct

+ AdjustedScore float64

+ Available bool

+ CapabilitiesMet bool

+ Provider string

+ RawScore float64

+ SwapPenalty float64

+ type ProvidersConfig struct

+ Providers map[string]ProviderConfig

+ Routing RoutingConfig

+ type RequestMetadata struct

+ MaxCostUSD *float64

+ PreferLocal bool

+ PreferProvider string

+ Priority RequestPriority

+ ProcessState string

+ RequestID string

+ RequiredCapabilities []Capability

+ SalienceSnapshot *ProviderSalienceSnapshot

+ Source string

+ type RequestPriority int

+ const PriorityCritical

+ const PriorityHigh

+ const PriorityLow

+ const PriorityNormal

+ type Router interface

+ DeregisterProvider func(name string)

+ RegisterProvider func(p Provider)

+ Route func(ctx context.Context, req *CompletionRequest) (Provider, *RoutingDecision, error)

+ Stats func() RouterStats

+ func BuildRouter(cfg *Config, opts ...BuildRouterOption) (Router, error)

+ type RouterStats struct

+ AvgLatencyByProvider map[string]time.Duration

+ EscalationCount int64

+ FallbackCount int64

+ RequestsByProvider map[string]int64

+ SovereigntyRatio float64

+ TokensByProvider map[string]TokenUsage

+ ToolCallRejectionsByProvider map[string]int64

+ TotalCostUSD float64

+ TotalRequests int64

+ type RoutingConfig struct

+ Default string

+ FallbackChain []string

+ LocalThreshold float64

+ MaxCostPerDayUSD float64

+ ProcessStateRouting map[string]string

+ type RoutingDecision struct

+ Escalated bool

+ FallbackFrom string

+ FallbackUsed bool

+ LatencyNs int64

+ Reason string

+ RequestID string

+ Scores []ProviderScore

+ SelectedProvider string

+ Timestamp time.Time

+ type SalienceConfig struct

+ DecayModel string

+ HalfLife int

+ WeightAuthorship float64

+ WeightChurn float64

+ WeightFrequency float64

+ WeightRecency float64

+ func DefaultSalienceConfig() *SalienceConfig

+ type SalienceScore struct

+ Authorship float64

+ Churn float64

+ CommitCount int

+ DaysAgo int

+ Frequency float64

+ Recency float64

+ Total float64

+ TotalChanges int

+ UniqueAuthors int

+ func ComputeFileSalience(repoPath, filePath string, daysWindow int, cfg *SalienceConfig) (*SalienceScore, error)

+ type ScoreHead struct

+ B1 []float32

+ B2 []float32

+ DIn int

+ DMid int

+ W1 [][]float32

+ W2 [][]float32

+ type ScoredMessage struct

+ CombinedScore float64

+ Content string

+ RecencyScore float64

+ RelevanceScore float64

+ Role string

+ Tokens int

+ TurnIndex int

+ type Server struct

+ func NewServer(cfg *Config, nucleus *Nucleus, process *Process) *Server

+ func (s *Server) Handler() http.Handler

+ func (s *Server) SetRouter(r Router)

+ func (s *Server) Shutdown(ctx context.Context) error

+ func (s *Server) Start() error

+ type SimpleRouter struct

+ func NewSimpleRouter(cfg RoutingConfig) *SimpleRouter

+ func (r *SimpleRouter) DeregisterProvider(name string)

+ func (r *SimpleRouter) RegisterProvider(p Provider)

+ func (r *SimpleRouter) Route(ctx context.Context, req *CompletionRequest) (Provider, *RoutingDecision, error)

+ func (r *SimpleRouter) Stats() RouterStats

+ type StreamChunk struct

+ Delta string

+ Done bool

+ Error error

+ ProviderMeta *ProviderMeta

+ StopReason string

+ ToolCallDelta *ToolCallDelta

+ Usage *TokenUsage

+ type StreamTailer interface

+ Name func() string

+ Tail func(ctx context.Context, path string, out chan<- CogBlock) error

+ type StubProvider struct

+ func NewStubProvider(name, response string) *StubProvider

+ func (s *StubProvider) Available(_ context.Context) bool

+ func (s *StubProvider) Capabilities() ProviderCapabilities

+ func (s *StubProvider) Complete(_ context.Context, _ *CompletionRequest) (*CompletionResponse, error)

+ func (s *StubProvider) Name() string

+ func (s *StubProvider) Ping(_ context.Context) (time.Duration, error)

+ func (s *StubProvider) Stream(_ context.Context, _ *CompletionRequest) (<-chan StreamChunk, error)

+ type SyncEnvelope struct

+ BlobHash string

+ Kind string

+ OriginNodeID string

+ Signature string

+ TargetNodeID string

+ Timestamp string

+ Version int

+ type SyncEvent struct

+ AlreadyHave bool

+ Envelope SyncEnvelope

+ FilePath string

+ Valid bool

+ ValidationError string

+ type SyncWatcher struct

+ BlobStore *BlobStore

+ PollInterval time.Duration

+ func NewSyncWatcher(blobStore *BlobStore, pollInterval time.Duration) *SyncWatcher

+ func (w *SyncWatcher) Watch(ctx context.Context, path string, out chan<- SyncEvent) error

+ type TRMConfig struct

+ DConv int

+ DHead int

+ DModel int

+ DState int

+ Expand int

+ NEventType int

+ NLayers int

+ NProbes int

+ func DefaultTRMConfig() TRMConfig

+ type TailerManager struct

+ func NewTailerManager(out chan<- CogBlock) *TailerManager

+ func (m *TailerManager) Register(tailer StreamTailer, path string) error

+ func (m *TailerManager) Run(ctx context.Context) error

+ func (m *TailerManager) Stats() map[string]TailerStats

+ type TailerStats struct

+ Errors uint64

+ EventsIngested uint64

+ LastEventTime time.Time

+ type TokenUsage struct

+ CacheReadTokens int

+ CacheWriteTokens int

+ InputTokens int

+ OutputTokens int

+ type ToolCall struct

+ Arguments string

+ ID string

+ Name string

+ type ToolCallDelta struct

+ ArgsDelta string

+ ID string

+ Index int

+ Name string

+ type ToolDefinition struct

+ Description string

+ InputSchema map[string]interface{}

+ Name string

+ type TrajectoryModel struct

+ func NewTrajectoryModel() *TrajectoryModel

+ func (m *TrajectoryModel) LastPrediction() []string

+ func (m *TrajectoryModel) Momentum() map[string]float64

+ func (m *TrajectoryModel) Stats() (cycles int64, meanError float64)

+ func (m *TrajectoryModel) Update(attended []string, fieldScores map[string]float64) ObserverUpdate

+ type TrustContext struct

+ Authenticated bool

+ Scope string

+ TrustScore float64

+ type TrustState struct

+ CoherenceFingerprint string

+ LastHeartbeatAt time.Time

+ LastHeartbeatHash string

+ LocalScore float64

+ type URIResolution struct

+ Fragment string

+ Path string

+ func ResolveURI(workspaceRoot, uri string) (*URIResolution, error)

+ type ValidationResult struct

+ Diagnostic *Diagnostic

+ Layer string

+ Pass bool

+ Timestamp string

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