Uses of Class
org.linuxforhealth.fhir.bucket.api.ResourceEntry
-
Packages that use ResourceEntry Package Description org.linuxforhealth.fhir.bucket.api org.linuxforhealth.fhir.bucket.persistence org.linuxforhealth.fhir.bucket.scanner -
-
Uses of ResourceEntry in org.linuxforhealth.fhir.bucket.api
Methods in org.linuxforhealth.fhir.bucket.api with parameters of type ResourceEntry Modifier and Type Method Description void
IResourceEntryProcessor. process(ResourceEntry re)
Process the resource entry (usually called from within a thread-poolboolean
IResourceHandler. process(ResourceEntry entry)
Add the resource entry to the thread-pool for processing, subject to the rate limiting we have to make sure memory consumption is kept in check -
Uses of ResourceEntry in org.linuxforhealth.fhir.bucket.persistence
Methods in org.linuxforhealth.fhir.bucket.persistence with parameters of type ResourceEntry Modifier and Type Method Description void
LogicalIdRecorder. recordLogicalId(ResourceEntry entry, java.lang.String logicalId, int responseTimeMs)
Save the new logical id and map it to the bundle it came from -
Uses of ResourceEntry in org.linuxforhealth.fhir.bucket.scanner
Methods in org.linuxforhealth.fhir.bucket.scanner with parameters of type ResourceEntry Modifier and Type Method Description void
BundleBreakerResourceProcessor. process(ResourceEntry re)
void
FHIRClientResourceProcessor. process(ResourceEntry re)
boolean
ResourceHandler. process(ResourceEntry entry)
protected void
FHIRClientResourceProcessor. processBadRequest(ResourceEntry re, FhirServerResponse response)
Record the error in the databaseConstructor parameters in org.linuxforhealth.fhir.bucket.scanner with type arguments of type ResourceEntry Constructor Description BaseFileReader(java.util.concurrent.ExecutorService commonPool, FileType fileType, java.util.function.Consumer<ResourceEntry> resourceHandler, int maxInflight, DataAccess da, boolean incremental, int recycleSeconds, boolean incrementalExact, double bundleCostFactor, java.util.Collection<BucketPath> bucketPaths)
Public constructorCOSReader(java.util.concurrent.ExecutorService commonPool, FileType fileType, COSClient client, java.util.function.Consumer<ResourceEntry> resourceHandler, int maxInflight, DataAccess da, boolean incremental, int recycleSeconds, boolean incrementalExact, double bundleCostFactor, java.util.Collection<BucketPath> bucketPaths)
Public constructorImmediateLocalFileReader(java.util.concurrent.ExecutorService commonPool, java.util.Set<FileType> fileTypes, java.lang.String baseDirectory, java.util.function.Consumer<ResourceEntry> resourceHandler, int maxInflight, double bundleCostFactor)
Public constructorLocalFileReader(java.util.concurrent.ExecutorService commonPool, FileType fileType, java.util.function.Consumer<ResourceEntry> resourceHandler, int maxInflight, DataAccess da, boolean incremental, int recycleSeconds, boolean incrementalExact, double bundleCostFactor, java.util.Collection<BucketPath> bucketPaths)
Public constructor
-