eventstojobs

package
v0.4.7 Latest Latest
Warning

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

Go to latest
Published: Dec 11, 2023 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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

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

func NewJobSetSubscription added in v0.3.72

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

func (js *JobSetSubscription) Subscribe() error

type JobSetSubscriptionExecutor added in v0.3.72

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

func NewJobSetSubscriptionExecutor added in v0.3.72

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

func (*JobSetSubscriptionExecutor) HasSubscription added in v0.3.72

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

func (*JobSetSubscriptionExecutor) Manage added in v0.3.72

func (jse *JobSetSubscriptionExecutor) Manage()

func (*JobSetSubscriptionExecutor) NumActiveSubscriptions added in v0.3.72

func (jse *JobSetSubscriptionExecutor) NumActiveSubscriptions() int

func (*JobSetSubscriptionExecutor) ScanForMissingSubscriptions added in v0.3.72

func (jse *JobSetSubscriptionExecutor) ScanForMissingSubscriptions()

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

Jump to

Keyboard shortcuts

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