Documentation
¶
Index ¶
- type Option
- func WithAddActivity(t *testing.T, name string, a func(task.ActivityContext) (any, error)) Option
- func WithAddActivityN(t *testing.T, index int, name string, ...) Option
- func WithAddOrchestrator(t *testing.T, name string, or func(*task.WorkflowContext) (any, error)) Option
- func WithAddWorkflowN(t *testing.T, index int, name string, ...) Option
- func WithDaprdOptions(index int, opts ...daprd.Option) Option
- func WithDaprds(daprds int) Option
- func WithHistorySigning(t *testing.T) Option
- func WithMTLS(t *testing.T) Option
- func WithNoDB() Option
- func WithPlacementOptions(opts ...placement.Option) Option
- func WithSchedulerAddress(addr string) Option
- func WithSchedulerInstance(sched *scheduler.Scheduler) Option
- func WithSchedulerOptions(opts ...scheduler.Option) Option
- func WithSigningDisabledN(index int) Option
- type Workflow
- func (w *Workflow) ActivityActorType(index int) string
- 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
- 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
- func (w *Workflow) ManagementClient(t *testing.T, ctx context.Context) *client.TaskHubGrpcClient
- func (w *Workflow) ManagementClientN(t *testing.T, ctx context.Context, index int) *client.TaskHubGrpcClient
- func (w *Workflow) Metrics(t *testing.T, ctx context.Context) map[string]float64
- func (w *Workflow) Placement() *placement.Placement
- func (w *Workflow) Registry() *task.TaskRegistry
- func (w *Workflow) RegistryN(index int) *task.TaskRegistry
- func (w *Workflow) ResetRegistry(t *testing.T)
- func (w *Workflow) Run(t *testing.T, ctx context.Context)
- func (w *Workflow) Scheduler() *scheduler.Scheduler
- func (w *Workflow) Sentry() *sentry.Sentry
- func (w *Workflow) StrayFire(t *testing.T, ctx context.Context, index int, instanceID string, mtls bool)
- func (w *Workflow) WaitForNoConnectedWorkers(t *testing.T, ctx context.Context)
- func (w *Workflow) WaitForNoConnectedWorkersN(t *testing.T, ctx context.Context, index int)
- func (w *Workflow) WaitUntilRunning(t *testing.T, ctx context.Context)
- func (w *Workflow) WorkflowActorType(index int) string
- func (w *Workflow) WorkflowClient(t *testing.T, ctx context.Context) *workflow.Client
- func (w *Workflow) WorkflowClientN(t *testing.T, ctx context.Context, index int) *workflow.Client
- func (w *Workflow) WriteWorkflowState(t *testing.T, ctx context.Context, index int, instanceID string, ...)
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 WithAddActivityN ¶
func WithAddOrchestrator ¶ added in v1.16.0
func WithAddWorkflowN ¶ added in v1.18.0
func WithDaprdOptions ¶ added in v1.16.0
func WithDaprds ¶ added in v1.15.6
func WithHistorySigning ¶ added in v1.18.4
WithHistorySigning enables the WorkflowHistorySigning feature flag on every daprd in the workflow. History signing needs the Sentry-issued workload identity for its attestation and signing keys, so this also enables the mTLS setup of WithMTLS. Prefer this over WithMTLS in tests that are about signing behavior, so the intent is explicit at the call site.
func WithMTLS ¶ added in v1.18.0
WithMTLS spins up a Sentry process for mTLS and enables the WorkflowHistorySigning feature flag on every daprd in the workflow.
func WithPlacementOptions ¶ added in v1.18.0
func WithSchedulerAddress ¶ added in v1.17.7
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
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.
func WithSchedulerOptions ¶ added in v1.18.0
func WithSigningDisabledN ¶ added in v1.18.0
WithSigningDisabledN excludes the daprd at the given index from having the WorkflowHistorySigning feature flag set. Has no effect without WithMTLS or WithHistorySigning.
type Workflow ¶
type Workflow struct {
// contains filtered or unexported fields
}
func NewClustered ¶ added in v1.17.13
NewClustered returns a Workflow whose daprds share a single app ID with WorkflowsClusteredDeployment enabled, representing a clustered deployment behind a load balancer.
func (*Workflow) ActivityActorType ¶ added in v1.18.4
ActivityActorType returns the activity actor type registered by the daprd at the given index (default namespace).
func (*Workflow) BackendClient ¶
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) GRPCClient ¶
func (*Workflow) GRPCClientN ¶ added in v1.16.0
GRPCClientForApp returns a GRPC client for the specified app index
func (*Workflow) ManagementClient ¶ added in v1.18.3
ManagementClient returns a backend client connected to daprd index 0 for control-plane operations only. See ManagementClientN.
func (*Workflow) ManagementClientN ¶ added in v1.18.3
func (w *Workflow) ManagementClientN(t *testing.T, ctx context.Context, index int) *client.TaskHubGrpcClient
ManagementClientN returns a backend client connected to the daprd at the given index for control-plane operations only (scheduling, waiting, raising events, fetching history). It does not start a work-item listener, so it never executes workflows and never advertises any worker capability.
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 (*Workflow) StrayFire ¶ added in v1.18.4
func (w *Workflow) StrayFire(t *testing.T, ctx context.Context, index int, instanceID string, mtls bool)
StrayFire schedules a stray new-event reminder against the workflow actor hosted by daprd index, driving its empty-inbox path, and waits until the scheduler has delivered it.
func (*Workflow) WaitForNoConnectedWorkers ¶ added in v1.17.13
func (*Workflow) WaitForNoConnectedWorkersN ¶ added in v1.17.13
func (*Workflow) WaitUntilRunning ¶
func (*Workflow) WorkflowActorType ¶ added in v1.18.4
WorkflowActorType returns the orchestrator actor type registered by the daprd at the given index (default namespace).
func (*Workflow) WorkflowClient ¶ added in v1.17.0
func (*Workflow) WorkflowClientN ¶ added in v1.17.0
func (*Workflow) WriteWorkflowState ¶ added in v1.18.4
func (w *Workflow) WriteWorkflowState(t *testing.T, ctx context.Context, index int, instanceID string, generation uint64, history, inbox []*protos.HistoryEvent)
WriteWorkflowState writes a fabricated durable workflow state for the given instance straight into the SQLite actor state store: the history and inbox event rows plus the metadata row describing them, in the exact key layout the workflow state loader reads. Existing history and inbox rows for the instance are deleted first so the metadata lengths stay authoritative. daprd in-memory caches are not touched; pair this with a scheduler-driven reminder or a fresh actor activation to make daprd observe the rows.
Source Files
Directories