conversion

Documentation

Index

• func FromEventSequence(es *armadaevents.EventSequence) ([]*api.EventMessage, error)
• func FromInternalCancel(userId string, queueName string, jobSetName string, time time.Time, ...) ([]*api.EventMessage, error)
• func FromInternalCancelled(userId string, queueName string, jobSetName string, time time.Time, ...) ([]*api.EventMessage, error)
• func FromInternalJobErrors(queueName string, jobSetName string, time time.Time, e *armadaevents.JobErrors) ([]*api.EventMessage, error)
• func FromInternalJobRunAssigned(queueName string, jobSetName string, time time.Time, ...) ([]*api.EventMessage, error)
• func FromInternalJobRunErrors(queueName string, jobSetName string, time time.Time, ...) ([]*api.EventMessage, error)
• func FromInternalJobRunPreempted(queueName string, jobSetName string, time time.Time, ...) ([]*api.EventMessage, error)
• func FromInternalJobRunRunning(queueName string, jobSetName string, time time.Time, ...) ([]*api.EventMessage, error)
• func FromInternalJobSucceeded(queueName string, jobSetName string, time time.Time, ...) ([]*api.EventMessage, error)
• func FromInternalLogDuplicateDetected(queueName string, jobSetName string, time time.Time, ...) ([]*api.EventMessage, error)
• func FromInternalLogJobRunLeased(queueName string, jobSetName string, time time.Time, ...) ([]*api.EventMessage, error)
• func FromInternalPreemptionRequested(userId string, queueName string, jobSetName string, time time.Time, ...) ([]*api.EventMessage, error)
• func FromInternalReprioritiseJob(userId string, queueName string, jobSetName string, time time.Time, ...) ([]*api.EventMessage, error)
• func FromInternalReprioritisedJob(userId string, queueName string, jobSetName string, time time.Time, ...) ([]*api.EventMessage, error)
• func FromInternalResourceUtilisation(queueName string, jobSetName string, time time.Time, ...) ([]*api.EventMessage, error)
• func FromInternalStandaloneIngressInfo(queueName string, jobSetName string, time time.Time, ...) ([]*api.EventMessage, error)
• func FromInternalSubmit(owner string, groups []string, queue string, jobSet string, time time.Time, ...) ([]*api.EventMessage, error)

Functions

func FromEventSequence

func FromEventSequence(es *armadaevents.EventSequence) ([]*api.EventMessage, error)

FromEventSequence Converts internal messages to external api messages Note that some internal api messages can result in multiple api messages so we need to return an array of messages TODO: once we no longer need to worry about legacy messages in the api we can move eventutil.ApiJobFromLogSubmitJob here

func FromInternalCancel

func FromInternalCancel(userId string, queueName string, jobSetName string, time time.Time, e *armadaevents.CancelJob) ([]*api.EventMessage, error)

func FromInternalCancelled

func FromInternalCancelled(userId string, queueName string, jobSetName string, time time.Time, e *armadaevents.CancelledJob) ([]*api.EventMessage, error)

func FromInternalJobErrors

func FromInternalJobErrors(queueName string, jobSetName string, time time.Time, e *armadaevents.JobErrors) ([]*api.EventMessage, error)

func FromInternalJobRunAssigned

func FromInternalJobRunAssigned(queueName string, jobSetName string, time time.Time, e *armadaevents.JobRunAssigned) ([]*api.EventMessage, error)

func FromInternalJobRunErrors

func FromInternalJobRunErrors(queueName string, jobSetName string, time time.Time, e *armadaevents.JobRunErrors) ([]*api.EventMessage, error)

func FromInternalJobRunPreempted

func FromInternalJobRunPreempted(queueName string, jobSetName string, time time.Time, e *armadaevents.JobRunPreempted) ([]*api.EventMessage, error)

func FromInternalJobRunRunning

func FromInternalJobRunRunning(queueName string, jobSetName string, time time.Time, e *armadaevents.JobRunRunning) ([]*api.EventMessage, error)

func FromInternalJobSucceeded

func FromInternalJobSucceeded(queueName string, jobSetName string, time time.Time, e *armadaevents.JobSucceeded) ([]*api.EventMessage, error)

func FromInternalLogDuplicateDetected

func FromInternalLogDuplicateDetected(queueName string, jobSetName string, time time.Time, e *armadaevents.JobDuplicateDetected) ([]*api.EventMessage, error)

func FromInternalLogJobRunLeased

func FromInternalLogJobRunLeased(queueName string, jobSetName string, time time.Time, e *armadaevents.JobRunLeased) ([]*api.EventMessage, error)

func FromInternalPreemptionRequested

func FromInternalPreemptionRequested(userId string, queueName string, jobSetName string, time time.Time, e *armadaevents.JobPreemptionRequested) ([]*api.EventMessage, error)

func FromInternalReprioritiseJob

func FromInternalReprioritiseJob(userId string, queueName string, jobSetName string, time time.Time, e *armadaevents.ReprioritiseJob) ([]*api.EventMessage, error)

func FromInternalReprioritisedJob

func FromInternalReprioritisedJob(userId string, queueName string, jobSetName string, time time.Time, e *armadaevents.ReprioritisedJob) ([]*api.EventMessage, error)

func FromInternalResourceUtilisation

func FromInternalResourceUtilisation(queueName string, jobSetName string, time time.Time, e *armadaevents.ResourceUtilisation) ([]*api.EventMessage, error)

func FromInternalStandaloneIngressInfo

func FromInternalStandaloneIngressInfo(queueName string, jobSetName string, time time.Time, e *armadaevents.StandaloneIngressInfo) ([]*api.EventMessage, error)

func FromInternalSubmit

func FromInternalSubmit(owner string, groups []string, queue string, jobSet string, time time.Time, e *armadaevents.SubmitJob) ([]*api.EventMessage, error)