Documentation
¶
Index ¶
- Constants
- func RegisterAll(registry *autocore.Registry) error
- type Scenario
- func ActivityWithRetries() Scenario
- func AllScenarios() []Scenario
- func ChildWorkflowBasic() Scenario
- func ChildWorkflowCancelFanout() Scenario
- func ChildWorkflowDetached() Scenario
- func DeepSelector() Scenario
- func ExhaustSignalCap() Scenario
- func Fanout() Scenario
- func FanoutWithRetries() Scenario
- func InlineActivityBasic() Scenario
- func InlineActivityFailure() Scenario
- func LongTimer() Scenario
- func NestedTimers() Scenario
- func NondeterministicPanic() Scenario
- func Noop() Scenario
- func PanicOnAttempt() Scenario
- func SignalConsumer() Scenario
- func SingleActivity() Scenario
Constants ¶
View Source
const ( ActivityNoop autocore.ActivityName[*scenariospb.NoopActivityInput, *scenariospb.NoopActivityOutput] = "noop_activity" ActivityPanic autocore.ActivityName[*emptypb.Empty, *emptypb.Empty] = "panic_activity" )
View Source
const ( NameFanout autocore.WorkflowName[*scenariospb.FanoutInput, *emptypb.Empty] = "fanout" NameFanoutWithRetries autocore.WorkflowName[*scenariospb.FanoutInput, *emptypb.Empty] = "fanout_with_retries" )
View Source
const NameActivityWithRetries autocore.WorkflowName[*scenariospb.ActivityWithRetriesInput, *emptypb.Empty] = "activity_with_retries"
View Source
const NameChildWorkflowBasic autocore.WorkflowName[*scenariospb.ChildWorkflowBasicInput, *emptypb.Empty] = "child_workflow_basic"
View Source
const NameChildWorkflowCancelFanout autocore.WorkflowName[*scenariospb.ChildWorkflowCancelFanoutInput, *emptypb.Empty] = "child_workflow_cancel_fanout"
View Source
const NameChildWorkflowDetached autocore.WorkflowName[*scenariospb.ChildWorkflowDetachedInput, *emptypb.Empty] = "child_workflow_detached"
View Source
const NameChildWorkflowInner autocore.WorkflowName[*scenariospb.NoopChildInput, *emptypb.Empty] = "child_workflow_inner"
NameChildWorkflowInner is the workflow function shared by every child-workflow scenario. The parent picks the child's behavior via NoopChildInput.sleep_ms: 0 means return immediately (basic); a small value means brief lifecycle visibility (detached); a long value (longer than the cancel-fanout window) lets the cancel propagate before the child completes naturally.
View Source
const NameDeepSelector autocore.WorkflowName[*scenariospb.DeepSelectorInput, *emptypb.Empty] = "deep_selector"
View Source
const NameExhaustSignalCap autocore.WorkflowName[*scenariospb.ExhaustSignalCapInput, *emptypb.Empty] = "exhaust_signal_cap"
View Source
const NameInlineActivityBasic autocore.WorkflowName[*scenariospb.InlineActivityBasicInput, *emptypb.Empty] = "inline_activity_basic"
View Source
const NameInlineActivityFailure autocore.WorkflowName[*scenariospb.InlineActivityFailureInput, *emptypb.Empty] = "inline_activity_failure"
View Source
const NameLongTimer autocore.WorkflowName[*scenariospb.LongTimerInput, *emptypb.Empty] = "long_timer"
View Source
const NameNestedTimers autocore.WorkflowName[*scenariospb.NestedTimersInput, *emptypb.Empty] = "nested_timers"
View Source
const NameNondeterministicPanic autocore.WorkflowName[*scenariospb.NondeterministicPanicInput, *emptypb.Empty] = "nondeterministic_panic"
View Source
const NameNoop autocore.WorkflowName[*scenariospb.NoopInput, *scenariospb.NoopInput] = "noop"
View Source
const NamePanicOnAttempt autocore.WorkflowName[*scenariospb.PanicOnAttemptInput, *emptypb.Empty] = "panic_on_attempt"
View Source
const NameSignalConsumer autocore.WorkflowName[*scenariospb.SignalConsumerInput, *emptypb.Empty] = "signal_consumer"
View Source
const NameSingleActivity autocore.WorkflowName[*scenariospb.SingleActivityInput, *emptypb.Empty] = "single_activity"
Variables ¶
This section is empty.
Functions ¶
func RegisterAll ¶
Types ¶
type Scenario ¶
func ActivityWithRetries ¶
func ActivityWithRetries() Scenario
func AllScenarios ¶
func AllScenarios() []Scenario
func ChildWorkflowBasic ¶
func ChildWorkflowBasic() Scenario
func ChildWorkflowCancelFanout ¶
func ChildWorkflowCancelFanout() Scenario
func ChildWorkflowDetached ¶
func ChildWorkflowDetached() Scenario
func DeepSelector ¶
func DeepSelector() Scenario
func ExhaustSignalCap ¶
func ExhaustSignalCap() Scenario
func FanoutWithRetries ¶
func FanoutWithRetries() Scenario
FanoutWithRetries shares the same workflow function as Fanout. The two scenarios differ only in the params the driver supplies: FanoutWithRetries is generated with a non-zero retry policy + non-zero fail probability so most activities recover via retry and a minority exhaust the budget.
func InlineActivityBasic ¶
func InlineActivityBasic() Scenario
func InlineActivityFailure ¶
func InlineActivityFailure() Scenario
func NestedTimers ¶
func NestedTimers() Scenario
func NondeterministicPanic ¶
func NondeterministicPanic() Scenario
func PanicOnAttempt ¶
func PanicOnAttempt() Scenario
func SignalConsumer ¶
func SignalConsumer() Scenario
func SingleActivity ¶
func SingleActivity() Scenario
Source Files
¶
- activities.go
- activity_with_retries.go
- all.go
- child_workflow_basic.go
- child_workflow_cancel_fanout.go
- child_workflow_detached.go
- child_workflows_inner.go
- deep_selector.go
- exhaust_signal_cap.go
- fanout.go
- inline_activity_basic.go
- inline_activity_failure.go
- long_timer.go
- nested_timers.go
- nondeterministic_panic.go
- noop.go
- panic_on_attempt.go
- registry.go
- signal_consumer.go
- single_activity.go
Directories
Click to show internal directories.
Click to hide internal directories.