Documentation
¶
Index ¶
- type Option
- type Workflow
- func (w *Workflow) BackendClient(t *testing.T, ctx context.Context) *client.TaskHubGrpcClient
- func (w *Workflow) Cleanup(t *testing.T)
- func (w *Workflow) ClusteredDeployment() bool
- func (w *Workflow) FastPath() bool
- 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)
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 WithAddWorkflowN ¶ added in v1.18.0
func WithClusteredDeployment ¶
WithClusteredDeployment explicitly enables or disables the WorkflowsClusteredDeployment feature flag on the underlying daprd, overriding the DAPR_INTEGRATION_WORKFLOW_CLUSTERED environment variable.
func WithFastPath ¶
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 (*Workflow) BackendClient ¶
func (*Workflow) ClusteredDeployment ¶
ClusteredDeployment reports whether the underlying daprd runs with the WorkflowsClusteredDeployment feature flag enabled.
func (*Workflow) FastPath ¶
FastPath reports whether the underlying daprd runs with the WorkflowsFastPath feature flag enabled.
func (*Workflow) GRPCClient ¶
func (*Workflow) Registry ¶
func (w *Workflow) Registry() *task.TaskRegistry
Source Files
Click to show internal directories.
Click to hide internal directories.