stalled

package

v1.18.8 Latest Latest Go to latest Published: Oct 21, 2026 License: Apache-2.0 Imports: 16 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/dapr/dapr

Links

Open Source Insights

Documentation ¶

Index ¶

type Option
type Permutation
- func NewPermutation(t *testing.T, opts PermutationOptions) *Permutation
type PermutationOptions
type Stalled
- func New(t *testing.T, fopts ...Option) *Stalled

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Option ¶

type Option func(*options)

func WithActivity ¶

func WithActivity(name string, activity task.Activity) Option

func WithInitialReplica ¶

func WithInitialReplica(name string) Option

func WithNamedWorkflowReplica ¶

func WithNamedWorkflowReplica(name string, workflow task.Workflow) Option

type Permutation ¶ added in v1.17.13

type Permutation struct {
	// contains filtered or unexported fields
}

Permutation is a clustered deployment process which drives the stall-and-recover scenario for a given placement of worker clients.

func NewPermutation ¶ added in v1.17.13

func NewPermutation(t *testing.T, opts PermutationOptions) *Permutation

func (*Permutation) Cleanup ¶ added in v1.17.13

func (p *Permutation) Cleanup(t *testing.T)

func (*Permutation) Execute ¶ added in v1.17.13

func (p *Permutation) Execute(t *testing.T, ctx context.Context)

func (*Permutation) Run ¶ added in v1.17.13

func (p *Permutation) Run(t *testing.T, ctx context.Context)

type PermutationOptions ¶ added in v1.17.13

type PermutationOptions struct {
	Daprds   int
	V1       []int
	V2       []int
	Recovery []int
}

PermutationOptions configures the worker client placement for a Permutation. Each phase's slice lists the daprd index each worker client connects to; duplicates mean multiple clients on the same daprd.

type Stalled ¶

type Stalled struct {
	CurrentClient *client.TaskHubGrpcClient
	// contains filtered or unexported fields
}

func New ¶

func New(t *testing.T, fopts ...Option) *Stalled

func (*Stalled) Cleanup ¶

func (f *Stalled) Cleanup(t *testing.T)

func (*Stalled) CountStalledEvents ¶

func (f *Stalled) CountStalledEvents(t *testing.T, ctx context.Context, id api.InstanceID) int

func (*Stalled) ReconnectAsReplica ¶ added in v1.17.13

func (f *Stalled) ReconnectAsReplica(t *testing.T, ctx context.Context, name string)

ReconnectAsReplica switches the workflow replica by disconnecting the current client and connecting a new one, without restarting daprd.

func (*Stalled) RestartAsReplica ¶

func (f *Stalled) RestartAsReplica(t *testing.T, ctx context.Context, name string)

func (*Stalled) Run ¶

func (f *Stalled) Run(t *testing.T, ctx context.Context)

func (*Stalled) ScheduleWorkflow ¶

func (f *Stalled) ScheduleWorkflow(t *testing.T, ctx context.Context) api.InstanceID

func (*Stalled) WaitForCompleted ¶

func (f *Stalled) WaitForCompleted(t *testing.T, ctx context.Context, id api.InstanceID)

func (*Stalled) WaitForNumberOfOrchestrationStartedEvents ¶

func (f *Stalled) WaitForNumberOfOrchestrationStartedEvents(t *testing.T, ctx context.Context, id api.InstanceID, expected int)

func (*Stalled) WaitForStalled ¶

func (f *Stalled) WaitForStalled(t *testing.T, ctx context.Context, id api.InstanceID) *protos.ExecutionStalledEvent

Source Files ¶

View all Source files

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