workflow

package

v1.19.0 Latest Latest Go to latest Published: Oct 22, 2026 License: Apache-2.0 Imports: 10 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 Workflow
- func New(t *testing.T, fopts ...Option) *Workflow

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Option ¶

type Option func(*options)

func WithAddActivityN ¶

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

func WithAddWorkflowN ¶ added in v1.18.0

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

func WithClusteredDeployment ¶ added in v1.19.0

func WithClusteredDeployment(enabled bool) Option

WithClusteredDeployment explicitly enables or disables the WorkflowsClusteredDeployment feature flag on the underlying daprd, overriding the DAPR_INTEGRATION_WORKFLOW_CLUSTERED environment variable.

func WithFastPath ¶ added in v1.19.0

func WithFastPath(enabled bool) Option

WithFastPath explicitly enables or disables the WorkflowsFastPath feature flag on the underlying daprd, overriding the DAPR_INTEGRATION_WORKFLOW_FASTPATH environment variable.

type Workflow ¶

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

func New ¶

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

func (*Workflow) BackendClient ¶

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

func (*Workflow) Cleanup ¶

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

func (*Workflow) ClusteredDeployment ¶ added in v1.19.0

func (w *Workflow) ClusteredDeployment() bool

ClusteredDeployment reports whether the underlying daprd runs with the WorkflowsClusteredDeployment feature flag enabled.

func (*Workflow) FastPath ¶ added in v1.19.0

func (w *Workflow) FastPath() bool

FastPath reports whether the underlying daprd runs with the WorkflowsFastPath feature flag enabled.

func (*Workflow) GRPCClient ¶

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

func (*Workflow) Metrics ¶

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

func (*Workflow) Registry ¶

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

func (*Workflow) Run ¶

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

Source Files ¶

View all Source files

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