Struct RelayKnowledgeService 

pub struct RelayKnowledgeService { /* private fields */ }

Shared application service used by CLI, Web, and future API adapters.

Implementations

impl RelayKnowledgeService

pub async fn codegraph_context( &self, request: CodeGraphContextRequest, context: RequestContext, ) -> Result<CodeGraphContextResponse, ApiError>

Builds an agent-oriented codegraph context pack with bounded graph expansion.

impl RelayKnowledgeService

pub async fn register_code_repository( &self, request: CodeRepositoryRegisterRequest, context: RequestContext, ) -> Result<CodeRepositoryRegisterResponse, ApiError>

Registers a Git repository as a code source.

pub async fn remove_code_repository( &self, repository: String, context: RequestContext, ) -> Result<CodeRepositoryRemoveResponse, ApiError>

Removes a registered code repository and its derived index state.

pub async fn index_code_repository( &self, request: CodeIndexRequest, context: RequestContext, ) -> Result<CodeRepositoryIndexResponse, ApiError>

Builds or updates the tree-sitter code index for a registered repository.

pub async fn start_code_repository_index( &self, request: CodeIndexRequest, context: RequestContext, ) -> Result<CodeRepositoryIndexStartResponse, ApiError>

Starts a repository index request, queueing cold full indexes for background execution.

pub async fn run_code_index_task_once( &self, task_id: Option<String>, context: RequestContext, ) -> Result<Option<CodeIndexTaskRecord>, ApiError>

Runs one queued code index task under a lease.

pub async fn preview_code_repository_scope( &self, request: CodeIndexRequest, context: RequestContext, ) -> Result<CodeRepositoryScopePreviewResponse, ApiError>

Previews the effective code repository indexing scope without writing rows.

pub async fn query_code_repository( &self, request: CodeRetrievalRequest, context: RequestContext, ) -> Result<CodeRepositoryQueryResponse, ApiError>

Queries indexed symbols, references, imports, calls, and code chunks.

pub async fn query_code_repository_feature_flags( &self, request: CodeFeatureFlagRequest, context: RequestContext, ) -> Result<CodeRepositoryFeatureFlagsResponse, ApiError>

Lists configuration-driven feature flags and their code graph relationships.

pub async fn impact_code_repository( &self, request: CodeImpactRequest, context: RequestContext, ) -> Result<CodeRepositoryImpactResponse, ApiError>

Returns impact radius for a Git diff using the indexed code graph.

pub async fn code_repository_status( &self, selector: CodeRepositorySelector, context: RequestContext, ) -> Result<CodeRepositoryStatusResponse, ApiError>

pub async fn code_repository_report( &self, selector: CodeRepositorySelector, context: RequestContext, ) -> Result<CodeRepositoryReportResponse, ApiError>

Builds a reusable operations report for a registered code repository.

impl RelayKnowledgeService

pub async fn remove_code_repository_set_member( &self, request: CodeRepositorySetRemoveMemberRequest, context: RequestContext, ) -> Result<CodeRepositorySetRemoveResponse, ApiError>

Removes one member snapshot from a repository set and releases its retention pin.

impl RelayKnowledgeService

pub async fn create_code_repository_set( &self, request: CodeRepositorySetCreateRequest, context: RequestContext, ) -> Result<CodeRepositorySetCreateResponse, ApiError>

Creates or updates a thin repository set.

pub async fn add_code_repository_set_member( &self, request: CodeRepositorySetAddMemberRequest, context: RequestContext, ) -> Result<CodeRepositorySetAddResponse, ApiError>

Adds one already-indexed repository snapshot to a repository set.

pub async fn query_code_repository_set( &self, request: CodeRepositorySetQueryRequest, context: RequestContext, ) -> Result<CodeRepositorySetQueryResponse, ApiError>

Queries every member scope and merges ranked candidates without changing single-repo search.

pub async fn code_repository_set_status( &self, set_alias: String, context: RequestContext, ) -> Result<CodeRepositorySetStatusResponse, ApiError>

Returns repository-set freshness and member diagnostics.

pub async fn refresh_code_repository_set( &self, set_alias: String, context: RequestContext, ) -> Result<CodeRepositorySetRefreshResponse, ApiError>

Rebuilds cross-repository import/module overlay edges.

pub async fn start_code_repository_set_refresh( &self, set_alias: String, context: RequestContext, ) -> Result<CodeRepositorySetRefreshResponse, ApiError>

Queues a repository-set overlay refresh task.

pub async fn run_code_repository_set_refresh_task_once( &self, task_id: Option<String>, context: RequestContext, ) -> Result<Option<CodeRepositorySetRefreshTaskRecord>, ApiError>

Runs one queued repository-set overlay refresh task under a lease.

impl RelayKnowledgeService

pub async fn software_global_projection( &self, request: SoftwareGlobalRequest, context: RequestContext, ) -> Result<SoftwareGlobalResponse, ApiError>

Reads the repository-scoped software global dependency and SDK projection.

impl RelayKnowledgeService

pub async fn reset_code_repository_index_tasks( &self, repository: String, context: RequestContext, ) -> Result<CodeRepositoryIndexResetResponse, ApiError>

Resets unfinished full index tasks for a registered repository.

pub async fn reconcile_startup_code_index_tasks(&self) -> Result<(), ApiError>

Reconciles expired or orphaned repository index leases before resident workers start.

impl RelayKnowledgeService

pub async fn codebase_view( &self, request: CodebaseViewRequest, context: RequestContext, ) -> Result<CodebaseViewResponse, ApiError>

Builds a deterministic, evidence-backed repository understanding view.

impl RelayKnowledgeService

pub async fn index_files( &self, request: FileIndexRequest, context: RequestContext, ) -> Result<FileIndexResponse, ApiError>

Scans configured or explicit file roots into the local file-location index.

pub async fn index_configured_files_once( &self, ) -> Result<FileIndexResponse, ApiError>

Runs one scan over configured roots when background file indexing is enabled.

pub async fn query_files( &self, request: FileQueryRequest, context: RequestContext, ) -> Result<FileQueryResponse, ApiError>

Queries the local file-location index with bounded latency.

pub async fn query_file_content( &self, request: FileContentQueryRequest, context: RequestContext, ) -> Result<FileContentQueryResponse, ApiError>

Queries the local file-content read model with provenance and role isolation.

impl RelayKnowledgeService

pub async fn model_profiles(&self) -> Result<ModelProfilesResponse, ApiError>

Lists redacted model provider profiles.

pub async fn save_model_profile( &self, name: &str, request: ModelProfileSaveRequest, ) -> Result<ModelProfilesResponse, ApiError>

Saves a model provider profile and returns the redacted profile list.

pub async fn delete_model_profile( &self, name: &str, ) -> Result<ModelProfilesResponse, ApiError>

Deletes a model provider profile and returns the redacted profile list.

pub async fn model_fallback_config( &self, ) -> Result<ModelFallbackConfig, ApiError>

Returns model fallback policy configuration.

pub async fn save_model_fallback_config( &self, config: ModelFallbackConfig, ) -> Result<ModelFallbackConfig, ApiError>

Saves model fallback policy configuration.

pub async fn model_catalog( &self, refresh: bool, ) -> Result<ModelCatalogResult, ApiError>

Returns the cached or refreshed public model catalog.

pub async fn probe_model_provider( &self, request: ModelConnectivityProbeRequest, ) -> Result<ModelConnectivityProbeResult, ApiError>

Probes a configured or overridden model profile.

pub async fn discover_model_provider( &self, request: ModelDiscoveryRequest, ) -> Result<ModelDiscoveryResult, ApiError>

Discovers models from a configured or overridden model profile.

impl RelayKnowledgeService

pub async fn health( &self, context: RequestContext, ) -> Result<HealthResponse, ApiError>

Returns liveness-safe service and data health diagnostics.

pub async fn read_only_health( &self, context: RequestContext, ) -> Result<HealthResponse, ApiError>

Returns control-plane health without opening cold graph storage.

impl RelayKnowledgeService

pub async fn service_status( &self, context: RequestContext, ) -> Result<ServiceStatusResponse, ApiError>

Returns the managed background service definition location and defaults.

pub async fn read_only_service_status( &self, context: RequestContext, ) -> Result<ServiceStatusResponse, ApiError>

Returns control-plane service diagnostics without opening cold storage.

impl RelayKnowledgeService

pub async fn storage_topology_diagnostics(&self) -> StorageTopologyDiagnostics

Returns storage topology diagnostics without exposing concrete storage handles.

pub async fn storage_topology_status( &self, context: RequestContext, ) -> Result<StorageTopologyResponse, ApiError>

impl RelayKnowledgeService

pub async fn start_code_repository_watcher( &self, ) -> Result<Option<WatcherHandle>, ApiError>

pub async fn stop_code_repository_watcher(&self)

impl RelayKnowledgeService

pub fn new(runtime: RuntimeConfiguration) -> Self

Creates a service from already validated foundational configuration.

pub fn with_store( runtime: RuntimeConfiguration, store: Arc<dyn KnowledgeStore>, ) -> Self

Creates a service backed by an explicit store for deterministic tests.

pub async fn from_process_environment() -> Result<Self, RuntimeConfigurationError>

Creates a service by reading the current process environment once.

pub async fn from_environment( environment: &EnvironmentConfig, ) -> Result<Self, RuntimeConfigurationError>

Creates a service from a deterministic environment snapshot.

pub async fn refresh_network_from_environment( &self, environment: &EnvironmentConfig, ) -> Result<(), RuntimeConfigurationError>

Applies network-related settings from a typed environment snapshot.

pub async fn refresh_network_from_process_environment( &self, ) -> Result<(), RuntimeConfigurationError>

Re-reads process environment variables and applies network changes.

pub fn observability(&self) -> ObservabilityRuntime

Returns the shared observability runtime for interface adapters.

pub fn model_provider_config(&self) -> ModelProviderConfigService

Returns the model provider configuration service rooted in runtime paths.

pub async fn check_for_updates( &self, force_refresh: bool, ) -> VersionCheckResponse

Checks configured release sources without opening graph storage.

pub async fn record_agent_audit( &self, event: AgentDurableAuditInput, ) -> Result<(), ApiError>

Persists a redacted agent protocol audit event through the durable sink.

pub async fn project_status( &self, context: RequestContext, ) -> Result<ProjectStatusResponse, ApiError>

Returns the current project status through the unified API contract.

pub fn runtime_diagnostics( &self, context: RequestContext, ) -> (ProjectStatusResponse, AgentProtocolStatus)

Returns runtime diagnostics without opening or migrating graph storage.

pub async fn ingest( &self, request: IngestRequest, context: RequestContext, ) -> Result<IngestResponse, ApiError>

Commits evidence into graph storage and refreshes all v1 index metadata.

pub async fn commit_multimodal_extraction( &self, request: MultimodalExtractionRequest, context: RequestContext, ) -> Result<MultimodalExtractionResponse, ApiError>

Commits derived multimodal worker output through the same bounded ingest path.

pub async fn retrieve_context( &self, request: HybridRetrievalRequest, context: RequestContext, ) -> Result<HybridRetrievalResponse, ApiError>

Retrieves context through the unified hybrid retrieval contract.

pub async fn inspect_graph( &self, _request: GraphInspectionRequest, context: RequestContext, ) -> Result<GraphInspectionResponse, ApiError>

Returns graph inspection information without exposing storage internals.

pub async fn graph_canvas( &self, request: GraphCanvasRequest, context: RequestContext, ) -> Result<GraphCanvasResponse, ApiError>

Returns a bounded read-only graph canvas snapshot for the Web workspace.

pub async fn refresh_indexes( &self, request: IndexRefreshRequest, context: RequestContext, ) -> Result<IndexRefreshResponse, ApiError>

Refreshes derived index metadata up to the current graph version.

pub async fn probe_embedding_provider( &self, context: RequestContext, ) -> Result<EmbeddingProviderProbeResponse, ApiError>

Probes the configured remote embedding provider without exposing secrets.

pub async fn reconcile_startup_indexes( &self, context: RequestContext, ) -> Result<ServiceRecoveryReport, ApiError>

Reconciles derived index cursors before resident service work starts.

pub fn storage_is_ready(&self) -> bool

Returns whether graph storage has already been opened by this service.

pub async fn run_code_index_worker_preview( &self, request: CodeIndexWorkerRunRequest, context: RequestContext, ) -> Result<CodeIndexWorkerRunResponse, ApiError>

Runs one split-worker preview code-index attempt through durable task leases.

pub fn agent_audit_log_path(&self) -> PathBuf

Returns the persistent agent audit log path resolved by the path boundary.

impl RelayKnowledgeService

pub async fn worker_status( &self, request: WorkerStatusRequest, context: RequestContext, ) -> Result<WorkerStatusResponse, ApiError>

Returns worker queue and backend readiness status.

pub async fn run_worker_once( &self, request: WorkerRunRequest, context: RequestContext, ) -> Result<WorkerRunResponse, ApiError>

Runs one bounded worker task in the foreground.

pub async fn list_proposals( &self, request: ProposalListApiRequest, context: RequestContext, ) -> Result<ProposalListResponse, ApiError>

Lists proposals awaiting or past manual lifecycle decisions.

pub async fn show_proposal( &self, proposal_id: String, context: RequestContext, ) -> Result<ProposalShowResponse, ApiError>

Shows one proposal and its conflict details.

pub async fn accept_proposal( &self, proposal_id: String, request: ProposalDecisionApiRequest, context: RequestContext, ) -> Result<ProposalDecisionResponse, ApiError>

Accepts a proposal by committing its payload through the graph pipeline.

pub async fn decide_proposal_without_commit( &self, proposal_id: String, next_state: ProposalState, request: ProposalDecisionApiRequest, context: RequestContext, ) -> Result<ProposalDecisionResponse, ApiError>

Rejects or supersedes a proposal without mutating graph facts.

pub async fn query_audit( &self, request: AuditQueryApiRequest, context: RequestContext, ) -> Result<AuditQueryResponse, ApiError>

Queries the durable audit sink.

pub async fn service_plan( &self, request: ServicePlanRequest, context: RequestContext, ) -> Result<ServicePlanResponse, ApiError>

Generates a service-manager plan without executing privileged commands.

pub async fn write_service_definition( &self, context: RequestContext, ) -> Result<ServiceDefinitionWriteResponse, ApiError>

Writes the generated service definition into the service directory.

pub async fn service_operator_status( &self, context: RequestContext, ) -> Result<ServiceOperatorResponse, ApiError>

Returns persisted silent-update operator status.

pub async fn set_service_operator_state( &self, state: ServiceOperatorState, context: RequestContext, ) -> Result<ServiceOperatorResponse, ApiError>

Pauses or resumes the silent-update operator.

Trait Implementations

impl Clone for RelayKnowledgeService

fn clone(&self) -> RelayKnowledgeService

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.