eventstojobs

Documentation

Index

• func EventsToJobResponse(message api.EventMessage) *js.JobServiceResponse
• func IsEventTerminal(message api.EventMessage) bool
• func IsStateTerminal(State js.JobServiceResponse_State) bool
• type EventsToJobService
  • func NewEventsToJobService(queue string, jobSetId string, jobId string, ...) *EventsToJobService
  • func (eventToJobService *EventsToJobService) SubscribeToJobSetId(context context.Context) error

Functions

func EventsToJobResponse

func EventsToJobResponse(message api.EventMessage) *js.JobServiceResponse

Translates api.EventMessage to a JobServiceReponse. Nil if api.EventMessage is not a relevant event for JobServiceResponse

func IsEventTerminal

func IsEventTerminal(message api.EventMessage) bool

Check if api.EventMessage is terminal event

func IsStateTerminal

func IsStateTerminal(State js.JobServiceResponse_State) bool

Check if JobServiceResponse is terminal

Types

type EventsToJobService

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

Service that subscribes to events and stores JobStatus in the repository.

func NewEventsToJobService

func NewEventsToJobService(
	queue string,
	jobSetId string,
	jobId string,
	jobServiceConfig *configuration.JobServiceConfiguration,
	jobServiceRepository repository.SQLJobService) *EventsToJobService

func (*EventsToJobService) SubscribeToJobSetId

func (eventToJobService *EventsToJobService) SubscribeToJobSetId(context context.Context) error

Subscribes to a JobSet from jobsetid