jobinfo

Documentation

Index

• type Envelope
• type Publisher
  • func NewPublisher(params PublisherParams) *Publisher
  • func (p Publisher) HandleJobEvent(ctx context.Context, event model.JobEvent) error
• type PublisherParams

Types

type Envelope

type Envelope struct {
	// Top level fields for job info decoding
	APIVersion string
	ID         string
	// Actual payload
	Info model.JobWithInfo
}

type Publisher

type Publisher struct {
	// contains filtered or unexported fields
}

func NewPublisher

func NewPublisher(params PublisherParams) *Publisher

func (Publisher) HandleJobEvent

func (p Publisher) HandleJobEvent(ctx context.Context, event model.JobEvent) error

type PublisherParams

type PublisherParams struct {
	JobStore jobstore.Store
	PubSub   pubsub.PubSub[Envelope]
}