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