Package app.ductape.sdk.processor.services

Class ProcessorService

java.lang.Object

app.ductape.sdk.processor.services.ProcessorService

public class ProcessorService
extends Object

Runtime job executor aligned to TS processor.service#runJobs.

Constructor Summary

Constructors

Constructor	Description
ProcessorService(RequestContext auth, ProcessorApiService processorApiService, JobsService jobsService, NotificationsService notificationsService, StorageService storageService, DatabaseService databaseService, GraphService graphService, ResilienceApiService resilienceApiService)
ProcessorService(RequestContext auth, ProcessorApiService processorApiService, JobsService jobsService, NotificationsService notificationsService, StorageService storageService, DatabaseService databaseService, GraphService graphService, BrokersService brokersService, FeatureService featureService, ProductsService productsService, ResilienceApiService resilienceApiService, JobsService.JobQueueAdapter queueAdapter)

Method Summary

Modifier and Type	Method	Description
void	recordJobExecutionPhaseFailed(String jobId, String errorMessage, String errorCode)
Map<String,Object>	runJobs(Map<String,Object> job, Map<String,Object> additionalLogs)
void	updateHealthcheckOnProcessor(String productTag, List<Map<String,Object>> tagsData)	TS parity intent for processor.service#updateHealthcheckOnProcessor.

Methods inherited from class java.lang.Object

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

Constructor Details

ProcessorService

public ProcessorService(RequestContext auth,
 ProcessorApiService processorApiService,
 JobsService jobsService,
 NotificationsService notificationsService,
 StorageService storageService,
 DatabaseService databaseService,
 GraphService graphService,
 ResilienceApiService resilienceApiService)

ProcessorService

public ProcessorService(RequestContext auth,
 ProcessorApiService processorApiService,
 JobsService jobsService,
 NotificationsService notificationsService,
 StorageService storageService,
 DatabaseService databaseService,
 GraphService graphService,
 BrokersService brokersService,
 FeatureService featureService,
 ProductsService productsService,
 ResilienceApiService resilienceApiService,
 JobsService.JobQueueAdapter queueAdapter)

Method Details

runJobs

public Map<String,Object> runJobs(Map<String,Object> job,
 Map<String,Object> additionalLogs)

recordJobExecutionPhaseFailed

public void recordJobExecutionPhaseFailed(String jobId,
 String errorMessage,
 String errorCode)

updateHealthcheckOnProcessor

public void updateHealthcheckOnProcessor(String productTag,
 List<Map<String,Object>> tagsData)

TS parity intent for processor.service#updateHealthcheckOnProcessor.