workflow

package

v1.17.17 Latest Latest Go to latest Published: Oct 20, 2026 License: Apache-2.0 Imports: 8 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Option func(*options)

func WithAddActivityN(t *testing.T, name string, a func(task.ActivityContext) (any, error)) Option

func WithAddOrchestratorN(t *testing.T, name string, or func(*task.OrchestrationContext) (any, error)) Option

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

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

func (w *Workflow) BackendClient(t *testing.T, ctx context.Context) *client.TaskHubGrpcClient

func (w *Workflow) Cleanup(t *testing.T)

func (w *Workflow) GRPCClient(t *testing.T, ctx context.Context) rtv1.DaprClient

func (w *Workflow) Metrics(t *testing.T, ctx context.Context) map[string]float64

func (w *Workflow) Registry() *task.TaskRegistry

func (w *Workflow) Run(t *testing.T, ctx context.Context)