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 JobUpdated
  • func NewJobUpdateEvent(job *job.Job) (*JobUpdated, error)
  • func (j *JobUpdated) Bytes() ([]byte, error)
• type ResourceCreated
  • func NewResourceCreatedEvent(rsc *resource.Resource) (*ResourceCreated, error)
  • func (r ResourceCreated) Bytes() ([]byte, error)
• type ResourceUpdated
  • func NewResourceUpdatedEvent(rsc *resource.Resource) (*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 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)