Class JobProcessorBase

JobProcessorBase is an abstraction layer to simplify the job submission process to Clara Platform API. This allows one to customize the grouping of received DICOM instances based on their workflow requirements.

Name, AeTitle and HandleInstance(InstanceStorageInfo) are the required properties and method to be implemented. SubmitPipelineJob(String, String, JobPriority, String, IList<InstanceStorageInfo>) may be used to submit a new job to the Clara Platform API. RemoveInstances(List<InstanceStorageInfo>) shall be called once job is submitted and can be removed from the temporary storage.

Inheritance
Object
JobProcessorBase
Implements
Namespace: Nvidia.Clara.DicomAdapter.API
Assembly: Nvidia.Clara.Dicom.API.dll
Syntax
public abstract class JobProcessorBase : IDisposable, IObserver<InstanceStorageInfo>

Constructors

| Improve this Doc View Source

JobProcessorBase(IInstanceStoredNotificationService, ILoggerFactory, IJobRepository, IInstanceCleanupQueue, CancellationToken)

Declaration
public JobProcessorBase(IInstanceStoredNotificationService instanceStoredNotificationService, ILoggerFactory loggerFactory, IJobRepository jobStore, IInstanceCleanupQueue cleanupQueue, CancellationToken cancellationToken)
Parameters
Type Name Description
IInstanceStoredNotificationService instanceStoredNotificationService
ILoggerFactory loggerFactory
IJobRepository jobStore
IInstanceCleanupQueue cleanupQueue
CancellationToken cancellationToken

Properties

| Improve this Doc View Source

AeTitle

Declaration
public abstract string AeTitle { get; }
Property Value
Type Description
String
| Improve this Doc View Source

CancellationToken

Declaration
protected CancellationToken CancellationToken { get; }
Property Value
Type Description
CancellationToken
| Improve this Doc View Source

Name

Declaration
public abstract string Name { get; }
Property Value
Type Description
String

Methods

| Improve this Doc View Source

Dispose()

Declaration
public void Dispose()
| Improve this Doc View Source

Dispose(Boolean)

Declaration
protected virtual void Dispose(bool disposing)
Parameters
Type Name Description
Boolean disposing
| Improve this Doc View Source

Finalize()

Declaration
protected void Finalize()
| Improve this Doc View Source

HandleInstance(InstanceStorageInfo)

Declaration
public abstract void HandleInstance(InstanceStorageInfo value)
Parameters
Type Name Description
InstanceStorageInfo value
| Improve this Doc View Source

OnCompleted()

Declaration
public void OnCompleted()
| Improve this Doc View Source

OnError(Exception)

Declaration
public void OnError(Exception error)
Parameters
Type Name Description
Exception error
| Improve this Doc View Source

OnNext(InstanceStorageInfo)

Declaration
public void OnNext(InstanceStorageInfo value)
Parameters
Type Name Description
InstanceStorageInfo value
| Improve this Doc View Source

RemoveInstances(List<InstanceStorageInfo>)

Declaration
protected void RemoveInstances(List<InstanceStorageInfo> instances)
Parameters
Type Name Description
List<InstanceStorageInfo> instances
| Improve this Doc View Source

SubmitPipelineJob(String, String, JobPriority, String, IList<InstanceStorageInfo>)

Declaration
protected Task SubmitPipelineJob(string jobName, string pipelineId, JobPriority jobPriority, string basePath, IList<InstanceStorageInfo> instances)
Parameters
Type Name Description
String jobName
String pipelineId
JobPriority jobPriority
String basePath
IList<InstanceStorageInfo> instances
Returns
Type Description
Task
| Improve this Doc View Source

ToString()

Declaration
public override string ToString()
Returns
Type Description
String

Implements

IObserver<>