workflow

Documentation

Index

• type Option
  • 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
  • func WithScheduler(enable bool) Option
• type Workflow
  • 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)

Types

type Option

type Option func(*options)

func WithAddActivityN

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

func WithAddOrchestratorN

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

func WithScheduler

func WithScheduler(enable bool) Option

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) 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)