Directories
¶
| Path | Synopsis |
|---|---|
|
BucketReader gets a list of files awaiting processing in the S3 intake buckets and adds each item to the queue for processing.
|
BucketReader gets a list of files awaiting processing in the S3 intake buckets and adds each item to the queue for processing. |
|
cleanup_reader periodically checks the processed items list in Fluctus for bags that should be deleted from the receiving buckets.
|
cleanup_reader periodically checks the processed items list in Fluctus for bags that should be deleted from the receiving buckets. |
|
fixity_reader periodically queries Fluctus for GenericFiles that haven't had a fixity check in X days.
|
fixity_reader periodically queries Fluctus for GenericFiles that haven't had a fixity check in X days. |
|
multiclean.go cleans up fragments from failed S3 multipart-uploads.
|
multiclean.go cleans up fragments from failed S3 multipart-uploads. |
|
request_reader periodically checks the processed items list in Fluctus for the following: 1.
|
request_reader periodically checks the processed items list in Fluctus for the following: 1. |
|
requeue puts a blob of json into the specified queue so that we can reprocess it.
|
requeue puts a blob of json into the specified queue so that we can reprocess it. |
Click to show internal directories.
Click to hide internal directories.