Versions in this module Expand all Collapse all v0 v0.1.0 Feb 27, 2025 Changes in this version + type AMQPJob struct + Body string + BodyEncoding *BodyEncoding + Connection string + ContentType string + Exchange string + Headers map[string]interface{} + RoutingKey string + func (amqpJob *AMQPJob) RemoveCredentials() + func (amqpJob *AMQPJob) Validate() error + type Auth struct + BearerToken null.String + Password null.String + Type AuthType + Username null.String + func (auth *Auth) Validate() error + type AuthType string + const AuthTypeBasic + const AuthTypeBearer + const AuthTypeNone + func (at AuthType) Valid() bool + type BodyEncoding string + const BodyEncodingBase64 + func (be *BodyEncoding) Valid() bool + type HTTPJob struct + Auth Auth + Body null.String + Headers map[string]string + Method string + URL string + ValidResponseCodes []int + func (httpJob *HTTPJob) RemoveCredentials() + func (httpJob *HTTPJob) Validate() error + type Job struct + AMQPJob *AMQPJob + AllowedFailedRuns *int + CreatedAt time.Time + CronSchedule null.String + ExecuteAt null.Time + HTTPJob *HTTPJob + ID uuid.UUID + NextRun null.Time + NumberOfRuns *int + Status JobStatus + Tags []string + Type JobType + UpdatedAt time.Time + func (j *Job) ApplyUpdate(update JobUpdate) + func (j *Job) RemoveCredentials() + func (j *Job) SetInitialRunTime() + func (j *Job) SetNextRunTime() + func (j *Job) Validate() error + type JobCreate struct + AMQPJob *AMQPJob + CronSchedule null.String + ExecuteAt null.Time + HTTPJob *HTTPJob + Tags []string + Type JobType + func (j *JobCreate) ToJob() *Job + type JobExecution struct + EndTime time.Time + ErrorMessage null.String + ID int + JobID uuid.UUID + NumberOfExecutions int + NumberOfRetries int + StartTime time.Time + Success bool + type JobExecutionStatus string + const JobExecutionStatusFailed + const JobExecutionStatusSuccessful + type JobStatus string + const JobStatusAwaitingNextExecution + const JobStatusCancelled + const JobStatusCompleted + const JobStatusExecuted + const JobStatusRunning + const JobStatusScheduled + const JobStatusStopped + func (js JobStatus) Valid() bool + type JobType string + const JobTypeAMQP + const JobTypeHTTP + func (jt JobType) Valid() bool + type JobUpdate struct + AMQP *AMQPJob + CronSchedule *string + ExecuteAt *time.Time + HTTP *HTTPJob + Tags *[]string + Type *JobType
Go to main page