eventstojobs

Documentation

Index

• func EventsToJobResponse(message api.EventMessage) *js.JobServiceResponse
• func IsEventTerminal(message api.EventMessage) bool
• func IsStateTerminal(State js.JobServiceResponse_State) bool
• type JobSetSubscription
  • func NewJobSetSubscription(ctx context.Context, eventReader events.JobEventReader, ...) *JobSetSubscription
  • func (js *JobSetSubscription) Subscribe() error
• type JobSetSubscriptionExecutor
  • func NewJobSetSubscriptionExecutor(ctx context.Context, eventReader events.JobEventReader, ...) *JobSetSubscriptionExecutor
  • func (jse *JobSetSubscriptionExecutor) HasSubscription(key *repository.JobSetKey) bool
  • func (jse *JobSetSubscriptionExecutor) Manage()
  • func (jse *JobSetSubscriptionExecutor) NumActiveSubscriptions() int
  • func (jse *JobSetSubscriptionExecutor) ScanForMissingSubscriptions()

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 JobSetSubscription

type JobSetSubscription struct {
	repository.JobSetKey
	// contains filtered or unexported fields
}

func NewJobSetSubscription

func NewJobSetSubscription(ctx context.Context, eventReader events.JobEventReader, subInfo *repository.SubscribedTuple, subTimeout time.Duration, subDoneChan chan<- *repository.JobSetKey, sqlJobService repository.SQLJobService) *JobSetSubscription

func (*JobSetSubscription) Subscribe

func (js *JobSetSubscription) Subscribe() error

type JobSetSubscriptionExecutor

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

func NewJobSetSubscriptionExecutor

func NewJobSetSubscriptionExecutor(ctx context.Context,
	eventReader events.JobEventReader,
	sqlJobService repository.SQLJobService,
	newSubChan <-chan *repository.SubscribedTuple,
	subTimeout time.Duration,
) *JobSetSubscriptionExecutor

func (*JobSetSubscriptionExecutor) HasSubscription

func (jse *JobSetSubscriptionExecutor) HasSubscription(key *repository.JobSetKey) bool

func (*JobSetSubscriptionExecutor) Manage

func (jse *JobSetSubscriptionExecutor) Manage()

func (*JobSetSubscriptionExecutor) NumActiveSubscriptions

func (jse *JobSetSubscriptionExecutor) NumActiveSubscriptions() int

func (*JobSetSubscriptionExecutor) ScanForMissingSubscriptions

func (jse *JobSetSubscriptionExecutor) ScanForMissingSubscriptions()

Looks for subscriptions that show as active in the DB but are not active in this executor.