Package fr.gouv.vitam.metadata.client
Class MetaDataClientRest
- java.lang.Object
-
- fr.gouv.vitam.common.client.DefaultClient
-
- fr.gouv.vitam.metadata.client.MetaDataClientRest
-
- All Implemented Interfaces:
BasicClient
,MockOrRestClient
,VitamAutoCloseable
,MetaDataClient
,java.lang.AutoCloseable
public class MetaDataClientRest extends DefaultClient implements MetaDataClient
-
-
Field Summary
-
Fields inherited from interface fr.gouv.vitam.common.client.BasicClient
STATUS_URL
-
-
Constructor Summary
Constructors Constructor Description MetaDataClientRest(VitamClientFactoryInterface<MetaDataClient> factory)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description RequestResponse<com.fasterxml.jackson.databind.JsonNode>
atomicUpdateBulk(java.util.List<com.fasterxml.jackson.databind.JsonNode> updateQueries)
Bulk Update units by a list of update query (DSL)void
checkStatus()
Check the status from the servicevoid
checkStatus(javax.ws.rs.core.MultivaluedHashMap<java.lang.String,java.lang.Object> headers)
Check the status from the service used to passe "X-SSL-CLIENT-CERT" header that contain a pem certificatevoid
close()
Close the underneath http clientGraphComputeResponse
computeGraph(com.fasterxml.jackson.databind.JsonNode queryDsl)
Compute graph of all Units/Got that match the given query dsl The returned number of treated object group is an estimation, as object group can be computed several timesGraphComputeResponse
computeGraph(GraphComputeResponse.GraphComputeAction action, java.util.Set<java.lang.String> ids)
Compute graph of all document match ids.void
consumeAnyEntityAndClose(javax.ws.rs.core.Response response)
Helper when an error occurs on client usage side to consume response howevercom.fasterxml.jackson.databind.JsonNode
createAccessionRegisterSymbolic()
Creates the AccessionRegisterSymbolics from ElasticSearch aggregations and nested aggregation request.void
deleteObjectGroupBulk(java.util.Collection<java.lang.String> listIds)
Delete Object Group Bulkvoid
deleteUnitsBulk(java.util.Collection<java.lang.String> listIds)
delete UnitsBulkvoid
exportReclassificationChildNodes(java.util.Set<java.lang.String> ids, java.lang.String unitsToUpdateJsonLineFileName, java.lang.String objectGroupsToUpdateJsonLineFileName)
Export all units and object groups that are a descendants of the provided units to workspace for graph update.javax.ws.rs.client.Client
getChunkedClient()
javax.ws.rs.client.Client
getClient()
VitamClientFactory<?>
getClientFactory()
RequestResponse<com.fasterxml.jackson.databind.JsonNode>
getObjectGroupByIdRaw(java.lang.String objectGroupId)
Search object group by path unit idRequestResponse<com.fasterxml.jackson.databind.JsonNode>
getObjectGroupsByIdsRaw(java.util.Collection<java.lang.String> objectGroupId)
Select raw object group by idsjava.lang.String
getResourcePath()
Get the resource path of the server.java.lang.String
getServiceUrl()
Get the service URLRequestResponse<com.fasterxml.jackson.databind.JsonNode>
getUnitByIdRaw(java.lang.String unitId)
Search units by path unit idRequestResponse<com.fasterxml.jackson.databind.JsonNode>
getUnitsByIdsRaw(java.util.Collection<java.lang.String> unitIds)
Select raw unis by idscom.fasterxml.jackson.databind.JsonNode
insertObjectGroup(com.fasterxml.jackson.databind.JsonNode insertQuery)
com.fasterxml.jackson.databind.JsonNode
insertObjectGroups(java.util.List<com.fasterxml.jackson.databind.JsonNode> insertQueries)
com.fasterxml.jackson.databind.JsonNode
insertUnitBulk(BulkUnitInsertRequest request)
javax.ws.rs.core.Response
make(VitamRequestBuilder request)
javax.ws.rs.core.Response
makeSpecifyingUrl(VitamRequestBuilder request)
javax.ws.rs.core.Response
processObsoleteComputedInheritedRules()
API to process obsolete compute inherited rules service for metadatas.javax.ws.rs.core.Response
purgeExpiredDipFiles()
API to process purge expired DIP files service for metadatas.javax.ws.rs.core.Response
purgeExpiredTransfersSIPFiles()
API to process purge expired tranfering SIP files service for metadatas.java.util.List<ReconstructionResponseItem>
reconstructCollection(java.util.List<ReconstructionRequestItem> reconstructionItems)
API to access and launch the Vitam reconstruction service for metadatas.boolean
refreshObjectGroups()
boolean
refreshUnits()
com.fasterxml.jackson.databind.JsonNode
reindex(IndexParameters indexParam)
Reindex a collection with parametersjavax.ws.rs.core.Response
runAuditDataConsistencyMongoEs()
API to process audit data consistency Mongo and ES service for metadatas.java.util.List<ObjectGroupPerOriginatingAgency>
selectAccessionRegisterOnObjectByOperationId(java.lang.String operationId)
java.util.List<UnitPerOriginatingAgency>
selectAccessionRegisterOnUnitByOperationId(java.lang.String operationId)
com.fasterxml.jackson.databind.JsonNode
selectObjectGroups(com.fasterxml.jackson.databind.JsonNode selectQuery)
Search objectgroups by select query (DSL)com.fasterxml.jackson.databind.JsonNode
selectObjectGrouptbyId(com.fasterxml.jackson.databind.JsonNode selectQuery, java.lang.String objectGroupId)
Search Object Group by query (DSL) and path objectGroup idcom.fasterxml.jackson.databind.JsonNode
selectUnitbyId(com.fasterxml.jackson.databind.JsonNode selectQuery, java.lang.String unitId)
Search units by query (DSL) and path unit idcom.fasterxml.jackson.databind.JsonNode
selectUnits(com.fasterxml.jackson.databind.JsonNode selectQuery)
Search units by select query (DSL)java.util.List<RequestResponseOK<com.fasterxml.jackson.databind.JsonNode>>
selectUnitsBulk(java.util.List<com.fasterxml.jackson.databind.JsonNode> selectQueryBulk)
Bulk Search units by a list of select query (DSL)com.fasterxml.jackson.databind.JsonNode
selectUnitsWithInheritedRules(com.fasterxml.jackson.databind.JsonNode selectQuery)
Select units with inherited rules by select query (DSL)static void
staticConsumeAnyEntityAndClose(javax.ws.rs.core.Response response)
This method consume everything (in particular InputStream) and close the response.javax.ws.rs.core.Response
storeGraph()
API to access and launch the Vitam store graph service for metadatas.javax.ws.rs.core.Response
streamObjects(com.fasterxml.jackson.databind.JsonNode selectQuery)
javax.ws.rs.core.Response
streamUnits(com.fasterxml.jackson.databind.JsonNode selectQuery)
SwitchIndexResult
switchIndexes(SwitchIndexParameters switchIndexParam)
Switch indexesjava.lang.String
toString()
void
updateObjectGroupById(com.fasterxml.jackson.databind.JsonNode queryUpdate, java.lang.String objectGroupId)
Update ObjectGroupRequestResponse<com.fasterxml.jackson.databind.JsonNode>
updateUnitBulk(com.fasterxml.jackson.databind.JsonNode updateQuery)
Update units Bulk.com.fasterxml.jackson.databind.JsonNode
updateUnitById(com.fasterxml.jackson.databind.JsonNode updateQuery, java.lang.String unitId)
Update units by query (DSL) and path unit idRequestResponse<com.fasterxml.jackson.databind.JsonNode>
updateUnitsRulesBulk(java.util.List<java.lang.String> unitsIds, RuleActions actions, java.util.Map<java.lang.String,DurationData> rulesToDurationData)
Update units rules Bulk.-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
-
Methods inherited from interface fr.gouv.vitam.common.client.MockOrRestClient
checkStatus, checkStatus, close, consumeAnyEntityAndClose, getResourcePath, getServiceUrl
-
-
-
-
Constructor Detail
-
MetaDataClientRest
public MetaDataClientRest(VitamClientFactoryInterface<MetaDataClient> factory)
-
-
Method Detail
-
insertUnitBulk
public com.fasterxml.jackson.databind.JsonNode insertUnitBulk(BulkUnitInsertRequest request) throws InvalidParseOperationException, MetaDataExecutionException, MetaDataNotFoundException, MetaDataDocumentSizeException, MetaDataClientServerException
-
selectUnits
public com.fasterxml.jackson.databind.JsonNode selectUnits(com.fasterxml.jackson.databind.JsonNode selectQuery) throws MetaDataExecutionException, MetaDataDocumentSizeException, InvalidParseOperationException, MetaDataClientServerException
Description copied from interface:MetaDataClient
Search units by select query (DSL)- Specified by:
selectUnits
in interfaceMetaDataClient
- Parameters:
selectQuery
- : select querySelectMultiQuery
as String
Null is not allowed- Returns:
- Json object {$hint:{},$result:[{},{}]}
- Throws:
MetaDataExecutionException
- thrown when internal Server Error (fatal technical exception thrown)MetaDataDocumentSizeException
- thrown when Query document Size is Too LargeInvalidParseOperationException
MetaDataClientServerException
-
selectUnitsBulk
public java.util.List<RequestResponseOK<com.fasterxml.jackson.databind.JsonNode>> selectUnitsBulk(java.util.List<com.fasterxml.jackson.databind.JsonNode> selectQueryBulk) throws MetaDataExecutionException, MetaDataDocumentSizeException, InvalidParseOperationException, MetaDataClientServerException
Description copied from interface:MetaDataClient
Bulk Search units by a list of select query (DSL)- Specified by:
selectUnitsBulk
in interfaceMetaDataClient
- Returns:
- RequestResponse object {$hint:{},$result:[{},{}]} containing a list of RequestResponse (RequestResponseOK or VitamError) as JsonNode linked to each selectQuery
- Throws:
MetaDataExecutionException
- thrown when internal Server Error (fatal technical exception thrown)MetaDataDocumentSizeException
- thrown when Query document Size is Too LargeInvalidParseOperationException
MetaDataClientServerException
-
selectObjectGroups
public com.fasterxml.jackson.databind.JsonNode selectObjectGroups(com.fasterxml.jackson.databind.JsonNode selectQuery) throws MetaDataExecutionException, MetaDataDocumentSizeException, InvalidParseOperationException, MetaDataClientServerException
Description copied from interface:MetaDataClient
Search objectgroups by select query (DSL)- Specified by:
selectObjectGroups
in interfaceMetaDataClient
- Parameters:
selectQuery
- : select querySelectMultiQuery
as String
Null is not allowed- Returns:
- Json object {$hint:{},$result:[{},{}]}
- Throws:
MetaDataExecutionException
- thrown when internal Server Error (fatal technical exception thrown)MetaDataDocumentSizeException
- thrown when Query document Size is Too LargeInvalidParseOperationException
MetaDataClientServerException
-
selectUnitbyId
public com.fasterxml.jackson.databind.JsonNode selectUnitbyId(com.fasterxml.jackson.databind.JsonNode selectQuery, java.lang.String unitId) throws MetaDataExecutionException, MetaDataDocumentSizeException, InvalidParseOperationException, MetaDataClientServerException
Description copied from interface:MetaDataClient
Search units by query (DSL) and path unit id- Specified by:
selectUnitbyId
in interfaceMetaDataClient
- Parameters:
selectQuery
- : select querySelect
as JsonNode
Null is not allowedunitId
- : unit id
null and blank is not allowed- Returns:
- Json object {$hint:{},$result:[{},{}]}
- Throws:
MetaDataExecutionException
- thrown when internal Server Error (fatal technical exception thrown)MetaDataDocumentSizeException
- thrown when Query document Size is Too LargeInvalidParseOperationException
MetaDataClientServerException
-
selectObjectGrouptbyId
public com.fasterxml.jackson.databind.JsonNode selectObjectGrouptbyId(com.fasterxml.jackson.databind.JsonNode selectQuery, java.lang.String objectGroupId) throws MetaDataExecutionException, MetaDataNotFoundException, MetaDataDocumentSizeException, InvalidParseOperationException, MetaDataClientServerException
Description copied from interface:MetaDataClient
Search Object Group by query (DSL) and path objectGroup id- Specified by:
selectObjectGrouptbyId
in interfaceMetaDataClient
- Parameters:
selectQuery
- : select querySelect
as JsonNode
Null is not allowedobjectGroupId
- : objectGroup id
null and blank is not allowed- Returns:
- Json object {$hint:{},$result:[{},{}]}
- Throws:
MetaDataExecutionException
- thrown when internal Server Error (fatal technical exception thrown)MetaDataNotFoundException
MetaDataDocumentSizeException
- thrown when Query document Size is Too LargeInvalidParseOperationException
- thrown when the Query is badly formatted or objectGroupId is emptyMetaDataClientServerException
-
updateUnitById
public com.fasterxml.jackson.databind.JsonNode updateUnitById(com.fasterxml.jackson.databind.JsonNode updateQuery, java.lang.String unitId) throws MetaDataExecutionException, MetaDataDocumentSizeException, InvalidParseOperationException, MetaDataClientServerException, MetaDataNotFoundException
Description copied from interface:MetaDataClient
Update units by query (DSL) and path unit id- Specified by:
updateUnitById
in interfaceMetaDataClient
- Parameters:
updateQuery
- update querySelect
as JsonNode
Null is not allowedunitId
- unit id
null and blank is not allowed- Returns:
- Json object {$hint:{},$result:[{},{}]}
- Throws:
MetaDataExecutionException
- thrown when internal Server Error (fatal technical exception thrown)MetaDataDocumentSizeException
- thrown when Query document Size is Too LargeInvalidParseOperationException
MetaDataClientServerException
MetaDataNotFoundException
-
insertObjectGroup
public com.fasterxml.jackson.databind.JsonNode insertObjectGroup(com.fasterxml.jackson.databind.JsonNode insertQuery) throws InvalidParseOperationException, MetaDataExecutionException, MetaDataNotFoundException, MetaDataDocumentSizeException, MetaDataClientServerException
- Specified by:
insertObjectGroup
in interfaceMetaDataClient
- Parameters:
insertQuery
- as String- Returns:
- response as JsonNode contains the request result
- Throws:
InvalidParseOperationException
MetaDataExecutionException
MetaDataNotFoundException
MetaDataDocumentSizeException
MetaDataClientServerException
-
insertObjectGroups
public com.fasterxml.jackson.databind.JsonNode insertObjectGroups(java.util.List<com.fasterxml.jackson.databind.JsonNode> insertQueries) throws InvalidParseOperationException, MetaDataExecutionException, MetaDataNotFoundException, MetaDataDocumentSizeException, MetaDataClientServerException
-
updateObjectGroupById
public void updateObjectGroupById(com.fasterxml.jackson.databind.JsonNode queryUpdate, java.lang.String objectGroupId) throws InvalidParseOperationException, MetaDataClientServerException, MetaDataExecutionException
Description copied from interface:MetaDataClient
Update ObjectGroup- Specified by:
updateObjectGroupById
in interfaceMetaDataClient
- Throws:
InvalidParseOperationException
MetaDataClientServerException
MetaDataExecutionException
-
selectAccessionRegisterOnUnitByOperationId
public java.util.List<UnitPerOriginatingAgency> selectAccessionRegisterOnUnitByOperationId(java.lang.String operationId) throws MetaDataClientServerException
- Specified by:
selectAccessionRegisterOnUnitByOperationId
in interfaceMetaDataClient
- Returns:
- the list of UnitsPerOriginatingAgency
- Throws:
MetaDataClientServerException
-
selectAccessionRegisterOnObjectByOperationId
public java.util.List<ObjectGroupPerOriginatingAgency> selectAccessionRegisterOnObjectByOperationId(java.lang.String operationId) throws MetaDataClientServerException
- Specified by:
selectAccessionRegisterOnObjectByOperationId
in interfaceMetaDataClient
- Returns:
- the list of ObjectGroupPerOriginatingAgency
- Throws:
MetaDataClientServerException
-
refreshUnits
public boolean refreshUnits() throws MetaDataClientServerException
- Specified by:
refreshUnits
in interfaceMetaDataClient
- Returns:
- True if the Units index is refreshed
- Throws:
MetaDataClientServerException
-
refreshObjectGroups
public boolean refreshObjectGroups() throws MetaDataClientServerException
- Specified by:
refreshObjectGroups
in interfaceMetaDataClient
- Returns:
- True if the ObjectGroups index is refreshed
- Throws:
MetaDataClientServerException
-
reindex
public com.fasterxml.jackson.databind.JsonNode reindex(IndexParameters indexParam) throws InvalidParseOperationException, MetaDataClientServerException, MetaDataNotFoundException
Description copied from interface:MetaDataClient
Reindex a collection with parameters- Specified by:
reindex
in interfaceMetaDataClient
- Parameters:
indexParam
- reindexation parameters- Returns:
- JsonObject containing information about the newly created index
- Throws:
InvalidParseOperationException
MetaDataClientServerException
MetaDataNotFoundException
- in case the index does not exist
-
switchIndexes
public SwitchIndexResult switchIndexes(SwitchIndexParameters switchIndexParam) throws InvalidParseOperationException, MetaDataClientServerException, MetaDataNotFoundException
Description copied from interface:MetaDataClient
Switch indexes- Specified by:
switchIndexes
in interfaceMetaDataClient
- Parameters:
switchIndexParam
- switch index parameters- Returns:
- JsonObject containing information about the newly created index
- Throws:
InvalidParseOperationException
MetaDataClientServerException
MetaDataNotFoundException
- in case the index does not exist
-
getUnitByIdRaw
public RequestResponse<com.fasterxml.jackson.databind.JsonNode> getUnitByIdRaw(java.lang.String unitId) throws VitamClientException
Description copied from interface:MetaDataClient
Search units by path unit id- Specified by:
getUnitByIdRaw
in interfaceMetaDataClient
- Parameters:
unitId
- : unit id
null and blank is not allowed- Returns:
- Json object {$hint:{},$result:[{}]} or vitam error
- Throws:
VitamClientException
-
getUnitsByIdsRaw
public RequestResponse<com.fasterxml.jackson.databind.JsonNode> getUnitsByIdsRaw(java.util.Collection<java.lang.String> unitIds) throws VitamClientException
Description copied from interface:MetaDataClient
Select raw unis by ids- Specified by:
getUnitsByIdsRaw
in interfaceMetaDataClient
- Parameters:
unitIds
- : unit ids
null and blank is not allowed- Returns:
- Json object {$hint:{},$result:[{}]} or vitam error
- Throws:
VitamClientException
-
getObjectGroupByIdRaw
public RequestResponse<com.fasterxml.jackson.databind.JsonNode> getObjectGroupByIdRaw(java.lang.String objectGroupId) throws VitamClientException
Description copied from interface:MetaDataClient
Search object group by path unit id- Specified by:
getObjectGroupByIdRaw
in interfaceMetaDataClient
- Parameters:
objectGroupId
- : objectGroup id
null and blank is not allowed- Returns:
- Json object {$hint:{},$result:[{}]} or vitam error
- Throws:
VitamClientException
-
getObjectGroupsByIdsRaw
public RequestResponse<com.fasterxml.jackson.databind.JsonNode> getObjectGroupsByIdsRaw(java.util.Collection<java.lang.String> objectGroupId) throws VitamClientException
Description copied from interface:MetaDataClient
Select raw object group by ids- Specified by:
getObjectGroupsByIdsRaw
in interfaceMetaDataClient
- Parameters:
objectGroupId
- : object group ids
null and blank is not allowed- Returns:
- Json object {$hint:{},$result:[{}]} or vitam error
- Throws:
VitamClientException
-
computeGraph
public GraphComputeResponse computeGraph(com.fasterxml.jackson.databind.JsonNode queryDsl) throws VitamClientException
Description copied from interface:MetaDataClient
Compute graph of all Units/Got that match the given query dsl The returned number of treated object group is an estimation, as object group can be computed several times- Specified by:
computeGraph
in interfaceMetaDataClient
- Returns:
- GraphComputeResponse
- Throws:
VitamClientException
-
computeGraph
public GraphComputeResponse computeGraph(GraphComputeResponse.GraphComputeAction action, java.util.Set<java.lang.String> ids) throws VitamClientException
Description copied from interface:MetaDataClient
Compute graph of all document match ids. The document can be UNIT, OBJECTGROUP, or UNIT AND OBJECTGROUP In case of UNIT AND OBJECTGROUP, the ids set is id of UNITs- Specified by:
computeGraph
in interfaceMetaDataClient
- Returns:
- GraphComputeResponse
- Throws:
VitamClientException
-
exportReclassificationChildNodes
public void exportReclassificationChildNodes(java.util.Set<java.lang.String> ids, java.lang.String unitsToUpdateJsonLineFileName, java.lang.String objectGroupsToUpdateJsonLineFileName) throws VitamClientException, MetaDataExecutionException
Description copied from interface:MetaDataClient
Export all units and object groups that are a descendants of the provided units to workspace for graph update.- Specified by:
exportReclassificationChildNodes
in interfaceMetaDataClient
- Parameters:
ids
- the unit ids for which all descendant nodes (units and object groups) are to be updated.- Throws:
VitamClientException
MetaDataExecutionException
-
deleteUnitsBulk
public void deleteUnitsBulk(java.util.Collection<java.lang.String> listIds) throws MetaDataExecutionException, MetaDataClientServerException
Description copied from interface:MetaDataClient
delete UnitsBulk- Specified by:
deleteUnitsBulk
in interfaceMetaDataClient
- Parameters:
listIds
- list of id to delete- Throws:
MetaDataExecutionException
- MetaDataExecutionExceptionMetaDataClientServerException
- MetaDataClientServerException
-
deleteObjectGroupBulk
public void deleteObjectGroupBulk(java.util.Collection<java.lang.String> listIds) throws MetaDataExecutionException, MetaDataClientServerException
Description copied from interface:MetaDataClient
Delete Object Group Bulk- Specified by:
deleteObjectGroupBulk
in interfaceMetaDataClient
- Parameters:
listIds
- list of id to delete- Throws:
MetaDataExecutionException
- MetaDataExecutionExceptionMetaDataClientServerException
- MetaDataClientServerException
-
storeGraph
public javax.ws.rs.core.Response storeGraph() throws MetaDataNotFoundException, MetaDataDocumentSizeException, MetaDataExecutionException, InvalidParseOperationException, MetaDataClientServerException
Description copied from interface:MetaDataClient
API to access and launch the Vitam store graph service for metadatas.- Specified by:
storeGraph
in interfaceMetaDataClient
- Returns:
- Throws:
MetaDataExecutionException
- MetaDataExecutionExceptionMetaDataClientServerException
- MetaDataClientServerExceptionMetaDataNotFoundException
MetaDataDocumentSizeException
InvalidParseOperationException
-
reconstructCollection
public java.util.List<ReconstructionResponseItem> reconstructCollection(java.util.List<ReconstructionRequestItem> reconstructionItems) throws MetaDataNotFoundException, InvalidParseOperationException, MetaDataClientServerException
Description copied from interface:MetaDataClient
API to access and launch the Vitam reconstruction service for metadatas.- Specified by:
reconstructCollection
in interfaceMetaDataClient
- Parameters:
reconstructionItems
- list of reconstruction request items- Returns:
- Throws:
MetaDataClientServerException
- MetaDataClientServerExceptionMetaDataNotFoundException
InvalidParseOperationException
-
updateUnitBulk
public RequestResponse<com.fasterxml.jackson.databind.JsonNode> updateUnitBulk(com.fasterxml.jackson.databind.JsonNode updateQuery) throws InvalidParseOperationException, MetaDataExecutionException, MetaDataNotFoundException, MetaDataDocumentSizeException, MetaDataClientServerException
Description copied from interface:MetaDataClient
Update units Bulk.- Specified by:
updateUnitBulk
in interfaceMetaDataClient
- Returns:
- Throws:
InvalidParseOperationException
MetaDataExecutionException
MetaDataNotFoundException
MetaDataDocumentSizeException
MetaDataClientServerException
-
atomicUpdateBulk
public RequestResponse<com.fasterxml.jackson.databind.JsonNode> atomicUpdateBulk(java.util.List<com.fasterxml.jackson.databind.JsonNode> updateQueries) throws InvalidParseOperationException, MetaDataExecutionException, MetaDataNotFoundException, MetaDataDocumentSizeException, MetaDataClientServerException
Description copied from interface:MetaDataClient
Bulk Update units by a list of update query (DSL)- Specified by:
atomicUpdateBulk
in interfaceMetaDataClient
- Parameters:
updateQueries
- : update queryUpdateMultiQuery
as String Null is not allowed List can be empty- Returns:
- RequestResponse object {$hint:{},$result:[{},{}]} containing a list of RequestResponse (RequestResponseOK or VitamError) as JsonNode linked to each updateQuery
- Throws:
InvalidParseOperationException
MetaDataExecutionException
MetaDataNotFoundException
MetaDataDocumentSizeException
MetaDataClientServerException
-
updateUnitsRulesBulk
public RequestResponse<com.fasterxml.jackson.databind.JsonNode> updateUnitsRulesBulk(java.util.List<java.lang.String> unitsIds, RuleActions actions, java.util.Map<java.lang.String,DurationData> rulesToDurationData) throws InvalidParseOperationException, MetaDataExecutionException, MetaDataNotFoundException, MetaDataDocumentSizeException, MetaDataClientServerException
Description copied from interface:MetaDataClient
Update units rules Bulk.- Specified by:
updateUnitsRulesBulk
in interfaceMetaDataClient
- Parameters:
unitsIds
- the bulk unit ids to update- Returns:
- Throws:
InvalidParseOperationException
MetaDataExecutionException
MetaDataNotFoundException
MetaDataDocumentSizeException
MetaDataClientServerException
-
selectUnitsWithInheritedRules
public com.fasterxml.jackson.databind.JsonNode selectUnitsWithInheritedRules(com.fasterxml.jackson.databind.JsonNode selectQuery) throws MetaDataDocumentSizeException, InvalidParseOperationException, MetaDataClientServerException, MetaDataExecutionException
Description copied from interface:MetaDataClient
Select units with inherited rules by select query (DSL)- Specified by:
selectUnitsWithInheritedRules
in interfaceMetaDataClient
- Parameters:
selectQuery
- : select query- Returns:
- Json object
- Throws:
MetaDataDocumentSizeException
- thrown when Query document Size is Too LargeInvalidParseOperationException
MetaDataClientServerException
MetaDataExecutionException
-
createAccessionRegisterSymbolic
public com.fasterxml.jackson.databind.JsonNode createAccessionRegisterSymbolic() throws MetaDataClientServerException, MetaDataExecutionException
Description copied from interface:MetaDataClient
Creates the AccessionRegisterSymbolics from ElasticSearch aggregations and nested aggregation request. Because the AccessionRegisterSymbolic is not available from this package, it is a JsonNode which is returned.- Specified by:
createAccessionRegisterSymbolic
in interfaceMetaDataClient
- Returns:
- a list of AccessionRegisterSymbolic as JsonNode
- Throws:
MetaDataClientServerException
MetaDataExecutionException
-
streamUnits
public javax.ws.rs.core.Response streamUnits(com.fasterxml.jackson.databind.JsonNode selectQuery) throws MetaDataClientServerException, MetadataScrollThresholdExceededException, MetadataScrollLimitExceededException
- Specified by:
streamUnits
in interfaceMetaDataClient
- Throws:
MetaDataClientServerException
MetadataScrollThresholdExceededException
MetadataScrollLimitExceededException
-
streamObjects
public javax.ws.rs.core.Response streamObjects(com.fasterxml.jackson.databind.JsonNode selectQuery) throws MetaDataClientServerException, MetadataScrollThresholdExceededException, MetadataScrollLimitExceededException
- Specified by:
streamObjects
in interfaceMetaDataClient
- Throws:
MetaDataClientServerException
MetadataScrollThresholdExceededException
MetadataScrollLimitExceededException
-
processObsoleteComputedInheritedRules
public javax.ws.rs.core.Response processObsoleteComputedInheritedRules() throws MetaDataNotFoundException, InvalidParseOperationException, MetaDataClientServerException
Description copied from interface:MetaDataClient
API to process obsolete compute inherited rules service for metadatas.- Specified by:
processObsoleteComputedInheritedRules
in interfaceMetaDataClient
- Returns:
- Throws:
MetaDataClientServerException
- MetaDataClientServerException InvalidParseOperationExceptionMetaDataNotFoundException
InvalidParseOperationException
-
purgeExpiredDipFiles
public javax.ws.rs.core.Response purgeExpiredDipFiles() throws MetaDataNotFoundException, InvalidParseOperationException, MetaDataClientServerException
Description copied from interface:MetaDataClient
API to process purge expired DIP files service for metadatas.- Specified by:
purgeExpiredDipFiles
in interfaceMetaDataClient
- Returns:
- Throws:
MetaDataClientServerException
- MetaDataClientServerException InvalidParseOperationExceptionMetaDataNotFoundException
InvalidParseOperationException
-
purgeExpiredTransfersSIPFiles
public javax.ws.rs.core.Response purgeExpiredTransfersSIPFiles() throws MetaDataNotFoundException, InvalidParseOperationException, MetaDataClientServerException
Description copied from interface:MetaDataClient
API to process purge expired tranfering SIP files service for metadatas.- Specified by:
purgeExpiredTransfersSIPFiles
in interfaceMetaDataClient
- Returns:
- Throws:
MetaDataClientServerException
- MetaDataClientServerException InvalidParseOperationExceptionMetaDataNotFoundException
InvalidParseOperationException
-
runAuditDataConsistencyMongoEs
public javax.ws.rs.core.Response runAuditDataConsistencyMongoEs() throws MetaDataNotFoundException, InvalidParseOperationException, MetaDataClientServerException
Description copied from interface:MetaDataClient
API to process audit data consistency Mongo and ES service for metadatas.- Specified by:
runAuditDataConsistencyMongoEs
in interfaceMetaDataClient
- Returns:
- Throws:
MetaDataClientServerException
- MetaDataClientServerException InvalidParseOperationExceptionMetaDataNotFoundException
InvalidParseOperationException
-
staticConsumeAnyEntityAndClose
public static void staticConsumeAnyEntityAndClose(javax.ws.rs.core.Response response)
This method consume everything (in particular InputStream) and close the response.- Parameters:
response
-
-
consumeAnyEntityAndClose
public final void consumeAnyEntityAndClose(javax.ws.rs.core.Response response)
Description copied from interface:MockOrRestClient
Helper when an error occurs on client usage side to consume response however- Specified by:
consumeAnyEntityAndClose
in interfaceMockOrRestClient
-
checkStatus
public void checkStatus() throws VitamApplicationServerException
Description copied from interface:MockOrRestClient
Check the status from the service- Specified by:
checkStatus
in interfaceMockOrRestClient
- Throws:
VitamApplicationServerException
- if the Server is unavailable
-
checkStatus
public void checkStatus(javax.ws.rs.core.MultivaluedHashMap<java.lang.String,java.lang.Object> headers) throws VitamApplicationServerException
Description copied from interface:MockOrRestClient
Check the status from the service used to passe "X-SSL-CLIENT-CERT" header that contain a pem certificate- Specified by:
checkStatus
in interfaceMockOrRestClient
- Throws:
VitamApplicationServerException
- if the Server is unavailable
-
getResourcePath
public java.lang.String getResourcePath()
Description copied from interface:MockOrRestClient
Get the resource path of the server.- Specified by:
getResourcePath
in interfaceMockOrRestClient
- Returns:
- the resource path as string
-
getServiceUrl
public java.lang.String getServiceUrl()
Description copied from interface:MockOrRestClient
Get the service URL- Specified by:
getServiceUrl
in interfaceMockOrRestClient
- Returns:
- the service URL
-
close
public void close()
Description copied from interface:MockOrRestClient
Close the underneath http client- Specified by:
close
in interfacejava.lang.AutoCloseable
- Specified by:
close
in interfaceMockOrRestClient
- Specified by:
close
in interfaceVitamAutoCloseable
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
makeSpecifyingUrl
public javax.ws.rs.core.Response makeSpecifyingUrl(VitamRequestBuilder request) throws VitamClientInternalException
- Throws:
VitamClientInternalException
-
make
public javax.ws.rs.core.Response make(VitamRequestBuilder request) throws VitamClientInternalException
- Throws:
VitamClientInternalException
-
getClientFactory
public VitamClientFactory<?> getClientFactory()
-
getClient
public javax.ws.rs.client.Client getClient()
-
getChunkedClient
public javax.ws.rs.client.Client getChunkedClient()
-
-