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) DeploymentTransition() *workflowpb.DeploymentTransition
- 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) 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) 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
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
func (*TestVars) DeploymentSeries ¶ added in v1.26.2
func (*TestVars) DeploymentTransition ¶
func (tv *TestVars) DeploymentTransition() *workflowpb.DeploymentTransition
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() *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
func (*TestVars) WithMessageIDNumber ¶ added in v1.27.0
func (*TestVars) WithNamespaceID ¶
func (*TestVars) WithNamespaceName ¶
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) 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.