Interface IJobs

Namespace

Cratis.Chronicle.Jobs

Assembly

Cratis.Chronicle.dll

Defines the system for working with jobs.

public interface IJobs

Extension Methods

JobsWaitHelpers.TryFindJobsOfType(IJobs, string, TimeSpan?)

JobsWaitHelpers.WaitForThereToBeJobOfType(IJobs, string, TimeSpan?)

JobsWaitHelpers.WaitForThereToBeJobs(IJobs, TimeSpan?)

JobsWaitHelpers.WaitForThereToBeNoJobs(IJobs, TimeSpan?, params JobStatus[])

JobsWaitHelpers.WaitTillJobCompletesOrIsDeleted(IJobs, JobId, TimeSpan?)

JobsWaitHelpers.WaitTillJobIsDeleted(IJobs, JobId, TimeSpan?)

JobsWaitHelpers.WaitTillJobMeetsPredicate(IJobs, JobId, Func<Job, bool>, TimeSpan?)

JobsWaitHelpers.WaitTillJobProgressCompleted(IJobs, JobId, TimeSpan?)

JobsWaitHelpers.WaitTillJobProgressStopped(IJobs, JobId, TimeSpan?)

MethodCalls.CallGenericMethod<TOut, T>(T, Expression<Func<T, Func<TOut>>>, params Type[])

MethodCalls.CallGenericMethod<TOut, T, T1>(T, Expression<Func<T, Func<T1, TOut>>>, T1, params Type[])

MethodCalls.CallGenericMethod<TOut, T, T1, T2>(T, Expression<Func<T, Func<T1, T2, TOut>>>, T1, T2, params Type[])

MethodCalls.CallGenericMethod<TOut, T, T1, T2, T3>(T, Expression<Func<T, Func<T1, T2, T3, TOut>>>, T1, T2, T3, params Type[])

ConverterExtensions.ConvertTo(object, Type)

ConceptExtensions.GetConceptValue(object)

ConceptExtensions.IsConcept(object)

JsonValueExtensions.ToJsonValue(object?)

ObservableExtensions.InvokeAndWrapWithSubject<TResult>(object, Func<CancellationToken, IObservable<TResult>>)

ObservableExtensions.InvokeAndWrapWithTransformSubject<TResult, TSource>(object, Func<CancellationToken, IObservable<TSource>>, Func<TSource, TResult>)

Methods

Delete(JobId)

Deletes the Job with the specified jobId.

Task Delete(JobId jobId)

Parameters

jobId JobId

The job id.

Returns

Task

Awaitable task.

GetJob(JobId)

Gets the Job with the specified jobId.

Task<Job?> GetJob(JobId jobId)

Parameters

jobId JobId

The job id.

Returns

Task<Job>

The job.

GetJobs()

Gets all the Jobs.

Task<IEnumerable<Job>> GetJobs()

Returns

Task<IEnumerable<Job>>

The jobs.

Resume(JobId)

Resumes the Job with the specified jobId.

Task<JobCommandResult> Resume(JobId jobId)

Parameters

jobId JobId

The job id.

Returns

Task<JobCommandResult>

The JobCommandResult telling whether the job was taken forward, and why not when it was not.

Stop(JobId)

Stops the Job with the specified jobId.

Task<JobCommandResult> Stop(JobId jobId)

Parameters

jobId JobId

The job id.

Returns

Task<JobCommandResult>

The JobCommandResult telling whether the job took the stop, and why not when it did not.