workflow

package

v1.16.0 Latest Latest Go to latest Published: Sep 16, 2025 License: Apache-2.0 Imports: 14 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Option func(*options)

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

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

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

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

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

func WithDaprds(daprds int) Option

func WithScheduler(enable bool) 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) BackendClientN(t *testing.T, ctx context.Context, index int) *client.TaskHubGrpcClient

BackendClient returns a backend client for the specified index

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

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

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

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

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

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 (w *Workflow) Metrics(t *testing.T, ctx context.Context) map[string]float64

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

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

Registry returns the registry for a specific index

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

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