Documentation ¶
Overview ¶
nolint:revive
Index ¶
- Constants
- Variables
- func EventBatchesToVersionHistory(versionHistory *historyspb.VersionHistory, eventBatches []*historypb.History) (*historyspb.VersionHistory, error)
- func NewContext() context.Context
- func NewFrontendClient(connection *grpc.ClientConn) workflowservice.WorkflowServiceClient
- func UsingSQLAdvancedVisibility() bool
- func WithDropTask(o *PollAndProcessWorkflowTaskOptions)
- func WithDumpHistory(o *PollAndProcessWorkflowTaskOptions)
- func WithForceNewWorkflowTask(o *PollAndProcessWorkflowTaskOptions)
- func WithNoDumpCommands(o *PollAndProcessWorkflowTaskOptions)
- func WithPollSticky(o *PollAndProcessWorkflowTaskOptions)
- func WithRespondSticky(o *PollAndProcessWorkflowTaskOptions)
- type AcquireShardFunctionalSuite
- type AddTasksSuite
- type AdminClient
- type AdvancedVisibilitySuite
- func (s *AdvancedVisibilitySuite) SetupSuite()
- func (s *AdvancedVisibilitySuite) SetupTest()
- func (s *AdvancedVisibilitySuite) TearDownSuite()
- func (s *AdvancedVisibilitySuite) TestBuildIdScavenger_DeletesUnusedBuildId()
- func (s *AdvancedVisibilitySuite) TestChildWorkflow_ParentWorkflow()
- func (s *AdvancedVisibilitySuite) TestCountGroupByWorkflow()
- func (s *AdvancedVisibilitySuite) TestCountWorkflow()
- func (s *AdvancedVisibilitySuite) TestListOpenWorkflow()
- func (s *AdvancedVisibilitySuite) TestListWorkflow()
- func (s *AdvancedVisibilitySuite) TestListWorkflow_ExecutionTime()
- func (s *AdvancedVisibilitySuite) TestListWorkflow_KeywordQuery()
- func (s *AdvancedVisibilitySuite) TestListWorkflow_MaxWindowSize()
- func (s *AdvancedVisibilitySuite) TestListWorkflow_OrQuery()
- func (s *AdvancedVisibilitySuite) TestListWorkflow_OrderBy()
- func (s *AdvancedVisibilitySuite) TestListWorkflow_PageToken()
- func (s *AdvancedVisibilitySuite) TestListWorkflow_SearchAfter()
- func (s *AdvancedVisibilitySuite) TestListWorkflow_SearchAttribute()
- func (s *AdvancedVisibilitySuite) TestListWorkflow_StringQuery()
- func (s *AdvancedVisibilitySuite) TestModifyWorkflowExecutionProperties()
- func (s *AdvancedVisibilitySuite) TestScanWorkflow()
- func (s *AdvancedVisibilitySuite) TestScanWorkflow_PageToken()
- func (s *AdvancedVisibilitySuite) TestScanWorkflow_SearchAttribute()
- func (s *AdvancedVisibilitySuite) TestUpsertWorkflowExecutionSearchAttributes()
- func (s *AdvancedVisibilitySuite) TestUpsertWorkflowExecution_InvalidKey()
- func (s *AdvancedVisibilitySuite) TestWorkerTaskReachability_ByBuildId()
- func (s *AdvancedVisibilitySuite) TestWorkerTaskReachability_ByBuildId_NotInNamespace()
- func (s *AdvancedVisibilitySuite) TestWorkerTaskReachability_ByBuildId_NotInTaskQueue()
- func (s *AdvancedVisibilitySuite) TestWorkerTaskReachability_EmptyBuildIds()
- func (s *AdvancedVisibilitySuite) TestWorkerTaskReachability_TooManyBuildIds()
- func (s *AdvancedVisibilitySuite) TestWorkerTaskReachability_Unversioned_InNamespace()
- func (s *AdvancedVisibilitySuite) TestWorkerTaskReachability_Unversioned_InTaskQueue()
- func (s *AdvancedVisibilitySuite) Test_BuildIdIndexedOnCompletion_UnversionedWorker()
- func (s *AdvancedVisibilitySuite) Test_BuildIdIndexedOnCompletion_VersionedWorker()
- func (s *AdvancedVisibilitySuite) Test_BuildIdIndexedOnReset()
- func (s *AdvancedVisibilitySuite) Test_BuildIdIndexedOnRetry()
- func (s *AdvancedVisibilitySuite) Test_LongWorkflowID()
- type ArchivalSuite
- func (s *ArchivalSuite) SetupSuite()
- func (s *ArchivalSuite) SetupTest()
- func (s *ArchivalSuite) TearDownSuite()
- func (s *ArchivalSuite) TestArchival_ArchiverWorker()
- func (s *ArchivalSuite) TestArchival_ContinueAsNew()
- func (s *ArchivalSuite) TestArchival_TimerQueueProcessor()
- func (s *ArchivalSuite) TestVisibilityArchival()
- type ArchiverBase
- type ClientFunctionalSuite
- func (s *ClientFunctionalSuite) SetupSuite()
- func (s *ClientFunctionalSuite) SetupTest()
- func (s *ClientFunctionalSuite) TearDownSuite()
- func (s *ClientFunctionalSuite) TearDownTest()
- func (s *ClientFunctionalSuite) TestActivityHeartbeatDetailsDuringRetry()
- func (s *ClientFunctionalSuite) TestAdminRebuildMutableState()
- func (s *ClientFunctionalSuite) TestBatchReset()
- func (s *ClientFunctionalSuite) TestBatchResetByBuildId()
- func (s *ClientFunctionalSuite) TestBatchSignal()
- func (s *ClientFunctionalSuite) TestBufferedEventsMutableStateSizeLimit()
- func (s *ClientFunctionalSuite) TestClientDataConverter()
- func (s *ClientFunctionalSuite) TestClientDataConverter_Failed()
- func (s *ClientFunctionalSuite) TestClientDataConverter_WithChild()
- func (s *ClientFunctionalSuite) TestContinueAsNewTightLoop()
- func (s *ClientFunctionalSuite) TestCronWorkflowCompletionStates()
- func (s *ClientFunctionalSuite) TestGetHistoryReverse()
- func (s *ClientFunctionalSuite) TestGetHistoryReverse_MultipleBranches()
- func (s *ClientFunctionalSuite) TestHTTPAPIBasics_Protojson()
- func (s *ClientFunctionalSuite) TestHTTPAPIBasics_ProtojsonPretty()
- func (s *ClientFunctionalSuite) TestHTTPAPIBasics_Shorthand()
- func (s *ClientFunctionalSuite) TestHTTPAPIBasics_ShorthandPretty()
- func (s *ClientFunctionalSuite) TestHTTPAPIHeaders()
- func (s *ClientFunctionalSuite) TestHTTPAPIPretty()
- func (s *ClientFunctionalSuite) TestHTTPAPI_OperatorService_ListSearchAttributes()
- func (s *ClientFunctionalSuite) TestMaxBufferedEventsLimit()
- func (s *ClientFunctionalSuite) TestQueryWorkflow_ClosedWithoutWorkflowTaskStarted()
- func (s *ClientFunctionalSuite) TestQueryWorkflow_Consistent_PiggybackQuery()
- func (s *ClientFunctionalSuite) TestQueryWorkflow_QueryBeforeStart()
- func (s *ClientFunctionalSuite) TestQueryWorkflow_QueryFailedWorkflowTask()
- func (s *ClientFunctionalSuite) TestQueryWorkflow_QueryWhileBackoff()
- func (s *ClientFunctionalSuite) TestQueryWorkflow_Sticky()
- func (s *ClientFunctionalSuite) TestStickyAutoReset()
- func (s *ClientFunctionalSuite) TestTooManyCancelRequests()
- func (s *ClientFunctionalSuite) TestTooManyChildWorkflows()
- func (s *ClientFunctionalSuite) TestTooManyPendingActivities()
- func (s *ClientFunctionalSuite) TestTooManyPendingSignals()
- func (s *ClientFunctionalSuite) Test_ActivityTimeouts()
- func (s *ClientFunctionalSuite) Test_BufferedQuery()
- func (s *ClientFunctionalSuite) Test_CancelActivityAndTimerBeforeComplete()
- func (s *ClientFunctionalSuite) Test_FinishWorkflowWithDeferredCommands()
- func (s *ClientFunctionalSuite) Test_InvalidCommandAttribute()
- func (s *ClientFunctionalSuite) Test_StickyWorkerRestartWorkflowTask()
- func (s *ClientFunctionalSuite) Test_UnhandledCommandAndNewTask()
- type DLQSuite
- func (s *DLQSuite) SetupSuite()
- func (s *DLQSuite) SetupTest()
- func (s *DLQSuite) TearDownSuite()
- func (s *DLQSuite) TestCancelRunningMerge()
- func (s *DLQSuite) TestListQueues()
- func (s *DLQSuite) TestMergeRealWorkflow()
- func (s *DLQSuite) TestPurgeRealWorkflow()
- func (s *DLQSuite) TestReadArtificialDLQTasks()
- type DeadlineExceededErrorSuite
- type EventualSuccessSuite
- type FrontendClient
- type FunctionalSuite
- func (s *FunctionalSuite) SetupSuite()
- func (s *FunctionalSuite) SetupTest()
- func (s *FunctionalSuite) TearDownSuite()
- func (s *FunctionalSuite) TestActivityCancellationNotStarted()
- func (s *FunctionalSuite) TestActivityHeartBeatWorkflow_Success()
- func (s *FunctionalSuite) TestActivityHeartBeatWorkflow_Timeout()
- func (s *FunctionalSuite) TestActivityRetry()
- func (s *FunctionalSuite) TestActivityRetry_Infinite()
- func (s *FunctionalSuite) TestBufferedEvents()
- func (s *FunctionalSuite) TestBufferedEventsOutOfOrder()
- func (s *FunctionalSuite) TestCancelTimer()
- func (s *FunctionalSuite) TestCancelTimer_CancelFiredAndBuffered()
- func (s *FunctionalSuite) TestChildWorkflowExecution()
- func (s *FunctionalSuite) TestChildWorkflowWithContinueAsNew()
- func (s *FunctionalSuite) TestChildWorkflowWithContinueAsNewParentTerminate()
- func (s *FunctionalSuite) TestCompleteWorkflowTaskAndCreateNewOne()
- func (s *FunctionalSuite) TestContinueAsNewRun_Timeout()
- func (s *FunctionalSuite) TestContinueAsNewWorkflow()
- func (s *FunctionalSuite) TestCronChildWorkflowExecution()
- func (s *FunctionalSuite) TestCronWorkflow()
- func (s *FunctionalSuite) TestCronWorkflow_Failed_Infinite()
- func (s *FunctionalSuite) TestDescribeTaskQueue()
- func (s *FunctionalSuite) TestDescribeWorkflowExecution()
- func (s *FunctionalSuite) TestEagerWorkflowStart_RetryStartAfterTimeout()
- func (s *FunctionalSuite) TestEagerWorkflowStart_RetryStartImmediately()
- func (s *FunctionalSuite) TestEagerWorkflowStart_RetryTaskAfterTimeout()
- func (s *FunctionalSuite) TestEagerWorkflowStart_StartNew()
- func (s *FunctionalSuite) TestEagerWorkflowStart_TerminateDuplicate()
- func (s *FunctionalSuite) TestExternalRequestCancelWorkflowExecution()
- func (s *FunctionalSuite) TestGetWorkflowExecutionHistory_All()
- func (s *FunctionalSuite) TestGetWorkflowExecutionHistory_Close()
- func (s *FunctionalSuite) TestImmediateChildCancellation_WorkflowTaskFailed()
- func (s *FunctionalSuite) TestNoTransientWorkflowTaskAfterFlushBufferedEvents()
- func (s *FunctionalSuite) TestRateLimitBufferedEvents()
- func (s *FunctionalSuite) TestRelayWorkflowTaskTimeout()
- func (s *FunctionalSuite) TestRequestCancelWorkflowCommandExecution_TargetFinished()
- func (s *FunctionalSuite) TestRequestCancelWorkflowCommandExecution_TargetNotFound()
- func (s *FunctionalSuite) TestRequestCancelWorkflowCommandExecution_TargetRunning()
- func (s *FunctionalSuite) TestResetWorkflow()
- func (s *FunctionalSuite) TestResetWorkflow_ReapplyAll()
- func (s *FunctionalSuite) TestResetWorkflow_ReapplyBufferAll()
- func (s *FunctionalSuite) TestResetWorkflow_ReapplyBufferNone()
- func (s *FunctionalSuite) TestResetWorkflow_ReapplyNone()
- func (s *FunctionalSuite) TestResetWorkflow_WorkflowTask_Schedule()
- func (s *FunctionalSuite) TestResetWorkflow_WorkflowTask_ScheduleToStart()
- func (s *FunctionalSuite) TestResetWorkflow_WorkflowTask_Start()
- func (s *FunctionalSuite) TestRespondWorkflowTaskCompleted_ReturnsErrorIfInvalidArgument()
- func (s *FunctionalSuite) TestRetryChildWorkflowExecution()
- func (s *FunctionalSuite) TestRetryFailChildWorkflowExecution()
- func (s *FunctionalSuite) TestSequentialWorkflow()
- func (s *FunctionalSuite) TestServerRejectsInvalidRequests()
- func (s *FunctionalSuite) TestSignalExternalWorkflowCommand()
- func (s *FunctionalSuite) TestSignalExternalWorkflowCommand_SignalSelf()
- func (s *FunctionalSuite) TestSignalExternalWorkflowCommand_UnKnownTarget()
- func (s *FunctionalSuite) TestSignalExternalWorkflowCommand_WithoutRunID()
- func (s *FunctionalSuite) TestSignalWithStartWithMemo()
- func (s *FunctionalSuite) TestSignalWithStartWorkflow()
- func (s *FunctionalSuite) TestSignalWithStartWorkflow_IDReusePolicy()
- func (s *FunctionalSuite) TestSignalWithStartWorkflow_NoWorkflowTaskCreated()
- func (s *FunctionalSuite) TestSignalWithStartWorkflow_StartDelay()
- func (s *FunctionalSuite) TestSignalWorkflow()
- func (s *FunctionalSuite) TestSignalWorkflow_Cron_NoWorkflowTaskCreated()
- func (s *FunctionalSuite) TestSignalWorkflow_DuplicateRequest()
- func (s *FunctionalSuite) TestSignalWorkflow_NoWorkflowTaskCreated()
- func (s *FunctionalSuite) TestSignalWorkflow_WorkflowCloseAttempted()
- func (s *FunctionalSuite) TestStartWithMemo()
- func (s *FunctionalSuite) TestStartWorkflowExecution()
- func (s *FunctionalSuite) TestStartWorkflowExecutionWithDelay()
- func (s *FunctionalSuite) TestStartWorkflowExecution_TerminateIfRunning()
- func (s *FunctionalSuite) TestStickyTaskqueueResetThenTimeout()
- func (s *FunctionalSuite) TestStickyTimeout_NonTransientWorkflowTask()
- func (s *FunctionalSuite) TestTerminateWorkflow()
- func (s *FunctionalSuite) TestTransientWorkflowTaskHistorySize()
- func (s *FunctionalSuite) TestTransientWorkflowTaskTimeout()
- func (s *FunctionalSuite) TestTryActivityCancellationFromWorkflow()
- func (s *FunctionalSuite) TestUpdateWorkflow_1stAccept_2ndAccept_2ndComplete_1stComplete()
- func (s *FunctionalSuite) TestUpdateWorkflow_1stAccept_2ndReject_1stComplete()
- func (s *FunctionalSuite) TestUpdateWorkflow_CompleteWorkflow_CancelUpdate()
- func (s *FunctionalSuite) TestUpdateWorkflow_CompletedSpeculativeWorkflowTask_DeduplicateID()
- func (s *FunctionalSuite) TestUpdateWorkflow_ConvertScheduledSpeculativeWorkflowTaskToNormal_BecauseOfSignal()
- func (s *FunctionalSuite) TestUpdateWorkflow_ConvertStartedSpeculativeWorkflowTaskToNormal_BecauseOfBufferedSignal()
- func (s *FunctionalSuite) TestUpdateWorkflow_FailSpeculativeWorkflowTask()
- func (s *FunctionalSuite) TestUpdateWorkflow_FirstNormalScheduledWorkflowTask_AcceptComplete()
- func (s *FunctionalSuite) TestUpdateWorkflow_FirstNormalScheduledWorkflowTask_Reject()
- func (s *FunctionalSuite) TestUpdateWorkflow_FirstNormalWorkflowTaskUpdateLost_BecauseOfShardMove()
- func (s *FunctionalSuite) TestUpdateWorkflow_NewNormalFromStartedWorkflowTask_Rejected()
- func (s *FunctionalSuite) TestUpdateWorkflow_NewNormalWorkflowTask_AcceptComplete()
- func (s *FunctionalSuite) TestUpdateWorkflow_NewNormalWorkflowTask_Reject()
- func (s *FunctionalSuite) TestUpdateWorkflow_NewScheduledSpeculativeWorkflowTaskLost_BecauseOfShardMove()
- func (s *FunctionalSuite) TestUpdateWorkflow_NewSpeculativeFromStartedWorkflowTask_Rejected()
- func (s *FunctionalSuite) TestUpdateWorkflow_NewSpeculativeWorkflowTask_AcceptComplete()
- func (s *FunctionalSuite) TestUpdateWorkflow_NewSpeculativeWorkflowTask_Reject()
- func (s *FunctionalSuite) TestUpdateWorkflow_NewSpeculativeWorkflowTask_WorkerSkippedProcessing_RejectByServer()
- func (s *FunctionalSuite) TestUpdateWorkflow_NewStartedSpeculativeWorkflowTaskLost_BecauseOfShardMove()
- func (s *FunctionalSuite) TestUpdateWorkflow_NewStickySpeculativeWorkflowTask_AcceptComplete()
- func (s *FunctionalSuite) TestUpdateWorkflow_NewStickySpeculativeWorkflowTask_AcceptComplete_StickyWorkerUnavailable()
- func (s *FunctionalSuite) TestUpdateWorkflow_NormalScheduledWorkflowTask_AcceptComplete()
- func (s *FunctionalSuite) TestUpdateWorkflow_ScheduleToStartTimeoutSpeculativeWorkflowTask()
- func (s *FunctionalSuite) TestUpdateWorkflow_ScheduleToStartTimeoutSpeculativeWorkflowTask_NormalTaskQueue()
- func (s *FunctionalSuite) TestUpdateWorkflow_ScheduledSpeculativeWorkflowTask_DeduplicateID()
- func (s *FunctionalSuite) TestUpdateWorkflow_ScheduledSpeculativeWorkflowTask_TerminateWorkflow()
- func (s *FunctionalSuite) TestUpdateWorkflow_SpeculativeWorkflowTask_Heartbeat()
- func (s *FunctionalSuite) TestUpdateWorkflow_StaleSpeculativeWorkflowTask_ClearMutableState_Accepted()
- func (s *FunctionalSuite) TestUpdateWorkflow_StaleSpeculativeWorkflowTask_CloseShard_DifferentStartedId_Rejected()
- func (s *FunctionalSuite) TestUpdateWorkflow_StaleSpeculativeWorkflowTask_CloseShard_SameStartedId_SameUpdateId_Accepted()
- func (s *FunctionalSuite) TestUpdateWorkflow_StaleSpeculativeWorkflowTask_SameStartedId_DifferentUpdateId_Rejected()
- func (s *FunctionalSuite) TestUpdateWorkflow_StartToCloseTimeoutSpeculativeWorkflowTask()
- func (s *FunctionalSuite) TestUpdateWorkflow_StartedSpeculativeWorkflowTask_DeduplicateID()
- func (s *FunctionalSuite) TestUpdateWorkflow_StartedSpeculativeWorkflowTask_TerminateWorkflow()
- func (s *FunctionalSuite) TestUpdateWorkflow_ValidateWorkerMessages()
- func (s *FunctionalSuite) TestUserTimers_CapDuration()
- func (s *FunctionalSuite) TestUserTimers_Sequential()
- func (s *FunctionalSuite) TestVisibility()
- func (s *FunctionalSuite) TestWorkflowContinueAsNew_TaskID()
- func (s *FunctionalSuite) TestWorkflowRetry()
- func (s *FunctionalSuite) TestWorkflowRetryFailures()
- func (s *FunctionalSuite) TestWorkflowTaskAndActivityTaskTimeoutsWorkflow()
- func (s *FunctionalSuite) TestWorkflowTaskFailed()
- func (s *FunctionalSuite) TestWorkflowTaskHeartbeatingWithEmptyResult()
- func (s *FunctionalSuite) TestWorkflowTaskHeartbeatingWithLocalActivitiesResult()
- func (s *FunctionalSuite) TestWorkflowTerminationSignalAfterRegularWorkflowTaskStarted()
- func (s *FunctionalSuite) TestWorkflowTerminationSignalAfterRegularWorkflowTaskStartedAndFailWorkflowTask()
- func (s *FunctionalSuite) TestWorkflowTerminationSignalAfterTransientWorkflowTaskStarted()
- func (s *FunctionalSuite) TestWorkflowTerminationSignalAfterTransientWorkflowTaskStartedAndFailWorkflowTask()
- func (s *FunctionalSuite) TestWorkflowTerminationSignalBeforeRegularWorkflowTaskStarted()
- func (s *FunctionalSuite) TestWorkflowTerminationSignalBeforeTransientWorkflowTaskStarted()
- func (s *FunctionalSuite) TestWorkflowTimeout()
- func (s *FunctionalSuite) Test_DeleteWorkflowExecution_Competed()
- func (s *FunctionalSuite) Test_DeleteWorkflowExecution_Running()
- func (s *FunctionalSuite) Test_DeleteWorkflowExecution_RunningWithTerminate()
- type FunctionalTestBase
- type FunctionalTestBaseSuite
- type HistoryClient
- type HistoryConfig
- type Option
- type OwnershipLostErrorSuite
- type ParentWithChildContinueAsNew
- type PersistenceTestBaseFactory
- type PollAndProcessWorkflowTaskOptionFunc
- type PollAndProcessWorkflowTaskOptions
- type PollAndProcessWorkflowTaskResponse
- type PurgeDLQTasksSuite
- type RawHistorySuite
- type RunIdGetter
- type ScheduleFunctionalSuite
- func (s *ScheduleFunctionalSuite) SetupSuite()
- func (s *ScheduleFunctionalSuite) SetupTest()
- func (s *ScheduleFunctionalSuite) TearDownSuite()
- func (s *ScheduleFunctionalSuite) TearDownTest()
- func (s *ScheduleFunctionalSuite) TestBasics()
- func (s *ScheduleFunctionalSuite) TestInput()
- func (s *ScheduleFunctionalSuite) TestLastCompletionAndError()
- func (s *ScheduleFunctionalSuite) TestListBeforeRun()
- func (s *ScheduleFunctionalSuite) TestNextTimeCache()
- func (s *ScheduleFunctionalSuite) TestRateLimit()
- func (s *ScheduleFunctionalSuite) TestRefresh()
- type SearchAttributeTestMapper
- type SizeLimitFunctionalSuite
- func (s *SizeLimitFunctionalSuite) SetupSuite()
- func (s *SizeLimitFunctionalSuite) SetupTest()
- func (s *SizeLimitFunctionalSuite) TearDownSuite()
- func (s *SizeLimitFunctionalSuite) TestTerminateWorkflowCausedByHistoryCountLimit()
- func (s *SizeLimitFunctionalSuite) TestTerminateWorkflowCausedByHistorySizeLimit()
- func (s *SizeLimitFunctionalSuite) TestTerminateWorkflowCausedByMsSizeLimit()
- func (s *SizeLimitFunctionalSuite) TestWorkflowFailed_PayloadSizeTooLarge()
- type SomeJSONStruct
- type TLSFunctionalSuite
- type TaskPoller
- func (p *TaskPoller) HandlePartialWorkflowTask(response *workflowservice.PollWorkflowTaskQueueResponse, ...) (*workflowservice.RespondWorkflowTaskCompletedResponse, error)
- func (p *TaskPoller) PollAndProcessActivityTask(dropTask bool) error
- func (p *TaskPoller) PollAndProcessActivityTaskWithID(dropTask bool) error
- func (p *TaskPoller) PollAndProcessWorkflowTask(funcs ...PollAndProcessWorkflowTaskOptionFunc) (res PollAndProcessWorkflowTaskResponse, err error)
- func (p *TaskPoller) PollAndProcessWorkflowTaskWithOptions(opts *PollAndProcessWorkflowTaskOptions) (res PollAndProcessWorkflowTaskResponse, err error)
- type TemporalParams
- type TestCluster
- func (tc *TestCluster) GetAdminClient() AdminClient
- func (tc *TestCluster) GetExecutionManager() persistence.ExecutionManager
- func (tc *TestCluster) GetFrontendClient() FrontendClient
- func (tc *TestCluster) GetHistoryClient() HistoryClient
- func (tc *TestCluster) GetHost() *temporalImpl
- func (tc *TestCluster) GetMatchingClient() matchingservice.MatchingServiceClient
- func (tc *TestCluster) GetOperatorClient() operatorservice.OperatorServiceClient
- func (tc *TestCluster) SetFaultInjectionRate(rate float64)
- func (tc *TestCluster) TearDownCluster() error
- type TestClusterConfig
- type TestClusterFactory
- type TestClusterParams
- type VersioningIntegSuite
- func (s *VersioningIntegSuite) SetupSuite()
- func (s *VersioningIntegSuite) SetupTest()
- func (s *VersioningIntegSuite) TearDownSuite()
- func (s *VersioningIntegSuite) TearDownTest()
- func (s *VersioningIntegSuite) TestBasicVersionUpdate()
- func (s *VersioningIntegSuite) TestDescribeTaskQueue()
- func (s *VersioningIntegSuite) TestDescribeWorkflowExecution()
- func (s *VersioningIntegSuite) TestDisableUserData()
- func (s *VersioningIntegSuite) TestDisableUserData_DLQ()
- func (s *VersioningIntegSuite) TestDisableUserData_DLQ_WithUnload()
- func (s *VersioningIntegSuite) TestDisableUserData_DefaultTasksBecomeUnversioned()
- func (s *VersioningIntegSuite) TestDisableUserData_QueryFails()
- func (s *VersioningIntegSuite) TestDisableUserData_UnversionedWorkflowRuns()
- func (s *VersioningIntegSuite) TestDisableUserData_WorkflowGetsStuck()
- func (s *VersioningIntegSuite) TestDispatchActivity()
- func (s *VersioningIntegSuite) TestDispatchActivityCompatible()
- func (s *VersioningIntegSuite) TestDispatchActivityCrossTQFails()
- func (s *VersioningIntegSuite) TestDispatchActivityEager()
- func (s *VersioningIntegSuite) TestDispatchActivityFail()
- func (s *VersioningIntegSuite) TestDispatchActivityTimeout()
- func (s *VersioningIntegSuite) TestDispatchChildWorkflow()
- func (s *VersioningIntegSuite) TestDispatchChildWorkflowCrossTQFails()
- func (s *VersioningIntegSuite) TestDispatchChildWorkflowUpgrade()
- func (s *VersioningIntegSuite) TestDispatchContinueAsNew()
- func (s *VersioningIntegSuite) TestDispatchCron()
- func (s *VersioningIntegSuite) TestDispatchNewWorkflow()
- func (s *VersioningIntegSuite) TestDispatchNewWorkflowStartWorkerFirst()
- func (s *VersioningIntegSuite) TestDispatchNotUsingVersioning()
- func (s *VersioningIntegSuite) TestDispatchQuery()
- func (s *VersioningIntegSuite) TestDispatchRetry()
- func (s *VersioningIntegSuite) TestDispatchUnversionedRemainsUnversioned()
- func (s *VersioningIntegSuite) TestDispatchUpgradeStopOld()
- func (s *VersioningIntegSuite) TestDispatchUpgradeWait()
- func (s *VersioningIntegSuite) TestLinkToNonexistentCompatibleVersionReturnsNotFound()
- func (s *VersioningIntegSuite) TestMaxTaskQueuesPerBuildIdEnforced()
- func (s *VersioningIntegSuite) TestSeriesOfUpdates()
- func (s *VersioningIntegSuite) TestVersioningChangesPropagate()
- func (s *VersioningIntegSuite) TestVersioningStatePersistsAcrossUnload()
- type WorkerConfig
Constants ¶
const NamespaceCacheRefreshInterval = time.Second
Variables ¶
var ( ErrEncodingIsNotSet = errors.New("payload encoding metadata is not set") ErrEncodingIsNotSupported = errors.New("payload encoding is not supported") )
var TestFlags struct { FrontendAddr string FrontendHTTPAddr string PersistenceType string PersistenceDriver string TestClusterConfigFile string PersistenceFaultInjectionRate float64 }
TestFlags contains the feature flags for functional tests
Functions ¶
func EventBatchesToVersionHistory ¶ added in v1.24.0
func EventBatchesToVersionHistory( versionHistory *historyspb.VersionHistory, eventBatches []*historypb.History, ) (*historyspb.VersionHistory, error)
func NewContext ¶
NewContext create new context with default timeout 90 seconds.
func NewFrontendClient ¶
func NewFrontendClient(connection *grpc.ClientConn) workflowservice.WorkflowServiceClient
NewFrontendClient creates a client to temporal frontend client
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)
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 AdminClient ¶
type AdminClient interface { adminservice.AdminServiceClient }
AdminClient is the interface exposed by admin service client
func NewAdminClient ¶
func NewAdminClient(connection *grpc.ClientConn) AdminClient
NewAdminClient creates a client to temporal admin client
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) 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) TestHTTPAPIBasics_Protojson ¶ added in v1.23.0
func (s *ClientFunctionalSuite) TestHTTPAPIBasics_Protojson()
func (*ClientFunctionalSuite) TestHTTPAPIBasics_ProtojsonPretty ¶ added in v1.23.0
func (s *ClientFunctionalSuite) TestHTTPAPIBasics_ProtojsonPretty()
func (*ClientFunctionalSuite) TestHTTPAPIBasics_Shorthand ¶ added in v1.23.0
func (s *ClientFunctionalSuite) TestHTTPAPIBasics_Shorthand()
func (*ClientFunctionalSuite) TestHTTPAPIBasics_ShorthandPretty ¶ added in v1.23.0
func (s *ClientFunctionalSuite) TestHTTPAPIBasics_ShorthandPretty()
func (*ClientFunctionalSuite) TestHTTPAPIHeaders ¶ added in v1.23.0
func (s *ClientFunctionalSuite) TestHTTPAPIHeaders()
func (*ClientFunctionalSuite) TestHTTPAPIPretty ¶ added in v1.23.0
func (s *ClientFunctionalSuite) TestHTTPAPIPretty()
func (*ClientFunctionalSuite) TestHTTPAPI_OperatorService_ListSearchAttributes ¶ added in v1.24.0
func (s *ClientFunctionalSuite) TestHTTPAPI_OperatorService_ListSearchAttributes()
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) 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_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_UnhandledCommandAndNewTask ¶ added in v1.23.0
func (s *ClientFunctionalSuite) Test_UnhandledCommandAndNewTask()
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.
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) 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 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 FrontendClient ¶
type FrontendClient interface { workflowservice.WorkflowServiceClient }
FrontendClient is the interface exposed by frontend service client
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) 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) TestBufferedEvents ¶ added in v1.23.0
func (s *FunctionalSuite) TestBufferedEvents()
func (*FunctionalSuite) TestBufferedEventsOutOfOrder ¶ added in v1.23.0
func (s *FunctionalSuite) TestBufferedEventsOutOfOrder()
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_Timeout ¶ added in v1.23.0
func (s *FunctionalSuite) TestContinueAsNewRun_Timeout()
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) 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) 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) TestResetWorkflow_ReapplyAll ¶ added in v1.23.0
func (s *FunctionalSuite) TestResetWorkflow_ReapplyAll()
func (*FunctionalSuite) TestResetWorkflow_ReapplyBufferAll ¶ added in v1.23.0
func (s *FunctionalSuite) TestResetWorkflow_ReapplyBufferAll()
func (*FunctionalSuite) TestResetWorkflow_ReapplyBufferNone ¶ added in v1.23.0
func (s *FunctionalSuite) TestResetWorkflow_ReapplyBufferNone()
func (*FunctionalSuite) TestResetWorkflow_ReapplyNone ¶ added in v1.23.0
func (s *FunctionalSuite) TestResetWorkflow_ReapplyNone()
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_IDReusePolicy ¶ added in v1.23.0
func (s *FunctionalSuite) TestSignalWithStartWorkflow_IDReusePolicy()
func (*FunctionalSuite) TestSignalWithStartWorkflow_NoWorkflowTaskCreated ¶ added in v1.23.0
func (s *FunctionalSuite) TestSignalWithStartWorkflow_NoWorkflowTaskCreated()
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_TerminateIfRunning ¶ added in v1.23.0
func (s *FunctionalSuite) TestStartWorkflowExecution_TerminateIfRunning()
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_CancelUpdate ¶
func (s *FunctionalSuite) TestUpdateWorkflow_CompleteWorkflow_CancelUpdate()
func (*FunctionalSuite) TestUpdateWorkflow_CompletedSpeculativeWorkflowTask_DeduplicateID ¶ added in v1.23.0
func (s *FunctionalSuite) TestUpdateWorkflow_CompletedSpeculativeWorkflowTask_DeduplicateID()
func (*FunctionalSuite) TestUpdateWorkflow_ConvertScheduledSpeculativeWorkflowTaskToNormal_BecauseOfSignal ¶ added in v1.23.0
func (s *FunctionalSuite) TestUpdateWorkflow_ConvertScheduledSpeculativeWorkflowTaskToNormal_BecauseOfSignal()
func (*FunctionalSuite) TestUpdateWorkflow_ConvertStartedSpeculativeWorkflowTaskToNormal_BecauseOfBufferedSignal ¶ added in v1.23.0
func (s *FunctionalSuite) TestUpdateWorkflow_ConvertStartedSpeculativeWorkflowTaskToNormal_BecauseOfBufferedSignal()
func (*FunctionalSuite) TestUpdateWorkflow_FailSpeculativeWorkflowTask ¶ added in v1.23.0
func (s *FunctionalSuite) TestUpdateWorkflow_FailSpeculativeWorkflowTask()
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_FirstNormalWorkflowTaskUpdateLost_BecauseOfShardMove ¶ added in v1.23.0
func (s *FunctionalSuite) TestUpdateWorkflow_FirstNormalWorkflowTaskUpdateLost_BecauseOfShardMove()
func (*FunctionalSuite) TestUpdateWorkflow_NewNormalFromStartedWorkflowTask_Rejected ¶ added in v1.23.0
func (s *FunctionalSuite) TestUpdateWorkflow_NewNormalFromStartedWorkflowTask_Rejected()
func (*FunctionalSuite) TestUpdateWorkflow_NewNormalWorkflowTask_AcceptComplete ¶ added in v1.23.0
func (s *FunctionalSuite) TestUpdateWorkflow_NewNormalWorkflowTask_AcceptComplete()
func (*FunctionalSuite) TestUpdateWorkflow_NewNormalWorkflowTask_Reject ¶ added in v1.23.0
func (s *FunctionalSuite) TestUpdateWorkflow_NewNormalWorkflowTask_Reject()
func (*FunctionalSuite) TestUpdateWorkflow_NewScheduledSpeculativeWorkflowTaskLost_BecauseOfShardMove ¶ added in v1.23.0
func (s *FunctionalSuite) TestUpdateWorkflow_NewScheduledSpeculativeWorkflowTaskLost_BecauseOfShardMove()
func (*FunctionalSuite) TestUpdateWorkflow_NewSpeculativeFromStartedWorkflowTask_Rejected ¶ added in v1.23.0
func (s *FunctionalSuite) TestUpdateWorkflow_NewSpeculativeFromStartedWorkflowTask_Rejected()
func (*FunctionalSuite) TestUpdateWorkflow_NewSpeculativeWorkflowTask_AcceptComplete ¶ added in v1.23.0
func (s *FunctionalSuite) TestUpdateWorkflow_NewSpeculativeWorkflowTask_AcceptComplete()
func (*FunctionalSuite) TestUpdateWorkflow_NewSpeculativeWorkflowTask_Reject ¶ added in v1.23.0
func (s *FunctionalSuite) TestUpdateWorkflow_NewSpeculativeWorkflowTask_Reject()
func (*FunctionalSuite) TestUpdateWorkflow_NewSpeculativeWorkflowTask_WorkerSkippedProcessing_RejectByServer ¶ added in v1.24.0
func (s *FunctionalSuite) TestUpdateWorkflow_NewSpeculativeWorkflowTask_WorkerSkippedProcessing_RejectByServer()
func (*FunctionalSuite) TestUpdateWorkflow_NewStartedSpeculativeWorkflowTaskLost_BecauseOfShardMove ¶ added in v1.23.0
func (s *FunctionalSuite) TestUpdateWorkflow_NewStartedSpeculativeWorkflowTaskLost_BecauseOfShardMove()
func (*FunctionalSuite) TestUpdateWorkflow_NewStickySpeculativeWorkflowTask_AcceptComplete ¶ added in v1.23.0
func (s *FunctionalSuite) TestUpdateWorkflow_NewStickySpeculativeWorkflowTask_AcceptComplete()
func (*FunctionalSuite) TestUpdateWorkflow_NewStickySpeculativeWorkflowTask_AcceptComplete_StickyWorkerUnavailable ¶ added in v1.23.0
func (s *FunctionalSuite) TestUpdateWorkflow_NewStickySpeculativeWorkflowTask_AcceptComplete_StickyWorkerUnavailable()
func (*FunctionalSuite) TestUpdateWorkflow_NormalScheduledWorkflowTask_AcceptComplete ¶ added in v1.23.0
func (s *FunctionalSuite) TestUpdateWorkflow_NormalScheduledWorkflowTask_AcceptComplete()
func (*FunctionalSuite) TestUpdateWorkflow_ScheduleToStartTimeoutSpeculativeWorkflowTask ¶ added in v1.23.0
func (s *FunctionalSuite) TestUpdateWorkflow_ScheduleToStartTimeoutSpeculativeWorkflowTask()
func (*FunctionalSuite) TestUpdateWorkflow_ScheduleToStartTimeoutSpeculativeWorkflowTask_NormalTaskQueue ¶ added in v1.23.0
func (s *FunctionalSuite) TestUpdateWorkflow_ScheduleToStartTimeoutSpeculativeWorkflowTask_NormalTaskQueue()
func (*FunctionalSuite) TestUpdateWorkflow_ScheduledSpeculativeWorkflowTask_DeduplicateID ¶ added in v1.23.0
func (s *FunctionalSuite) TestUpdateWorkflow_ScheduledSpeculativeWorkflowTask_DeduplicateID()
func (*FunctionalSuite) TestUpdateWorkflow_ScheduledSpeculativeWorkflowTask_TerminateWorkflow ¶ added in v1.23.0
func (s *FunctionalSuite) TestUpdateWorkflow_ScheduledSpeculativeWorkflowTask_TerminateWorkflow()
func (*FunctionalSuite) TestUpdateWorkflow_SpeculativeWorkflowTask_Heartbeat ¶ added in v1.23.0
func (s *FunctionalSuite) TestUpdateWorkflow_SpeculativeWorkflowTask_Heartbeat()
func (*FunctionalSuite) TestUpdateWorkflow_StaleSpeculativeWorkflowTask_ClearMutableState_Accepted ¶ added in v1.23.0
func (s *FunctionalSuite) TestUpdateWorkflow_StaleSpeculativeWorkflowTask_ClearMutableState_Accepted()
func (*FunctionalSuite) TestUpdateWorkflow_StaleSpeculativeWorkflowTask_CloseShard_DifferentStartedId_Rejected ¶ added in v1.23.0
func (s *FunctionalSuite) TestUpdateWorkflow_StaleSpeculativeWorkflowTask_CloseShard_DifferentStartedId_Rejected()
func (*FunctionalSuite) TestUpdateWorkflow_StaleSpeculativeWorkflowTask_CloseShard_SameStartedId_SameUpdateId_Accepted ¶ added in v1.23.0
func (s *FunctionalSuite) TestUpdateWorkflow_StaleSpeculativeWorkflowTask_CloseShard_SameStartedId_SameUpdateId_Accepted()
func (*FunctionalSuite) TestUpdateWorkflow_StaleSpeculativeWorkflowTask_SameStartedId_DifferentUpdateId_Rejected ¶ added in v1.23.0
func (s *FunctionalSuite) TestUpdateWorkflow_StaleSpeculativeWorkflowTask_SameStartedId_DifferentUpdateId_Rejected()
func (*FunctionalSuite) TestUpdateWorkflow_StartToCloseTimeoutSpeculativeWorkflowTask ¶ added in v1.23.0
func (s *FunctionalSuite) TestUpdateWorkflow_StartToCloseTimeoutSpeculativeWorkflowTask()
func (*FunctionalSuite) TestUpdateWorkflow_StartedSpeculativeWorkflowTask_DeduplicateID ¶ added in v1.23.0
func (s *FunctionalSuite) TestUpdateWorkflow_StartedSpeculativeWorkflowTask_DeduplicateID()
func (*FunctionalSuite) TestUpdateWorkflow_StartedSpeculativeWorkflowTask_TerminateWorkflow ¶ added in v1.23.0
func (s *FunctionalSuite) TestUpdateWorkflow_StartedSpeculativeWorkflowTask_TerminateWorkflow()
func (*FunctionalSuite) TestUpdateWorkflow_ValidateWorkerMessages ¶ added in v1.23.0
func (s *FunctionalSuite) TestUpdateWorkflow_ValidateWorkerMessages()
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()
func (*FunctionalSuite) Test_DeleteWorkflowExecution_Competed ¶ added in v1.23.0
func (s *FunctionalSuite) Test_DeleteWorkflowExecution_Competed()
func (*FunctionalSuite) Test_DeleteWorkflowExecution_Running ¶ added in v1.23.0
func (s *FunctionalSuite) Test_DeleteWorkflowExecution_Running()
func (*FunctionalSuite) Test_DeleteWorkflowExecution_RunningWithTerminate ¶ added in v1.23.0
func (s *FunctionalSuite) Test_DeleteWorkflowExecution_RunningWithTerminate()
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)
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 HistoryClient ¶
type HistoryClient interface { historyservice.HistoryServiceClient }
HistoryClient is the interface exposed by history service client
func NewHistoryClient ¶
func NewHistoryClient(connection *grpc.ClientConn) HistoryClient
NewHistoryClient creates a client to temporal history service client
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 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 { *require.Assertions 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) 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 SomeJSONStruct ¶ added in v1.23.0
type SomeJSONStruct struct {
SomeField string `json:"someField"`
}
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 { Engine FrontendClient 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() AdminClient
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() FrontendClient
GetFrontendClient returns a frontend client from the test cluster
func (*TestCluster) GetHistoryClient ¶
func (tc *TestCluster) GetHistoryClient() HistoryClient
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) SetFaultInjectionRate ¶
func (tc *TestCluster) SetFaultInjectionRate(rate float64)
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 *require.Assertions 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) TestBasicVersionUpdate ¶ added in v1.23.0
func (s *VersioningIntegSuite) TestBasicVersionUpdate()
func (*VersioningIntegSuite) TestDescribeTaskQueue ¶ added in v1.23.0
func (s *VersioningIntegSuite) TestDescribeTaskQueue()
func (*VersioningIntegSuite) TestDescribeWorkflowExecution ¶ added in v1.23.0
func (s *VersioningIntegSuite) TestDescribeWorkflowExecution()
func (*VersioningIntegSuite) TestDisableUserData ¶ added in v1.23.0
func (s *VersioningIntegSuite) TestDisableUserData()
func (*VersioningIntegSuite) TestDisableUserData_DLQ ¶ added in v1.23.0
func (s *VersioningIntegSuite) TestDisableUserData_DLQ()
func (*VersioningIntegSuite) TestDisableUserData_DLQ_WithUnload ¶ added in v1.23.0
func (s *VersioningIntegSuite) TestDisableUserData_DLQ_WithUnload()
func (*VersioningIntegSuite) TestDisableUserData_DefaultTasksBecomeUnversioned ¶ added in v1.23.0
func (s *VersioningIntegSuite) TestDisableUserData_DefaultTasksBecomeUnversioned()
func (*VersioningIntegSuite) TestDisableUserData_QueryFails ¶ added in v1.23.0
func (s *VersioningIntegSuite) TestDisableUserData_QueryFails()
func (*VersioningIntegSuite) TestDisableUserData_UnversionedWorkflowRuns ¶ added in v1.23.0
func (s *VersioningIntegSuite) TestDisableUserData_UnversionedWorkflowRuns()
func (*VersioningIntegSuite) TestDisableUserData_WorkflowGetsStuck ¶ added in v1.23.0
func (s *VersioningIntegSuite) TestDisableUserData_WorkflowGetsStuck()
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) TestDispatchActivityEager ¶ added in v1.23.0
func (s *VersioningIntegSuite) TestDispatchActivityEager()
func (*VersioningIntegSuite) TestDispatchActivityFail ¶ added in v1.23.0
func (s *VersioningIntegSuite) TestDispatchActivityFail()
func (*VersioningIntegSuite) TestDispatchActivityTimeout ¶ added in v1.23.0
func (s *VersioningIntegSuite) TestDispatchActivityTimeout()
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) TestDispatchChildWorkflowUpgrade ¶ added in v1.23.0
func (s *VersioningIntegSuite) TestDispatchChildWorkflowUpgrade()
func (*VersioningIntegSuite) TestDispatchContinueAsNew ¶ added in v1.23.0
func (s *VersioningIntegSuite) TestDispatchContinueAsNew()
func (*VersioningIntegSuite) TestDispatchCron ¶ added in v1.23.0
func (s *VersioningIntegSuite) TestDispatchCron()
func (*VersioningIntegSuite) TestDispatchNewWorkflow ¶ added in v1.23.0
func (s *VersioningIntegSuite) TestDispatchNewWorkflow()
func (*VersioningIntegSuite) TestDispatchNewWorkflowStartWorkerFirst ¶ added in v1.23.0
func (s *VersioningIntegSuite) TestDispatchNewWorkflowStartWorkerFirst()
func (*VersioningIntegSuite) TestDispatchNotUsingVersioning ¶ added in v1.23.0
func (s *VersioningIntegSuite) TestDispatchNotUsingVersioning()
func (*VersioningIntegSuite) TestDispatchQuery ¶ added in v1.23.0
func (s *VersioningIntegSuite) TestDispatchQuery()
func (*VersioningIntegSuite) TestDispatchRetry ¶ added in v1.23.0
func (s *VersioningIntegSuite) TestDispatchRetry()
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) TestDispatchUpgradeWait ¶ added in v1.23.0
func (s *VersioningIntegSuite) TestDispatchUpgradeWait()
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) TestSeriesOfUpdates ¶ added in v1.23.0
func (s *VersioningIntegSuite) TestSeriesOfUpdates()
func (*VersioningIntegSuite) TestVersioningChangesPropagate ¶ added in v1.23.0
func (s *VersioningIntegSuite) TestVersioningChangesPropagate()
func (*VersioningIntegSuite) TestVersioningStatePersistsAcrossUnload ¶ added in v1.23.0
func (s *VersioningIntegSuite) TestVersioningStatePersistsAcrossUnload()
type WorkerConfig ¶
WorkerConfig is the config for enabling/disabling Temporal worker
Source Files ¶
- acquire_shard.go
- activity.go
- add_tasks.go
- admin.go
- advanced_visibility.go
- archival.go
- cancel_workflow.go
- child_workflow.go
- client.go
- client_suite.go
- context.go
- continue_as_new.go
- cron.go
- describe.go
- dlq.go
- dynamicconfig.go
- eager_workflow_start.go
- flag.go
- functional.go
- functional_test_base.go
- functional_test_base_suite.go
- gethistory.go
- http_api.go
- max_buffered_event.go
- namespace_delete.go
- namespace_interceptor.go
- onebox.go
- purge_dlq_tasks_api.go
- query_workflow.go
- relay_task.go
- reset_workflow.go
- schedule.go
- signal_workflow.go
- simple_monitor.go
- simple_service_resolver.go
- sizelimit.go
- stickytq.go
- taskpoller.go
- test_cluster.go
- test_search_attribute_mapper.go
- tls.go
- transient_task.go
- update_workflow.go
- user_timers.go
- utils.go
- versioning.go
- workflow.go
- workflow_buffered_events.go
- workflow_delete_execution.go
- workflow_failures.go
- workflow_memo.go
- workflow_task.go
- workflow_timer.go
- workflow_visibility.go