Documentation
¶
Index ¶
- type Any
- func (a Any) ApplicationFailure() *failurepb.Failure
- func (a Any) EventID() int64
- func (a Any) InfiniteTimeout() *durationpb.Duration
- func (a Any) Int() int
- func (a Any) Int64() int64
- func (a Any) Payload() *commonpb.Payload
- func (a Any) Payloads() *commonpb.Payloads
- func (a Any) RunID() string
- func (a Any) String() string
- func (a Any) WorkflowKey() definition.WorkflowKey
- type Global
- type TestVars
- func (tv *TestVars) ActivityID() string
- func (tv *TestVars) ActivityType() *commonpb.ActivityType
- func (tv *TestVars) Any() Any
- func (tv *TestVars) BuildID() string
- func (tv *TestVars) ClientIdentity() string
- func (tv *TestVars) Deployment() *deploymentpb.Deployment
- func (tv *TestVars) DeploymentSeries() string
- func (tv *TestVars) DeploymentVersion() *deploymentspb.WorkerDeploymentVersion
- func (tv *TestVars) DeploymentVersionString() string
- func (tv *TestVars) DeploymentVersionStringV32() string
- func (tv *TestVars) DeploymentVersionTransition() *workflowpb.DeploymentVersionTransition
- func (tv *TestVars) ExternalDeploymentVersion() *deploymentpb.WorkerDeploymentVersion
- func (tv *TestVars) Global() Global
- func (tv *TestVars) HandlerName() string
- func (tv *TestVars) IndexName() string
- func (tv *TestVars) MessageID() string
- func (tv *TestVars) Namespace() *namespace.Namespace
- func (tv *TestVars) NamespaceID() namespace.ID
- func (tv *TestVars) NamespaceName() namespace.Name
- func (tv *TestVars) Operation() string
- func (tv *TestVars) Query() *querypb.WorkflowQuery
- func (tv *TestVars) QueryType() string
- func (tv *TestVars) RequestID() string
- func (tv *TestVars) RunID() string
- func (tv *TestVars) Service() string
- func (tv *TestVars) SignalName() string
- func (tv *TestVars) StickyExecutionAttributes(timeout time.Duration) *taskqueuepb.StickyExecutionAttributes
- func (tv *TestVars) StickyTaskQueue() *taskqueuepb.TaskQueue
- func (tv *TestVars) TaskQueue() *taskqueuepb.TaskQueue
- func (tv *TestVars) TimerID() string
- func (tv *TestVars) UpdateID() string
- func (tv *TestVars) UpdateRef() *updatepb.UpdateRef
- func (tv *TestVars) VersioningOverridePinned(useV32 bool) *workflowpb.VersioningOverride
- func (tv *TestVars) WithActivityIDNumber(n int) *TestVars
- func (tv *TestVars) WithBuildIDNumber(n int) *TestVars
- func (tv *TestVars) WithDeploymentSeriesNumber(n int) *TestVars
- func (tv *TestVars) WithMessageIDNumber(n int) *TestVars
- func (tv *TestVars) WithNamespaceID(namespaceID namespace.ID) *TestVars
- func (tv *TestVars) WithNamespaceName(namespaceName namespace.Name) *TestVars
- func (tv *TestVars) WithRequestID(requestID string) *TestVars
- func (tv *TestVars) WithRunID(runID string) *TestVars
- func (tv *TestVars) WithTaskQueue(taskQueue string) *TestVars
- func (tv *TestVars) WithTaskQueueNumber(n int) *TestVars
- func (tv *TestVars) WithTimerIDNumber(n int) *TestVars
- func (tv *TestVars) WithUpdateIDNumber(n int) *TestVars
- func (tv *TestVars) WithWorkflowIDNumber(n int) *TestVars
- func (tv *TestVars) WorkerDeploymentOptions(versioned bool) *deploymentpb.WorkerDeploymentOptions
- func (tv *TestVars) WorkerIdentity() string
- func (tv *TestVars) WorkflowExecution() *commonpb.WorkflowExecution
- func (tv *TestVars) WorkflowID() string
- func (tv *TestVars) WorkflowType() *commonpb.WorkflowType
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Any ¶
type Any struct {
// contains filtered or unexported fields
}
func (Any) ApplicationFailure ¶ added in v1.26.0
func (Any) InfiniteTimeout ¶ added in v1.27.0
func (a Any) InfiniteTimeout() *durationpb.Duration
func (Any) WorkflowKey ¶ added in v1.28.0
func (a Any) WorkflowKey() definition.WorkflowKey
type TestVars ¶
type TestVars struct {
// contains filtered or unexported fields
}
func (*TestVars) ActivityID ¶
func (*TestVars) ActivityType ¶
func (tv *TestVars) ActivityType() *commonpb.ActivityType
func (*TestVars) ClientIdentity ¶ added in v1.25.0
func (*TestVars) Deployment ¶ added in v1.26.2
func (tv *TestVars) Deployment() *deploymentpb.Deployment
[cleanup-wv-pre-release]
func (*TestVars) DeploymentSeries ¶ added in v1.26.2
[cleanup-wv-pre-release]
func (*TestVars) DeploymentVersion ¶ added in v1.27.0
func (tv *TestVars) DeploymentVersion() *deploymentspb.WorkerDeploymentVersion
func (*TestVars) DeploymentVersionString ¶ added in v1.27.0
DeploymentVersionString returns v31 string
func (*TestVars) DeploymentVersionStringV32 ¶ added in v1.28.0
func (*TestVars) DeploymentVersionTransition ¶ added in v1.27.0
func (tv *TestVars) DeploymentVersionTransition() *workflowpb.DeploymentVersionTransition
func (*TestVars) ExternalDeploymentVersion ¶ added in v1.28.0
func (tv *TestVars) ExternalDeploymentVersion() *deploymentpb.WorkerDeploymentVersion
func (*TestVars) HandlerName ¶
func (*TestVars) NamespaceID ¶
func (*TestVars) NamespaceName ¶
func (*TestVars) Query ¶ added in v1.27.0
func (tv *TestVars) Query() *querypb.WorkflowQuery
func (*TestVars) RunID ¶
RunID is different from other getters. By default, it returns an empty string. This is to simplify the usage of WorkflowExecution() which most of the time doesn't need RunID. Otherwise, RunID can be set explicitly using WithRunID.
func (*TestVars) SignalName ¶ added in v1.27.0
func (*TestVars) StickyExecutionAttributes ¶ added in v1.26.2
func (tv *TestVars) StickyExecutionAttributes(timeout time.Duration) *taskqueuepb.StickyExecutionAttributes
func (*TestVars) StickyTaskQueue ¶
func (tv *TestVars) StickyTaskQueue() *taskqueuepb.TaskQueue
func (*TestVars) TaskQueue ¶
func (tv *TestVars) TaskQueue() *taskqueuepb.TaskQueue
func (*TestVars) VersioningOverridePinned ¶ added in v1.27.0
func (tv *TestVars) VersioningOverridePinned(useV32 bool) *workflowpb.VersioningOverride
func (*TestVars) WithActivityIDNumber ¶ added in v1.27.0
func (*TestVars) WithBuildIDNumber ¶ added in v1.27.0
func (*TestVars) WithDeploymentSeriesNumber ¶ added in v1.27.0
[cleanup-wv-pre-release]
func (*TestVars) WithMessageIDNumber ¶ added in v1.27.0
func (*TestVars) WithNamespaceID ¶
func (*TestVars) WithNamespaceName ¶
func (*TestVars) WithRequestID ¶ added in v1.27.0
func (*TestVars) WithTaskQueue ¶
func (*TestVars) WithTaskQueueNumber ¶ added in v1.27.0
func (*TestVars) WithTimerIDNumber ¶ added in v1.27.0
func (*TestVars) WithUpdateIDNumber ¶ added in v1.27.0
func (*TestVars) WithWorkflowIDNumber ¶ added in v1.27.0
func (*TestVars) WorkerDeploymentOptions ¶ added in v1.27.0
func (tv *TestVars) WorkerDeploymentOptions(versioned bool) *deploymentpb.WorkerDeploymentOptions
func (*TestVars) WorkerIdentity ¶
func (*TestVars) WorkflowExecution ¶
func (tv *TestVars) WorkflowExecution() *commonpb.WorkflowExecution
func (*TestVars) WorkflowID ¶
func (*TestVars) WorkflowType ¶
func (tv *TestVars) WorkflowType() *commonpb.WorkflowType
Click to show internal directories.
Click to hide internal directories.