Work begun on implementing Jobs and their Descriptors

This commit is contained in:
Tristan B. Velloza Kildaire 2022-01-12 17:29:03 +02:00
parent 9bdb98423d
commit 63db311cdd
1 changed files with 84 additions and 0 deletions

84
source/tasky/jobs.d Normal file
View File

@ -0,0 +1,84 @@
/**
* Jobs
*
* Contains tools for describing different types
* of jobs and what event handlers will be triggered
* for them along with the creation of actual
* Jobs (schedulable units).
*/
module tasky.jobs;
import tasky.exceptions : TaskyException;
/**
* A Job to be scheduled
*/
public class Job
{
private this(Descriptor jobType, byte[] payload)
{
/* TODO: Extract needed information from here */
}
protected Job newJob(Descriptor jobType, byte[] payload)
{
/**
* This is mark protected for a reason, don't
* try and call this directly
*/
assert(jobType);
assert(payload.length);
return new Job(jobType, payload);
}
}
public final class JobException : TaskyException
{
this(string message)
{
super("(JobError) "~message);
}
}
/**
* Descriptor
*
* This represents a type of Job, complete
* with the data to be sent and a type ID
*/
public abstract class Descriptor
{
private ulong descriptorClass;
/**
* For this "class of Job" the unique
* id is taken in as `descriptorClass`
*/
final this(ulong descriptorClass)
{
this.descriptorClass = descriptorClass;
}
/**
* Instantiates a Job based on this Descriptor
* ("Job template") with the given payload
* to be sent
*/
public final Job spawnJob(byte[] payload)
{
Job instantiatedDescriptor;
if(payload.length == 0)
{
throw new Exception("JobSpawnError: Empty payloads not allowed");
}
return instantiatedDescriptor;
}
}