Struct RelayKnowledgeService 

pub struct RelayKnowledgeService { /* private fields */ }

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

Implementations

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 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 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 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>

Returns the current code repository index status.

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 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.

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 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.

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 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 health( &self, context: RequestContext, ) -> Result<HealthResponse, ApiError>

Returns service and data health for diagnostics.

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 async fn service_status( &self, context: RequestContext, ) -> Result<ServiceStatusResponse, ApiError>

Returns the managed background service definition location and defaults.

pub fn agent_audit_log_path(&self) -> PathBuf

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

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.