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
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.
Source Files
Click to show internal directories.
Click to hide internal directories.