Enum SearchEngineBackend 

pub enum SearchEngineBackend {
    Elasticsearch(ElasticSearchEngine<ElasticSearchParameterResolver<PGConnection>>),
    Postgres(PgSearchEngine<PgSearchParameterResolver<PGConnection>>),
}

A configured search engine.

The concrete engines differ in their resolver type, so a caller holding one generically would have to thread that type everywhere. This dispatches instead, which is what lets the server and the worker switch backends by configuration alone.

Variants

Elasticsearch(ElasticSearchEngine<ElasticSearchParameterResolver<PGConnection>>)

Postgres(PgSearchEngine<PgSearchParameterResolver<PGConnection>>)

Implementations

impl SearchEngineBackend

pub async fn is_connected(&self) -> Result<(), OperationOutcomeError>

Whether the backend is reachable, for a caller that waits on it at startup.

Errors

Returns an error if the backend cannot be reached.

pub const fn name(&self) -> &'static str

What this backend is, for logging that has to say which one it waited on.

pub const fn lock_kind(&self) -> SearchIndexBackend

Which search_index_locks row this backend’s indexing progress is tracked under.

Trait Implementations

impl Clone for SearchEngineBackend

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl SearchEngine for SearchEngineBackend

async fn search( &self, fhir_version: &SupportedFHIRVersions, tenant: &TenantId, project: &ProjectId, search_request: &SearchRequest, options: Option<SearchOptions>, ) -> Result<SearchReturn, OperationOutcomeError>

async fn index( &self, fhir_version: SupportedFHIRVersions, resource: Vec<IndexResource>, ) -> Result<IndexOutcome, OperationOutcomeError>

async fn migrate( &self, fhir_version: &SupportedFHIRVersions, ) -> Result<(), OperationOutcomeError>