tests

package
v1.26.2-121.3 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 2, 2024 License: MIT Imports: 152 Imported by: 0

Documentation

Overview

nolint:revive

Index

Constants

View Source 
const NamespaceCacheRefreshInterval = time.Second

Variables

View Source 
var (
	ErrEncodingIsNotSet       = errors.New("payload encoding metadata is not set")
	ErrEncodingIsNotSupported = errors.New("payload encoding is not supported")
)
View Source 
var TestFlags struct {
	FrontendAddr             string
	FrontendHTTPAddr         string
	PersistenceType          string
	PersistenceDriver        string
	TestClusterConfigFile    string
	FaultInjectionConfigFile string
}

TestFlags contains the feature flags for functional tests

Functions

func CaNOnceWorkflow added in v1.25.0 

func CaNOnceWorkflow(ctx workflow.Context, input string) (string, error)

func EventBatchesToVersionHistory added in v1.24.0 

func EventBatchesToVersionHistory(
	versionHistory *historyspb.VersionHistory,
	eventBatches []*historypb.History,
) (*historyspb.VersionHistory, error)

func NewContext 

func NewContext() context.Context

NewContext create new context with default timeout 90 seconds.

func RandomizedNexusEndpoint added in v1.25.0 

func RandomizedNexusEndpoint(name string) string

func UsingSQLAdvancedVisibility added in v1.23.0 

func UsingSQLAdvancedVisibility() bool

func WithDropTask added in v1.22.1 

func WithDropTask(o *PollAndProcessWorkflowTaskOptions)

func WithDumpHistory added in v1.22.1 

func WithDumpHistory(o *PollAndProcessWorkflowTaskOptions)

func WithForceNewWorkflowTask added in v1.22.1 

func WithForceNewWorkflowTask(o *PollAndProcessWorkflowTaskOptions)

func WithNoDumpCommands added in v1.22.1 

func WithNoDumpCommands(o *PollAndProcessWorkflowTaskOptions)

func WithPollSticky added in v1.22.1 

func WithPollSticky(o *PollAndProcessWorkflowTaskOptions)

func WithRespondSticky added in v1.22.1 

func WithRespondSticky(o *PollAndProcessWorkflowTaskOptions)

func WithoutRetries added in v1.25.0 

func WithoutRetries(o *PollAndProcessWorkflowTaskOptions)

Types

type AcquireShardFunctionalSuite added in v1.23.0 

type AcquireShardFunctionalSuite struct {
	FunctionalTestBase
	// contains filtered or unexported fields
}

AcquireShardFunctionalSuite is the base test suite for testing acquire shard.

func (*AcquireShardFunctionalSuite) SetupSuite added in v1.23.0 

func (s *AcquireShardFunctionalSuite) SetupSuite()

SetupSuite sets up the test suite by setting the log recorder.

func (*AcquireShardFunctionalSuite) TearDownSuite added in v1.23.0 

func (s *AcquireShardFunctionalSuite) TearDownSuite()

TearDownSuite tears down the test suite by shutting down the test cluster after a short delay.

type AddTasksSuite added in v1.23.0 

type AddTasksSuite struct {
	FunctionalTestBase
	*require.Assertions
	// contains filtered or unexported fields
}

AddTasksSuite is a separate suite because we need to override the history service's executable wrapper.

func (*AddTasksSuite) SetupSuite added in v1.23.0 

func (s *AddTasksSuite) SetupSuite()

SetupSuite creates the test cluster and registers the executorWrapper with the history service.

func (*AddTasksSuite) SetupTest added in v1.23.0 

func (s *AddTasksSuite) SetupTest()

func (*AddTasksSuite) TearDownSuite added in v1.23.0 

func (s *AddTasksSuite) TearDownSuite()

func (*AddTasksSuite) TestAddTasks_ErrGetShardByID added in v1.23.0 

func (s *AddTasksSuite) TestAddTasks_ErrGetShardByID()

func (*AddTasksSuite) TestAddTasks_GetEngineErr added in v1.23.0 

func (s *AddTasksSuite) TestAddTasks_GetEngineErr()

func (*AddTasksSuite) TestAddTasks_Ok added in v1.23.0 

func (s *AddTasksSuite) TestAddTasks_Ok()

type AdvancedVisibilitySuite added in v1.23.0 

type AdvancedVisibilitySuite struct {
	// override suite.Suite.Assertions with require.Assertions; this means that s.NotNil(nil) will stop the test,
	// not merely log an error
	*require.Assertions
	protorequire.ProtoAssertions
	historyrequire.HistoryRequire
	FunctionalTestBase
	// contains filtered or unexported fields
}

func (*AdvancedVisibilitySuite) SetupSuite added in v1.23.0 

func (s *AdvancedVisibilitySuite) SetupSuite()

This cluster use customized threshold for history config

func (*AdvancedVisibilitySuite) SetupTest added in v1.23.0 

func (s *AdvancedVisibilitySuite) SetupTest()

func (*AdvancedVisibilitySuite) TearDownSuite added in v1.23.0 

func (s *AdvancedVisibilitySuite) TearDownSuite()

func (*AdvancedVisibilitySuite) TestBuildIdScavenger_DeletesUnusedBuildId added in v1.23.0 

func (s *AdvancedVisibilitySuite) TestBuildIdScavenger_DeletesUnusedBuildId()

func (*AdvancedVisibilitySuite) TestChildWorkflow_ParentWorkflow added in v1.23.0 

func (s *AdvancedVisibilitySuite) TestChildWorkflow_ParentWorkflow()

func (*AdvancedVisibilitySuite) TestCountGroupByWorkflow added in v1.23.0 

func (s *AdvancedVisibilitySuite) TestCountGroupByWorkflow()

func (*AdvancedVisibilitySuite) TestCountWorkflow added in v1.23.0 

func (s *AdvancedVisibilitySuite) TestCountWorkflow()

func (*AdvancedVisibilitySuite) TestListOpenWorkflow added in v1.23.0 

func (s *AdvancedVisibilitySuite) TestListOpenWorkflow()

func (*AdvancedVisibilitySuite) TestListWorkflow added in v1.23.0 

func (s *AdvancedVisibilitySuite) TestListWorkflow()

func (*AdvancedVisibilitySuite) TestListWorkflow_ExecutionTime added in v1.23.0 

func (s *AdvancedVisibilitySuite) TestListWorkflow_ExecutionTime()

func (*AdvancedVisibilitySuite) TestListWorkflow_KeywordQuery added in v1.23.0 

func (s *AdvancedVisibilitySuite) TestListWorkflow_KeywordQuery()

func (*AdvancedVisibilitySuite) TestListWorkflow_MaxWindowSize added in v1.23.0 

func (s *AdvancedVisibilitySuite) TestListWorkflow_MaxWindowSize()

To test last page search trigger max window size error

func (*AdvancedVisibilitySuite) TestListWorkflow_OrQuery added in v1.23.0 

func (s *AdvancedVisibilitySuite) TestListWorkflow_OrQuery()

func (*AdvancedVisibilitySuite) TestListWorkflow_OrderBy added in v1.23.0 

func (s *AdvancedVisibilitySuite) TestListWorkflow_OrderBy()

func (*AdvancedVisibilitySuite) TestListWorkflow_PageToken added in v1.23.0 

func (s *AdvancedVisibilitySuite) TestListWorkflow_PageToken()

func (*AdvancedVisibilitySuite) TestListWorkflow_SearchAfter added in v1.23.0 

func (s *AdvancedVisibilitySuite) TestListWorkflow_SearchAfter()

func (*AdvancedVisibilitySuite) TestListWorkflow_SearchAttribute added in v1.23.0 

func (s *AdvancedVisibilitySuite) TestListWorkflow_SearchAttribute()

func (*AdvancedVisibilitySuite) TestListWorkflow_StringQuery added in v1.23.0 

func (s *AdvancedVisibilitySuite) TestListWorkflow_StringQuery()

func (*AdvancedVisibilitySuite) TestModifyWorkflowExecutionProperties added in v1.23.0 

func (s *AdvancedVisibilitySuite) TestModifyWorkflowExecutionProperties()

func (*AdvancedVisibilitySuite) TestScanWorkflow added in v1.23.0 

func (s *AdvancedVisibilitySuite) TestScanWorkflow()

func (*AdvancedVisibilitySuite) TestScanWorkflow_PageToken added in v1.23.0 

func (s *AdvancedVisibilitySuite) TestScanWorkflow_PageToken()

func (*AdvancedVisibilitySuite) TestScanWorkflow_SearchAttribute added in v1.23.0 

func (s *AdvancedVisibilitySuite) TestScanWorkflow_SearchAttribute()

func (*AdvancedVisibilitySuite) TestScheduleListingWithSearchAttributes added in v1.25.0 

func (s *AdvancedVisibilitySuite) TestScheduleListingWithSearchAttributes()

func (*AdvancedVisibilitySuite) TestUpsertWorkflowExecutionSearchAttributes added in v1.23.0 

func (s *AdvancedVisibilitySuite) TestUpsertWorkflowExecutionSearchAttributes()

func (*AdvancedVisibilitySuite) TestUpsertWorkflowExecution_InvalidKey added in v1.23.0 

func (s *AdvancedVisibilitySuite) TestUpsertWorkflowExecution_InvalidKey()

func (*AdvancedVisibilitySuite) TestWorkerTaskReachability_ByBuildId added in v1.23.0 

func (s *AdvancedVisibilitySuite) TestWorkerTaskReachability_ByBuildId()

func (*AdvancedVisibilitySuite) TestWorkerTaskReachability_ByBuildId_NotInNamespace added in v1.23.0 

func (s *AdvancedVisibilitySuite) TestWorkerTaskReachability_ByBuildId_NotInNamespace()

func (*AdvancedVisibilitySuite) TestWorkerTaskReachability_ByBuildId_NotInTaskQueue added in v1.23.0 

func (s *AdvancedVisibilitySuite) TestWorkerTaskReachability_ByBuildId_NotInTaskQueue()

func (*AdvancedVisibilitySuite) TestWorkerTaskReachability_EmptyBuildIds added in v1.23.0 

func (s *AdvancedVisibilitySuite) TestWorkerTaskReachability_EmptyBuildIds()

func (*AdvancedVisibilitySuite) TestWorkerTaskReachability_TooManyBuildIds added in v1.23.0 

func (s *AdvancedVisibilitySuite) TestWorkerTaskReachability_TooManyBuildIds()

func (*AdvancedVisibilitySuite) TestWorkerTaskReachability_Unversioned_InNamespace added in v1.23.0 

func (s *AdvancedVisibilitySuite) TestWorkerTaskReachability_Unversioned_InNamespace()

func (*AdvancedVisibilitySuite) TestWorkerTaskReachability_Unversioned_InTaskQueue added in v1.23.0 

func (s *AdvancedVisibilitySuite) TestWorkerTaskReachability_Unversioned_InTaskQueue()

func (*AdvancedVisibilitySuite) Test_BuildIdIndexedOnCompletion_UnversionedWorker added in v1.23.0 

func (s *AdvancedVisibilitySuite) Test_BuildIdIndexedOnCompletion_UnversionedWorker()

func (*AdvancedVisibilitySuite) Test_BuildIdIndexedOnCompletion_VersionedWorker added in v1.23.0 

func (s *AdvancedVisibilitySuite) Test_BuildIdIndexedOnCompletion_VersionedWorker()

func (*AdvancedVisibilitySuite) Test_BuildIdIndexedOnReset added in v1.23.0 

func (s *AdvancedVisibilitySuite) Test_BuildIdIndexedOnReset()

func (*AdvancedVisibilitySuite) Test_BuildIdIndexedOnRetry added in v1.23.0 

func (s *AdvancedVisibilitySuite) Test_BuildIdIndexedOnRetry()

func (*AdvancedVisibilitySuite) Test_LongWorkflowID added in v1.23.0 

func (s *AdvancedVisibilitySuite) Test_LongWorkflowID()

type ArchivalSuite added in v1.23.0 

type ArchivalSuite struct {
	*require.Assertions
	FunctionalTestBase
}

func (*ArchivalSuite) SetupSuite added in v1.23.0 

func (s *ArchivalSuite) SetupSuite()

func (*ArchivalSuite) SetupTest added in v1.23.0 

func (s *ArchivalSuite) SetupTest()

func (*ArchivalSuite) TearDownSuite added in v1.23.0 

func (s *ArchivalSuite) TearDownSuite()

func (*ArchivalSuite) TestArchival_ArchiverWorker added in v1.23.0 

func (s *ArchivalSuite) TestArchival_ArchiverWorker()

func (*ArchivalSuite) TestArchival_ContinueAsNew added in v1.23.0 

func (s *ArchivalSuite) TestArchival_ContinueAsNew()

func (*ArchivalSuite) TestArchival_TimerQueueProcessor added in v1.23.0 

func (s *ArchivalSuite) TestArchival_TimerQueueProcessor()

func (*ArchivalSuite) TestVisibilityArchival added in v1.23.0 

func (s *ArchivalSuite) TestVisibilityArchival()

type ArchiverBase 

type ArchiverBase struct {
	// contains filtered or unexported fields
}

ArchiverBase is a base struct for archiver provider being used in functional tests

type ClientFunctionalSuite added in v1.23.0 

type ClientFunctionalSuite struct {
	// override suite.Suite.Assertions with require.Assertions; this means that s.NotNil(nil) will stop the test,
	// not merely log an error
	*require.Assertions
	FunctionalTestBase
	historyrequire.HistoryRequire
	// contains filtered or unexported fields
}

func (*ClientFunctionalSuite) SetupSuite added in v1.23.0 

func (s *ClientFunctionalSuite) SetupSuite()

func (*ClientFunctionalSuite) SetupTest added in v1.23.0 

func (s *ClientFunctionalSuite) SetupTest()

func (*ClientFunctionalSuite) TearDownSuite added in v1.23.0 

func (s *ClientFunctionalSuite) TearDownSuite()

func (*ClientFunctionalSuite) TearDownTest added in v1.23.0 

func (s *ClientFunctionalSuite) TearDownTest()

func (*ClientFunctionalSuite) TestActivityHeartbeatDetailsDuringRetry added in v1.23.0 

func (s *ClientFunctionalSuite) TestActivityHeartbeatDetailsDuringRetry()

func (*ClientFunctionalSuite) TestAdminRebuildMutableState added in v1.23.0 

func (s *ClientFunctionalSuite) TestAdminRebuildMutableState()

func (*ClientFunctionalSuite) TestBatchReset added in v1.23.0 

func (s *ClientFunctionalSuite) TestBatchReset()

func (*ClientFunctionalSuite) TestBatchResetByBuildId added in v1.23.0 

func (s *ClientFunctionalSuite) TestBatchResetByBuildId()

func (*ClientFunctionalSuite) TestBatchSignal added in v1.23.0 

func (s *ClientFunctionalSuite) TestBatchSignal()

func (*ClientFunctionalSuite) TestBufferedEventsMutableStateSizeLimit added in v1.23.0 

func (s *ClientFunctionalSuite) TestBufferedEventsMutableStateSizeLimit()

func (*ClientFunctionalSuite) TestClientDataConverter added in v1.23.0 

func (s *ClientFunctionalSuite) TestClientDataConverter()

func (*ClientFunctionalSuite) TestClientDataConverter_Failed added in v1.23.0 

func (s *ClientFunctionalSuite) TestClientDataConverter_Failed()

func (*ClientFunctionalSuite) TestClientDataConverter_WithChild added in v1.23.0 

func (s *ClientFunctionalSuite) TestClientDataConverter_WithChild()

func (*ClientFunctionalSuite) TestContinueAsNewTightLoop added in v1.23.0 

func (s *ClientFunctionalSuite) TestContinueAsNewTightLoop()

func (*ClientFunctionalSuite) TestCronWorkflowCompletionStates added in v1.23.0 

func (s *ClientFunctionalSuite) TestCronWorkflowCompletionStates()

func (*ClientFunctionalSuite) TestGetHistoryReverse added in v1.23.0 

func (s *ClientFunctionalSuite) TestGetHistoryReverse()

func (*ClientFunctionalSuite) TestGetHistoryReverse_MultipleBranches added in v1.23.0 

func (s *ClientFunctionalSuite) TestGetHistoryReverse_MultipleBranches()

func (*ClientFunctionalSuite) TestMaxBufferedEventsLimit added in v1.23.0 

func (s *ClientFunctionalSuite) TestMaxBufferedEventsLimit()

func (*ClientFunctionalSuite) TestQueryWorkflow_ClosedWithoutWorkflowTaskStarted added in v1.23.0 

func (s *ClientFunctionalSuite) TestQueryWorkflow_ClosedWithoutWorkflowTaskStarted()

func (*ClientFunctionalSuite) TestQueryWorkflow_Consistent_PiggybackQuery added in v1.23.0 

func (s *ClientFunctionalSuite) TestQueryWorkflow_Consistent_PiggybackQuery()

func (*ClientFunctionalSuite) TestQueryWorkflow_QueryBeforeStart added in v1.23.0 

func (s *ClientFunctionalSuite) TestQueryWorkflow_QueryBeforeStart()

func (*ClientFunctionalSuite) TestQueryWorkflow_QueryFailedWorkflowTask added in v1.23.0 

func (s *ClientFunctionalSuite) TestQueryWorkflow_QueryFailedWorkflowTask()

func (*ClientFunctionalSuite) TestQueryWorkflow_QueryWhileBackoff added in v1.23.0 

func (s *ClientFunctionalSuite) TestQueryWorkflow_QueryWhileBackoff()

func (*ClientFunctionalSuite) TestQueryWorkflow_Sticky added in v1.23.0 

func (s *ClientFunctionalSuite) TestQueryWorkflow_Sticky()

func (*ClientFunctionalSuite) TestStickyAutoReset added in v1.23.0 

func (s *ClientFunctionalSuite) TestStickyAutoReset()

func (*ClientFunctionalSuite) TestTooManyCancelRequests added in v1.23.0 

func (s *ClientFunctionalSuite) TestTooManyCancelRequests()

func (*ClientFunctionalSuite) TestTooManyChildWorkflows added in v1.23.0 

func (s *ClientFunctionalSuite) TestTooManyChildWorkflows()

func (*ClientFunctionalSuite) TestTooManyPendingActivities added in v1.23.0 

func (s *ClientFunctionalSuite) TestTooManyPendingActivities()

TestTooManyPendingActivities verifies that we don't allow users to schedule new activities when they've already reached the limit for pending activities.

func (*ClientFunctionalSuite) TestTooManyPendingSignals added in v1.23.0 

func (s *ClientFunctionalSuite) TestTooManyPendingSignals()

func (*ClientFunctionalSuite) TestUpdateWorkflow_ContinueAsNewAfterUpdateAdmitted added in v1.26.0 

func (s *ClientFunctionalSuite) TestUpdateWorkflow_ContinueAsNewAfterUpdateAdmitted()

func (*ClientFunctionalSuite) TestUpdateWorkflow_TerminateWorkflowAfterUpdateAccepted added in v1.25.0 

func (s *ClientFunctionalSuite) TestUpdateWorkflow_TerminateWorkflowAfterUpdateAccepted()

TestUpdateWorkflow_TerminateWorkflowDuringUpdate executes a long-running update (schedules a sequence of activity calls) and terminates the workflow after the update has been accepted but before it has been completed. It checks that the client gets a NotFound error when attempting to fetch the update result (rather than a timeout).

func (*ClientFunctionalSuite) TestUpdateWorkflow_TerminateWorkflowAfterUpdateAdmitted added in v1.25.0 

func (s *ClientFunctionalSuite) TestUpdateWorkflow_TerminateWorkflowAfterUpdateAdmitted()

func (*ClientFunctionalSuite) Test_ActivityTimeouts added in v1.23.0 

func (s *ClientFunctionalSuite) Test_ActivityTimeouts()

func (*ClientFunctionalSuite) Test_BufferedQuery added in v1.23.0 

func (s *ClientFunctionalSuite) Test_BufferedQuery()

func (*ClientFunctionalSuite) Test_BufferedSignalCausesUnhandledCommandAndSchedulesNewTask added in v1.24.0 

func (s *ClientFunctionalSuite) Test_BufferedSignalCausesUnhandledCommandAndSchedulesNewTask()

This test simulates workflow try to complete itself while there is buffered event. Event sequence: 

1st WorkflowTask runs a local activity.
While local activity is running, a signal is received by server.
After signal is received, local activity completed, and workflow drains signal chan (no signal yet) and complete workflow.
Server failed the complete request because there is unhandled signal.
Server rescheduled a new workflow task.
Workflow runs the local activity again and drain the signal chan (with one signal) and complete workflow.
Server complete workflow as requested.

func (*ClientFunctionalSuite) Test_CancelActivityAndTimerBeforeComplete added in v1.23.0 

func (s *ClientFunctionalSuite) Test_CancelActivityAndTimerBeforeComplete()

func (*ClientFunctionalSuite) Test_FinishWorkflowWithDeferredCommands added in v1.23.0 

func (s *ClientFunctionalSuite) Test_FinishWorkflowWithDeferredCommands()

func (*ClientFunctionalSuite) Test_InvalidCommandAttribute added in v1.23.0 

func (s *ClientFunctionalSuite) Test_InvalidCommandAttribute()

This test simulates workflow generate command with invalid attributes. Server is expected to fail the workflow task and schedule a retry immediately for first attempt, but if workflow task keeps failing, server will drop the task and wait for timeout to schedule additional retries. This is the same behavior as the SDK used to do, but now we would do on server.

func (*ClientFunctionalSuite) Test_StickyWorkerRestartWorkflowTask added in v1.23.0 

func (s *ClientFunctionalSuite) Test_StickyWorkerRestartWorkflowTask()

func (*ClientFunctionalSuite) Test_WorkflowCanBeCompletedDespiteAdmittedUpdate added in v1.24.0 

func (s *ClientFunctionalSuite) Test_WorkflowCanBeCompletedDespiteAdmittedUpdate()

Analogous to Test_BufferedSignalCausesUnhandledCommandAndSchedulesNewTask TODO: rename to previous name (Test_AdmittedUpdateCausesUnhandledCommandAndSchedulesNewTask) when/if admitted updates start to block workflow from completing.

  1. The worker starts executing the first WFT, before any update is sent.
  2. While the first WFT is being executed, an update is sent.
  3. Once the server has received the update, the workflow tries to complete itself.
  4. The server fails update request with error and completes WF.

type DLQSuite added in v1.23.0 

type DLQSuite struct {
	FunctionalTestBase
	*require.Assertions
	// contains filtered or unexported fields
}

func (*DLQSuite) SetupSuite added in v1.23.0 

func (s *DLQSuite) SetupSuite()

func (*DLQSuite) SetupTest added in v1.23.0 

func (s *DLQSuite) SetupTest()

func (*DLQSuite) TearDownSuite added in v1.23.0 

func (s *DLQSuite) TearDownSuite()

func (*DLQSuite) TestCancelRunningMerge added in v1.23.0 

func (s *DLQSuite) TestCancelRunningMerge()

func (*DLQSuite) TestListQueues added in v1.23.0 

func (s *DLQSuite) TestListQueues()

func (*DLQSuite) TestMergeRealWorkflow added in v1.23.0 

func (s *DLQSuite) TestMergeRealWorkflow()

This test executes actual workflows for which we've set up an executor wrapper to return a terminal error. This causes the workflow tasks to be added to the DLQ. This tests the end-to-end functionality of the DLQ, whereas the above test is more for testing specific CLI flags when reading from the DLQ. This test will then call DescribeDLQJob and CancelDLQJob api to verify.

func (*DLQSuite) TestPurgeRealWorkflow added in v1.23.0 

func (s *DLQSuite) TestPurgeRealWorkflow()

This test executes an actual workflow for which we've set up an executor wrapper to return a terminal error. This causes the workflow task to be added to the DLQ. This tests the end-to-end functionality of the DLQ, whereas the above test is more for testing specific CLI flags when reading from the DLQ. After the workflow task is added to the DLQ, this test then purges the DLQ and verifies that the task was deleted. This test will then call DescribeDLQJob and CancelDLQJob api to verify.

func (*DLQSuite) TestReadArtificialDLQTasks added in v1.23.0 

func (s *DLQSuite) TestReadArtificialDLQTasks()

type DeadlineExceededErrorSuite added in v1.23.0 

type DeadlineExceededErrorSuite struct {
	AcquireShardFunctionalSuite
}

DeadlineExceededErrorSuite is the test suite for testing what happens when acquire shard returns a deadline exceeded.

func (*DeadlineExceededErrorSuite) SetupSuite added in v1.23.0 

func (s *DeadlineExceededErrorSuite) SetupSuite()

SetupSuite reads the deadline exceeded error targeted fault injection config from the test data folder.

func (*DeadlineExceededErrorSuite) TestDoesRetry added in v1.23.0 

func (s *DeadlineExceededErrorSuite) TestDoesRetry()

TestDoesRetry verifies that we do retry acquiring the shard when we get a deadline exceeded error because that should be considered a transient error.

type DescribeTaskQueueSuite added in v1.25.0 

type DescribeTaskQueueSuite struct {
	*require.Assertions
	FunctionalTestBase
}

func (*DescribeTaskQueueSuite) SetupSuite added in v1.25.0 

func (s *DescribeTaskQueueSuite) SetupSuite()

func (*DescribeTaskQueueSuite) SetupTest added in v1.25.0 

func (s *DescribeTaskQueueSuite) SetupTest()

func (*DescribeTaskQueueSuite) TearDownSuite added in v1.25.0 

func (s *DescribeTaskQueueSuite) TearDownSuite()

func (*DescribeTaskQueueSuite) TestAddMultipleTasksMultiplePartitions_ValidateStats added in v1.25.0 

func (s *DescribeTaskQueueSuite) TestAddMultipleTasksMultiplePartitions_ValidateStats()

func (*DescribeTaskQueueSuite) TestAddNoTasks_ValidateStats added in v1.25.0 

func (s *DescribeTaskQueueSuite) TestAddNoTasks_ValidateStats()

func (*DescribeTaskQueueSuite) TestAddSingleTask_ValidateStats added in v1.25.0 

func (s *DescribeTaskQueueSuite) TestAddSingleTask_ValidateStats()

func (*DescribeTaskQueueSuite) TestAddSingleTask_ValidateStatsLegacyAPIMode added in v1.25.0 

func (s *DescribeTaskQueueSuite) TestAddSingleTask_ValidateStatsLegacyAPIMode()

type EventualSuccessSuite added in v1.23.0 

type EventualSuccessSuite struct {
	AcquireShardFunctionalSuite
}

EventualSuccessSuite is the test suite for testing what happens when acquire shard returns a deadline exceeded error followed by a successful acquire shard call.

func (*EventualSuccessSuite) SetupSuite added in v1.23.0 

func (s *EventualSuccessSuite) SetupSuite()

SetupSuite reads the targeted eventual success fault injection config from the testdata folder. This config deterministically causes the first acquire shard call to return a deadline exceeded error, and it causes the next call to return a successful response.

func (*EventualSuccessSuite) TestEventuallySucceeds added in v1.23.0 

func (s *EventualSuccessSuite) TestEventuallySucceeds()

TestEventuallySucceeds verifies that we eventually succeed in acquiring the shard when we get a deadline exceeded error followed by a successful acquire shard call.

type FunctionalSuite added in v1.23.0 

type FunctionalSuite struct {
	// override suite.Suite.Assertions with require.Assertions; this means that s.NotNil(nil) will stop the test,
	// not merely log an error
	*require.Assertions
	protorequire.ProtoAssertions
	historyrequire.HistoryRequire
	updateutils.UpdateUtils
	FunctionalTestBase
}

func (*FunctionalSuite) SetupSuite added in v1.23.0 

func (s *FunctionalSuite) SetupSuite()

func (*FunctionalSuite) SetupTest added in v1.23.0 

func (s *FunctionalSuite) SetupTest()

func (*FunctionalSuite) TearDownSuite added in v1.23.0 

func (s *FunctionalSuite) TearDownSuite()

func (*FunctionalSuite) TestActivityCancellationNotStarted added in v1.23.0 

func (s *FunctionalSuite) TestActivityCancellationNotStarted()

func (*FunctionalSuite) TestActivityHeartBeatWorkflow_Success added in v1.23.0 

func (s *FunctionalSuite) TestActivityHeartBeatWorkflow_Success()

func (*FunctionalSuite) TestActivityHeartBeatWorkflow_Timeout added in v1.23.0 

func (s *FunctionalSuite) TestActivityHeartBeatWorkflow_Timeout()

func (*FunctionalSuite) TestActivityHeartBeat_RecordIdentity added in v1.24.0 

func (s *FunctionalSuite) TestActivityHeartBeat_RecordIdentity()

TestActivityHeartBeat_RecordIdentity verifies that the identity of the worker sending the heartbeat is recorded in pending activity info and returned in describe workflow API response. This happens only when the worker identity is not sent when a poller picks the task.

func (*FunctionalSuite) TestActivityRetry added in v1.23.0 

func (s *FunctionalSuite) TestActivityRetry()

func (*FunctionalSuite) TestActivityRetry_Infinite added in v1.23.0 

func (s *FunctionalSuite) TestActivityRetry_Infinite()

func (*FunctionalSuite) TestActivityTaskCompleteForceCompletion added in v1.25.0 

func (s *FunctionalSuite) TestActivityTaskCompleteForceCompletion()

func (*FunctionalSuite) TestActivityTaskCompleteRejectCompletion added in v1.25.0 

func (s *FunctionalSuite) TestActivityTaskCompleteRejectCompletion()

func (*FunctionalSuite) TestBufferedEvents added in v1.23.0 

func (s *FunctionalSuite) TestBufferedEvents()

func (*FunctionalSuite) TestBufferedEventsOutOfOrder added in v1.23.0 

func (s *FunctionalSuite) TestBufferedEventsOutOfOrder()

func (*FunctionalSuite) TestBufferedSignalIsDroppedOnReset added in v1.26.0 

func (s *FunctionalSuite) TestBufferedSignalIsDroppedOnReset()

func (*FunctionalSuite) TestBufferedSignalIsReappliedOnReset added in v1.26.0 

func (s *FunctionalSuite) TestBufferedSignalIsReappliedOnReset()

func (*FunctionalSuite) TestCancelTimer added in v1.23.0 

func (s *FunctionalSuite) TestCancelTimer()

func (*FunctionalSuite) TestCancelTimer_CancelFiredAndBuffered added in v1.23.0 

func (s *FunctionalSuite) TestCancelTimer_CancelFiredAndBuffered()

func (*FunctionalSuite) TestChildWorkflowExecution added in v1.23.0 

func (s *FunctionalSuite) TestChildWorkflowExecution()

func (*FunctionalSuite) TestChildWorkflowWithContinueAsNew added in v1.23.0 

func (s *FunctionalSuite) TestChildWorkflowWithContinueAsNew()

func (*FunctionalSuite) TestChildWorkflowWithContinueAsNewParentTerminate added in v1.23.0 

func (s *FunctionalSuite) TestChildWorkflowWithContinueAsNewParentTerminate()

func (*FunctionalSuite) TestCompleteWorkflowTaskAndCreateNewOne added in v1.23.0 

func (s *FunctionalSuite) TestCompleteWorkflowTaskAndCreateNewOne()

func (*FunctionalSuite) TestContinueAsNewRun_ExecutionTimeout added in v1.25.0 

func (s *FunctionalSuite) TestContinueAsNewRun_ExecutionTimeout()

func (*FunctionalSuite) TestContinueAsNewRun_RunTimeout added in v1.25.0 

func (s *FunctionalSuite) TestContinueAsNewRun_RunTimeout()

func (*FunctionalSuite) TestContinueAsNewWorkflow added in v1.23.0 

func (s *FunctionalSuite) TestContinueAsNewWorkflow()

func (*FunctionalSuite) TestCronChildWorkflowExecution added in v1.23.0 

func (s *FunctionalSuite) TestCronChildWorkflowExecution()

func (*FunctionalSuite) TestCronWorkflow added in v1.23.0 

func (s *FunctionalSuite) TestCronWorkflow()

func (*FunctionalSuite) TestCronWorkflow_Failed_Infinite added in v1.23.0 

func (s *FunctionalSuite) TestCronWorkflow_Failed_Infinite()

func (*FunctionalSuite) TestDeleteWorkflowExecution_CompetedWorkflow added in v1.25.0 

func (s *FunctionalSuite) TestDeleteWorkflowExecution_CompetedWorkflow()

func (*FunctionalSuite) TestDeleteWorkflowExecution_JustTerminatedWorkflow added in v1.25.0 

func (s *FunctionalSuite) TestDeleteWorkflowExecution_JustTerminatedWorkflow()

func (*FunctionalSuite) TestDeleteWorkflowExecution_RunningWorkflow added in v1.25.0 

func (s *FunctionalSuite) TestDeleteWorkflowExecution_RunningWorkflow()

func (*FunctionalSuite) TestDescribeTaskQueue added in v1.23.0 

func (s *FunctionalSuite) TestDescribeTaskQueue()

func (*FunctionalSuite) TestDescribeWorkflowExecution added in v1.23.0 

func (s *FunctionalSuite) TestDescribeWorkflowExecution()

func (*FunctionalSuite) TestEagerWorkflowStart_RetryStartAfterTimeout added in v1.23.0 

func (s *FunctionalSuite) TestEagerWorkflowStart_RetryStartAfterTimeout()

func (*FunctionalSuite) TestEagerWorkflowStart_RetryStartImmediately added in v1.23.0 

func (s *FunctionalSuite) TestEagerWorkflowStart_RetryStartImmediately()

func (*FunctionalSuite) TestEagerWorkflowStart_RetryTaskAfterTimeout added in v1.23.0 

func (s *FunctionalSuite) TestEagerWorkflowStart_RetryTaskAfterTimeout()

func (*FunctionalSuite) TestEagerWorkflowStart_StartNew added in v1.23.0 

func (s *FunctionalSuite) TestEagerWorkflowStart_StartNew()

func (*FunctionalSuite) TestEagerWorkflowStart_TerminateDuplicate added in v1.23.0 

func (s *FunctionalSuite) TestEagerWorkflowStart_TerminateDuplicate()

func (*FunctionalSuite) TestExecuteMultiOperation added in v1.24.0 

func (s *FunctionalSuite) TestExecuteMultiOperation()

func (*FunctionalSuite) TestExternalRequestCancelWorkflowExecution added in v1.23.0 

func (s *FunctionalSuite) TestExternalRequestCancelWorkflowExecution()

func (*FunctionalSuite) TestGetWorkflowExecutionHistory_All added in v1.23.0 

func (s *FunctionalSuite) TestGetWorkflowExecutionHistory_All()

func (*FunctionalSuite) TestGetWorkflowExecutionHistory_Close added in v1.23.0 

func (s *FunctionalSuite) TestGetWorkflowExecutionHistory_Close()

Note: not *RawHistorySuite.

func (*FunctionalSuite) TestImmediateChildCancellation_WorkflowTaskFailed added in v1.23.0 

func (s *FunctionalSuite) TestImmediateChildCancellation_WorkflowTaskFailed()

func (*FunctionalSuite) TestNoTransientWorkflowTaskAfterFlushBufferedEvents added in v1.23.0 

func (s *FunctionalSuite) TestNoTransientWorkflowTaskAfterFlushBufferedEvents()

func (*FunctionalSuite) TestRateLimitBufferedEvents added in v1.23.0 

func (s *FunctionalSuite) TestRateLimitBufferedEvents()

func (*FunctionalSuite) TestRelayWorkflowTaskTimeout added in v1.23.0 

func (s *FunctionalSuite) TestRelayWorkflowTaskTimeout()

func (*FunctionalSuite) TestRequestCancelWorkflowCommandExecution_TargetFinished added in v1.23.0 

func (s *FunctionalSuite) TestRequestCancelWorkflowCommandExecution_TargetFinished()

func (*FunctionalSuite) TestRequestCancelWorkflowCommandExecution_TargetNotFound added in v1.23.0 

func (s *FunctionalSuite) TestRequestCancelWorkflowCommandExecution_TargetNotFound()

func (*FunctionalSuite) TestRequestCancelWorkflowCommandExecution_TargetRunning added in v1.23.0 

func (s *FunctionalSuite) TestRequestCancelWorkflowCommandExecution_TargetRunning()

func (*FunctionalSuite) TestResetWorkflow added in v1.23.0 

func (s *FunctionalSuite) TestResetWorkflow()

func (*FunctionalSuite) TestResetWorkflowAfterTimeout added in v1.26.0 

func (s *FunctionalSuite) TestResetWorkflowAfterTimeout()

func (*FunctionalSuite) TestResetWorkflow_ExcludeNoneReapplyAll added in v1.24.0 

func (s *FunctionalSuite) TestResetWorkflow_ExcludeNoneReapplyAll()

func (*FunctionalSuite) TestResetWorkflow_ExcludeNoneReapplyDefault added in v1.25.1 

func (s *FunctionalSuite) TestResetWorkflow_ExcludeNoneReapplyDefault()

func (*FunctionalSuite) TestResetWorkflow_ExcludeNoneReapplyNone added in v1.24.0 

func (s *FunctionalSuite) TestResetWorkflow_ExcludeNoneReapplyNone()

func (*FunctionalSuite) TestResetWorkflow_ExcludeNoneReapplySignal added in v1.24.0 

func (s *FunctionalSuite) TestResetWorkflow_ExcludeNoneReapplySignal()

func (*FunctionalSuite) TestResetWorkflow_ExcludeSignalReapplyAll added in v1.24.0 

func (s *FunctionalSuite) TestResetWorkflow_ExcludeSignalReapplyAll()

func (*FunctionalSuite) TestResetWorkflow_ExcludeSignalReapplyNone added in v1.24.0 

func (s *FunctionalSuite) TestResetWorkflow_ExcludeSignalReapplyNone()

func (*FunctionalSuite) TestResetWorkflow_ExcludeSignalReapplySignal added in v1.24.0 

func (s *FunctionalSuite) TestResetWorkflow_ExcludeSignalReapplySignal()

func (*FunctionalSuite) TestResetWorkflow_ResetAfterContinueAsNew added in v1.25.0 

func (s *FunctionalSuite) TestResetWorkflow_ResetAfterContinueAsNew()

func (*FunctionalSuite) TestResetWorkflow_WorkflowTask_Schedule added in v1.23.0 

func (s *FunctionalSuite) TestResetWorkflow_WorkflowTask_Schedule()

func (*FunctionalSuite) TestResetWorkflow_WorkflowTask_ScheduleToStart added in v1.23.0 

func (s *FunctionalSuite) TestResetWorkflow_WorkflowTask_ScheduleToStart()

func (*FunctionalSuite) TestResetWorkflow_WorkflowTask_Start added in v1.23.0 

func (s *FunctionalSuite) TestResetWorkflow_WorkflowTask_Start()

func (*FunctionalSuite) TestRespondWorkflowTaskCompleted_ReturnsErrorIfInvalidArgument added in v1.23.0 

func (s *FunctionalSuite) TestRespondWorkflowTaskCompleted_ReturnsErrorIfInvalidArgument()

func (*FunctionalSuite) TestRetryChildWorkflowExecution added in v1.23.0 

func (s *FunctionalSuite) TestRetryChildWorkflowExecution()

func (*FunctionalSuite) TestRetryFailChildWorkflowExecution added in v1.23.0 

func (s *FunctionalSuite) TestRetryFailChildWorkflowExecution()

func (*FunctionalSuite) TestSequentialWorkflow added in v1.23.0 

func (s *FunctionalSuite) TestSequentialWorkflow()

func (*FunctionalSuite) TestServerRejectsInvalidRequests added in v1.23.0 

func (s *FunctionalSuite) TestServerRejectsInvalidRequests()

func (*FunctionalSuite) TestSignalExternalWorkflowCommand added in v1.23.0 

func (s *FunctionalSuite) TestSignalExternalWorkflowCommand()

func (*FunctionalSuite) TestSignalExternalWorkflowCommand_SignalSelf added in v1.23.0 

func (s *FunctionalSuite) TestSignalExternalWorkflowCommand_SignalSelf()

func (*FunctionalSuite) TestSignalExternalWorkflowCommand_UnKnownTarget added in v1.23.0 

func (s *FunctionalSuite) TestSignalExternalWorkflowCommand_UnKnownTarget()

func (*FunctionalSuite) TestSignalExternalWorkflowCommand_WithoutRunID added in v1.23.0 

func (s *FunctionalSuite) TestSignalExternalWorkflowCommand_WithoutRunID()

func (*FunctionalSuite) TestSignalWithStartWithMemo added in v1.23.0 

func (s *FunctionalSuite) TestSignalWithStartWithMemo()

func (*FunctionalSuite) TestSignalWithStartWorkflow added in v1.23.0 

func (s *FunctionalSuite) TestSignalWithStartWorkflow()

func (*FunctionalSuite) TestSignalWithStartWorkflow_NoWorkflowTaskCreated added in v1.23.0 

func (s *FunctionalSuite) TestSignalWithStartWorkflow_NoWorkflowTaskCreated()

func (*FunctionalSuite) TestSignalWithStartWorkflow_ResolveIDDeduplication added in v1.24.0 

func (s *FunctionalSuite) TestSignalWithStartWorkflow_ResolveIDDeduplication()

func (*FunctionalSuite) TestSignalWithStartWorkflow_StartDelay added in v1.23.0 

func (s *FunctionalSuite) TestSignalWithStartWorkflow_StartDelay()

func (*FunctionalSuite) TestSignalWorkflow added in v1.23.0 

func (s *FunctionalSuite) TestSignalWorkflow()

func (*FunctionalSuite) TestSignalWorkflow_Cron_NoWorkflowTaskCreated added in v1.23.0 

func (s *FunctionalSuite) TestSignalWorkflow_Cron_NoWorkflowTaskCreated()

func (*FunctionalSuite) TestSignalWorkflow_DuplicateRequest added in v1.23.0 

func (s *FunctionalSuite) TestSignalWorkflow_DuplicateRequest()

func (*FunctionalSuite) TestSignalWorkflow_NoWorkflowTaskCreated added in v1.23.0 

func (s *FunctionalSuite) TestSignalWorkflow_NoWorkflowTaskCreated()

func (*FunctionalSuite) TestSignalWorkflow_WorkflowCloseAttempted added in v1.23.0 

func (s *FunctionalSuite) TestSignalWorkflow_WorkflowCloseAttempted()

func (*FunctionalSuite) TestStartWithMemo added in v1.23.0 

func (s *FunctionalSuite) TestStartWithMemo()

func (*FunctionalSuite) TestStartWorkflowExecution added in v1.23.0 

func (s *FunctionalSuite) TestStartWorkflowExecution()

func (*FunctionalSuite) TestStartWorkflowExecutionWithDelay added in v1.23.0 

func (s *FunctionalSuite) TestStartWorkflowExecutionWithDelay()

func (*FunctionalSuite) TestStartWorkflowExecution_Terminate added in v1.24.0 

func (s *FunctionalSuite) TestStartWorkflowExecution_Terminate()

func (*FunctionalSuite) TestStickyTaskqueueResetThenTimeout added in v1.23.0 

func (s *FunctionalSuite) TestStickyTaskqueueResetThenTimeout()

func (*FunctionalSuite) TestStickyTimeout_NonTransientWorkflowTask added in v1.23.0 

func (s *FunctionalSuite) TestStickyTimeout_NonTransientWorkflowTask()

func (*FunctionalSuite) TestTerminateWorkflow added in v1.23.0 

func (s *FunctionalSuite) TestTerminateWorkflow()

func (*FunctionalSuite) TestTransientWorkflowTaskHistorySize added in v1.23.0 

func (s *FunctionalSuite) TestTransientWorkflowTaskHistorySize()

func (*FunctionalSuite) TestTransientWorkflowTaskTimeout added in v1.23.0 

func (s *FunctionalSuite) TestTransientWorkflowTaskTimeout()

func (*FunctionalSuite) TestTryActivityCancellationFromWorkflow added in v1.23.0 

func (s *FunctionalSuite) TestTryActivityCancellationFromWorkflow()

func (*FunctionalSuite) TestUpdateWorkflow_1stAccept_2ndAccept_2ndComplete_1stComplete added in v1.23.0 

func (s *FunctionalSuite) TestUpdateWorkflow_1stAccept_2ndAccept_2ndComplete_1stComplete()

func (*FunctionalSuite) TestUpdateWorkflow_1stAccept_2ndReject_1stComplete added in v1.23.0 

func (s *FunctionalSuite) TestUpdateWorkflow_1stAccept_2ndReject_1stComplete()

func (*FunctionalSuite) TestUpdateWorkflow_CompleteWorkflow_AbortUpdates added in v1.24.0 

func (s *FunctionalSuite) TestUpdateWorkflow_CompleteWorkflow_AbortUpdates()

func (*FunctionalSuite) TestUpdateWorkflow_CompletedSpeculativeWorkflowTask_DeduplicateID added in v1.23.0 

func (s *FunctionalSuite) TestUpdateWorkflow_CompletedSpeculativeWorkflowTask_DeduplicateID()

func (*FunctionalSuite) TestUpdateWorkflow_CompletedWorkflow added in v1.25.0 

func (s *FunctionalSuite) TestUpdateWorkflow_CompletedWorkflow()

func (*FunctionalSuite) TestUpdateWorkflow_ContinueAsNew_UpdateIsNotCarriedOver added in v1.26.0 

func (s *FunctionalSuite) TestUpdateWorkflow_ContinueAsNew_UpdateIsNotCarriedOver()

func (*FunctionalSuite) TestUpdateWorkflow_EmptySpeculativeWorkflowTask_AcceptComplete added in v1.25.0 

func (s *FunctionalSuite) TestUpdateWorkflow_EmptySpeculativeWorkflowTask_AcceptComplete()

func (*FunctionalSuite) TestUpdateWorkflow_EmptySpeculativeWorkflowTask_Reject added in v1.25.0 

func (s *FunctionalSuite) TestUpdateWorkflow_EmptySpeculativeWorkflowTask_Reject()

func (*FunctionalSuite) TestUpdateWorkflow_FirstNormalScheduledWorkflowTask_AcceptComplete added in v1.23.0 

func (s *FunctionalSuite) TestUpdateWorkflow_FirstNormalScheduledWorkflowTask_AcceptComplete()

func (*FunctionalSuite) TestUpdateWorkflow_FirstNormalScheduledWorkflowTask_Reject added in v1.23.0 

func (s *FunctionalSuite) TestUpdateWorkflow_FirstNormalScheduledWorkflowTask_Reject()

func (*FunctionalSuite) TestUpdateWorkflow_FirstNormalWorkflowTask_UpdateResurrectedAfterRegistryCleared added in v1.25.0 

func (s *FunctionalSuite) TestUpdateWorkflow_FirstNormalWorkflowTask_UpdateResurrectedAfterRegistryCleared()

func (*FunctionalSuite) TestUpdateWorkflow_LastWorkflowTask_HasUpdateMessage added in v1.25.0 

func (s *FunctionalSuite) TestUpdateWorkflow_LastWorkflowTask_HasUpdateMessage()

func (*FunctionalSuite) TestUpdateWorkflow_NormalScheduledWorkflowTask_AcceptComplete added in v1.23.0 

func (s *FunctionalSuite) TestUpdateWorkflow_NormalScheduledWorkflowTask_AcceptComplete()

func (*FunctionalSuite) TestUpdateWorkflow_NotEmptySpeculativeWorkflowTask_AcceptComplete added in v1.25.0 

func (s *FunctionalSuite) TestUpdateWorkflow_NotEmptySpeculativeWorkflowTask_AcceptComplete()

func (*FunctionalSuite) TestUpdateWorkflow_NotEmptySpeculativeWorkflowTask_Reject added in v1.25.0 

func (s *FunctionalSuite) TestUpdateWorkflow_NotEmptySpeculativeWorkflowTask_Reject()

func (*FunctionalSuite) TestUpdateWorkflow_RunningWorkflowTask_NewEmptySpeculativeWorkflowTask_Rejected added in v1.25.0 

func (s *FunctionalSuite) TestUpdateWorkflow_RunningWorkflowTask_NewEmptySpeculativeWorkflowTask_Rejected()

func (*FunctionalSuite) TestUpdateWorkflow_RunningWorkflowTask_NewNotEmptySpeculativeWorkflowTask_Rejected added in v1.25.0 

func (s *FunctionalSuite) TestUpdateWorkflow_RunningWorkflowTask_NewNotEmptySpeculativeWorkflowTask_Rejected()

func (*FunctionalSuite) TestUpdateWorkflow_ScheduledSpeculativeWorkflowTask_ConvertToNormalBecauseOfSignal added in v1.25.0 

func (s *FunctionalSuite) TestUpdateWorkflow_ScheduledSpeculativeWorkflowTask_ConvertToNormalBecauseOfSignal()

func (*FunctionalSuite) TestUpdateWorkflow_ScheduledSpeculativeWorkflowTask_DeduplicateID added in v1.23.0 

func (s *FunctionalSuite) TestUpdateWorkflow_ScheduledSpeculativeWorkflowTask_DeduplicateID()

func (*FunctionalSuite) TestUpdateWorkflow_ScheduledSpeculativeWorkflowTask_LostUpdate added in v1.25.0 

func (s *FunctionalSuite) TestUpdateWorkflow_ScheduledSpeculativeWorkflowTask_LostUpdate()

func (*FunctionalSuite) TestUpdateWorkflow_ScheduledSpeculativeWorkflowTask_TerminateWorkflow added in v1.23.0 

func (s *FunctionalSuite) TestUpdateWorkflow_ScheduledSpeculativeWorkflowTask_TerminateWorkflow()

func (*FunctionalSuite) TestUpdateWorkflow_SpeculativeWorkflowTask_Fail added in v1.25.0 

func (s *FunctionalSuite) TestUpdateWorkflow_SpeculativeWorkflowTask_Fail()

func (*FunctionalSuite) TestUpdateWorkflow_SpeculativeWorkflowTask_Heartbeat added in v1.23.0 

func (s *FunctionalSuite) TestUpdateWorkflow_SpeculativeWorkflowTask_Heartbeat()

func (*FunctionalSuite) TestUpdateWorkflow_SpeculativeWorkflowTask_QueryFailureClearsWFContext added in v1.25.0 

func (s *FunctionalSuite) TestUpdateWorkflow_SpeculativeWorkflowTask_QueryFailureClearsWFContext()

func (*FunctionalSuite) TestUpdateWorkflow_SpeculativeWorkflowTask_ScheduleToStartTimeout added in v1.25.0 

func (s *FunctionalSuite) TestUpdateWorkflow_SpeculativeWorkflowTask_ScheduleToStartTimeout()

func (*FunctionalSuite) TestUpdateWorkflow_SpeculativeWorkflowTask_ScheduleToStartTimeoutOnNormalTaskQueue added in v1.25.0 

func (s *FunctionalSuite) TestUpdateWorkflow_SpeculativeWorkflowTask_ScheduleToStartTimeoutOnNormalTaskQueue()

func (*FunctionalSuite) TestUpdateWorkflow_SpeculativeWorkflowTask_StartToCloseTimeout added in v1.25.0 

func (s *FunctionalSuite) TestUpdateWorkflow_SpeculativeWorkflowTask_StartToCloseTimeout()

func (*FunctionalSuite) TestUpdateWorkflow_SpeculativeWorkflowTask_WorkerSkippedProcessing_RejectByServer added in v1.25.0 

func (s *FunctionalSuite) TestUpdateWorkflow_SpeculativeWorkflowTask_WorkerSkippedProcessing_RejectByServer()

func (*FunctionalSuite) TestUpdateWorkflow_StaleSpeculativeWorkflowTask_Fail_BecauseOfDifferentStartTime added in v1.25.0 

func (s *FunctionalSuite) TestUpdateWorkflow_StaleSpeculativeWorkflowTask_Fail_BecauseOfDifferentStartTime()

func (*FunctionalSuite) TestUpdateWorkflow_StaleSpeculativeWorkflowTask_Fail_BecauseOfDifferentStartedId added in v1.25.0 

func (s *FunctionalSuite) TestUpdateWorkflow_StaleSpeculativeWorkflowTask_Fail_BecauseOfDifferentStartedId()

func (*FunctionalSuite) TestUpdateWorkflow_StaleSpeculativeWorkflowTask_Fail_NewWorkflowTaskWith2Updates added in v1.25.0 

func (s *FunctionalSuite) TestUpdateWorkflow_StaleSpeculativeWorkflowTask_Fail_NewWorkflowTaskWith2Updates()

func (*FunctionalSuite) TestUpdateWorkflow_StartedSpeculativeWorkflowTask_ConvertToNormalBecauseOfBufferedSignal added in v1.25.0 

func (s *FunctionalSuite) TestUpdateWorkflow_StartedSpeculativeWorkflowTask_ConvertToNormalBecauseOfBufferedSignal()

func (*FunctionalSuite) TestUpdateWorkflow_StartedSpeculativeWorkflowTask_DeduplicateID added in v1.23.0 

func (s *FunctionalSuite) TestUpdateWorkflow_StartedSpeculativeWorkflowTask_DeduplicateID()

func (*FunctionalSuite) TestUpdateWorkflow_StartedSpeculativeWorkflowTask_LostUpdate added in v1.25.0 

func (s *FunctionalSuite) TestUpdateWorkflow_StartedSpeculativeWorkflowTask_LostUpdate()

func (*FunctionalSuite) TestUpdateWorkflow_StartedSpeculativeWorkflowTask_TerminateWorkflow added in v1.23.0 

func (s *FunctionalSuite) TestUpdateWorkflow_StartedSpeculativeWorkflowTask_TerminateWorkflow()

func (*FunctionalSuite) TestUpdateWorkflow_StickySpeculativeWorkflowTask_AcceptComplete added in v1.25.0 

func (s *FunctionalSuite) TestUpdateWorkflow_StickySpeculativeWorkflowTask_AcceptComplete()

func (*FunctionalSuite) TestUpdateWorkflow_StickySpeculativeWorkflowTask_AcceptComplete_StickyWorkerUnavailable added in v1.25.0 

func (s *FunctionalSuite) TestUpdateWorkflow_StickySpeculativeWorkflowTask_AcceptComplete_StickyWorkerUnavailable()

func (*FunctionalSuite) TestUpdateWorkflow_UpdatesAreSentToWorkerInOrderOfAdmission added in v1.25.0 

func (s *FunctionalSuite) TestUpdateWorkflow_UpdatesAreSentToWorkerInOrderOfAdmission()

func (*FunctionalSuite) TestUpdateWorkflow_ValidateWorkerMessages added in v1.23.0 

func (s *FunctionalSuite) TestUpdateWorkflow_ValidateWorkerMessages()

func (*FunctionalSuite) TestUpdateWorkflow_WaitAccepted_GotCompleted added in v1.26.0 

func (s *FunctionalSuite) TestUpdateWorkflow_WaitAccepted_GotCompleted()

func (*FunctionalSuite) TestUserTimers_CapDuration added in v1.23.0 

func (s *FunctionalSuite) TestUserTimers_CapDuration()

func (*FunctionalSuite) TestUserTimers_Sequential added in v1.23.0 

func (s *FunctionalSuite) TestUserTimers_Sequential()

func (*FunctionalSuite) TestVisibility added in v1.23.0 

func (s *FunctionalSuite) TestVisibility()

func (*FunctionalSuite) TestWorkflowContinueAsNew_TaskID added in v1.23.0 

func (s *FunctionalSuite) TestWorkflowContinueAsNew_TaskID()

func (*FunctionalSuite) TestWorkflowRetry added in v1.23.0 

func (s *FunctionalSuite) TestWorkflowRetry()

func (*FunctionalSuite) TestWorkflowRetryFailures added in v1.23.0 

func (s *FunctionalSuite) TestWorkflowRetryFailures()

func (*FunctionalSuite) TestWorkflowTaskAndActivityTaskTimeoutsWorkflow added in v1.23.0 

func (s *FunctionalSuite) TestWorkflowTaskAndActivityTaskTimeoutsWorkflow()

func (*FunctionalSuite) TestWorkflowTaskFailed added in v1.23.0 

func (s *FunctionalSuite) TestWorkflowTaskFailed()

func (*FunctionalSuite) TestWorkflowTaskHeartbeatingWithEmptyResult added in v1.23.0 

func (s *FunctionalSuite) TestWorkflowTaskHeartbeatingWithEmptyResult()

func (*FunctionalSuite) TestWorkflowTaskHeartbeatingWithLocalActivitiesResult added in v1.23.0 

func (s *FunctionalSuite) TestWorkflowTaskHeartbeatingWithLocalActivitiesResult()

func (*FunctionalSuite) TestWorkflowTerminationSignalAfterRegularWorkflowTaskStarted added in v1.23.0 

func (s *FunctionalSuite) TestWorkflowTerminationSignalAfterRegularWorkflowTaskStarted()

func (*FunctionalSuite) TestWorkflowTerminationSignalAfterRegularWorkflowTaskStartedAndFailWorkflowTask added in v1.23.0 

func (s *FunctionalSuite) TestWorkflowTerminationSignalAfterRegularWorkflowTaskStartedAndFailWorkflowTask()

func (*FunctionalSuite) TestWorkflowTerminationSignalAfterTransientWorkflowTaskStarted added in v1.23.0 

func (s *FunctionalSuite) TestWorkflowTerminationSignalAfterTransientWorkflowTaskStarted()

func (*FunctionalSuite) TestWorkflowTerminationSignalAfterTransientWorkflowTaskStartedAndFailWorkflowTask added in v1.23.0 

func (s *FunctionalSuite) TestWorkflowTerminationSignalAfterTransientWorkflowTaskStartedAndFailWorkflowTask()

func (*FunctionalSuite) TestWorkflowTerminationSignalBeforeRegularWorkflowTaskStarted added in v1.23.0 

func (s *FunctionalSuite) TestWorkflowTerminationSignalBeforeRegularWorkflowTaskStarted()

func (*FunctionalSuite) TestWorkflowTerminationSignalBeforeTransientWorkflowTaskStarted added in v1.23.0 

func (s *FunctionalSuite) TestWorkflowTerminationSignalBeforeTransientWorkflowTaskStarted()

func (*FunctionalSuite) TestWorkflowTimeout added in v1.23.0 

func (s *FunctionalSuite) TestWorkflowTimeout()

type FunctionalTestBase added in v1.23.0 

type FunctionalTestBase struct {
	suite.Suite

	Logger log.Logger
	// contains filtered or unexported fields
}

FunctionalTestBase is a base struct for functional tests

func (*FunctionalTestBase) DurationNear added in v1.23.0 

func (s *FunctionalTestBase) DurationNear(value, target, tolerance time.Duration)

func (*FunctionalTestBase) OverrideDynamicConfig added in v1.25.0 

func (s *FunctionalTestBase) OverrideDynamicConfig(setting dynamicconfig.GenericSetting, value any) (cleanup func())

func (*FunctionalTestBase) SetupTest added in v1.25.0 

func (s *FunctionalTestBase) SetupTest()

All test suites that inherit FunctionalTestBase and overwrite SetupTest must call this base FunctionalTestBase.SetupTest function to distribute the tests into partitions. Otherwise, the test suite will be executed multiple times in each partition. Furthermore, all test suites in the "tests/" directory that don't inherit from FunctionalTestBase must implement SetupTest that calls checkTestShard.

type FunctionalTestBaseSuite added in v1.23.0 

type FunctionalTestBaseSuite struct {
	*require.Assertions
	FunctionalTestBase
	// contains filtered or unexported fields
}

func (*FunctionalTestBaseSuite) SetupSuite added in v1.23.0 

func (s *FunctionalTestBaseSuite) SetupSuite()

func (*FunctionalTestBaseSuite) SetupTest added in v1.23.0 

func (s *FunctionalTestBaseSuite) SetupTest()

func (*FunctionalTestBaseSuite) TearDownSuite added in v1.23.0 

func (s *FunctionalTestBaseSuite) TearDownSuite()

func (*FunctionalTestBaseSuite) TestWithFxOptionsForService added in v1.23.0 

func (s *FunctionalTestBaseSuite) TestWithFxOptionsForService()

type HistoryConfig 

type HistoryConfig struct {
	NumHistoryShards           int32
	NumHistoryHosts            int
	HistoryCountLimitError     int
	HistoryCountLimitWarn      int
	HistorySizeLimitError      int
	HistorySizeLimitWarn       int
	BlobSizeLimitError         int
	BlobSizeLimitWarn          int
	MutableStateSizeLimitError int
	MutableStateSizeLimitWarn  int
}

HistoryConfig contains configs for history service

type Option added in v1.23.0 

type Option func(params *TestClusterParams)

func WithFxOptionsForService added in v1.23.0 

func WithFxOptionsForService(serviceName primitives.ServiceName, options ...fx.Option) Option

WithFxOptionsForService returns an Option which, when passed as an argument to setupSuite, will append the given list of fx options to the end of the arguments to the fx.New call for the given service. For example, if you want to obtain the shard controller for the history service, you can do this: 

var shardController shard.Controller
s.setupSuite(t, tests.WithFxOptionsForService(primitives.HistoryService, fx.Populate(&shardController)))
// now you can use shardController during your test

This is similar to the pattern of plumbing dependencies through the TestClusterConfig, but it's much more convenient, scalable and flexible. The reason we need to do this on a per-service basis is that there are separate fx apps for each one.

type OwnershipLostErrorSuite added in v1.23.0 

type OwnershipLostErrorSuite struct {
	AcquireShardFunctionalSuite
}

OwnershipLostErrorSuite is the test suite for testing what happens when acquire shard returns an ownership lost error.

func (*OwnershipLostErrorSuite) SetupSuite added in v1.23.0 

func (s *OwnershipLostErrorSuite) SetupSuite()

SetupSuite reads the shard ownership lost error fault injection config from the testdata folder.

func (*OwnershipLostErrorSuite) TestDoesNotRetry added in v1.23.0 

func (s *OwnershipLostErrorSuite) TestDoesNotRetry()

TestDoesNotRetry verifies that we do not retry acquiring the shard when we get an ownership lost error.

type ParentWithChildContinueAsNew added in v1.23.0 

type ParentWithChildContinueAsNew struct {
	// contains filtered or unexported fields
}

type PersistenceTestBaseFactory added in v1.23.0 

type PersistenceTestBaseFactory interface {
	NewTestBase(options *persistencetests.TestBaseOptions) *persistencetests.TestBase
}

type PollAndProcessWorkflowTaskOptionFunc added in v1.22.1 

type PollAndProcessWorkflowTaskOptionFunc func(*PollAndProcessWorkflowTaskOptions)

func WithExpectedAttemptCount added in v1.22.1 

func WithExpectedAttemptCount(c int) PollAndProcessWorkflowTaskOptionFunc

func WithQueryResult added in v1.22.1 

func WithQueryResult(r *querypb.WorkflowQueryResult) PollAndProcessWorkflowTaskOptionFunc

func WithRetries added in v1.22.1 

func WithRetries(c int) PollAndProcessWorkflowTaskOptionFunc

type PollAndProcessWorkflowTaskOptions added in v1.22.1 

type PollAndProcessWorkflowTaskOptions struct {
	DumpHistory          bool
	DumpCommands         bool
	DropTask             bool
	PollSticky           bool
	RespondSticky        bool
	ExpectedAttemptCount int
	Retries              int
	ForceNewWorkflowTask bool
	QueryResult          *querypb.WorkflowQueryResult
}

type PollAndProcessWorkflowTaskResponse added in v1.22.1 

type PollAndProcessWorkflowTaskResponse struct {
	IsQueryTask bool
	NewTask     *workflowservice.RespondWorkflowTaskCompletedResponse
}

type PurgeDLQTasksSuite added in v1.23.0 

type PurgeDLQTasksSuite struct {
	*require.Assertions
	FunctionalTestBase
	// contains filtered or unexported fields
}

func (*PurgeDLQTasksSuite) SetupSuite added in v1.23.0 

func (s *PurgeDLQTasksSuite) SetupSuite()

func (*PurgeDLQTasksSuite) SetupTest added in v1.23.0 

func (s *PurgeDLQTasksSuite) SetupTest()

func (*PurgeDLQTasksSuite) TearDownSuite added in v1.23.0 

func (s *PurgeDLQTasksSuite) TearDownSuite()

func (*PurgeDLQTasksSuite) TestPurgeDLQTasks added in v1.23.0 

func (s *PurgeDLQTasksSuite) TestPurgeDLQTasks()

type RawHistorySuite added in v1.23.0 

type RawHistorySuite struct {
	*require.Assertions
	FunctionalTestBase
	historyrequire.HistoryRequire
}

func (*RawHistorySuite) SetupSuite added in v1.23.0 

func (s *RawHistorySuite) SetupSuite()

func (*RawHistorySuite) SetupTest added in v1.23.0 

func (s *RawHistorySuite) SetupTest()

func (*RawHistorySuite) TearDownSuite added in v1.23.0 

func (s *RawHistorySuite) TearDownSuite()

func (*RawHistorySuite) TestGetWorkflowExecutionHistory_GetRawHistoryData added in v1.23.0 

func (s *RawHistorySuite) TestGetWorkflowExecutionHistory_GetRawHistoryData()

type RunIdGetter added in v1.23.0 

type RunIdGetter interface {
	GetRunId() string
}

type ScheduleFunctionalSuite added in v1.23.0 

type ScheduleFunctionalSuite struct {
	protorequire.ProtoAssertions
	historyrequire.HistoryRequire
	FunctionalTestBase
	// contains filtered or unexported fields
}

func (*ScheduleFunctionalSuite) SetupSuite added in v1.23.0 

func (s *ScheduleFunctionalSuite) SetupSuite()

func (*ScheduleFunctionalSuite) SetupTest added in v1.23.0 

func (s *ScheduleFunctionalSuite) SetupTest()

func (*ScheduleFunctionalSuite) TearDownSuite added in v1.23.0 

func (s *ScheduleFunctionalSuite) TearDownSuite()

func (*ScheduleFunctionalSuite) TearDownTest added in v1.23.0 

func (s *ScheduleFunctionalSuite) TearDownTest()

func (*ScheduleFunctionalSuite) TestBasics added in v1.23.0 

func (s *ScheduleFunctionalSuite) TestBasics()

func (*ScheduleFunctionalSuite) TestExperimentalHsmInput added in v1.25.0 

func (s *ScheduleFunctionalSuite) TestExperimentalHsmInput()

func (*ScheduleFunctionalSuite) TestExperimentalHsmLastCompletionAndError added in v1.25.0 

func (s *ScheduleFunctionalSuite) TestExperimentalHsmLastCompletionAndError()

func (*ScheduleFunctionalSuite) TestInput added in v1.23.0 

func (s *ScheduleFunctionalSuite) TestInput()

func (*ScheduleFunctionalSuite) TestLastCompletionAndError added in v1.23.0 

func (s *ScheduleFunctionalSuite) TestLastCompletionAndError()

func (*ScheduleFunctionalSuite) TestListBeforeRun added in v1.23.0 

func (s *ScheduleFunctionalSuite) TestListBeforeRun()

func (*ScheduleFunctionalSuite) TestNextTimeCache added in v1.23.0 

func (s *ScheduleFunctionalSuite) TestNextTimeCache()

func (*ScheduleFunctionalSuite) TestRateLimit added in v1.23.0 

func (s *ScheduleFunctionalSuite) TestRateLimit()

func (*ScheduleFunctionalSuite) TestRefresh added in v1.23.0 

func (s *ScheduleFunctionalSuite) TestRefresh()

type SearchAttributeTestMapper 

type SearchAttributeTestMapper struct{}

func NewSearchAttributeTestMapper 

func NewSearchAttributeTestMapper() *SearchAttributeTestMapper

func (*SearchAttributeTestMapper) GetAlias 

func (t *SearchAttributeTestMapper) GetAlias(fieldName string, namespace string) (string, error)

func (*SearchAttributeTestMapper) GetFieldName 

func (t *SearchAttributeTestMapper) GetFieldName(alias string, namespace string) (string, error)

type SizeLimitFunctionalSuite added in v1.23.0 

type SizeLimitFunctionalSuite struct {
	// override suite.Suite.Assertions with require.Assertions; this means that s.NotNil(nil) will stop the test,
	// not merely log an error
	*require.Assertions
	historyrequire.HistoryRequire
	FunctionalTestBase
}

func (*SizeLimitFunctionalSuite) SetupSuite added in v1.23.0 

func (s *SizeLimitFunctionalSuite) SetupSuite()

This cluster use customized threshold for history config

func (*SizeLimitFunctionalSuite) SetupTest added in v1.23.0 

func (s *SizeLimitFunctionalSuite) SetupTest()

func (*SizeLimitFunctionalSuite) TearDownSuite added in v1.23.0 

func (s *SizeLimitFunctionalSuite) TearDownSuite()

func (*SizeLimitFunctionalSuite) TestTerminateWorkflowCausedByHistoryCountLimit added in v1.23.0 

func (s *SizeLimitFunctionalSuite) TestTerminateWorkflowCausedByHistoryCountLimit()

func (*SizeLimitFunctionalSuite) TestTerminateWorkflowCausedByHistorySizeLimit added in v1.23.0 

func (s *SizeLimitFunctionalSuite) TestTerminateWorkflowCausedByHistorySizeLimit()

func (*SizeLimitFunctionalSuite) TestTerminateWorkflowCausedByMsSizeLimit added in v1.23.0 

func (s *SizeLimitFunctionalSuite) TestTerminateWorkflowCausedByMsSizeLimit()

func (*SizeLimitFunctionalSuite) TestWorkflowFailed_PayloadSizeTooLarge added in v1.23.0 

func (s *SizeLimitFunctionalSuite) TestWorkflowFailed_PayloadSizeTooLarge()

type TLSFunctionalSuite added in v1.23.0 

type TLSFunctionalSuite struct {
	FunctionalTestBase
	// contains filtered or unexported fields
}

func (*TLSFunctionalSuite) SetupSuite added in v1.23.0 

func (s *TLSFunctionalSuite) SetupSuite()

func (*TLSFunctionalSuite) SetupTest added in v1.23.0 

func (s *TLSFunctionalSuite) SetupTest()

func (*TLSFunctionalSuite) TearDownSuite added in v1.23.0 

func (s *TLSFunctionalSuite) TearDownSuite()

func (*TLSFunctionalSuite) TearDownTest added in v1.23.0 

func (s *TLSFunctionalSuite) TearDownTest()

func (*TLSFunctionalSuite) TestGRPCMTLS added in v1.23.0 

func (s *TLSFunctionalSuite) TestGRPCMTLS()

func (*TLSFunctionalSuite) TestHTTPMTLS added in v1.23.0 

func (s *TLSFunctionalSuite) TestHTTPMTLS()

type TaskPoller 

type TaskPoller struct {
	Client                       workflowservice.WorkflowServiceClient
	Namespace                    string
	TaskQueue                    *taskqueuepb.TaskQueue
	StickyTaskQueue              *taskqueuepb.TaskQueue
	StickyScheduleToStartTimeout time.Duration
	Identity                     string
	WorkflowTaskHandler          workflowTaskHandler
	ActivityTaskHandler          activityTaskHandler
	QueryHandler                 queryHandler
	MessageHandler               messageHandler
	Logger                       log.Logger
	T                            *testing.T
}

TaskPoller is used in functional tests to poll workflow or activity task queues.

func (*TaskPoller) HandlePartialWorkflowTask 

func (p *TaskPoller) HandlePartialWorkflowTask(response *workflowservice.PollWorkflowTaskQueueResponse, forceCreateNewWorkflowTask bool) (*workflowservice.RespondWorkflowTaskCompletedResponse, error)

HandlePartialWorkflowTask for workflow task

func (*TaskPoller) PollAndProcessActivityTask 

func (p *TaskPoller) PollAndProcessActivityTask(dropTask bool) error

PollAndProcessActivityTask for activity tasks

func (*TaskPoller) PollAndProcessActivityTaskWithID 

func (p *TaskPoller) PollAndProcessActivityTaskWithID(dropTask bool) error

PollAndProcessActivityTaskWithID is similar to PollAndProcessActivityTask but using RespondActivityTask...ByID

func (*TaskPoller) PollAndProcessWorkflowTask 

func (p *TaskPoller) PollAndProcessWorkflowTask(funcs ...PollAndProcessWorkflowTaskOptionFunc) (res PollAndProcessWorkflowTaskResponse, err error)

func (*TaskPoller) PollAndProcessWorkflowTaskWithOptions added in v1.22.1 

func (p *TaskPoller) PollAndProcessWorkflowTaskWithOptions(opts *PollAndProcessWorkflowTaskOptions) (res PollAndProcessWorkflowTaskResponse, err error)

type TemporalParams 

type TemporalParams struct {
	ClusterMetadataConfig            *cluster.Config
	PersistenceConfig                config.Persistence
	MetadataMgr                      persistence.MetadataManager
	ClusterMetadataManager           persistence.ClusterMetadataManager
	ShardMgr                         persistence.ShardManager
	ExecutionManager                 persistence.ExecutionManager
	TaskMgr                          persistence.TaskManager
	NamespaceReplicationQueue        persistence.NamespaceReplicationQueue
	AbstractDataStoreFactory         persistenceClient.AbstractDataStoreFactory
	VisibilityStoreFactory           visibility.VisibilityStoreFactory
	Logger                           log.Logger
	ClusterNo                        int
	ArchiverMetadata                 carchiver.ArchivalMetadata
	ArchiverProvider                 provider.ArchiverProvider
	EnableReadHistoryFromArchival    bool
	HistoryConfig                    *HistoryConfig
	ESConfig                         *esclient.Config
	ESClient                         esclient.Client
	WorkerConfig                     *WorkerConfig
	MockAdminClient                  map[string]adminservice.AdminServiceClient
	NamespaceReplicationTaskExecutor namespace.ReplicationTaskExecutor
	SpanExporters                    []otelsdktrace.SpanExporter
	DynamicConfigOverrides           map[dynamicconfig.Key]interface{}
	TLSConfigProvider                *encryption.FixedTLSConfigProvider
	CaptureMetricsHandler            *metricstest.CaptureHandler
	// ServiceFxOptions is populated by WithFxOptionsForService.
	ServiceFxOptions     map[primitives.ServiceName][]fx.Option
	TaskCategoryRegistry tasks.TaskCategoryRegistry
}

TemporalParams contains everything needed to bootstrap Temporal

type TestCluster 

type TestCluster struct {
	// contains filtered or unexported fields
}

TestCluster is a base struct for functional tests

func NewClusterWithPersistenceTestBaseFactory added in v1.23.0 

func NewClusterWithPersistenceTestBaseFactory(t *testing.T, options *TestClusterConfig, logger log.Logger, tbFactory PersistenceTestBaseFactory) (*TestCluster, error)

func (*TestCluster) GetAdminClient 

func (tc *TestCluster) GetAdminClient() adminservice.AdminServiceClient

GetAdminClient returns an admin client from the test cluster

func (*TestCluster) GetExecutionManager 

func (tc *TestCluster) GetExecutionManager() persistence.ExecutionManager

GetExecutionManager returns an execution manager factory from the test cluster

func (*TestCluster) GetFrontendClient 

func (tc *TestCluster) GetFrontendClient() workflowservice.WorkflowServiceClient

GetFrontendClient returns a frontend client from the test cluster

func (*TestCluster) GetHistoryClient 

func (tc *TestCluster) GetHistoryClient() historyservice.HistoryServiceClient

GetHistoryClient returns a history client from the test cluster

func (*TestCluster) GetHost 

func (tc *TestCluster) GetHost() *temporalImpl

func (*TestCluster) GetMatchingClient added in v1.21.0 

func (tc *TestCluster) GetMatchingClient() matchingservice.MatchingServiceClient

GetMatchingClient returns a matching client from the test cluster

func (*TestCluster) GetOperatorClient 

func (tc *TestCluster) GetOperatorClient() operatorservice.OperatorServiceClient

func (*TestCluster) OverrideDynamicConfig added in v1.25.0 

func (tc *TestCluster) OverrideDynamicConfig(t *testing.T, key dynamicconfig.GenericSetting, value any) (cleanup func())

func (*TestCluster) TearDownCluster 

func (tc *TestCluster) TearDownCluster() error

TearDownCluster tears down the test cluster

type TestClusterConfig 

type TestClusterConfig struct {
	FrontendAddress        string
	EnableArchival         bool
	IsMasterCluster        bool
	ClusterNo              int
	ClusterMetadata        cluster.Config
	Persistence            persistencetests.TestBaseOptions
	HistoryConfig          *HistoryConfig
	ESConfig               *esclient.Config
	WorkerConfig           *WorkerConfig
	MockAdminClient        map[string]adminservice.AdminServiceClient
	FaultInjection         config.FaultInjection `yaml:"faultInjection"`
	DynamicConfigOverrides map[dynamicconfig.Key]interface{}
	GenerateMTLS           bool
	EnableMetricsCapture   bool
	// ServiceFxOptions can be populated using WithFxOptionsForService.
	ServiceFxOptions map[primitives.ServiceName][]fx.Option
}

TestClusterConfig are config for a test cluster

func GetTestClusterConfig 

func GetTestClusterConfig(configFile string) (*TestClusterConfig, error)

GetTestClusterConfig return test cluster config

type TestClusterFactory added in v1.23.0 

type TestClusterFactory interface {
	NewCluster(t *testing.T, options *TestClusterConfig, logger log.Logger) (*TestCluster, error)
}

func NewTestClusterFactory added in v1.23.0 

func NewTestClusterFactory() TestClusterFactory

func NewTestClusterFactoryWithCustomTestBaseFactory added in v1.23.0 

func NewTestClusterFactoryWithCustomTestBaseFactory(tbFactory PersistenceTestBaseFactory) TestClusterFactory

type TestClusterParams added in v1.23.0 

type TestClusterParams struct {
	ServiceOptions map[primitives.ServiceName][]fx.Option
}

TestClusterParams contains the variables which are used to configure test suites via the Option type.

func ApplyTestClusterParams added in v1.23.0 

func ApplyTestClusterParams(options []Option) TestClusterParams

type VersioningIntegSuite added in v1.23.0 

type VersioningIntegSuite struct {
	// override suite.Suite.Assertions with require.Assertions; this means that s.NotNil(nil) will stop the test,
	// not merely log an error
	FunctionalTestBase
	// contains filtered or unexported fields
}

func (*VersioningIntegSuite) SetupSuite added in v1.23.0 

func (s *VersioningIntegSuite) SetupSuite()

func (*VersioningIntegSuite) SetupTest added in v1.23.0 

func (s *VersioningIntegSuite) SetupTest()

func (*VersioningIntegSuite) TearDownSuite added in v1.23.0 

func (s *VersioningIntegSuite) TearDownSuite()

func (*VersioningIntegSuite) TearDownTest added in v1.23.0 

func (s *VersioningIntegSuite) TearDownTest()

func (*VersioningIntegSuite) TestAssignmentRuleDelete added in v1.24.0 

func (s *VersioningIntegSuite) TestAssignmentRuleDelete()

func (*VersioningIntegSuite) TestAssignmentRuleInsert added in v1.24.0 

func (s *VersioningIntegSuite) TestAssignmentRuleInsert()

func (*VersioningIntegSuite) TestAssignmentRuleReplace added in v1.24.0 

func (s *VersioningIntegSuite) TestAssignmentRuleReplace()

func (*VersioningIntegSuite) TestBasicVersionUpdate added in v1.23.0 

func (s *VersioningIntegSuite) TestBasicVersionUpdate()

func (*VersioningIntegSuite) TestCommitBuildID added in v1.24.0 

func (s *VersioningIntegSuite) TestCommitBuildID()

func (*VersioningIntegSuite) TestDescribeTaskQueueEnhanced_ReportFlags added in v1.24.0 

func (s *VersioningIntegSuite) TestDescribeTaskQueueEnhanced_ReportFlags()

func (*VersioningIntegSuite) TestDescribeTaskQueueEnhanced_TooManyBuildIds added in v1.24.0 

func (s *VersioningIntegSuite) TestDescribeTaskQueueEnhanced_TooManyBuildIds()

func (*VersioningIntegSuite) TestDescribeTaskQueueEnhanced_Unversioned added in v1.24.0 

func (s *VersioningIntegSuite) TestDescribeTaskQueueEnhanced_Unversioned()

func (*VersioningIntegSuite) TestDescribeTaskQueueEnhanced_Versioned_BasicReachability added in v1.24.0 

func (s *VersioningIntegSuite) TestDescribeTaskQueueEnhanced_Versioned_BasicReachability()

func (*VersioningIntegSuite) TestDescribeTaskQueueEnhanced_Versioned_ReachabilityCache added in v1.24.0 

func (s *VersioningIntegSuite) TestDescribeTaskQueueEnhanced_Versioned_ReachabilityCache()

func (*VersioningIntegSuite) TestDescribeTaskQueueLegacy_VersionSets added in v1.24.0 

func (s *VersioningIntegSuite) TestDescribeTaskQueueLegacy_VersionSets()

func (*VersioningIntegSuite) TestDescribeWorkflowExecution added in v1.23.0 

func (s *VersioningIntegSuite) TestDescribeWorkflowExecution()

func (*VersioningIntegSuite) TestDispatchActivity added in v1.23.0 

func (s *VersioningIntegSuite) TestDispatchActivity()

func (*VersioningIntegSuite) TestDispatchActivityCompatible added in v1.23.0 

func (s *VersioningIntegSuite) TestDispatchActivityCompatible()

func (*VersioningIntegSuite) TestDispatchActivityCrossTQFails added in v1.23.0 

func (s *VersioningIntegSuite) TestDispatchActivityCrossTQFails()

func (*VersioningIntegSuite) TestDispatchActivityCrossTq added in v1.24.0 

func (s *VersioningIntegSuite) TestDispatchActivityCrossTq()

func (*VersioningIntegSuite) TestDispatchActivityEager added in v1.23.0 

func (s *VersioningIntegSuite) TestDispatchActivityEager()

func (*VersioningIntegSuite) TestDispatchActivityFail added in v1.23.0 

func (s *VersioningIntegSuite) TestDispatchActivityFail()

func (*VersioningIntegSuite) TestDispatchActivityFailCrossTq added in v1.24.0 

func (s *VersioningIntegSuite) TestDispatchActivityFailCrossTq()

func (*VersioningIntegSuite) TestDispatchActivityFailOld added in v1.24.0 

func (s *VersioningIntegSuite) TestDispatchActivityFailOld()

func (*VersioningIntegSuite) TestDispatchActivityOld added in v1.24.0 

func (s *VersioningIntegSuite) TestDispatchActivityOld()

func (*VersioningIntegSuite) TestDispatchActivityTimeout added in v1.23.0 

func (s *VersioningIntegSuite) TestDispatchActivityTimeout()

func (*VersioningIntegSuite) TestDispatchActivityTimeoutCrossTq added in v1.24.0 

func (s *VersioningIntegSuite) TestDispatchActivityTimeoutCrossTq()

func (*VersioningIntegSuite) TestDispatchActivityTimeoutOld added in v1.24.0 

func (s *VersioningIntegSuite) TestDispatchActivityTimeoutOld()

func (*VersioningIntegSuite) TestDispatchActivityUpgrade added in v1.24.0 

func (s *VersioningIntegSuite) TestDispatchActivityUpgrade()

func (*VersioningIntegSuite) TestDispatchChildWorkflow added in v1.23.0 

func (s *VersioningIntegSuite) TestDispatchChildWorkflow()

func (*VersioningIntegSuite) TestDispatchChildWorkflowCrossTQFails added in v1.23.0 

func (s *VersioningIntegSuite) TestDispatchChildWorkflowCrossTQFails()

func (*VersioningIntegSuite) TestDispatchChildWorkflowCrossTq added in v1.24.0 

func (s *VersioningIntegSuite) TestDispatchChildWorkflowCrossTq()

func (*VersioningIntegSuite) TestDispatchChildWorkflowOld added in v1.24.0 

func (s *VersioningIntegSuite) TestDispatchChildWorkflowOld()

func (*VersioningIntegSuite) TestDispatchChildWorkflowUpgrade added in v1.23.0 

func (s *VersioningIntegSuite) TestDispatchChildWorkflowUpgrade()

func (*VersioningIntegSuite) TestDispatchChildWorkflowUpgradeOld added in v1.24.0 

func (s *VersioningIntegSuite) TestDispatchChildWorkflowUpgradeOld()

func (*VersioningIntegSuite) TestDispatchContinueAsNew added in v1.23.0 

func (s *VersioningIntegSuite) TestDispatchContinueAsNew()

func (*VersioningIntegSuite) TestDispatchContinueAsNewCrossTq added in v1.24.0 

func (s *VersioningIntegSuite) TestDispatchContinueAsNewCrossTq()

func (*VersioningIntegSuite) TestDispatchContinueAsNewOld added in v1.24.0 

func (s *VersioningIntegSuite) TestDispatchContinueAsNewOld()

func (*VersioningIntegSuite) TestDispatchContinueAsNewUpgrade added in v1.24.0 

func (s *VersioningIntegSuite) TestDispatchContinueAsNewUpgrade()

func (*VersioningIntegSuite) TestDispatchContinueAsNewUpgradeOld added in v1.24.0 

func (s *VersioningIntegSuite) TestDispatchContinueAsNewUpgradeOld()

func (*VersioningIntegSuite) TestDispatchCron added in v1.23.0 

func (s *VersioningIntegSuite) TestDispatchCron()

func (*VersioningIntegSuite) TestDispatchCronOld added in v1.24.0 

func (s *VersioningIntegSuite) TestDispatchCronOld()

func (*VersioningIntegSuite) TestDispatchNewWorkflow added in v1.23.0 

func (s *VersioningIntegSuite) TestDispatchNewWorkflow()

func (*VersioningIntegSuite) TestDispatchNewWorkflowOld added in v1.24.0 

func (s *VersioningIntegSuite) TestDispatchNewWorkflowOld()

func (*VersioningIntegSuite) TestDispatchNewWorkflowStartWorkerFirst added in v1.23.0 

func (s *VersioningIntegSuite) TestDispatchNewWorkflowStartWorkerFirst()

func (*VersioningIntegSuite) TestDispatchNewWorkflowWithRamp added in v1.24.0 

func (s *VersioningIntegSuite) TestDispatchNewWorkflowWithRamp()

func (*VersioningIntegSuite) TestDispatchNotUsingVersioning added in v1.23.0 

func (s *VersioningIntegSuite) TestDispatchNotUsingVersioning()

func (*VersioningIntegSuite) TestDispatchNotUsingVersioningOld added in v1.24.0 

func (s *VersioningIntegSuite) TestDispatchNotUsingVersioningOld()

func (*VersioningIntegSuite) TestDispatchQuery added in v1.23.0 

func (s *VersioningIntegSuite) TestDispatchQuery()

func (*VersioningIntegSuite) TestDispatchQueryOld added in v1.25.0 

func (s *VersioningIntegSuite) TestDispatchQueryOld()

func (*VersioningIntegSuite) TestDispatchRetry added in v1.23.0 

func (s *VersioningIntegSuite) TestDispatchRetry()

func (*VersioningIntegSuite) TestDispatchRetryOld added in v1.24.0 

func (s *VersioningIntegSuite) TestDispatchRetryOld()

func (*VersioningIntegSuite) TestDispatchUnversionedRemainsUnversioned added in v1.23.0 

func (s *VersioningIntegSuite) TestDispatchUnversionedRemainsUnversioned()

func (*VersioningIntegSuite) TestDispatchUpgradeStopOld added in v1.23.0 

func (s *VersioningIntegSuite) TestDispatchUpgradeStopOld()

func (*VersioningIntegSuite) TestDispatchUpgradeStopOldOld added in v1.24.0 

func (s *VersioningIntegSuite) TestDispatchUpgradeStopOldOld()

func (*VersioningIntegSuite) TestDispatchUpgradeWait added in v1.23.0 

func (s *VersioningIntegSuite) TestDispatchUpgradeWait()

func (*VersioningIntegSuite) TestDispatchUpgradeWaitOld added in v1.24.0 

func (s *VersioningIntegSuite) TestDispatchUpgradeWaitOld()

func (*VersioningIntegSuite) TestFirstWorkflowTaskAssignment_Spooled added in v1.24.0 

func (s *VersioningIntegSuite) TestFirstWorkflowTaskAssignment_Spooled()

func (*VersioningIntegSuite) TestFirstWorkflowTaskAssignment_SyncMatch added in v1.24.0 

func (s *VersioningIntegSuite) TestFirstWorkflowTaskAssignment_SyncMatch()

func (*VersioningIntegSuite) TestIndependentActivityTaskAssignment_Spooled_UnversionedWorkflow added in v1.24.0 

func (s *VersioningIntegSuite) TestIndependentActivityTaskAssignment_Spooled_UnversionedWorkflow()

func (*VersioningIntegSuite) TestIndependentActivityTaskAssignment_Spooled_VersionedWorkflow added in v1.24.0 

func (s *VersioningIntegSuite) TestIndependentActivityTaskAssignment_Spooled_VersionedWorkflow()

func (*VersioningIntegSuite) TestIndependentActivityTaskAssignment_SyncMatch_UnversionedWorkflow added in v1.24.0 

func (s *VersioningIntegSuite) TestIndependentActivityTaskAssignment_SyncMatch_UnversionedWorkflow()

func (*VersioningIntegSuite) TestIndependentActivityTaskAssignment_SyncMatch_VersionedWorkflow added in v1.24.0 

func (s *VersioningIntegSuite) TestIndependentActivityTaskAssignment_SyncMatch_VersionedWorkflow()

func (*VersioningIntegSuite) TestLinkToNonexistentCompatibleVersionReturnsNotFound added in v1.23.0 

func (s *VersioningIntegSuite) TestLinkToNonexistentCompatibleVersionReturnsNotFound()

func (*VersioningIntegSuite) TestMaxTaskQueuesPerBuildIdEnforced added in v1.23.0 

func (s *VersioningIntegSuite) TestMaxTaskQueuesPerBuildIdEnforced()

func (*VersioningIntegSuite) TestRedirectRuleDelete added in v1.24.0 

func (s *VersioningIntegSuite) TestRedirectRuleDelete()

func (*VersioningIntegSuite) TestRedirectRuleInsert added in v1.24.0 

func (s *VersioningIntegSuite) TestRedirectRuleInsert()

func (*VersioningIntegSuite) TestRedirectRuleReplace added in v1.24.0 

func (s *VersioningIntegSuite) TestRedirectRuleReplace()

func (*VersioningIntegSuite) TestRedirectWithConcurrentActivities added in v1.25.0 

func (s *VersioningIntegSuite) TestRedirectWithConcurrentActivities()

func (*VersioningIntegSuite) TestResetWorkflowAssignsToCorrectBuildId added in v1.24.0 

func (s *VersioningIntegSuite) TestResetWorkflowAssignsToCorrectBuildId()

func (*VersioningIntegSuite) TestResetWorkflowAssignsToCorrectBuildId_CaN_Inherit added in v1.24.0 

func (s *VersioningIntegSuite) TestResetWorkflowAssignsToCorrectBuildId_CaN_Inherit()

func (*VersioningIntegSuite) TestResetWorkflowAssignsToCorrectBuildId_CaN_NoInherit added in v1.24.0 

func (s *VersioningIntegSuite) TestResetWorkflowAssignsToCorrectBuildId_CaN_NoInherit()

func (*VersioningIntegSuite) TestResetWorkflowAssignsToCorrectBuildId_ChildWF_Inherit added in v1.24.0 

func (s *VersioningIntegSuite) TestResetWorkflowAssignsToCorrectBuildId_ChildWF_Inherit()

func (*VersioningIntegSuite) TestResetWorkflowAssignsToCorrectBuildId_ChildWF_NoInherit added in v1.24.0 

func (s *VersioningIntegSuite) TestResetWorkflowAssignsToCorrectBuildId_ChildWF_NoInherit()

func (*VersioningIntegSuite) TestSeriesOfUpdates added in v1.23.0 

func (s *VersioningIntegSuite) TestSeriesOfUpdates()

func (*VersioningIntegSuite) TestUnversionedWorkflowStaysUnversioned added in v1.24.0 

func (s *VersioningIntegSuite) TestUnversionedWorkflowStaysUnversioned()

func (*VersioningIntegSuite) TestVersionRuleBuildIdValidation added in v1.26.0 

func (s *VersioningIntegSuite) TestVersionRuleBuildIdValidation()

func (*VersioningIntegSuite) TestVersionRuleConflictToken added in v1.24.0 

func (s *VersioningIntegSuite) TestVersionRuleConflictToken()

func (*VersioningIntegSuite) TestVersioningChangesPropagate added in v1.23.0 

func (s *VersioningIntegSuite) TestVersioningChangesPropagate()

func (*VersioningIntegSuite) TestVersioningStatePersistsAcrossUnload added in v1.23.0 

func (s *VersioningIntegSuite) TestVersioningStatePersistsAcrossUnload()

func (*VersioningIntegSuite) TestWorkflowStaysInBuildId added in v1.24.0 

func (s *VersioningIntegSuite) TestWorkflowStaysInBuildId()

func (*VersioningIntegSuite) TestWorkflowTaskRedirectInRetryFirstTask added in v1.24.0 

func (s *VersioningIntegSuite) TestWorkflowTaskRedirectInRetryFirstTask()

func (*VersioningIntegSuite) TestWorkflowTaskRedirectInRetryNonFirstTask added in v1.24.0 

func (s *VersioningIntegSuite) TestWorkflowTaskRedirectInRetryNonFirstTask()

type WorkerConfig 

type WorkerConfig struct {
	EnableArchiver    bool
	EnableReplicator  bool
	StartWorkerAnyway bool
}

WorkerConfig is the config for enabling/disabling Temporal worker

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.