Package fr.gouv.vitam.storage.offers.tape.cas

Class AccessRequestReferentialRepository

java.lang.Object

fr.gouv.vitam.storage.offers.tape.cas.AccessRequestReferentialRepository

public class AccessRequestReferentialRepository
extends java.lang.Object

Constructor Summary

Constructors

Constructor	Description
AccessRequestReferentialRepository(com.mongodb.client.MongoCollection<org.bson.Document> collection)

Method Summary

Modifier and Type	Method	Description
java.util.List<TapeAccessRequestReferentialEntity>	cleanupAndGetExpiredAccessRequests()
long	countExpiredAccessRequests()
long	countNonReadyAccessRequests()
long	countReadyAccessRequests()
boolean	deleteAccessRequestById(java.lang.String accessRequestId)
java.util.Set<java.lang.String>	excludeArchiveIdsStillRequiredByAccessRequests(java.util.Set<java.lang.String> archiveIdsToCheck)
java.util.Optional<TapeAccessRequestReferentialEntity>	findByRequestId(java.lang.String requestId)
java.util.List<TapeAccessRequestReferentialEntity>	findByRequestIds(java.util.Set<java.lang.String> requestIds)
java.util.List<TapeAccessRequestReferentialEntity>	findByUnavailableArchiveId(java.lang.String archiveId)
java.util.List<TapeAccessRequestReferentialEntity>	findNonReadyAccessRequests()
void	insert(TapeAccessRequestReferentialEntity accessRequestReferentialEntity)
CloseableIterator<TapeLibraryObjectReferentialId>	listObjectIdsForActiveAccessRequests()
boolean	updateAccessRequest(TapeAccessRequestReferentialEntity updatedAccessRequestEntity, int expectedVersion)

Methods inherited from class java.lang.Object

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

Constructor Detail

AccessRequestReferentialRepository

public AccessRequestReferentialRepository(com.mongodb.client.MongoCollection<org.bson.Document> collection)

Method Detail

insert

public void insert(TapeAccessRequestReferentialEntity accessRequestReferentialEntity)
            throws AccessRequestReferentialException

Throws:

AccessRequestReferentialException

findByRequestId

public java.util.Optional<TapeAccessRequestReferentialEntity> findByRequestId(java.lang.String requestId)
                                                                       throws AccessRequestReferentialException

Throws:

AccessRequestReferentialException

findByRequestIds

public java.util.List<TapeAccessRequestReferentialEntity> findByRequestIds(java.util.Set<java.lang.String> requestIds)
                                                                    throws AccessRequestReferentialException

Throws:

AccessRequestReferentialException

countNonReadyAccessRequests

public long countNonReadyAccessRequests()
                                 throws AccessRequestReferentialException

Throws:

AccessRequestReferentialException

countReadyAccessRequests

public long countReadyAccessRequests()
                              throws AccessRequestReferentialException

Throws:

AccessRequestReferentialException

countExpiredAccessRequests

public long countExpiredAccessRequests()
                                throws AccessRequestReferentialException

Throws:

AccessRequestReferentialException

findNonReadyAccessRequests

public java.util.List<TapeAccessRequestReferentialEntity> findNonReadyAccessRequests()
                                                                              throws AccessRequestReferentialException

Throws:

AccessRequestReferentialException

findByUnavailableArchiveId

public java.util.List<TapeAccessRequestReferentialEntity> findByUnavailableArchiveId(java.lang.String archiveId)
                                                                              throws AccessRequestReferentialException

Throws:

AccessRequestReferentialException

deleteAccessRequestById

public boolean deleteAccessRequestById(java.lang.String accessRequestId)
                                throws AccessRequestReferentialException

Throws:

AccessRequestReferentialException

cleanupAndGetExpiredAccessRequests

public java.util.List<TapeAccessRequestReferentialEntity> cleanupAndGetExpiredAccessRequests()
                                                                                      throws AccessRequestReferentialException

Throws:

AccessRequestReferentialException

excludeArchiveIdsStillRequiredByAccessRequests

public java.util.Set<java.lang.String> excludeArchiveIdsStillRequiredByAccessRequests(java.util.Set<java.lang.String> archiveIdsToCheck)

updateAccessRequest

public boolean updateAccessRequest(TapeAccessRequestReferentialEntity updatedAccessRequestEntity,
                                   int expectedVersion)
                            throws AccessRequestReferentialException

Throws:

AccessRequestReferentialException

listObjectIdsForActiveAccessRequests

public CloseableIterator<TapeLibraryObjectReferentialId> listObjectIdsForActiveAccessRequests()
                                                                                       throws AccessRequestReferentialException

Throws:

AccessRequestReferentialException