workflow

package
v1.17.7-rc.3 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 14, 2026 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Option 

type Option func(*options)

func WithAddActivity added in v1.16.0 

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

func WithAddActivityN 

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

func WithAddOrchestrator added in v1.16.0 

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

func WithAddOrchestratorN 

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

func WithDaprdOptions added in v1.16.0 

func WithDaprdOptions(index int, opts ...daprd.Option) Option

func WithDaprds added in v1.15.6 

func WithDaprds(daprds int) Option

func WithNoDB added in v1.17.0 

func WithNoDB() Option

func WithSchedulerAddress added in v1.17.7 

func WithSchedulerAddress(addr string) Option

WithSchedulerAddress overrides the address used for the daprd's --scheduler-host-address flag. Use this to point daprd at a proxy that fronts the real scheduler.

func WithSchedulerInstance added in v1.17.7 

func WithSchedulerInstance(sched *scheduler.Scheduler) Option

WithSchedulerInstance lets a test supply a pre-constructed scheduler. The framework uses this scheduler instead of creating its own and skips adding it to its process list (the caller is responsible for that). Combine with WithSchedulerAddress when interposing a proxy.

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) BackendClientN added in v1.16.0 

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

BackendClient returns a backend client for the specified index

func (*Workflow) Cleanup 

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

func (*Workflow) DB added in v1.15.0 

func (w *Workflow) DB() *sqlite.SQLite

func (*Workflow) Dapr added in v1.15.0 

func (w *Workflow) Dapr() *daprd.Daprd

func (*Workflow) DaprN added in v1.15.6 

func (w *Workflow) DaprN(i int) *daprd.Daprd

func (*Workflow) GRPCClient 

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

func (*Workflow) GRPCClientN added in v1.16.0 

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

GRPCClientForApp returns a GRPC client for the specified app index

func (*Workflow) Metrics 

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

func (*Workflow) Registry added in v1.15.0 

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

func (*Workflow) RegistryN added in v1.16.0 

func (w *Workflow) RegistryN(index int) *task.TaskRegistry

Registry returns the registry for a specific index

func (*Workflow) ResetRegistry added in v1.17.0 

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

func (*Workflow) Run 

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

func (*Workflow) Scheduler added in v1.17.0 

func (w *Workflow) Scheduler() *scheduler.Scheduler

func (*Workflow) WaitUntilRunning 

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

func (*Workflow) WorkflowClient added in v1.17.0 

func (w *Workflow) WorkflowClient(t *testing.T, ctx context.Context) *workflow.Client

func (*Workflow) WorkflowClientN added in v1.17.0 

func (w *Workflow) WorkflowClientN(t *testing.T, ctx context.Context, index int) *workflow.Client

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.