stalled

package

v1.17.2 Latest Latest Go to latest Published: Mar 19, 2026 License: Apache-2.0 Imports: 13 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Option func(*options)

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

func WithInitialReplica(name string) Option

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

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

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

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

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

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

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

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

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

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

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