Class SearchCoordinatorSvcImpl

java.lang.Object
ca.uhn.fhir.jpa.search.SearchCoordinatorSvcImpl
All Implemented Interfaces:
ca.uhn.fhir.jpa.api.svc.ISearchCoordinatorSvc

@Component("mySearchCoordinatorSvc") public class SearchCoordinatorSvcImpl extends Object implements ca.uhn.fhir.jpa.api.svc.ISearchCoordinatorSvc
  • Constructor Summary

    Constructors
    Constructor
    Description
    SearchCoordinatorSvcImpl(ca.uhn.fhir.context.FhirContext theContext, ca.uhn.fhir.jpa.api.config.DaoConfig theDaoConfig, ca.uhn.fhir.interceptor.api.IInterceptorBroadcaster theInterceptorBroadcaster, org.springframework.transaction.PlatformTransactionManager theManagedTxManager, ISearchCacheSvc theSearchCacheSvc, ISearchResultCacheSvc theSearchResultCacheSvc, ca.uhn.fhir.jpa.api.dao.DaoRegistry theDaoRegistry, ca.uhn.fhir.jpa.dao.SearchBuilderFactory theSearchBuilderFactory, ISynchronousSearchSvc theSynchronousSearchSvc, PersistedJpaBundleProviderFactory thePersistedJpaBundleProviderFactory, ca.uhn.fhir.jpa.partition.IRequestPartitionHelperSvc theRequestPartitionHelperService, ca.uhn.fhir.rest.server.util.ISearchParamRegistry theSearchParamRegistry, SearchStrategyFactory theSearchStrategyFactory, ExceptionService theExceptionSvc, org.springframework.beans.factory.BeanFactory theBeanFactory)
    Constructor
  • Method Summary

    Modifier and Type
    Method
    Description
    void
     
    List<ca.uhn.fhir.rest.api.server.storage.ResourcePersistentId>
    getResources(String theUuid, int theFrom, int theTo, ca.uhn.fhir.rest.api.server.RequestDetails theRequestDetails)
    This method is called by the HTTP client processing thread in order to fetch resources.
     
    ca.uhn.fhir.rest.api.server.IBundleProvider
    registerSearch(ca.uhn.fhir.jpa.api.dao.IFhirResourceDao<?> theCallingDao, SearchParameterMap theParams, String theResourceType, ca.uhn.fhir.rest.api.CacheControlDirective theCacheControlDirective, ca.uhn.fhir.rest.api.server.RequestDetails theRequestDetails, ca.uhn.fhir.interceptor.model.RequestPartitionId theRequestPartitionId)
     
    void
    setLoadingThrottleForUnitTests(Integer theLoadingThrottleForUnitTests)
     
    void
    setNeverUseLocalSearchForUnitTests(boolean theNeverUseLocalSearchForUnitTests)
     
    void
    setSyncSizeForUnitTests(int theSyncSize)
     
    static org.springframework.data.domain.Pageable
    toPage(int theFromIndex, int theToIndex)
    Creates a Pageable using a start and end index

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
  • Constructor Details

    • SearchCoordinatorSvcImpl

      public SearchCoordinatorSvcImpl(ca.uhn.fhir.context.FhirContext theContext, ca.uhn.fhir.jpa.api.config.DaoConfig theDaoConfig, ca.uhn.fhir.interceptor.api.IInterceptorBroadcaster theInterceptorBroadcaster, org.springframework.transaction.PlatformTransactionManager theManagedTxManager, ISearchCacheSvc theSearchCacheSvc, ISearchResultCacheSvc theSearchResultCacheSvc, ca.uhn.fhir.jpa.api.dao.DaoRegistry theDaoRegistry, ca.uhn.fhir.jpa.dao.SearchBuilderFactory theSearchBuilderFactory, ISynchronousSearchSvc theSynchronousSearchSvc, PersistedJpaBundleProviderFactory thePersistedJpaBundleProviderFactory, ca.uhn.fhir.jpa.partition.IRequestPartitionHelperSvc theRequestPartitionHelperService, ca.uhn.fhir.rest.server.util.ISearchParamRegistry theSearchParamRegistry, SearchStrategyFactory theSearchStrategyFactory, ExceptionService theExceptionSvc, org.springframework.beans.factory.BeanFactory theBeanFactory)
      Constructor
  • Method Details

    • setLoadingThrottleForUnitTests

      public void setLoadingThrottleForUnitTests(Integer theLoadingThrottleForUnitTests)
    • setNeverUseLocalSearchForUnitTests

      public void setNeverUseLocalSearchForUnitTests(boolean theNeverUseLocalSearchForUnitTests)
    • setSyncSizeForUnitTests

      public void setSyncSizeForUnitTests(int theSyncSize)
    • cancelAllActiveSearches

      public void cancelAllActiveSearches()
      Specified by:
      cancelAllActiveSearches in interface ca.uhn.fhir.jpa.api.svc.ISearchCoordinatorSvc
    • getResources

      @Transactional(propagation=NEVER) public List<ca.uhn.fhir.rest.api.server.storage.ResourcePersistentId> getResources(String theUuid, int theFrom, int theTo, @Nullable ca.uhn.fhir.rest.api.server.RequestDetails theRequestDetails)
      This method is called by the HTTP client processing thread in order to fetch resources.
      Specified by:
      getResources in interface ca.uhn.fhir.jpa.api.svc.ISearchCoordinatorSvc
    • registerSearch

      public ca.uhn.fhir.rest.api.server.IBundleProvider registerSearch(ca.uhn.fhir.jpa.api.dao.IFhirResourceDao<?> theCallingDao, SearchParameterMap theParams, String theResourceType, ca.uhn.fhir.rest.api.CacheControlDirective theCacheControlDirective, ca.uhn.fhir.rest.api.server.RequestDetails theRequestDetails, ca.uhn.fhir.interceptor.model.RequestPartitionId theRequestPartitionId)
      Specified by:
      registerSearch in interface ca.uhn.fhir.jpa.api.svc.ISearchCoordinatorSvc
    • getSearchTotal

      Specified by:
      getSearchTotal in interface ca.uhn.fhir.jpa.api.svc.ISearchCoordinatorSvc
    • toPage

      @Nullable public static org.springframework.data.domain.Pageable toPage(int theFromIndex, int theToIndex)
      Creates a Pageable using a start and end index