event

package
v0.11.10 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 16, 2024 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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 added in v0.9.0

type JobStateChange struct {
	Event

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

func NewJobStateChangeEvent added in v0.9.0

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

func (*JobStateChange) Bytes added in v0.9.0

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

type JobUpdated

type JobUpdated struct {
	Event

	Job *job.Job
}

func NewJobUpdateEvent

func NewJobUpdateEvent(job *job.Job) (*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 ResourceUpdated

type ResourceUpdated struct {
	Event

	Resource *resource.Resource
}

func NewResourceUpdatedEvent

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

func (ResourceUpdated) Bytes

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

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL