Package org.linuxforhealth.fhir.operation.bulkdata.client

Class BulkDataClient

java.lang.Object

org.linuxforhealth.fhir.operation.bulkdata.client.BulkDataClient

public class BulkDataClient
extends java.lang.Object

BulkData Client to connect to the other server.

Constructor Summary

Constructors

Constructor	Description
BulkDataClient(java.lang.String bulkdataSource, java.lang.String outcomeSource, java.lang.String incomingUrl, java.lang.String baseUri, ConfigurationAdapter adapter)

Method Summary

Modifier and Type	Method	Description
javax.ws.rs.core.Response.Status	delete(java.lang.String job)	deletes the given job.
void	handleStandardResponseStatus(int httpStatus)
PollingLocationResponse	status(java.lang.String job)
java.lang.String	submitExport(Instant since, java.util.Set<java.lang.String> types, OperationConstants.ExportType exportType, java.lang.String outputFormat, java.lang.String typeFilters, java.lang.String groupId)	Submit the export job.
java.lang.String	submitImport(java.lang.String inputFormat, java.lang.String inputSource, java.util.List<Input> inputs, StorageDetail storageDetail)	submit import job with bulkdata.
void	verifyTenant(JobParameter jobParameters)	verifies the tenant based on the job parameters.

Methods inherited from class java.lang.Object

clone, equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

BulkDataClient

public BulkDataClient(java.lang.String bulkdataSource,
                      java.lang.String outcomeSource,
                      java.lang.String incomingUrl,
                      java.lang.String baseUri,
                      ConfigurationAdapter adapter)

Parameters:

bulkdataSource - the source

outcomeSource -

incomingUrl -

baseUri -

adapter -

Method Detail

submitExport

public java.lang.String submitExport(Instant since,
                                     java.util.Set<java.lang.String> types,
                                     OperationConstants.ExportType exportType,
                                     java.lang.String outputFormat,
                                     java.lang.String typeFilters,
                                     java.lang.String groupId)
                              throws java.lang.Exception

Submit the export job.

Parameters:

since -

types -

exportType -

outputFormat -

typeFilters -

groupId -

Returns:

Throws:

java.lang.Exception

status

public PollingLocationResponse status(java.lang.String job)
                               throws java.lang.Exception

Parameters:

job -

Returns:

a PollingLocationResponse or null if the job is still running

Throws:

java.lang.Exception

handleStandardResponseStatus

public void handleStandardResponseStatus(int httpStatus)
                                  throws FHIROperationException

Throws:

FHIROperationException

delete

public javax.ws.rs.core.Response.Status delete(java.lang.String job)
                                        throws FHIROperationException

deletes the given job.

Parameters:

job -

Returns:

status code

Throws:

FHIROperationException

verifyTenant

public void verifyTenant(JobParameter jobParameters)
                  throws FHIROperationException

verifies the tenant based on the job parameters.

Parameters:

jobParameters -

Throws:

FHIROperationException

submitImport

public java.lang.String submitImport(java.lang.String inputFormat,
                                     java.lang.String inputSource,
                                     java.util.List<Input> inputs,
                                     StorageDetail storageDetail)
                              throws java.lang.Exception

submit import job with bulkdata.

Parameters:

inputFormat -

inputSource -

inputs -

storageDetail -

Returns:

Throws:

java.lang.Exception