engine

type AnthropicProvider struct {
	// contains filtered or unexported fields
}

type AssembleOption func(*assembleOpts)

type AttentionProbe struct {
	QProj   [][]float32 // [d_head][d_model]
	KProj   [][]float32 // [d_head][d_model]
	VProj   [][]float32 // [d_head][d_model]
	OutProj [][]float32 // [d_model][d_head]
	DHead   int
}

type AttentionalField struct {
	// contains filtered or unexported fields
}

type AttentionalZone string

type BackgroundTaskOpts struct {
	Prompt          string
	Model           string
	Effort          string
	MCPConfig       string
	AllowedTools    []string
	Source          string // "discord", "signal", "http", etc.
	CallbackChannel string // channel to report results to
	Identity        string // NodeID of the requestor
	MaxBudgetUSD    float64
	Timeout         time.Duration
	WorkDir         string // working directory for the process
	SystemPrompt    string
}

type BenchmarkPrompt struct {
	Prompt           string   `json:"prompt"`
	ExpectedDocs     []string `json:"expected_docs"`     // partial path/ID fragments to match
	ExpectedKeywords []string `json:"expected_keywords"` // words expected in response (future)
}

type BenchmarkResult struct {
	Prompt       string
	AssemblyMs   int64
	TotalTokens  int
	InjectedDocs []string
	ExpectedDocs []string
	Recall       float64 // |injected ∩ expected| / |expected|
	Precision    float64 // |injected ∩ expected| / |injected|
	Response     string  // for manual review
	ResponseMs   int64
}

type BenchmarkSuite struct {
	// contains filtered or unexported fields
}

type BlobEntry struct {
	Hash        string   `json:"hash"`
	Size        int64    `json:"size"`
	ContentType string   `json:"content_type"`
	Refs        []string `json:"refs,omitempty"` // CogDoc URIs that reference this blob
	SyncedTo    []string `json:"synced_to,omitempty"`
	StoredAt    string   `json:"stored_at"`
}

type BlobPointer struct {
	Hash         string `yaml:"hash" json:"hash"`
	Size         int64  `yaml:"size" json:"size"`
	ContentType  string `yaml:"content_type" json:"content_type"`
	OriginalPath string `yaml:"original_path" json:"original_path"`
}

type BlobStore struct {
	// contains filtered or unexported fields
}

type BlockArtifact = cogblock.BlockArtifact

type BlockProvenance = cogblock.BlockProvenance

type BuildRouterOption func(*buildRouterOpts)

type Capability string

type ChunkMeta struct {
	DocID        string `json:"doc_id"`
	Path         string `json:"path"`
	Title        string `json:"title"`
	SectionTitle string `json:"section_title"`
	ChunkIdx     int    `json:"chunk_idx"`
	ChunkID      string `json:"chunk_id"`
	TextPreview  string `json:"text_preview"`
}

type ClaudeCodeProvider struct {
	// contains filtered or unexported fields
}

type ClaudeCodeTailer struct {
	Watcher *FileWatcher
}

type CodexProvider struct {
	// contains filtered or unexported fields
}

type CogBlock struct {
	ID        string    `json:"id"`
	Timestamp time.Time `json:"timestamp"`
	SessionID string    `json:"session_id,omitempty"`
	ThreadID  string    `json:"thread_id,omitempty"`

	// Source identification.
	SourceChannel   string `json:"source_channel"`
	SourceTransport string `json:"source_transport"`
	SourceIdentity  string `json:"source_identity,omitempty"`

	// Target.
	TargetIdentity string `json:"target_identity,omitempty"`
	WorkspaceID    string `json:"workspace_id,omitempty"`

	// Content.
	Kind         CogBlockKind      `json:"kind"`
	RawPayload   json.RawMessage   `json:"raw_payload,omitempty"`
	Messages     []ProviderMessage `json:"messages,omitempty"`
	SystemPrompt string            `json:"system_prompt,omitempty"`

	// Provenance.
	Provenance   BlockProvenance `json:"provenance"`
	TrustContext TrustContext    `json:"trust_context"`

	// Ledger linkage.
	LedgerRef string `json:"ledger_ref,omitempty"`

	// Artifacts produced from processing this block.
	Artifacts []BlockArtifact `json:"artifacts,omitempty"`
}

type CogBlockKind = cogblock.CogBlockKind

type CogDocIndex struct {
	// ByURI maps canonical cog:// URI → document.
	ByURI map[string]*IndexedCogdoc
	// ByType maps type string → all documents of that type.
	ByType map[string][]*IndexedCogdoc
	// ByTag maps tag string → all documents carrying that tag.
	ByTag map[string][]*IndexedCogdoc
	// ByStatus maps status string → all documents with that status.
	ByStatus map[string][]*IndexedCogdoc
	// RefGraph maps source URI → its explicit DocRef targets.
	RefGraph map[string][]DocRef
	// InverseRefs maps target URI → list of source URIs that reference it.
	InverseRefs map[string][]string
}

type CoherenceReport struct {
	Pass      bool               `json:"pass"`
	Results   []ValidationResult `json:"results"`
	Timestamp string             `json:"timestamp"`
}

type CompletionRequest struct {
	// SystemPrompt carries nucleus content: identity, role, self-model.
	SystemPrompt string `json:"system_prompt"`

	// Messages is the conversation history in the current foveal window.
	Messages []ProviderMessage `json:"messages"`

	// Context is the assembled foveal content from the attentional field.
	Context []ContextItem `json:"context,omitempty"`

	// MaxTokens is the generation limit.
	MaxTokens int `json:"max_tokens,omitempty"`

	// Temperature controls randomness [0.0, 1.0].
	Temperature *float64 `json:"temperature,omitempty"`

	// TopP is the nucleus sampling parameter.
	TopP *float64 `json:"top_p,omitempty"`

	// Stop sequences that terminate generation.
	Stop []string `json:"stop,omitempty"`

	// Tools defines MCP tool definitions the model can invoke.
	Tools []ToolDefinition `json:"tools,omitempty"`

	// ToolChoice constrains tool use: "auto", "none", "required", or a name.
	ToolChoice string `json:"tool_choice,omitempty"`

	// ModelOverride, when non-empty, instructs the provider to use this model
	// instead of its configured default. Set by --model flag or request body.
	ModelOverride string `json:"model_override,omitempty"`

	// InteractionID links the request back to the canonical ingress CogBlock.
	InteractionID string `json:"interaction_id,omitempty"`

	// Metadata carries routing/ledger information not sent to the model.
	Metadata RequestMetadata `json:"metadata"`
}

type CompletionResponse struct {
	Content      string       `json:"content"`
	ToolCalls    []ToolCall   `json:"tool_calls,omitempty"`
	StopReason   string       `json:"stop_reason"` // "end_turn" | "max_tokens" | "tool_use"
	Usage        TokenUsage   `json:"usage"`
	ProviderMeta ProviderMeta `json:"provider_meta"`
}

type Config struct {
	// WorkspaceRoot is the absolute path to the cog-workspace root.
	WorkspaceRoot string

	// CogDir is WorkspaceRoot/.cog
	CogDir string

	// Port the HTTP API listens on. Default: 6931 (ln(2) × 10⁴).
	Port int

	// ConsolidationInterval is how often the consolidation loop fires (seconds).
	ConsolidationInterval int

	// HeartbeatInterval is the dormant-state heartbeat cadence (seconds).
	HeartbeatInterval int

	// SalienceDaysWindow is the git history window for salience scoring.
	SalienceDaysWindow int

	// OutputReserve is tokens reserved for model generation (subtracted from budget).
	OutputReserve int

	// TRMWeightsPath is the path to the TRM binary weights file.
	// If empty, TRM is disabled and keyword+salience scoring is used.
	TRMWeightsPath string

	// TRMEmbeddingsPath is the path to the TRM embedding index binary.
	TRMEmbeddingsPath string

	// TRMChunksPath is the path to the TRM chunk metadata JSON.
	TRMChunksPath string

	// OllamaEmbedEndpoint is the Ollama /api/embeddings endpoint URL.
	// Default: http://localhost:11434
	OllamaEmbedEndpoint string

	// OllamaEmbedModel is the embedding model name for Ollama.
	// Default: nomic-embed-text
	OllamaEmbedModel string

	// ToolCallValidationEnabled gates runtime validation for model-emitted tool calls.
	// Providers that advertise CapToolUse are trusted and skip this guardrail.
	ToolCallValidationEnabled bool

	// DigestPaths maps stream tailer adapter names to JSONL file/directory paths.
	// Empty map means external digestion is disabled.
	DigestPaths map[string]string

	LocalModel string
	// contains filtered or unexported fields
}

type ConsolidationAction struct {
	WorkspaceRoot string
	MaxEvents     int
	Now           func() time.Time
}

type ConstellationBridge interface {
	EmitHeartbeat(payload KernelHeartbeatPayload) (HeartbeatReceipt, error)
	TrustSnapshot() ConstellationTrustSnapshot
	Start(ctx context.Context) error
	Stop()
}

type ConstellationTrustSnapshot struct {
	SelfCoherencePass    bool      `json:"self_coherence_pass"`
	SelfTrustScore       float64   `json:"self_trust_score"`
	PeerTrustMean        float64   `json:"peer_trust_mean"`
	PeerCount            int       `json:"peer_count"`
	TrustedPeerCount     int       `json:"trusted_peer_count"`
	ConstellationHealthy bool      `json:"constellation_healthy"`
	Timestamp            time.Time `json:"timestamp"`
}

type ConsumerEntry struct {
	Path     string `yaml:"path" json:"path"`
	Type     string `yaml:"type" json:"type"` // json, sed, plist
	JSONPath string `yaml:"jsonpath,omitempty" json:"jsonpath,omitempty"`
	Template string `yaml:"template,omitempty" json:"template,omitempty"`
	Match    string `yaml:"match,omitempty" json:"match,omitempty"`
	Replace  string `yaml:"replace,omitempty" json:"replace,omitempty"`
	Key      string `yaml:"key,omitempty" json:"key,omitempty"`
}

type ContainerConfig struct {
	Name          string
	WorkspaceRoot string
	Port          int
	Command       []string
	Env           map[string]string
	RestartPolicy string
}

type ContainerRuntime interface {
	Start(image string, config ContainerConfig) (containerID string, err error)
	Stop(containerID string) error
	Status(containerID string) (ContainerStatus, error)
	Logs(containerID string, follow bool) (io.ReadCloser, error)
	Exec(containerID string, command []string) ([]byte, error)
	Pull(image string) error
}

type ContainerStatus struct {
	Exists  bool
	Running bool
	Status  string
}

type ContentPart struct {
	Type     string `json:"type"`
	Text     string `json:"text,omitempty"`
	ImageURL string `json:"image_url,omitempty"`
}

type ContextBlock struct {
	Name      string `json:"name"`      // e.g. "nucleus", "project", "knowledge", "node", "field", "events"
	Tier      int    `json:"tier"`      // 0=fixed, 1=priority, 2=flexible, 3=expendable
	Stability int    `json:"stability"` // 0-100: higher = less likely to change between turns (KV cache hint)
	Content   string `json:"content"`   // Rendered markdown/text
	Tokens    int    `json:"tokens"`    // Estimated token count
	Hash      string `json:"hash"`      // Content hash for change detection
}

type ContextFrame struct {
	Blocks     []ContextBlock `json:"blocks"`
	Budget     int            `json:"budget"`
	UsedTokens int            `json:"used_tokens"`
	Anchor     string         `json:"anchor,omitempty"`
	Goal       string         `json:"goal,omitempty"`
}

type ContextItem struct {
	ID            string          `json:"id"` // cog:// URI or memory address
	Zone          AttentionalZone `json:"zone"`
	Salience      float64         `json:"salience"`
	Content       string          `json:"content"`
	TokenEstimate int             `json:"token_estimate,omitempty"`
}

type ContextPackage struct {
	// NucleusText is the identity card content — always present (Zone 0).
	NucleusText string

	// ClientSystem is the client's system prompt if provided (Zone 1).
	ClientSystem string

	// FovealDocs are the CogDocs selected for injection (Zone 1).
	FovealDocs []FovealDoc

	// Conversation is the scored/filtered conversation history (Zone 2).
	Conversation []ScoredMessage

	// CurrentMessage is the latest user message — always present (Zone 3).
	CurrentMessage *ProviderMessage

	// TotalTokens is the approximate token count of the assembled context.
	TotalTokens int

	// OutputReserve is tokens reserved for generation.
	OutputReserve int

	// InjectedPaths is the list of injected absolute file paths (for logging).
	InjectedPaths []string
}

type Conv1D struct {
	Weight   [][][]float32 // [channels][1][kernel_size]
	Bias     []float32     // [channels]
	Channels int
	Kernel   int
}

type DaemonHealth struct {
	Status    string `json:"status"`
	Version   string `json:"version"`
	State     string `json:"state"`
	Identity  string `json:"identity"`
	Workspace string `json:"workspace"`
}

type DaemonState struct {
	Mode      string `yaml:"mode"`
	Endpoint  string `yaml:"endpoint"`
	Container string `yaml:"container,omitempty"`
	Workspace string `yaml:"workspace"`
	StartedAt string `yaml:"started_at"`
	Image     string `yaml:"image,omitempty"`
	PID       *int   `yaml:"pid"`
}

type DebugBudget struct {
	Total         int `json:"total"`
	OutputReserve int `json:"output_reserve"`
	Used          int `json:"used"`
	Remaining     int `json:"remaining"`
}

type DebugClientInfo struct {
	MessagesCount   int    `json:"messages_count"`
	HasSystemPrompt bool   `json:"has_system_prompt"`
	ModelRequested  string `json:"model_requested"`
	QueryExtracted  string `json:"query_extracted"`
}

type DebugContextView struct {
	Zones  []DebugZone `json:"zones"`
	Budget DebugBudget `json:"budget"`
}

type DebugEngineInfo struct {
	NucleusTokens         int      `json:"nucleus_tokens"`
	ClientSystemTokens    int      `json:"client_system_tokens"`
	CogDocsScored         int      `json:"cogdocs_scored"`
	CogDocsInjected       int      `json:"cogdocs_injected"`
	CogDocsInjectedPaths  []string `json:"cogdocs_injected_paths"`
	ConversationTurnsIn   int      `json:"conversation_turns_in"`
	ConversationTurnsKept int      `json:"conversation_turns_kept"`
	CurrentMessageTokens  int      `json:"current_message_tokens"`
	TotalTokens           int      `json:"total_tokens"`
	Budget                int      `json:"budget"`
	OutputReserve         int      `json:"output_reserve"`
	FlexBudgetUsed        int      `json:"flex_budget_used"`
}

type DebugProviderInfo struct {
	Selected       string `json:"selected"`
	Model          string `json:"model"`
	ResponseTokens int    `json:"response_tokens"`
	LatencyMs      int64  `json:"latency_ms"`
}

type DebugSnapshot struct {
	Timestamp time.Time         `json:"timestamp"`
	Client    DebugClientInfo   `json:"client"`
	Engine    DebugEngineInfo   `json:"engine"`
	Provider  DebugProviderInfo `json:"provider"`
	Context   DebugContextView  `json:"context"`
}

type DebugZone struct {
	Zone           string          `json:"zone"`
	Tokens         int             `json:"tokens"`
	ContentPreview string          `json:"content_preview,omitempty"`
	Items          []DebugZoneItem `json:"items,omitempty"`
}

type DebugZoneItem struct {
	ID        string  `json:"id,omitempty"`
	Title     string  `json:"title,omitempty"`
	Role      string  `json:"role,omitempty"`
	Tokens    int     `json:"tokens"`
	Salience  float64 `json:"salience,omitempty"`
	Recency   float64 `json:"recency,omitempty"`
	Relevance float64 `json:"relevance,omitempty"`
	Reason    string  `json:"reason,omitempty"`
	Preview   string  `json:"preview"`
}

type Diagnostic struct {
	Rule       string `json:"rule"`
	Expected   string `json:"expected"`
	Actual     string `json:"actual"`
	Suggestion string `json:"suggestion"`
	Severity   string `json:"severity"` // "error", "warning", "info"
}

type DocRef struct {
	// URI is the target cog:// URI.
	URI string `yaml:"uri"`
	// Rel is the relationship label (e.g. "related", "supersedes", "depends-on").
	Rel string `yaml:"rel"`
}

type EmbeddingIndex struct {
	Embeddings [][]float32 // [N][dim]
	Chunks     []ChunkMeta
	Dim        int
}

type EventEnvelope struct {
	HashedPayload EventPayload  `json:"hashed_payload"`
	Metadata      EventMetadata `json:"metadata,omitempty"`
}

type EventMetadata struct {
	Hash   string `json:"hash,omitempty"`
	Seq    int64  `json:"seq,omitempty"`
	Source string `json:"source,omitempty"`
}

type EventPayload struct {
	Type      string                 `json:"type"`
	Timestamp string                 `json:"timestamp"`
	SessionID string                 `json:"session_id"`
	PriorHash string                 `json:"prior_hash,omitempty"`
	Data      map[string]interface{} `json:"data,omitempty"`
}

type ExperimentConfig struct {
	Type    string `yaml:"type"`
	Title   string `yaml:"title"`
	Created string `yaml:"created"`
	Run     struct {
		PromptsFile         string  `yaml:"prompts_file"`         // path to benchmark_prompts.json
		Model               string  `yaml:"model"`                // e.g. "qwen3.5:9b"
		Budget              int     `yaml:"budget"`               // token budget (0 = default 4096)
		Method              string  `yaml:"method"`               // e.g. "keyword-match"
		RegressionThreshold float64 `yaml:"regression_threshold"` // recall drop that triggers flag (default 0.1)
		BaselineRun         string  `yaml:"baseline_run"`         // path to previous result CogDoc for comparison
	} `yaml:"run"`
}

type ExperimentDelta struct {
	RecallDelta    float64
	PrecisionDelta float64
	IsRegression   bool
}

type FileScore struct {
	Path  string
	Score float64
}

type FileWatcher struct {
	PollInterval time.Duration
}

type FovealDoc struct {
	URI          string
	Path         string
	Title        string
	Content      string
	Summary      string
	SchemaIssues []string
	Salience     float64
	Tokens       int
	Reason       string // "high-salience", "query-match", or "both"
}

type Gate struct {
	// contains filtered or unexported fields
}

type GateEvent struct {
	// Type is the event category (e.g. "user.message", "tool.call", "heartbeat").
	Type string

	// Content is the raw content of the event (e.g. user message text).
	Content string

	// Timestamp records when the event arrived.
	Timestamp time.Time

	// SessionID is the originating session (empty for internal events).
	SessionID string

	// Data holds type-specific structured data.
	Data map[string]interface{}
}

type GateResult struct {
	// Elevated is the set of memory files to bring into the fovea for this event.
	Elevated []FileScore

	// StateTransition is the suggested next process state (empty = no change).
	StateTransition ProcessState

	// Accepted records whether the event was accepted into the fovea.
	Accepted bool
}

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

type HeartbeatReceipt struct {
	Hash      string    `json:"hash,omitempty"`
	Timestamp time.Time `json:"timestamp,omitempty"`
	PeersSent int       `json:"peers_sent"`
}

type IndexResult struct {
	Index     int
	Score     float32
	ChunkMeta ChunkMeta
}

type IndexedCogdoc struct {
	// URI is the canonical cog:// address of this document.
	URI string
	// Path is the absolute filesystem path.
	Path string
	// ID is the value of the `id:` frontmatter field (may be empty).
	ID string
	// Title is the value of the `title:` frontmatter field.
	Title string
	// Type is the value of the `type:` frontmatter field (e.g. "insight").
	Type string
	// Tags is the value of the `tags:` frontmatter field.
	Tags []string
	// Status is the value of the `status:` frontmatter field (e.g. "active").
	Status string
	// Created is the value of the `created:` frontmatter field (string, any format).
	Created string
	// Refs are the explicit `refs:` entries in the frontmatter.
	Refs []DocRef
	// InlineRefs are cog:// URIs found in the document body (extracted by regex).
	InlineRefs []string
}

type InferenceEvent struct {
	RequestID       string           `json:"request_id"`
	Timestamp       time.Time        `json:"timestamp"`
	Provider        string           `json:"provider"`
	Model           string           `json:"model"`
	ProcessState    string           `json:"process_state"`
	Usage           TokenUsage       `json:"usage"`
	CostUSD         float64          `json:"cost_usd"`
	Latency         time.Duration    `json:"latency"`
	RoutingDecision *RoutingDecision `json:"routing_decision,omitempty"`
	Escalated       bool             `json:"escalated"`
	Source          string           `json:"source"`
	Success         bool             `json:"success"`
	Error           string           `json:"error,omitempty"`
}

type KernelHeartbeatPayload struct {
	ProcessState         string    `json:"process_state"`
	FieldSize            int       `json:"field_size"`
	CoherenceFingerprint string    `json:"coherence_fingerprint"`
	NucleusFingerprint   string    `json:"nucleus_fingerprint"`
	LedgerHead           string    `json:"ledger_head,omitempty"`
	Timestamp            time.Time `json:"timestamp"`
}

type LayerNorm struct {
	Weight []float32 // [dim]
	Bias   []float32 // [dim]
	Dim    int
	Eps    float32
}

type LightCone struct {
	States []MambaState // one per layer
}

type LightConeInfo struct {
	ConversationID string    `json:"conversation_id"`
	NLayers        int       `json:"n_layers"`
	LayerNorms     []float64 `json:"layer_norms"`
	CompressedNorm float64   `json:"compressed_norm"`
	UpdatedAt      time.Time `json:"updated_at"`
}

type LightConeManager struct {
	// contains filtered or unexported fields
}

type Linear struct {
	Weight [][]float32 // [out_features][in_features]
	Bias   []float32   // [out_features] or nil
	InDim  int
	OutDim int
}

type MambaBlock struct {
	Norm    LayerNorm
	InProj  [][]float32 // [2*d_inner][d_model] — projects to (x_ssm, z)
	Conv    Conv1D
	XProj   [][]float32 // [d_state*2+1][d_inner] — projects to (B, C, delta)
	LogA    [][]float32 // [d_inner][d_state]
	D       []float32   // [d_inner] skip connection
	OutProj [][]float32 // [d_model][d_inner]
	DInner  int
	DState  int
}

type MambaState struct {
	H [][]float32 // [d_inner][d_state]
}

type MambaTRM struct {
	Config     TRMConfig
	TypeEmbed  [][]float32      // [n_event_types][d_model]
	InputProj  Linear           // 2*d_model → d_model
	Layers     []MambaBlock     // [n_layers]
	FinalNorm  LayerNorm        // d_model
	Probes     []AttentionProbe // [n_probes]
	ProbeNorms []LayerNorm      // [n_probes]
	Head       ScoreHead
}

type ManagedProcess struct {
	ID              string        `json:"id"`
	Kind            ProcessKind   `json:"kind"`
	Status          ProcessStatus `json:"status"`
	Source          string        `json:"source"`           // "http", "discord", "signal", etc.
	CallbackChannel string        `json:"callback_channel"` // where to deliver results
	Identity        string        `json:"identity"`         // NodeID of requestor
	StartedAt       time.Time     `json:"started_at"`
	FinishedAt      *time.Time    `json:"finished_at,omitempty"`
	Error           string        `json:"error,omitempty"`

	Usage *TokenUsage
	// contains filtered or unexported fields
}

type ManagedProcessOpts struct {
	Kind            ProcessKind
	Source          string
	CallbackChannel string
	Identity        string
	Cancel          func()
}

type NerdctlRuntime struct {
	// contains filtered or unexported fields
}

type NilBridge struct{}

type NodeHealth struct {
	// contains filtered or unexported fields
}

type NodeManifest struct {
	APIVersion string                `yaml:"apiVersion" json:"apiVersion"`
	Kind       string                `yaml:"kind" json:"kind"`
	Services   map[string]ServiceDef `yaml:"services" json:"services"`
}

type Nucleus struct {

	// Name is the identity name (e.g. "Cog", "Sandy").
	Name string

	// Role is the identity role descriptor.
	Role string

	// Card is the full text of the identity card (markdown).
	Card string

	// WorkspaceRoot is the absolute path to the workspace.
	WorkspaceRoot string

	// LoadedAt records when this nucleus was loaded.
	LoadedAt time.Time
	// contains filtered or unexported fields
}

type ObserverUpdate struct {
	// PredictionError is the Jaccard distance between the previous prediction
	// and the paths actually attended this cycle (0 = perfect, 1 = total miss).
	PredictionError float64

	// Prediction is the set of paths the model expects to be attended next cycle.
	Prediction []string

	// Receding is the set of paths that were predicted last cycle but dropped
	// out this cycle (expected, then stopped being attended).
	Receding []string

	// Cycle is the cycle number that just completed.
	Cycle int64

	// MeanError is the running mean prediction error across all cycles.
	MeanError float64
}

type OllamaProvider struct {
	// contains filtered or unexported fields
}

type OpenAICompatProvider struct {
	// contains filtered or unexported fields
}

type OpenClawTailer struct {
	Watcher      *FileWatcher
	ScanInterval time.Duration
}

type PiProvider struct {
	// contains filtered or unexported fields
}

type PredictedChunk struct {
	Path         string  `json:"path"`
	SectionTitle string  `json:"section_title,omitempty"`
	Score        float32 `json:"score"`
}

type Process struct {

	// NodeID is the stable kernel node identity persisted across restarts.
	NodeID string

	// TrustState carries local trust, coherence, and heartbeat metadata.
	TrustState TrustState
	// contains filtered or unexported fields
}

type ProcessKind int

type ProcessManager struct {
	// contains filtered or unexported fields
}

type ProcessManagerConfig struct {
	MaxGlobal      int // 0 = unlimited
	MaxPerIdentity int // 0 = unlimited
}

type ProcessState int

type ProcessStats struct {
	Total     int            `json:"total"`
	Running   int            `json:"running"`
	Completed int            `json:"completed"`
	Failed    int            `json:"failed"`
	Cancelled int            `json:"cancelled"`
	ByKind    map[string]int `json:"by_kind"`
	BySource  map[string]int `json:"by_source"`
}

type ProcessStatus int

type ProcessSummary struct {
	ID              string `json:"id"`
	Kind            string `json:"kind"`
	Status          string `json:"status"`
	Source          string `json:"source"`
	Identity        string `json:"identity,omitempty"`
	StartedAt       string `json:"started_at"`
	Duration        string `json:"duration"`
	CallbackChannel string `json:"callback_channel,omitempty"`
	Error           string `json:"error,omitempty"`
}

type Projection struct {
	// Base is the workspace-relative prefix under the workspace root
	// (e.g. ".cog/mem/"). Mutually exclusive with ExtBase.
	Base string
	// ExtBase is a workspace-root-relative prefix for paths that live
	// outside .cog/ (e.g. ".claude/skills/").
	ExtBase string
	// Pattern controls resolution: "direct" | "directory" | "glob" | "singleton".
	Pattern string
	// Suffix is appended to the resolved path for "direct" patterns
	// (e.g. ".cog.md" for specs).
	Suffix string
	// GlobPat is a fmt.Sprintf template (one %s) for "glob" patterns.
	// E.g. "%s-*.md" matches numbered ADR files.
	GlobPat string
}

type ProprioceptiveEntry struct {
	Timestamp   string           `json:"timestamp"`
	Event       string           `json:"event,omitempty"`
	Provider    string           `json:"provider,omitempty"`
	ToolName    string           `json:"tool_name,omitempty"`
	ToolCallID  string           `json:"tool_call_id,omitempty"`
	ToolArgs    string           `json:"tool_args,omitempty"`
	Reason      string           `json:"reason,omitempty"`
	Query       string           `json:"query"`
	Predicted   []PredictedChunk `json:"predicted"`
	Actual      []string         `json:"actual"`
	Hits        int              `json:"hits"`
	Delta       float64          `json:"delta"`
	ResponseLen int              `json:"response_len"`
}

type ProprioceptiveLogger struct {
	// contains filtered or unexported fields
}

type Provider interface {
	// Complete sends a context package and waits for the full response.
	Complete(ctx context.Context, req *CompletionRequest) (*CompletionResponse, error)

	// Stream sends a request and returns a channel of incremental chunks.
	// The channel closes when done or on error. Providers that don't support
	// streaming must fall back to Complete and send a single chunk.
	Stream(ctx context.Context, req *CompletionRequest) (<-chan StreamChunk, error)

	// Name returns the provider identifier (e.g. "ollama", "anthropic").
	Name() string

	// Available reports whether the provider is ready to serve requests.
	// For local providers: checks the model server is running and model loaded.
	Available(ctx context.Context) bool

	// Capabilities returns what this provider supports.
	Capabilities() ProviderCapabilities

	// Ping probes the endpoint and returns measured latency.
	Ping(ctx context.Context) (time.Duration, error)
}

type ProviderCapabilities struct {
	Capabilities       []Capability `json:"capabilities"`
	MaxContextTokens   int          `json:"max_context_tokens"`
	MaxOutputTokens    int          `json:"max_output_tokens"`
	ModelsAvailable    []string     `json:"models_available"`
	IsLocal            bool         `json:"is_local"`
	AgenticHarness     bool         `json:"agentic_harness,omitempty"`
	CostPerInputToken  float64      `json:"cost_per_input_token"`
	CostPerOutputToken float64      `json:"cost_per_output_token"`
}

type ProviderConfig struct {
	Type          string                 `yaml:"type,omitempty" json:"type,omitempty"`
	APIKeyEnv     string                 `yaml:"api_key_env,omitempty" json:"api_key_env,omitempty"`
	Endpoint      string                 `yaml:"endpoint,omitempty" json:"endpoint,omitempty"`
	Model         string                 `yaml:"model" json:"model"`
	ContextWindow int                    `yaml:"context_window,omitempty" json:"context_window,omitempty"`
	MaxTokens     int                    `yaml:"max_tokens,omitempty" json:"max_tokens,omitempty"`
	Timeout       int                    `yaml:"timeout,omitempty" json:"timeout,omitempty"`
	Headers       map[string]string      `yaml:"headers,omitempty" json:"headers,omitempty"`
	Options       map[string]interface{} `yaml:"options,omitempty" json:"options,omitempty"`
	Enabled       *bool                  `yaml:"enabled,omitempty" json:"enabled,omitempty"`
}

type ProviderMessage struct {
	Role         string        `json:"role"` // "user", "assistant", "system", "tool"
	Content      string        `json:"content"`
	ContentParts []ContentPart `json:"content_parts,omitempty"`
	Name         string        `json:"name,omitempty"`
	ToolCallID   string        `json:"tool_call_id,omitempty"`
	ToolCalls    []ToolCall    `json:"tool_calls,omitempty"`
}

type ProviderMeta struct {
	Provider string        `json:"provider"`
	Model    string        `json:"model"`
	Latency  time.Duration `json:"latency"`
	Region   string        `json:"region,omitempty"`
	Cached   bool          `json:"cached,omitempty"`
}

type ProviderSalienceEntry struct {
	ID       string          `json:"id"`
	Salience float64         `json:"salience"`
	Zone     AttentionalZone `json:"zone"`
}

type ProviderSalienceSnapshot struct {
	TopItems       []ProviderSalienceEntry `json:"top_items"`
	FocalPoint     string                  `json:"focal_point"`
	MomentumVector []float64               `json:"momentum_vector,omitempty"`
}

type ProviderScore struct {
	Provider        string  `json:"provider"`
	RawScore        float64 `json:"raw_score"`
	SwapPenalty     float64 `json:"swap_penalty"`
	AdjustedScore   float64 `json:"adjusted_score"`
	Available       bool    `json:"available"`
	CapabilitiesMet bool    `json:"capabilities_met"`
}

type ProvidersConfig struct {
	Providers map[string]ProviderConfig `yaml:"providers" json:"providers"`
	Routing   RoutingConfig             `yaml:"routing" json:"routing"`
}

type RequestMetadata struct {
	RequestID            string                    `json:"request_id"`
	ProcessState         string                    `json:"process_state"` // from ProcessState.String()
	Priority             RequestPriority           `json:"priority"`
	PreferLocal          bool                      `json:"prefer_local,omitempty"`
	PreferProvider       string                    `json:"prefer_provider,omitempty"` // force-route to named provider
	MaxCostUSD           *float64                  `json:"max_cost_usd,omitempty"`
	RequiredCapabilities []Capability              `json:"required_capabilities,omitempty"`
	Source               string                    `json:"source,omitempty"`
	SalienceSnapshot     *ProviderSalienceSnapshot `json:"salience_snapshot,omitempty"`
}

type RequestPriority int

type Router interface {
	// Route selects the best provider for a request.
	Route(ctx context.Context, req *CompletionRequest) (Provider, *RoutingDecision, error)

	// RegisterProvider adds a provider to the pool.
	RegisterProvider(p Provider)

	// DeregisterProvider removes a provider.
	DeregisterProvider(name string)

	// Stats returns routing statistics.
	Stats() RouterStats
}

type RouterStats struct {
	TotalRequests                int64                    `json:"total_requests"`
	RequestsByProvider           map[string]int64         `json:"requests_by_provider"`
	ToolCallRejectionsByProvider map[string]int64         `json:"tool_call_rejections_by_provider,omitempty"`
	EscalationCount              int64                    `json:"escalation_count"`
	FallbackCount                int64                    `json:"fallback_count"`
	SovereigntyRatio             float64                  `json:"sovereignty_ratio"`
	TotalCostUSD                 float64                  `json:"total_cost_usd"`
	TokensByProvider             map[string]TokenUsage    `json:"tokens_by_provider"`
	AvgLatencyByProvider         map[string]time.Duration `json:"avg_latency_by_provider"`
}

type RoutingConfig struct {
	Default             string            `yaml:"default" json:"default"`
	LocalThreshold      float64           `yaml:"local_threshold" json:"local_threshold"`
	FallbackChain       []string          `yaml:"fallback_chain" json:"fallback_chain"`
	MaxCostPerDayUSD    float64           `yaml:"max_cost_per_day_usd,omitempty" json:"max_cost_per_day_usd,omitempty"`
	ProcessStateRouting map[string]string `yaml:"process_state_routing,omitempty" json:"process_state_routing,omitempty"`
}

type RoutingDecision struct {
	RequestID        string          `json:"request_id"`
	SelectedProvider string          `json:"selected_provider"`
	Scores           []ProviderScore `json:"scores"`
	Reason           string          `json:"reason"`
	Escalated        bool            `json:"escalated"`
	FallbackUsed     bool            `json:"fallback_used"`
	FallbackFrom     string          `json:"fallback_from,omitempty"`
	Timestamp        time.Time       `json:"timestamp"`
	LatencyNs        int64           `json:"latency_ns"`
}

type SalienceConfig struct {
	WeightRecency    float64
	WeightFrequency  float64
	WeightChurn      float64
	WeightAuthorship float64
	DecayModel       string
	HalfLife         int // days
}

type SalienceScore struct {
	Recency       float64
	Frequency     float64
	Churn         float64
	Authorship    float64
	Total         float64
	CommitCount   int
	TotalChanges  int
	UniqueAuthors int
	DaysAgo       int
}

type ScoreHead struct {
	W1   [][]float32 // [d_model][2*d_model]
	B1   []float32   // [d_model]
	W2   [][]float32 // [1][d_model]
	B2   []float32   // [1]
	DIn  int         // 2*d_model
	DMid int         // d_model
}

type ScoredMessage struct {
	Role           string
	Content        string
	Tokens         int
	TurnIndex      int     // 0 = oldest
	RecencyScore   float64 // 1.0 = most recent, decays toward 0
	RelevanceScore float64 // keyword overlap with current query
	CombinedScore  float64 // weighted combination
}

type Server struct {
	// contains filtered or unexported fields
}

type ServiceDef struct {
	Port      int             `yaml:"port" json:"port"`
	Binary    string          `yaml:"binary,omitempty" json:"binary,omitempty"`
	Workdir   string          `yaml:"workdir,omitempty" json:"workdir,omitempty"`
	Venv      string          `yaml:"venv,omitempty" json:"venv,omitempty"`
	Command   string          `yaml:"command" json:"command"`
	Health    string          `yaml:"health" json:"health"`
	Restart   string          `yaml:"restart" json:"restart"`
	Launchd   string          `yaml:"launchd,omitempty" json:"launchd,omitempty"`
	DependsOn []string        `yaml:"depends_on" json:"depends_on"`
	Consumers []ConsumerEntry `yaml:"consumers,omitempty" json:"consumers,omitempty"`
}

type ServiceHealth struct {
	Port   int       `json:"port"`
	Status string    `json:"status"` // healthy, degraded, down
	At     time.Time `json:"probed_at"`
}

type SimpleRouter struct {
	// contains filtered or unexported fields
}

type StreamChunk struct {
	Delta         string         `json:"delta,omitempty"`
	ToolCallDelta *ToolCallDelta `json:"tool_call_delta,omitempty"`
	Done          bool           `json:"done"`
	StopReason    string         `json:"stop_reason,omitempty"`   // e.g. "end_turn", "max_tokens", "tool_use"
	Usage         *TokenUsage    `json:"usage,omitempty"`         // populated on final chunk
	ProviderMeta  *ProviderMeta  `json:"provider_meta,omitempty"` // populated on final chunk
	Error         error          `json:"-"`
}

type StreamTailer interface {
	// Tail starts watching a file/directory for new JSONL lines.
	// It sends normalized CogBlocks on the output channel.
	// It respects context cancellation for graceful shutdown.
	Tail(ctx context.Context, path string, out chan<- CogBlock) error
	// Name returns the adapter name (e.g., "claude-code", "openclaw").
	Name() string
}

type StubProvider struct {
	// contains filtered or unexported fields
}

type SyncEnvelope struct {
	Version      int    `json:"version"`
	OriginNodeID string `json:"origin_node_id"`
	TargetNodeID string `json:"target_node_id"`
	BlobHash     string `json:"blob_hash"`
	Timestamp    string `json:"timestamp"`
	Kind         string `json:"kind"`
	Signature    string `json:"signature"`
}

type SyncEvent struct {
	Envelope        SyncEnvelope
	FilePath        string
	Valid           bool
	ValidationError string
	AlreadyHave     bool
}

type SyncWatcher struct {
	BlobStore    *BlobStore
	PollInterval time.Duration
}

type TRMConfig struct {
	DModel     int // embedding dimension (384)
	DState     int // SSM state dimension (4)
	DConv      int // convolution kernel width (2)
	NLayers    int // number of Mamba blocks (2)
	Expand     int // expansion factor (1)
	NProbes    int // number of attention probes (4)
	DHead      int // attention head dimension (128)
	NEventType int // number of event types (4)
}

type TailerManager struct {
	// contains filtered or unexported fields
}

type TailerStats struct {
	EventsIngested uint64
	Errors         uint64
	LastEventTime  time.Time
}

type TokenUsage struct {
	InputTokens      int `json:"input_tokens"`
	OutputTokens     int `json:"output_tokens"`
	CacheReadTokens  int `json:"cache_read_tokens,omitempty"`
	CacheWriteTokens int `json:"cache_write_tokens,omitempty"`
}

type ToolCall struct {
	ID        string `json:"id"`
	Name      string `json:"name"`
	Arguments string `json:"arguments"`
}

type ToolCallDelta struct {
	Index     int    `json:"index"`
	ID        string `json:"id,omitempty"`
	Name      string `json:"name,omitempty"`
	ArgsDelta string `json:"args_delta,omitempty"`
}

type ToolDefinition struct {
	Name        string                 `json:"name"`
	Description string                 `json:"description"`
	InputSchema map[string]interface{} `json:"input_schema"`
}

type TrajectoryModel struct {
	// contains filtered or unexported fields
}

type TrustContext = cogblock.TrustContext

type TrustState struct {
	LocalScore           float64   `json:"local_score"`
	LastHeartbeatHash    string    `json:"last_heartbeat_hash,omitempty"`
	LastHeartbeatAt      time.Time `json:"last_heartbeat_at,omitempty"`
	CoherenceFingerprint string    `json:"coherence_fingerprint,omitempty"`
}

type URIResolution struct {
	// Path is the absolute filesystem path.
	Path string
	// Fragment is the section anchor stripped from the URI (empty if none).
	Fragment string
}

type ValidationResult struct {
	Pass       bool        `json:"pass"`
	Layer      string      `json:"layer"`
	Diagnostic *Diagnostic `json:"diagnostic,omitempty"`
	Timestamp  string      `json:"timestamp"`
}