Class: MinioService
Defined in: packages/microservices/raptor/src/shared/minio.service.ts:56
Implements
OnModuleInit
Constructors
Constructor
new MinioService(
configSvc):MinioService
Defined in: packages/microservices/raptor/src/shared/minio.service.ts:65
Parameters
configSvc
ConfigService
Returns
MinioService
Methods
cleanupOldFiles()
cleanupOldFiles(
maxAgeInDays):Promise<void>
Defined in: packages/microservices/raptor/src/shared/minio.service.ts:543
Parameters
maxAgeInDays
number = 7
Returns
Promise<void>
createJobMetadata()
createJobMetadata(
jobId,inputId,initialData?):Promise<void>
Defined in: packages/microservices/raptor/src/shared/minio.service.ts:329
Parameters
jobId
string
inputId
string
initialData?
Partial<JobMetadata>
Returns
Promise<void>
deleteInputData()
deleteInputData(
inputId):Promise<void>
Defined in: packages/microservices/raptor/src/shared/minio.service.ts:277
Parameters
inputId
string
Returns
Promise<void>
deleteOutputData()
deleteOutputData(
outputId):Promise<void>
Defined in: packages/microservices/raptor/src/shared/minio.service.ts:303
Parameters
outputId
string
Returns
Promise<void>
getAllJobMetadata()
getAllJobMetadata():
Promise<JobMetadata[]>
Defined in: packages/microservices/raptor/src/shared/minio.service.ts:506
Returns
Promise<JobMetadata[]>
getCompletedSequenceCount()
getCompletedSequenceCount(
parentJobId):Promise<number>
Defined in: packages/microservices/raptor/src/shared/minio.service.ts:433
Count completed sequence markers for a parent job.
Parameters
parentJobId
string
Returns
Promise<number>
getInputData()
getInputData(
inputId):Promise<string>
Defined in: packages/microservices/raptor/src/shared/minio.service.ts:166
Parameters
inputId
string
Returns
Promise<string>
getJobMetadata()
getJobMetadata(
jobId):Promise<JobMetadata>
Defined in: packages/microservices/raptor/src/shared/minio.service.ts:483
Parameters
jobId
string
Returns
Promise<JobMetadata>
getOutputData()
getOutputData(
outputId):Promise<string>
Defined in: packages/microservices/raptor/src/shared/minio.service.ts:238
Parameters
outputId
string
Returns
Promise<string>
isHealthy()
isHealthy():
Promise<boolean>
Defined in: packages/microservices/raptor/src/shared/minio.service.ts:579
Returns
Promise<boolean>
listCompletedSequences()
listCompletedSequences(
parentJobId):Promise<string[]>
Defined in: packages/microservices/raptor/src/shared/minio.service.ts:458
Optionally list the completed sequence job IDs.
Parameters
parentJobId
string
Returns
Promise<string[]>
markSequenceCompleted()
markSequenceCompleted(
parentJobId,sequenceJobId):Promise<void>
Defined in: packages/microservices/raptor/src/shared/minio.service.ts:402
Mark a child sequence as completed in a race-safe way by writing a standalone marker object. This avoids read-modify-write races on the parent metadata object when many sequences complete concurrently.
Parameters
parentJobId
string
sequenceJobId
string
Returns
Promise<void>
onModuleInit()
onModuleInit():
Promise<void>
Defined in: packages/microservices/raptor/src/shared/minio.service.ts:95
Returns
Promise<void>
Implementation of
OnModuleInit.onModuleInit
storeInputData()
storeInputData(
inputData):Promise<string>
Defined in: packages/microservices/raptor/src/shared/minio.service.ts:139
Parameters
inputData
any
Returns
Promise<string>
storeOutputData()
storeOutputData(
outputData,inputId):Promise<string>
Defined in: packages/microservices/raptor/src/shared/minio.service.ts:205
Parameters
outputData
string | Readable
inputId
string
Returns
Promise<string>
updateJobMetadata()
updateJobMetadata(
jobId,updates):Promise<void>
Defined in: packages/microservices/raptor/src/shared/minio.service.ts:362
Parameters
jobId
string
updates
Partial<JobMetadata>
Returns
Promise<void>