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) Int32() int32
- 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) UInt32() uint32
- func (a Any) UInt64() uint64
- 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) SDKDeploymentVersion() worker.WorkerDeploymentVersion
- 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) WithBuildID(buildID string) *TestVars
- func (tv *TestVars) WithBuildIDNumber(n int) *TestVars
- func (tv *TestVars) WithDeploymentSeries(deploymentSeries string) *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) WithWorkflowID(workflowID string) *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 ¶
func (Any) InfiniteTimeout ¶
func (a Any) InfiniteTimeout() *durationpb.Duration
func (Any) WorkflowKey ¶
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 ¶
func (*TestVars) Deployment ¶
func (tv *TestVars) Deployment() *deploymentpb.Deployment
[cleanup-wv-pre-release]
func (*TestVars) DeploymentSeries ¶
[cleanup-wv-pre-release]
func (*TestVars) DeploymentVersion ¶
func (tv *TestVars) DeploymentVersion() *deploymentspb.WorkerDeploymentVersion
func (*TestVars) DeploymentVersionString ¶
DeploymentVersionString returns v31 string
func (*TestVars) DeploymentVersionStringV32 ¶
func (*TestVars) DeploymentVersionTransition ¶
func (tv *TestVars) DeploymentVersionTransition() *workflowpb.DeploymentVersionTransition
func (*TestVars) ExternalDeploymentVersion ¶
func (tv *TestVars) ExternalDeploymentVersion() *deploymentpb.WorkerDeploymentVersion
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) SDKDeploymentVersion ¶
func (tv *TestVars) SDKDeploymentVersion() worker.WorkerDeploymentVersion
SDKDeploymentVersion returns SDK worker deployment version
func (*TestVars) SignalName ¶
func (*TestVars) StickyExecutionAttributes ¶
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(useV32 bool) *workflowpb.VersioningOverride
func (*TestVars) WithActivityIDNumber ¶
func (*TestVars) WithBuildID ¶
func (*TestVars) WithBuildIDNumber ¶
func (*TestVars) WithDeploymentSeries ¶
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) WithWorkflowID ¶
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.