Versions in this module Expand all Collapse all v0 v0.7.1 Jul 25, 2023 v0.7.0 Jul 20, 2023 Changes in this version + type Event struct + ID uuid.UUID + OccurredAt time.Time + func NewBaseEvent() (Event, error) + type JobCreated struct + Job *job.Job + func NewJobCreatedEvent(job *job.Job) (*JobCreated, error) + func (j *JobCreated) Bytes() ([]byte, error) + type JobDeleted struct + JobName job.Name + JobTenant tenant.Tenant + func NewJobDeleteEvent(tnnt tenant.Tenant, jobName job.Name) (*JobDeleted, error) + func (j *JobDeleted) Bytes() ([]byte, error) + type JobRunFailed struct + JobRun *scheduler.JobRun + func NewJobRunFailedEvent(jobRun *scheduler.JobRun) (*JobRunFailed, error) + func (j *JobRunFailed) Bytes() ([]byte, error) + type JobRunInProgress struct + JobRun *scheduler.JobRun + func NewJobRunInProgressEvent(jobRun *scheduler.JobRun) (*JobRunInProgress, error) + func (j *JobRunInProgress) Bytes() ([]byte, error) + type JobRunSuccess struct + JobRun *scheduler.JobRun + func NewJobRunSuccessEvent(jobRun *scheduler.JobRun) (*JobRunSuccess, error) + func (j *JobRunSuccess) Bytes() ([]byte, error) + type JobRunWaitUpstream struct + JobRun *scheduler.JobRun + func NewJobRunWaitUpstreamEvent(jobRun *scheduler.JobRun) (*JobRunWaitUpstream, error) + func (j *JobRunWaitUpstream) Bytes() ([]byte, error) + type JobStateChange struct + JobName job.Name + JobTenant tenant.Tenant + State job.State + func NewJobStateChangeEvent(tnnt tenant.Tenant, jobName job.Name, state job.State) (*JobStateChange, error) + func (j *JobStateChange) Bytes() ([]byte, error) + type JobUpdated struct + Job *job.Job + func NewJobUpdateEvent(job *job.Job) (*JobUpdated, error) + func (j *JobUpdated) Bytes() ([]byte, error) + type ResourceCreated struct + Resource *resource.Resource + func NewResourceCreatedEvent(rsc *resource.Resource) (*ResourceCreated, error) + func (r ResourceCreated) Bytes() ([]byte, error) + type ResourceUpdated struct + Resource *resource.Resource + func NewResourceUpdatedEvent(rsc *resource.Resource) (*ResourceUpdated, error) + func (r ResourceUpdated) Bytes() ([]byte, error)
Go to main page