job

Documentation

Index

• func AddJob(idPrefix string, requestorUserId string, jobType protos.JobStatus_JobType, ...) (*protos.JobStatus, error)
• func CompleteJob(jobId string, success bool, message string, outputFilePath string, ...) error
• func ListenForExternalTriggeredJobs(prefix string, callback func(*protos.JobStatus), db *mongo.Database, ...)
• func UpdateJob(jobId string, status protos.JobStatus_Status, message string, logId string, ...) error

Functions

func AddJob

func AddJob(
	idPrefix string,
	requestorUserId string,
	jobType protos.JobStatus_JobType,
	jobItemId string,
	jobName string,
	elementList []string,
	jobTimeoutSec uint32,
	db *mongo.Database,
	idgen idgen.IDGenerator,
	ts timestamper.ITimeStamper,
	logger logger.ILogger,
	sendUpdate func(*protos.JobStatus)) (*protos.JobStatus, error)

func CompleteJob

func CompleteJob(jobId string, success bool, message string, outputFilePath string, otherLogFiles []string, db *mongo.Database, ts timestamper.ITimeStamper, logger logger.ILogger) error

Expected to be called from the thing running the job. This allows setting some output fields

func ListenForExternalTriggeredJobs

func ListenForExternalTriggeredJobs(prefix string, callback func(*protos.JobStatus), db *mongo.Database, logger logger.ILogger)

func UpdateJob

func UpdateJob(jobId string, status protos.JobStatus_Status, message string, logId string, db *mongo.Database, ts timestamper.ITimeStamper, logger logger.ILogger) error

Expected to be called from the thing running the job. This updates the DB status, which hopefully the go thread started by AddJob will notice and fire off an update