mirror of
https://github.com/temporalio/temporal.git
synced 2026-08-30 18:41:49 -07:00
e004436d8b
## What changed? (1) elapsed-duration / skipped-duration **bounds** that auto-disable time-skipping (2) a new `TimeSkippingTimerTask` that wakes the workflow when an elapsed bound is reached (3) time-skipping support for backoff timers (start-with-delay / cron / retry / CaN-with-backoff) plus an exclusion for child workflows that haven't scheduled their first WT ## Why? the completion of the feature ## How did you test it? - [x] built - [x] run locally and tested manually - [x] covered by existing tests - [x] added new unit test(s) - [x] added new functional test(s)
95 lines
3.2 KiB
Go
95 lines
3.2 KiB
Go
// Code generated by protoc-gen-go-helpers. DO NOT EDIT.
|
|
package enums
|
|
|
|
import (
|
|
"fmt"
|
|
)
|
|
|
|
var (
|
|
TaskSource_shorthandValue = map[string]int32{
|
|
"Unspecified": 0,
|
|
"History": 1,
|
|
"DbBacklog": 2,
|
|
}
|
|
)
|
|
|
|
// TaskSourceFromString parses a TaskSource value from either the protojson
|
|
// canonical SCREAMING_CASE enum or the traditional temporal PascalCase enum to TaskSource
|
|
func TaskSourceFromString(s string) (TaskSource, error) {
|
|
if v, ok := TaskSource_value[s]; ok {
|
|
return TaskSource(v), nil
|
|
} else if v, ok := TaskSource_shorthandValue[s]; ok {
|
|
return TaskSource(v), nil
|
|
}
|
|
return TaskSource(0), fmt.Errorf("%s is not a valid TaskSource", s)
|
|
}
|
|
|
|
var (
|
|
TaskType_shorthandValue = map[string]int32{
|
|
"Unspecified": 0,
|
|
"ReplicationHistory": 1,
|
|
"ReplicationSyncActivity": 2,
|
|
"TransferWorkflowTask": 3,
|
|
"TransferActivityTask": 4,
|
|
"TransferCloseExecution": 5,
|
|
"TransferCancelExecution": 6,
|
|
"TransferStartChildExecution": 7,
|
|
"TransferSignalExecution": 8,
|
|
"TransferResetWorkflow": 10,
|
|
"WorkflowTaskTimeout": 12,
|
|
"ActivityTimeout": 13,
|
|
"UserTimer": 14,
|
|
"WorkflowRunTimeout": 15,
|
|
"DeleteHistoryEvent": 16,
|
|
"ActivityRetryTimer": 17,
|
|
"WorkflowBackoffTimer": 18,
|
|
"VisibilityStartExecution": 19,
|
|
"VisibilityUpsertExecution": 20,
|
|
"VisibilityCloseExecution": 21,
|
|
"VisibilityDeleteExecution": 22,
|
|
"TransferDeleteExecution": 24,
|
|
"ReplicationSyncWorkflowState": 25,
|
|
"ArchivalArchiveExecution": 26,
|
|
"StateMachineOutbound": 27,
|
|
"StateMachineTimer": 28,
|
|
"WorkflowExecutionTimeout": 29,
|
|
"ReplicationSyncHsm": 30,
|
|
"ReplicationSyncVersionedTransition": 31,
|
|
"ChasmPure": 32,
|
|
"Chasm": 33,
|
|
"ReplicationDeleteExecution": 34,
|
|
"WorkerCommands": 35,
|
|
"TimeskippingTimer": 36,
|
|
}
|
|
)
|
|
|
|
// TaskTypeFromString parses a TaskType value from either the protojson
|
|
// canonical SCREAMING_CASE enum or the traditional temporal PascalCase enum to TaskType
|
|
func TaskTypeFromString(s string) (TaskType, error) {
|
|
if v, ok := TaskType_value[s]; ok {
|
|
return TaskType(v), nil
|
|
} else if v, ok := TaskType_shorthandValue[s]; ok {
|
|
return TaskType(v), nil
|
|
}
|
|
return TaskType(0), fmt.Errorf("%s is not a valid TaskType", s)
|
|
}
|
|
|
|
var (
|
|
TaskPriority_shorthandValue = map[string]int32{
|
|
"Unspecified": 0,
|
|
"High": 1,
|
|
"Low": 10,
|
|
}
|
|
)
|
|
|
|
// TaskPriorityFromString parses a TaskPriority value from either the protojson
|
|
// canonical SCREAMING_CASE enum or the traditional temporal PascalCase enum to TaskPriority
|
|
func TaskPriorityFromString(s string) (TaskPriority, error) {
|
|
if v, ok := TaskPriority_value[s]; ok {
|
|
return TaskPriority(v), nil
|
|
} else if v, ok := TaskPriority_shorthandValue[s]; ok {
|
|
return TaskPriority(v), nil
|
|
}
|
|
return TaskPriority(0), fmt.Errorf("%s is not a valid TaskPriority", s)
|
|
}
|