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
- 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) DeploymentVersionTransition() *workflowpb.DeploymentVersionTransition
- 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() *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 ¶
func (a Any) InfiniteTimeout() *durationpb.Duration
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 ¶
func (tv *TestVars) DeploymentVersion() *deploymentspb.WorkerDeploymentVersion
func (*TestVars) DeploymentVersionString ¶
func (*TestVars) DeploymentVersionTransition ¶
func (tv *TestVars) DeploymentVersionTransition() *workflowpb.DeploymentVersionTransition
func (*TestVars) HandlerName ¶
func (*TestVars) NamespaceID ¶
func (*TestVars) NamespaceName ¶
func (*TestVars) Query ¶
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 ¶
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 ¶
func (tv *TestVars) VersioningOverridePinned() *workflowpb.VersioningOverride
func (*TestVars) WithActivityIDNumber ¶
func (*TestVars) WithBuildIDNumber ¶
func (*TestVars) WithDeploymentSeriesNumber ¶
[cleanup-wv-pre-release]
func (*TestVars) WithMessageIDNumber ¶
func (*TestVars) WithNamespaceID ¶
func (*TestVars) WithNamespaceName ¶
func (*TestVars) WithRequestID ¶
func (*TestVars) WithTaskQueue ¶
func (*TestVars) WithTaskQueueNumber ¶
func (*TestVars) WithTimerIDNumber ¶
func (*TestVars) WithUpdateIDNumber ¶
func (*TestVars) WithWorkflowIDNumber ¶
func (*TestVars) WorkerDeploymentOptions ¶
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.