event

Documentation

Index

• type Event
  • func NewBaseEvent() (Event, error)
• type JobCreated
  • func NewJobCreatedEvent(job *job.Job) (*JobCreated, error)
  • func (j *JobCreated) Bytes() ([]byte, error)
• type JobDeleted
  • func NewJobDeleteEvent(tnnt tenant.Tenant, jobName job.Name) (*JobDeleted, error)
  • func (j *JobDeleted) Bytes() ([]byte, error)
• type JobRunFailed
  • func NewJobRunFailedEvent(jobRun *scheduler.JobRun) (*JobRunFailed, error)
  • func (j *JobRunFailed) Bytes() ([]byte, error)
• type JobRunInProgress
  • func NewJobRunInProgressEvent(jobRun *scheduler.JobRun) (*JobRunInProgress, error)
  • func (j *JobRunInProgress) Bytes() ([]byte, error)
• type JobRunSuccess
  • func NewJobRunSuccessEvent(jobRun *scheduler.JobRun) (*JobRunSuccess, error)
  • func (j *JobRunSuccess) Bytes() ([]byte, error)
• type JobRunWaitUpstream
  • func NewJobRunWaitUpstreamEvent(jobRun *scheduler.JobRun) (*JobRunWaitUpstream, error)
  • func (j *JobRunWaitUpstream) Bytes() ([]byte, error)
• type JobStateChange
  • func NewJobStateChangeEvent(tnnt tenant.Tenant, jobName job.Name, state job.State) (*JobStateChange, error)
  • func (j *JobStateChange) Bytes() ([]byte, error)
• type JobUpdated
  • func NewJobUpdateEvent(job *job.Job, updateImpact job.UpdateImpact) (*JobUpdated, error)
  • func (j *JobUpdated) Bytes() ([]byte, error)
• type ResourceCreated
  • func NewResourceCreatedEvent(rsc *resource.Resource) (*ResourceCreated, error)
  • func (r ResourceCreated) Bytes() ([]byte, error)
• type ResourceDeleted
  • func NewResourceDeleteEvent(rsc *resource.Resource) (*ResourceDeleted, error)
  • func (r ResourceDeleted) Bytes() ([]byte, error)
• type ResourceUpdated
  • func NewResourceUpdatedEvent(rsc *resource.Resource, impact resource.UpdateImpact) (*ResourceUpdated, error)
  • func (r ResourceUpdated) Bytes() ([]byte, error)

Types

type Event

type Event struct {
	ID         uuid.UUID
	OccurredAt time.Time
}

func NewBaseEvent

func NewBaseEvent() (Event, error)

type JobCreated

type JobCreated struct {
	Event

	Job *job.Job
}

func NewJobCreatedEvent

func NewJobCreatedEvent(job *job.Job) (*JobCreated, error)

func (*JobCreated) Bytes

func (j *JobCreated) Bytes() ([]byte, error)

type JobDeleted

type JobDeleted struct {
	Event

	JobName   job.Name
	JobTenant tenant.Tenant
}

func NewJobDeleteEvent

func NewJobDeleteEvent(tnnt tenant.Tenant, jobName job.Name) (*JobDeleted, error)

func (*JobDeleted) Bytes

func (j *JobDeleted) Bytes() ([]byte, error)

type JobRunFailed

type JobRunFailed struct {
	Event

	JobRun *scheduler.JobRun
}

func NewJobRunFailedEvent

func NewJobRunFailedEvent(jobRun *scheduler.JobRun) (*JobRunFailed, error)

func (*JobRunFailed) Bytes

func (j *JobRunFailed) Bytes() ([]byte, error)

type JobRunInProgress

type JobRunInProgress struct {
	Event

	JobRun *scheduler.JobRun
}

func NewJobRunInProgressEvent

func NewJobRunInProgressEvent(jobRun *scheduler.JobRun) (*JobRunInProgress, error)

func (*JobRunInProgress) Bytes

func (j *JobRunInProgress) Bytes() ([]byte, error)

type JobRunSuccess

type JobRunSuccess struct {
	Event

	JobRun *scheduler.JobRun
}

func NewJobRunSuccessEvent

func NewJobRunSuccessEvent(jobRun *scheduler.JobRun) (*JobRunSuccess, error)

func (*JobRunSuccess) Bytes

func (j *JobRunSuccess) Bytes() ([]byte, error)

type JobRunWaitUpstream

type JobRunWaitUpstream struct {
	Event

	JobRun *scheduler.JobRun
}

func NewJobRunWaitUpstreamEvent

func NewJobRunWaitUpstreamEvent(jobRun *scheduler.JobRun) (*JobRunWaitUpstream, error)

func (*JobRunWaitUpstream) Bytes

func (j *JobRunWaitUpstream) Bytes() ([]byte, error)

type JobStateChange

type JobStateChange struct {
	Event

	JobName   job.Name
	JobTenant tenant.Tenant
	State     job.State
}

func NewJobStateChangeEvent

func NewJobStateChangeEvent(tnnt tenant.Tenant, jobName job.Name, state job.State) (*JobStateChange, error)

func (*JobStateChange) Bytes

func (j *JobStateChange) Bytes() ([]byte, error)

type JobUpdated

type JobUpdated struct {
	Event
	UpdateImpact job.UpdateImpact
	Job          *job.Job
}

func NewJobUpdateEvent

func NewJobUpdateEvent(job *job.Job, updateImpact job.UpdateImpact) (*JobUpdated, error)

func (*JobUpdated) Bytes

func (j *JobUpdated) Bytes() ([]byte, error)

type ResourceCreated

type ResourceCreated struct {
	Event

	Resource *resource.Resource
}

func NewResourceCreatedEvent

func NewResourceCreatedEvent(rsc *resource.Resource) (*ResourceCreated, error)

func (ResourceCreated) Bytes

func (r ResourceCreated) Bytes() ([]byte, error)

type ResourceDeleted

type ResourceDeleted struct {
	Event

	Resource *resource.Resource
}

func NewResourceDeleteEvent

func NewResourceDeleteEvent(rsc *resource.Resource) (*ResourceDeleted, error)

func (ResourceDeleted) Bytes

func (r ResourceDeleted) Bytes() ([]byte, error)

type ResourceUpdated

type ResourceUpdated struct {
	Event

	Resource     *resource.Resource
	UpdateImpact pbInt.ChangeImpact
}

func NewResourceUpdatedEvent

func NewResourceUpdatedEvent(rsc *resource.Resource, impact resource.UpdateImpact) (*ResourceUpdated, error)

func (ResourceUpdated) Bytes

func (r ResourceUpdated) Bytes() ([]byte, error)