Package org.apache.jackrabbit.oak.spi.blob.stats

Interface BlobStatsCollector

  • All Known Subinterfaces:
    ExtendedBlobStatsCollector
    All Known Implementing Classes:
    BlobStoreStats
    @ConsumerType
public interface BlobStatsCollector
    BlobStoreStatsCollector receives callback when blobs are written and read from BlobStore

    • Method Detail

      • uploaded

        void uploaded​(long timeTaken,
              java.util.concurrent.TimeUnit unit,
              long size)
        Called when a binary content is written to BlobStore
        Parameters:
        timeTaken - time taken to perform the operation
        unit - unit of time taken
        size - size of binary content being written

      • uploadCompleted

        void uploadCompleted​(java.lang.String blobId)
        Invoked when upload for a binary file get completed. In case of chunked BlobStore this invoked when all the chunks have been uploaded
        Parameters:
        blobId - id of the blob which got uploaded. Even in case of chunked blobStores its the id of main blob

      • uploadFailed

        void uploadFailed()
        Invoked when an upload of a binary fails.

      • downloaded

        void downloaded​(java.lang.String blobId,
                long timeTaken,
                java.util.concurrent.TimeUnit unit,
                long size)
        Called when a binary content is read from BlobStore
        Parameters:
        blobId - id of blob whose content are being read. For BlobStore which break up file in chunks it would be chunkId
        timeTaken - time taken to perform the operation
        unit - unit of time taken
        size - size of binary content being read

      • downloadCompleted

        void downloadCompleted​(java.lang.String blobId)
        Invoked when download for a binary file get completed. In case of chunked BlobStore this invoked when all the chunks have been downloaded
        Parameters:
        blobId - id of the blob which got downloaded. Even in case of chunked blobStores its the id of main blob

      • downloadFailed

        void downloadFailed​(java.lang.String blobId)
        Called when an attempt to download a binary file fails.
        Parameters:
        blobId - id of the blob for which the download failed

      • deleted

        void deleted​(java.lang.String blobId,
             long timeTaken,
             java.util.concurrent.TimeUnit unit)
        Called when a binary is deleted from the BlobStore
        Parameters:
        blobId - id of blob being deleted
        timeTaken - time taken to perform the delete
        unit - unit of time taken

      • deleteCompleted

        void deleteCompleted​(java.lang.String blobId)
        Called when deletion of a binary is completed.
        Parameters:
        blobId - id of the blob which was deleted

      • deleteFailed

        void deleteFailed()
        Called when deletion of a binary fails.

      • deletedAllOlderThan

        void deletedAllOlderThan​(long timeTaken,
                         java.util.concurrent.TimeUnit unit,
                         long min)
        Called when deleting binaries older than a specified date, via DataStore.deleteAllOlderThan(long).
        Parameters:
        timeTaken - time taken to perform the deletion
        unit - unit of time taken
        min - time used for determining what to delete - older than this time gets deleted

      • deleteAllOlderThanCompleted

        void deleteAllOlderThanCompleted​(int deletedCount)
        Called when DataStore.deleteAllOlderThan(long) is completed.
        Parameters:
        deletedCount - count of records deleted

      • deleteAllOlderThanFailed

        void deleteAllOlderThanFailed​(long min)
        Called when DataStore.deleteAllOlderThan(long) fails.
        Parameters:
        min - time used for determining what to delete

      • recordAdded

        void recordAdded​(long timeTaken,
                 java.util.concurrent.TimeUnit unit,
                 long size)
        Called when a binary is added via DataStore.addRecord(InputStream).
        Parameters:
        timeTaken - time taken to perform the operation
        unit - unit of time taken
        size - size of binary content being read

      • addRecordCompleted

        void addRecordCompleted​(java.lang.String blobId)
        Called when a call to DataStore.addRecord(InputStream) is completed.
        Parameters:
        blobId - id of the record which was added

      • getRecordCalled

        void getRecordCalled​(long timeTaken,
                     java.util.concurrent.TimeUnit unit,
                     long size)
        Called when a DataRecord is retrieved via DataStore.getRecord(DataIdentifier).
        Parameters:
        timeTaken - time taken to perform the operation
        unit - unit of time taken
        size - size of the binary

      • getRecordCompleted

        void getRecordCompleted​(java.lang.String blobId)
        Called when a call to DataStore.getRecord(DataIdentifier) is completed.
        Parameters:
        blobId - id of the record retrieved

      • getRecordIfStoredCalled

        void getRecordIfStoredCalled​(long timeTaken,
                             java.util.concurrent.TimeUnit unit,
                             long size)
        Called when a DataRecord is retrieved via DataStore.getRecordIfStored(DataIdentifier).
        Parameters:
        timeTaken - time taken to perform the operation
        unit - unit of time taken
        size - size of the binary

      • getRecordIfStoredCompleted

        void getRecordIfStoredCompleted​(java.lang.String blobId)
        Called when a call to DataStore.getRecordIfStored(DataIdentifier) is completed.
        Parameters:
        blobId - id of the record retrieved

      • getRecordFromReferenceCalled

        void getRecordFromReferenceCalled​(long timeTaken,
                                  java.util.concurrent.TimeUnit unit,
                                  long size)
        Called when a DataRecord is retrieved via DataStore.getRecordFromReference(String).
        Parameters:
        timeTaken - time taken to perform the operation
        unit - unit of time taken
        size - size of the binary

      • getRecordFromReferenceCompleted

        void getRecordFromReferenceCompleted​(java.lang.String reference)
        Called when a call to DataStore.getRecordFromReference(String) is completed.
        Parameters:
        reference - reference of the record retrieved

      • getRecordFromReferenceFailed

        void getRecordFromReferenceFailed​(java.lang.String reference)
        Called when a call to DataStore.getRecordFromReference(String) fails.
        Parameters:
        reference - reference of the record

      • getAllIdentifiersCalled

        void getAllIdentifiersCalled​(long timeTaken,
                             java.util.concurrent.TimeUnit unit)
        Called when DataStore.getAllIdentifiers() is called.
        Parameters:
        timeTaken - time taken to perform the operation
        unit - unit of time taken