spring-boot-demo/com.ainsoft.rag.demo

Package-level declarations

Types

ApiErrorResponse

data class ApiErrorResponse(val code: String, val message: String)

ApiExceptionHandler

@RestControllerAdvice

class ApiExceptionHandler

DemoApplication

@SpringBootApplication

class DemoApplication

DemoSampleController

@RestController

@RequestMapping(value = ["/api/rag/demo"])

class DemoSampleController(sampleDataService: DemoSampleDataService)

DemoSampleDataService

@Service

class DemoSampleDataService(engine: RagEngine)

DemoSampleLoadResponse

data class DemoSampleLoadResponse(val status: String, val tenantId: String, val principals: List<String>, val suggestedQuery: String, val docIds: List<String>)

FrontendController

@Controller

class FrontendController

IngestRequest

data class IngestRequest(val tenantId: String, val docId: String, val text: String, val acl: List<String>, val metadata: Map<String, String> = emptyMap(), val sourceUri: String? = null, val page: Int? = null, val pageMarkers: List<PageMarkerRequest>? = null)

IngestResponse

data class IngestResponse(val status: String, val tenantId: String, val docId: String)

PageMarkerRequest

data class PageMarkerRequest(val page: Int, val offsetStart: Int, val offsetEnd: Int)

ProviderEndpointDeltaResponse

data class ProviderEndpointDeltaResponse(val provider: String, val requestDelta: Long, val successDelta: Long, val failureDelta: Long, val retryDelta: Long, val circuitOpenDelta: Long, val avgLatencyDeltaMillis: Double, val p95LatencyDeltaMillis: Double)

ProviderEndpointResponse

data class ProviderEndpointResponse(val provider: String, val requestCount: Long, val successCount: Long, val failureCount: Long, val retryCount: Long, val circuitOpenCount: Long, val avgLatencyMillis: Double, val p95LatencyMillis: Double, val circuitOpen: Boolean, val lastError: String?)

ProviderHealthApiResponse

data class ProviderHealthApiResponse(val providerTelemetry: ProviderTelemetryResponse, val recentProviderWindowMillis: Long? = null, val recentProviderTelemetry: ProviderTelemetryResponse? = null, val providerTelemetryDelta: ProviderTelemetryDeltaResponse? = null, val providerEndpointDeltas: List<ProviderEndpointDeltaResponse> = emptyList(), val providerTenantScopeDeltas: List<ProviderScopeDeltaResponse> = emptyList(), val providerCommandScopeDeltas: List<ProviderScopeDeltaResponse> = emptyList())

ProviderHealthDeltaSection

data class ProviderHealthDeltaSection(val overall: ProviderTelemetryDeltaResponse, val endpoints: List<ProviderEndpointDeltaResponse> = emptyList(), val tenantScopes: List<ProviderScopeDeltaResponse> = emptyList(), val commandScopes: List<ProviderScopeDeltaResponse> = emptyList())

ProviderHealthObservabilityResponse

data class ProviderHealthObservabilityResponse(val generatedAtEpochMillis: Long, val global: ProviderHealthSnapshotSection, val recent: ProviderHealthSnapshotSection? = null, val delta: ProviderHealthDeltaSection? = null)

ProviderHealthSnapshotSection

data class ProviderHealthSnapshotSection(val windowMillis: Long? = null, val telemetry: ProviderTelemetryResponse)

ProviderScopeDeltaResponse

data class ProviderScopeDeltaResponse(val scopeType: String, val scope: String, val requestDelta: Long, val successDelta: Long, val failureDelta: Long, val retryDelta: Long, val circuitOpenDelta: Long, val avgLatencyDeltaMillis: Double, val p95LatencyDeltaMillis: Double)

ProviderScopeResponse

data class ProviderScopeResponse(val scope: String, val requestCount: Long, val successCount: Long, val failureCount: Long, val retryCount: Long, val circuitOpenCount: Long, val avgLatencyMillis: Double, val p95LatencyMillis: Double)

ProviderTelemetryDeltaResponse

data class ProviderTelemetryDeltaResponse(val requestDelta: Long, val successDelta: Long, val failureDelta: Long, val retryDelta: Long, val circuitOpenDelta: Long, val failureRateDeltaPct: Double, val avgLatencyDeltaMillis: Double, val p95LatencyDeltaMillis: Double)

ProviderTelemetryResponse

data class ProviderTelemetryResponse(val requestCount: Long, val successCount: Long, val failureCount: Long, val retryCount: Long, val circuitOpenCount: Long, val avgLatencyMillis: Double, val p95LatencyMillis: Double, val endpoints: List<ProviderEndpointResponse>, val tenantScopes: List<ProviderScopeResponse>, val commandScopes: List<ProviderScopeResponse>)

RagController

@RestController

@RequestMapping(value = ["/api/rag"])

class RagController(engine: RagEngine, properties: RagProperties, ragConfig: RagConfig, embeddingProvider: EmbeddingProvider)

SearchApiRequest

data class SearchApiRequest(val tenantId: String, val principals: List<String>, val query: String, val topK: Int = 8, val filter: Map<String, String> = emptyMap(), val openSource: Boolean = false, val snippetContext: Int = 160, val sourceCharset: String = "UTF-8", val sourceLoadProfile: String? = null, val providerHealthDetail: Boolean = false, val recentProviderWindowMillis: Long? = null, val diagnosticScoreThreshold: Double = Double.NEGATIVE_INFINITY, val diagnosticMaxSamples: Int = 5)

SearchApiResponse

data class SearchApiResponse(val tenantId: String, val query: String, val hits: List<SearchHitResponse>, val meta: SearchMetaResponse)

SearchDiagnosticsApiResponse

data class SearchDiagnosticsApiResponse(val tenantId: String, val query: String, val derivedEmptyReason: String, val tenantDocs: Int, val lexicalMatchesWithoutAcl: Int, val vectorMatchesWithoutAcl: Int, val lexicalMatchesWithAcl: Int, val vectorMatchesWithAcl: Int, val lexicalSampleDocIdsWithoutAcl: List<String>, val vectorSampleDocIdsWithoutAcl: List<String>, val lexicalSampleDocIdsWithAcl: List<String>, val vectorSampleDocIdsWithAcl: List<String>, val executedQuery: String, val queryRewriteApplied: Boolean, val queryRewriterType: String?, val correctiveRetryApplied: Boolean, val initialConfidence: Double?, val finalConfidence: Double?, val rerankerType: String?, val summaryCandidatesUsed: Boolean, val providerFallbackApplied: Boolean, val providerFallbackReason: String?, val providersUsed: List<String>, val notes: List<String>, val providerHealthSummary: ProviderTelemetryResponse, val recentProviderWindowMillis: Long? = null, val recentProviderHealthSummary: ProviderTelemetryResponse? = null, val providerTelemetryDelta: ProviderTelemetryDeltaResponse? = null, val providerEndpointDeltas: List<ProviderEndpointDeltaResponse> = emptyList(), val providerTenantScopeDeltas: List<ProviderScopeDeltaResponse> = emptyList(), val providerCommandScopeDeltas: List<ProviderScopeDeltaResponse> = emptyList())

SearchHitResponse

data class SearchHitResponse(val docId: String, val chunkId: String, val score: Double, val text: String?, val contentKind: String, val page: Int?, val sourceUri: String?, val offsetStart: Int?, val offsetEnd: Int?, val sourceSnippet: String?, val snippetStatus: String, val snippetDetail: SnippetDetailResponse?, val metadata: Map<String, String>)

SearchMetaResponse

data class SearchMetaResponse(val resultCount: Int, val requestedTopK: Int, val principalCount: Int, val aclApplied: Boolean, val filterApplied: Boolean, val openSourceRequested: Boolean, val sourceLoadProfile: String?, val emptyReason: String?, val snippetAvailableCount: Int, val snippetStatusCounts: Map<String, Int>, val executedQuery: String, val queryRewriteApplied: Boolean, val queryRewriterType: String?, val correctiveRetryApplied: Boolean, val initialConfidence: Double?, val finalConfidence: Double?, val rerankerType: String?, val summaryCandidatesUsed: Boolean, val providerFallbackApplied: Boolean, val providerFallbackReason: String?, val providersUsed: List<String>, val notes: List<String>, val providerHealthSummary: ProviderTelemetryResponse, val recentProviderWindowMillis: Long? = null, val recentProviderHealthSummary: ProviderTelemetryResponse? = null, val providerTelemetryDelta: ProviderTelemetryDeltaResponse? = null, val providerEndpointDeltas: List<ProviderEndpointDeltaResponse> = emptyList(), val providerTenantScopeDeltas: List<ProviderScopeDeltaResponse> = emptyList(), val providerCommandScopeDeltas: List<ProviderScopeDeltaResponse> = emptyList())

SnippetDetailResponse

data class SnippetDetailResponse(val code: String, val message: String, val retryable: Boolean)

SpaFallbackControllerAdvice

@ControllerAdvice

@Order(value = -2147483648)

class SpaFallbackControllerAdvice

StatsResponse

data class StatsResponse(val tenantId: String?, val docs: Long, val chunks: Long, val snapshotCount: Int, val indexSizeBytes: Long, val lastCommitEpochMillis: Long?, val lastCommitIso: String?, val statsCacheEntries: Int, val statsCacheHitCount: Long, val statsCacheMissCount: Long, val statsCacheEvictionCount: Long, val statsCacheExpiredCount: Long, val statsCacheHitRatePct: Double, val statsCacheTtlMillis: Long, val statsCacheMaxEntries: Int, val statsCacheMaxEntriesPerTenant: Int, val statsCachePersistenceMode: String, val providerTelemetry: ProviderTelemetryResponse, val recentProviderWindowMillis: Long? = null, val recentProviderTelemetry: ProviderTelemetryResponse? = null, val providerTelemetryDelta: ProviderTelemetryDeltaResponse? = null, val providerEndpointDeltas: List<ProviderEndpointDeltaResponse> = emptyList(), val providerTenantScopeDeltas: List<ProviderScopeDeltaResponse> = emptyList(), val providerCommandScopeDeltas: List<ProviderScopeDeltaResponse> = emptyList())

Functions

main

fun main(args: Array<String>)