scenarios

package

v19.3.2 Latest Latest Go to latest Published: Sep 10, 2026 License: MIT Imports: 12 Imported by: 0

Documentation ¶

Index ¶

Constants
func ChannelName(n int) string
func RegisterAll(registry *autocore.Registry) error
type Scenario

Constants ¶

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 FirstChannelName = autocore.ReservedPrefix + "ch:1"

FirstChannelName is the name autocore generates for the first channel a workflow creates, so it is what a sender addresses to reach the first channel of a scenario that creates its channels up front.

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: 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 ChannelName ¶

func ChannelName(n int) string

ChannelName returns the name autocore generates for the n-th (1-based) channel a workflow creates, for scenarios that create their channels up front in a deterministic order.

func RegisterAll ¶

func RegisterAll(registry *autocore.Registry) error

Types ¶

type Scenario ¶

type Scenario struct {
	Name     string
	Register func(r *autocore.Registry) error
	// NewInput returns a populated input proto for one execution. failProb
	// is the config-supplied failure probability; scenarios that need a
	// non-zero default apply it when failProb is 0.
	NewInput func(rng *rand.Rand, failProb float32) proto.Message
	// NewDrive returns the drive script for one execution: the external
	// operations (channel sends, cancellation) the driver performs against the
	// workflow. Derived from the same input NewInput produced. Nil when the
	// scenario needs no external driving.
	NewDrive func(rng *rand.Rand, input proto.Message) []flowtest.DriveOp
	// Expect returns the allowed terminal states for one execution with the
	// given input, derived from the scenario's semantics and its drive script.
	Expect func(input proto.Message) []flowtest.TerminalState
}

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 Fanout ¶

func Fanout() 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 LongTimer ¶

func LongTimer() Scenario

func NestedTimers ¶

func NestedTimers() Scenario

func NondeterministicPanic ¶

func NondeterministicPanic() Scenario

func Noop ¶

func Noop() Scenario

func PanicOnAttempt ¶

func PanicOnAttempt() Scenario

func SignalConsumer ¶

func SignalConsumer() Scenario

func SingleActivity ¶

func SingleActivity() Scenario

Directories ¶

Path	Synopsis
scenariospb

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL

Documentation ¶

Index ¶

Constants ¶

Variables ¶

Functions ¶

func ChannelName ¶

func RegisterAll ¶

Types ¶

type Scenario ¶

func ActivityWithRetries ¶

func AllScenarios ¶

func ChildWorkflowBasic ¶

func ChildWorkflowCancelFanout ¶

func ChildWorkflowDetached ¶

func DeepSelector ¶

func ExhaustSignalCap ¶

func Fanout ¶

func FanoutWithRetries ¶

func InlineActivityBasic ¶

func InlineActivityFailure ¶

func LongTimer ¶

func NestedTimers ¶

func NondeterministicPanic ¶

func Noop ¶

func PanicOnAttempt ¶

func SignalConsumer ¶

func SingleActivity ¶

Source Files ¶

Directories ¶