Изменение времени сна Uber Cadence на основе внешнего (например, пользовательского) ввода - PullRequest
Новая
       24

Изменение времени сна Uber Cadence на основе внешнего (например, пользовательского) ввода

0 голосов
/ 25 апреля 2019

Есть ли пример того, как рабочий процесс Cadence изменяет продолжительность ожидания на основе внешнего ввода?

Сценарий, который я ищу, заключается в следующем: рабочий процесс переходит в режим ожидания до времени X, но после запуска режима сна, нодо его завершения существует внешний триггер, который вызывает изменение времени X на время Y. Y может быть либо позже, либо раньше, чем X. Это может быть даже раньше, чем «сейчас», что должно немедленно отключить сон.

1 Ответ

0 голосов
/ 25 апреля 2019

Вот фрагмент кода для того, что вы ищете 

func SampleTimerWorkflow(ctx workflow.Context, timerDelay time.Duration) error 
{
    logger := workflow.GetLogger(ctx)
    resetCh := workflow.GetSignalChannel(ctx, "reset")

    timerFired := false
    delay := timerDelay
    for ;!timerFired; {
        selector := workflow.NewSelector(ctx)

        logger.Sugar().Infof("Setting up a timer to fire after: %v", delay)
        timerCancelCtx, cancelTimerHandler := workflow.WithCancel(ctx)
        timerFuture := workflow.NewTimer(timerCancelCtx, delay)
        selector.AddFuture(timerFuture, func(f workflow.Future) {
            logger.Info("Timer Fired.")
            timerFired = true
        })

        selector.AddReceive(resetCh, func(c workflow.Channel, more bool) {
            logger.Info("Reset signal received.")
            logger.Info("Cancel outstanding timer.")
            cancelTimerHandler()

            var t int
            c.Receive(ctx, &t)
            logger.Sugar().Infof("Reset delay: %v seconds", t)
            delay = time.Second * time.Duration(t)
        })

        logger.Info("Waiting for timer to fire.")
        selector.Select(ctx)
    }

    workflow.GetLogger(ctx).Info("Workflow completed.")
    return nil
}

Теперь вы можете отправить сигнал для сброса таймера на 10 секунд, как показано ниже: 

cadence-cli --domain <domain> wf signal -w <workflow_id>  --name reset --input 10
...