persistencetests

package
v0.8.2 Latest Latest
Warning

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

Go to latest
Published: Aug 13, 2019 License: MIT Imports: 28 Imported by: 1

Documentation

Index

Constants

View Source
const TimePrecision = 2 * time.Millisecond

TimePrecision is needed to account for database timestamp precision. Cassandra only provides milliseconds timestamp precision, so we need to use tolerance when doing comparison

Variables

This section is empty.

Functions

func GenerateRandomDBName

func GenerateRandomDBName(n int) string

GenerateRandomDBName helper

Types

type ExecutionManagerSuite

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

ExecutionManagerSuite contains matching persistence tests

func (*ExecutionManagerSuite) SetupSuite

func (s *ExecutionManagerSuite) SetupSuite()

SetupSuite implementation

func (*ExecutionManagerSuite) SetupTest

func (s *ExecutionManagerSuite) SetupTest()

SetupTest implementation

func (*ExecutionManagerSuite) TearDownSuite

func (s *ExecutionManagerSuite) TearDownSuite()

TearDownSuite implementation

func (*ExecutionManagerSuite) TestCancelTransferTaskTasks

func (s *ExecutionManagerSuite) TestCancelTransferTaskTasks()

TestCancelTransferTaskTasks test

func (*ExecutionManagerSuite) TestConflictResolveWorkflowExecutionCurrentIsNotSelf added in v0.7.0

func (s *ExecutionManagerSuite) TestConflictResolveWorkflowExecutionCurrentIsNotSelf()

TestConflictResolveWorkflowExecutionCurrentIsNotSelf test

func (*ExecutionManagerSuite) TestConflictResolveWorkflowExecutionCurrentIsSelf added in v0.7.0

func (s *ExecutionManagerSuite) TestConflictResolveWorkflowExecutionCurrentIsSelf()

TestConflictResolveWorkflowExecutionCurrentIsSelf test

func (*ExecutionManagerSuite) TestConflictResolveWorkflowExecutionMismatch added in v0.7.0

func (s *ExecutionManagerSuite) TestConflictResolveWorkflowExecutionMismatch()

TestConflictResolveWorkflowExecutionMismatch test

func (*ExecutionManagerSuite) TestContinueAsNew

func (s *ExecutionManagerSuite) TestContinueAsNew()

TestContinueAsNew test

func (*ExecutionManagerSuite) TestCreateGetShardBackfill

func (s *ExecutionManagerSuite) TestCreateGetShardBackfill()

TestCreateGetShardBackfill test

func (*ExecutionManagerSuite) TestCreateGetUpdateGetShard

func (s *ExecutionManagerSuite) TestCreateGetUpdateGetShard()

TestCreateGetUpdateGetShard test

func (*ExecutionManagerSuite) TestCreateWorkflowExecutionBrandNew

func (s *ExecutionManagerSuite) TestCreateWorkflowExecutionBrandNew()

TestCreateWorkflowExecutionBrandNew test

func (*ExecutionManagerSuite) TestCreateWorkflowExecutionConcurrentCreate

func (s *ExecutionManagerSuite) TestCreateWorkflowExecutionConcurrentCreate()

TestCreateWorkflowExecutionConcurrentCreate test

func (*ExecutionManagerSuite) TestCreateWorkflowExecutionRunIDReuseWithReplication

func (s *ExecutionManagerSuite) TestCreateWorkflowExecutionRunIDReuseWithReplication()

TestCreateWorkflowExecutionRunIDReuseWithReplication test

func (*ExecutionManagerSuite) TestCreateWorkflowExecutionRunIDReuseWithoutReplication

func (s *ExecutionManagerSuite) TestCreateWorkflowExecutionRunIDReuseWithoutReplication()

TestCreateWorkflowExecutionRunIDReuseWithoutReplication test

func (*ExecutionManagerSuite) TestCreateWorkflowExecutionStateCloseStatus added in v0.5.9

func (s *ExecutionManagerSuite) TestCreateWorkflowExecutionStateCloseStatus()

TestCreateWorkflowExecutionStateCloseStatus test

func (*ExecutionManagerSuite) TestDeleteCurrentWorkflow

func (s *ExecutionManagerSuite) TestDeleteCurrentWorkflow()

TestDeleteCurrentWorkflow test

func (*ExecutionManagerSuite) TestDeleteWorkflow

func (s *ExecutionManagerSuite) TestDeleteWorkflow()

TestDeleteWorkflow test

func (*ExecutionManagerSuite) TestGetCurrentWorkflow

func (s *ExecutionManagerSuite) TestGetCurrentWorkflow()

TestGetCurrentWorkflow test

func (*ExecutionManagerSuite) TestGetWorkflow

func (s *ExecutionManagerSuite) TestGetWorkflow()

TestGetWorkflow test

func (*ExecutionManagerSuite) TestPersistenceStartWorkflow

func (s *ExecutionManagerSuite) TestPersistenceStartWorkflow()

TestPersistenceStartWorkflow test

func (*ExecutionManagerSuite) TestPersistenceStartWorkflowWithReplicationState

func (s *ExecutionManagerSuite) TestPersistenceStartWorkflowWithReplicationState()

TestPersistenceStartWorkflowWithReplicationState test

func (*ExecutionManagerSuite) TestReplicationTasks

func (s *ExecutionManagerSuite) TestReplicationTasks()

TestReplicationTasks test

func (*ExecutionManagerSuite) TestReplicationTransferTaskTasks

func (s *ExecutionManagerSuite) TestReplicationTransferTaskTasks()

TestReplicationTransferTaskTasks test

func (*ExecutionManagerSuite) TestSignalTransferTaskTasks

func (s *ExecutionManagerSuite) TestSignalTransferTaskTasks()

TestSignalTransferTaskTasks test

func (*ExecutionManagerSuite) TestTimerTasksComplete

func (s *ExecutionManagerSuite) TestTimerTasksComplete()

TestTimerTasksComplete test

func (*ExecutionManagerSuite) TestTimerTasksRangeComplete

func (s *ExecutionManagerSuite) TestTimerTasksRangeComplete()

TestTimerTasksRangeComplete test

func (*ExecutionManagerSuite) TestTransferTasksComplete

func (s *ExecutionManagerSuite) TestTransferTasksComplete()

TestTransferTasksComplete test

func (*ExecutionManagerSuite) TestTransferTasksRangeComplete

func (s *ExecutionManagerSuite) TestTransferTasksRangeComplete()

TestTransferTasksRangeComplete test

func (*ExecutionManagerSuite) TestTransferTasksThroughUpdate

func (s *ExecutionManagerSuite) TestTransferTasksThroughUpdate()

TestTransferTasksThroughUpdate test

func (*ExecutionManagerSuite) TestUpdateAndClearBufferedEvents

func (s *ExecutionManagerSuite) TestUpdateAndClearBufferedEvents()

TestUpdateAndClearBufferedEvents test

func (*ExecutionManagerSuite) TestUpdateDeleteWorkflow added in v0.5.3

func (s *ExecutionManagerSuite) TestUpdateDeleteWorkflow()

TestUpdateDeleteWorkflow mocks the timer behavoir to clean up workflow.

func (*ExecutionManagerSuite) TestUpdateWorkflow

func (s *ExecutionManagerSuite) TestUpdateWorkflow()

TestUpdateWorkflow test

func (*ExecutionManagerSuite) TestUpdateWorkflowExecutionStateCloseStatus added in v0.5.9

func (s *ExecutionManagerSuite) TestUpdateWorkflowExecutionStateCloseStatus()

TestUpdateWorkflowExecutionStateCloseStatus test

func (*ExecutionManagerSuite) TestWorkflowMutableStateActivities

func (s *ExecutionManagerSuite) TestWorkflowMutableStateActivities()

TestWorkflowMutableStateActivities test

func (*ExecutionManagerSuite) TestWorkflowMutableStateChildExecutions

func (s *ExecutionManagerSuite) TestWorkflowMutableStateChildExecutions()

TestWorkflowMutableStateChildExecutions test

func (*ExecutionManagerSuite) TestWorkflowMutableStateInfo

func (s *ExecutionManagerSuite) TestWorkflowMutableStateInfo()

TestWorkflowMutableStateInfo test

func (*ExecutionManagerSuite) TestWorkflowMutableStateRequestCancel

func (s *ExecutionManagerSuite) TestWorkflowMutableStateRequestCancel()

TestWorkflowMutableStateRequestCancel test

func (*ExecutionManagerSuite) TestWorkflowMutableStateSignalInfo

func (s *ExecutionManagerSuite) TestWorkflowMutableStateSignalInfo()

TestWorkflowMutableStateSignalInfo test

func (*ExecutionManagerSuite) TestWorkflowMutableStateSignalRequested

func (s *ExecutionManagerSuite) TestWorkflowMutableStateSignalRequested()

TestWorkflowMutableStateSignalRequested test

func (*ExecutionManagerSuite) TestWorkflowMutableStateTimers

func (s *ExecutionManagerSuite) TestWorkflowMutableStateTimers()

TestWorkflowMutableStateTimers test

func (*ExecutionManagerSuite) TestWorkflowReplicationState

func (s *ExecutionManagerSuite) TestWorkflowReplicationState()

TestWorkflowReplicationState test

type ExecutionManagerSuiteForEventsV2 added in v0.5.0

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

ExecutionManagerSuiteForEventsV2 contains matching persistence tests

func (*ExecutionManagerSuiteForEventsV2) SetupSuite added in v0.5.0

func (s *ExecutionManagerSuiteForEventsV2) SetupSuite()

SetupSuite implementation

func (*ExecutionManagerSuiteForEventsV2) SetupTest added in v0.5.0

func (s *ExecutionManagerSuiteForEventsV2) SetupTest()

SetupTest implementation

func (*ExecutionManagerSuiteForEventsV2) TearDownSuite added in v0.5.0

func (s *ExecutionManagerSuiteForEventsV2) TearDownSuite()

TearDownSuite implementation

func (*ExecutionManagerSuiteForEventsV2) TestContinueAsNew added in v0.5.0

func (s *ExecutionManagerSuiteForEventsV2) TestContinueAsNew()

TestContinueAsNew test

func (*ExecutionManagerSuiteForEventsV2) TestWorkflowCreation added in v0.5.0

func (s *ExecutionManagerSuiteForEventsV2) TestWorkflowCreation()

TestWorkflowCreation test

func (*ExecutionManagerSuiteForEventsV2) TestWorkflowResetNoCurrNoReplicate added in v0.5.2

func (s *ExecutionManagerSuiteForEventsV2) TestWorkflowResetNoCurrNoReplicate()

TestWorkflowResetNoCurrNoReplicate test

func (*ExecutionManagerSuiteForEventsV2) TestWorkflowResetNoCurrWithReplicate added in v0.5.2

func (s *ExecutionManagerSuiteForEventsV2) TestWorkflowResetNoCurrWithReplicate()

TestWorkflowResetNoCurrWithReplicate test

func (*ExecutionManagerSuiteForEventsV2) TestWorkflowResetWithCurrWithReplicate added in v0.5.2

func (s *ExecutionManagerSuiteForEventsV2) TestWorkflowResetWithCurrWithReplicate()

TestWorkflowResetWithCurrWithReplicate test

func (*ExecutionManagerSuiteForEventsV2) TestWorkflowWithReplicationState added in v0.5.0

func (s *ExecutionManagerSuiteForEventsV2) TestWorkflowWithReplicationState()

TestWorkflowWithReplicationState test

type HistoryPerfSuite added in v0.5.0

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

HistoryPerfSuite contains history persistence tests

func (*HistoryPerfSuite) SetupSuite added in v0.5.0

func (s *HistoryPerfSuite) SetupSuite()

SetupSuite implementation

func (*HistoryPerfSuite) SetupTest added in v0.5.0

func (s *HistoryPerfSuite) SetupTest()

SetupTest implementation

func (*HistoryPerfSuite) TearDownSuite added in v0.5.0

func (s *HistoryPerfSuite) TearDownSuite()

TearDownSuite implementation

func (*HistoryPerfSuite) TestPerf added in v0.5.0

func (s *HistoryPerfSuite) TestPerf()

TestPerf is the test entry === RUN TestCassandraHistoryPerformance/TestPerf appendV1-batch size: 1 , time eslapsed: 3454.098 milliseconds appendV2-batch size: 1 , time eslapsed: 1022.303 milliseconds appendV1-batch size: 2 , time eslapsed: 1579.684 milliseconds appendV2-batch size: 2 , time eslapsed: 457.522 milliseconds appendV1-batch size: 5 , time eslapsed: 627.084 milliseconds appendV2-batch size: 5 , time eslapsed: 191.902 milliseconds appendV1-batch size: 10 , time eslapsed: 324.444 milliseconds appendV2-batch size: 10 , time eslapsed: 106.51 milliseconds appendV1-batch size: 100 , time eslapsed: 45.617 milliseconds appendV2-batch size: 100 , time eslapsed: 18.488 milliseconds appendV1-batch size: 500 , time eslapsed: 28.697 milliseconds appendV2-batch size: 500 , time eslapsed: 14.168 milliseconds appendV1-batch size: 1000 , time eslapsed: 28.188 milliseconds appendV2-batch size: 1000 , time eslapsed: 12.643 milliseconds readV1-batch size: 1 , time eslapsed: 31.842 milliseconds readv2-batch size: 1 , time eslapsed: 23.431 milliseconds readV1-batch size: 2 , time eslapsed: 26.428 milliseconds readv2-batch size: 2 , time eslapsed: 19.373 milliseconds readV1-batch size: 5 , time eslapsed: 18.031 milliseconds readv2-batch size: 5 , time eslapsed: 11.139 milliseconds readV1-batch size: 10 , time eslapsed: 13.673 milliseconds readv2-batch size: 10 , time eslapsed: 8.602 milliseconds readV1-batch size: 100 , time eslapsed: 11.497 milliseconds readv2-batch size: 100 , time eslapsed: 6.315 milliseconds readV1-batch size: 500 , time eslapsed: 11.975 milliseconds readv2-batch size: 500 , time eslapsed: 5.927 milliseconds readV1-batch size: 1000 , time eslapsed: 9.965 milliseconds readv2-batch size: 1000 , time eslapsed: 5.758 milliseconds time="2018-10-21T19:33:02-07:00" level=info msg="dropped namespace" keyspace=test_wofofrfwrw --- PASS: TestCassandraHistoryPerformance (10.07s)

--- PASS: TestCassandraHistoryPerformance/TestPerf (8.13s)

PASS

type HistoryPersistenceSuite

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

HistoryPersistenceSuite contains history persistence tests

func (*HistoryPersistenceSuite) AppendHistoryEvents

func (s *HistoryPersistenceSuite) AppendHistoryEvents(domainID string, workflowExecution gen.WorkflowExecution,
	firstEventID, eventBatchVersion int64, rangeID, txID int64, eventsBatch *gen.History, overwrite bool) error

AppendHistoryEvents helper

func (*HistoryPersistenceSuite) DeleteWorkflowExecutionHistory

func (s *HistoryPersistenceSuite) DeleteWorkflowExecutionHistory(domainID string,
	workflowExecution gen.WorkflowExecution) error

DeleteWorkflowExecutionHistory helper

func (*HistoryPersistenceSuite) GetWorkflowExecutionHistory

func (s *HistoryPersistenceSuite) GetWorkflowExecutionHistory(domainID string, workflowExecution gen.WorkflowExecution,
	firstEventID, nextEventID int64, pageSize int, token []byte) (*gen.History, []byte, error)

GetWorkflowExecutionHistory helper

func (*HistoryPersistenceSuite) SetupSuite

func (s *HistoryPersistenceSuite) SetupSuite()

SetupSuite implementation

func (*HistoryPersistenceSuite) SetupTest

func (s *HistoryPersistenceSuite) SetupTest()

SetupTest implementation

func (*HistoryPersistenceSuite) TearDownSuite

func (s *HistoryPersistenceSuite) TearDownSuite()

TearDownSuite implementation

func (*HistoryPersistenceSuite) TestAppendAndGet

func (s *HistoryPersistenceSuite) TestAppendAndGet()

TestAppendAndGet test

func (*HistoryPersistenceSuite) TestAppendAndGetByBatch added in v0.5.0

func (s *HistoryPersistenceSuite) TestAppendAndGetByBatch()

TestAppendAndGetByBatch test

func (*HistoryPersistenceSuite) TestAppendHistoryEvents

func (s *HistoryPersistenceSuite) TestAppendHistoryEvents()

TestAppendHistoryEvents test

func (*HistoryPersistenceSuite) TestDeleteHistoryEvents

func (s *HistoryPersistenceSuite) TestDeleteHistoryEvents()

TestDeleteHistoryEvents test

func (*HistoryPersistenceSuite) TestGetHistoryEvents

func (s *HistoryPersistenceSuite) TestGetHistoryEvents()

TestGetHistoryEvents test

func (*HistoryPersistenceSuite) TestGetHistoryEventsCompatibility

func (s *HistoryPersistenceSuite) TestGetHistoryEventsCompatibility()

TestGetHistoryEventsCompatibility test

func (*HistoryPersistenceSuite) TestOverwriteAndShadowingHistoryEvents

func (s *HistoryPersistenceSuite) TestOverwriteAndShadowingHistoryEvents()

TestOverwriteAndShadowingHistoryEvents test

type HistoryV2PersistenceSuite added in v0.5.0

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

HistoryV2PersistenceSuite contains history persistence tests

func (*HistoryV2PersistenceSuite) SetupSuite added in v0.5.0

func (s *HistoryV2PersistenceSuite) SetupSuite()

SetupSuite implementation

func (*HistoryV2PersistenceSuite) SetupTest added in v0.5.0

func (s *HistoryV2PersistenceSuite) SetupTest()

SetupTest implementation

func (*HistoryV2PersistenceSuite) TearDownSuite added in v0.5.0

func (s *HistoryV2PersistenceSuite) TearDownSuite()

TearDownSuite implementation

func (*HistoryV2PersistenceSuite) TestConcurrentlyCreateAndAppendBranches added in v0.5.0

func (s *HistoryV2PersistenceSuite) TestConcurrentlyCreateAndAppendBranches()

TestConcurrentlyCreateAndAppendBranches test

func (*HistoryV2PersistenceSuite) TestConcurrentlyForkAndAppendBranches added in v0.5.0

func (s *HistoryV2PersistenceSuite) TestConcurrentlyForkAndAppendBranches()

TestConcurrentlyForkAndAppendBranches test

func (*HistoryV2PersistenceSuite) TestGenUUIDs added in v0.5.0

func (s *HistoryV2PersistenceSuite) TestGenUUIDs()

TestGenUUIDs testing uuid.New() can generate unique UUID

func (*HistoryV2PersistenceSuite) TestReadBranchByPagination added in v0.5.7

func (s *HistoryV2PersistenceSuite) TestReadBranchByPagination()

TestReadBranchByPagination test

type MatchingPersistenceSuite

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

MatchingPersistenceSuite contains matching persistence tests

func (*MatchingPersistenceSuite) SetupSuite

func (s *MatchingPersistenceSuite) SetupSuite()

SetupSuite implementation

func (*MatchingPersistenceSuite) SetupTest

func (s *MatchingPersistenceSuite) SetupTest()

SetupTest implementation

func (*MatchingPersistenceSuite) TearDownSuite

func (s *MatchingPersistenceSuite) TearDownSuite()

TearDownSuite implementation

func (*MatchingPersistenceSuite) TestCompleteDecisionTask

func (s *MatchingPersistenceSuite) TestCompleteDecisionTask()

TestCompleteDecisionTask test

func (*MatchingPersistenceSuite) TestCompleteTasksLessThan added in v0.5.4

func (s *MatchingPersistenceSuite) TestCompleteTasksLessThan()

TestCompleteTasksLessThan test

func (*MatchingPersistenceSuite) TestCreateTask

func (s *MatchingPersistenceSuite) TestCreateTask()

TestCreateTask test

func (*MatchingPersistenceSuite) TestGetDecisionTasks

func (s *MatchingPersistenceSuite) TestGetDecisionTasks()

TestGetDecisionTasks test

func (*MatchingPersistenceSuite) TestGetTasksWithNoMaxReadLevel added in v0.5.7

func (s *MatchingPersistenceSuite) TestGetTasksWithNoMaxReadLevel()

TestGetTasksWithNoMaxReadLevel test

func (*MatchingPersistenceSuite) TestLeaseAndUpdateTaskList

func (s *MatchingPersistenceSuite) TestLeaseAndUpdateTaskList()

TestLeaseAndUpdateTaskList test

func (*MatchingPersistenceSuite) TestLeaseAndUpdateTaskListSticky

func (s *MatchingPersistenceSuite) TestLeaseAndUpdateTaskListSticky()

TestLeaseAndUpdateTaskListSticky test

func (*MatchingPersistenceSuite) TestListWithMultipleTaskList added in v0.5.4

func (s *MatchingPersistenceSuite) TestListWithMultipleTaskList()

TestListWithMultipleTaskList test

func (*MatchingPersistenceSuite) TestListWithOneTaskList added in v0.5.4

func (s *MatchingPersistenceSuite) TestListWithOneTaskList()

TestListWithOneTaskList test

type MetadataPersistenceSuite

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

MetadataPersistenceSuite contains metadata persistence tests

func (*MetadataPersistenceSuite) CreateDomain

func (m *MetadataPersistenceSuite) CreateDomain(info *p.DomainInfo, config *p.DomainConfig,
	replicationConfig *p.DomainReplicationConfig, isGlobaldomain bool, configVersion int64, failoverVersion int64) (*p.CreateDomainResponse, error)

CreateDomain helper

func (*MetadataPersistenceSuite) DeleteDomain

func (m *MetadataPersistenceSuite) DeleteDomain(id, name string) error

DeleteDomain helper

func (*MetadataPersistenceSuite) GetDomain

func (m *MetadataPersistenceSuite) GetDomain(id, name string) (*p.GetDomainResponse, error)

GetDomain helper

func (*MetadataPersistenceSuite) SetupSuite

func (m *MetadataPersistenceSuite) SetupSuite()

SetupSuite implementation

func (*MetadataPersistenceSuite) SetupTest

func (m *MetadataPersistenceSuite) SetupTest()

SetupTest implementation

func (*MetadataPersistenceSuite) TearDownSuite

func (m *MetadataPersistenceSuite) TearDownSuite()

TearDownSuite implementation

func (*MetadataPersistenceSuite) TestConcurrentCreateDomain

func (m *MetadataPersistenceSuite) TestConcurrentCreateDomain()

TestConcurrentCreateDomain test

func (*MetadataPersistenceSuite) TestConcurrentUpdateDomain

func (m *MetadataPersistenceSuite) TestConcurrentUpdateDomain()

TestConcurrentUpdateDomain test

func (*MetadataPersistenceSuite) TestCreateDomain

func (m *MetadataPersistenceSuite) TestCreateDomain()

TestCreateDomain test

func (*MetadataPersistenceSuite) TestDeleteDomain

func (m *MetadataPersistenceSuite) TestDeleteDomain()

TestDeleteDomain test

func (*MetadataPersistenceSuite) TestGetDomain

func (m *MetadataPersistenceSuite) TestGetDomain()

TestGetDomain test

func (*MetadataPersistenceSuite) TestUpdateDomain

func (m *MetadataPersistenceSuite) TestUpdateDomain()

TestUpdateDomain test

func (*MetadataPersistenceSuite) UpdateDomain

func (m *MetadataPersistenceSuite) UpdateDomain(info *p.DomainInfo, config *p.DomainConfig, replicationConfig *p.DomainReplicationConfig,
	configVersion int64, failoverVersion int64, dbVersion int64) error

UpdateDomain helper

type MetadataPersistenceSuiteV2

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

MetadataPersistenceSuiteV2 is test of the V2 version of metadata persistence

func (*MetadataPersistenceSuiteV2) CreateDomain

func (m *MetadataPersistenceSuiteV2) CreateDomain(info *p.DomainInfo, config *p.DomainConfig,
	replicationConfig *p.DomainReplicationConfig, isGlobaldomain bool, configVersion int64, failoverVersion int64) (*p.CreateDomainResponse, error)

CreateDomain helper method

func (*MetadataPersistenceSuiteV2) DeleteDomain

func (m *MetadataPersistenceSuiteV2) DeleteDomain(id, name string) error

DeleteDomain helper method

func (*MetadataPersistenceSuiteV2) GetDomain

func (m *MetadataPersistenceSuiteV2) GetDomain(id, name string) (*p.GetDomainResponse, error)

GetDomain helper method

func (*MetadataPersistenceSuiteV2) ListDomains

func (m *MetadataPersistenceSuiteV2) ListDomains(pageSize int, pageToken []byte) (*p.ListDomainsResponse, error)

ListDomains helper method

func (*MetadataPersistenceSuiteV2) SetupSuite

func (m *MetadataPersistenceSuiteV2) SetupSuite()

SetupSuite implementation

func (*MetadataPersistenceSuiteV2) SetupTest

func (m *MetadataPersistenceSuiteV2) SetupTest()

SetupTest implementation

func (*MetadataPersistenceSuiteV2) TearDownSuite

func (m *MetadataPersistenceSuiteV2) TearDownSuite()

TearDownSuite implementation

func (*MetadataPersistenceSuiteV2) TearDownTest

func (m *MetadataPersistenceSuiteV2) TearDownTest()

TearDownTest implementation

func (*MetadataPersistenceSuiteV2) TestConcurrentCreateDomain

func (m *MetadataPersistenceSuiteV2) TestConcurrentCreateDomain()

TestConcurrentCreateDomain test

func (*MetadataPersistenceSuiteV2) TestConcurrentUpdateDomain

func (m *MetadataPersistenceSuiteV2) TestConcurrentUpdateDomain()

TestConcurrentUpdateDomain test

func (*MetadataPersistenceSuiteV2) TestCreateDomain

func (m *MetadataPersistenceSuiteV2) TestCreateDomain()

TestCreateDomain test

func (*MetadataPersistenceSuiteV2) TestDeleteDomain

func (m *MetadataPersistenceSuiteV2) TestDeleteDomain()

TestDeleteDomain test

func (*MetadataPersistenceSuiteV2) TestGetDomain

func (m *MetadataPersistenceSuiteV2) TestGetDomain()

TestGetDomain test

func (*MetadataPersistenceSuiteV2) TestListDomains

func (m *MetadataPersistenceSuiteV2) TestListDomains()

TestListDomains test

func (*MetadataPersistenceSuiteV2) TestUpdateDomain

func (m *MetadataPersistenceSuiteV2) TestUpdateDomain()

TestUpdateDomain test

func (*MetadataPersistenceSuiteV2) UpdateDomain

func (m *MetadataPersistenceSuiteV2) UpdateDomain(info *p.DomainInfo, config *p.DomainConfig, replicationConfig *p.DomainReplicationConfig,
	configVersion int64, failoverVersion int64, failoverNotificationVersion int64, notificationVersion int64) error

UpdateDomain helper method

type PersistenceTestCluster

type PersistenceTestCluster interface {
	DatabaseName() string
	SetupTestDatabase()
	TearDownTestDatabase()
	CreateSession()
	DropDatabase()
	Config() config.Persistence
	LoadSchema(fileNames []string, schemaDir string)
	LoadVisibilitySchema(fileNames []string, schemaDir string)
}

PersistenceTestCluster exposes management operations on a database

type ShardPersistenceSuite

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

ShardPersistenceSuite contains shard persistence tests

func (*ShardPersistenceSuite) SetupSuite

func (s *ShardPersistenceSuite) SetupSuite()

SetupSuite implementation

func (*ShardPersistenceSuite) SetupTest

func (s *ShardPersistenceSuite) SetupTest()

SetupTest implementation

func (*ShardPersistenceSuite) TearDownSuite

func (s *ShardPersistenceSuite) TearDownSuite()

TearDownSuite implementation

func (*ShardPersistenceSuite) TestCreateShard

func (s *ShardPersistenceSuite) TestCreateShard()

TestCreateShard test

func (*ShardPersistenceSuite) TestGetShard

func (s *ShardPersistenceSuite) TestGetShard()

TestGetShard test

func (*ShardPersistenceSuite) TestUpdateShard

func (s *ShardPersistenceSuite) TestUpdateShard()

TestUpdateShard test

type TestBase

type TestBase struct {
	suite.Suite
	ShardMgr              p.ShardManager
	ExecutionMgrFactory   pfactory.Factory
	ExecutionManager      p.ExecutionManager
	TaskMgr               p.TaskManager
	HistoryMgr            p.HistoryManager
	HistoryV2Mgr          p.HistoryV2Manager
	MetadataManager       p.MetadataManager
	MetadataManagerV2     p.MetadataManager
	MetadataProxy         p.MetadataManager
	VisibilityMgr         p.VisibilityManager
	ShardInfo             *p.ShardInfo
	TaskIDGenerator       TransferTaskIDGenerator
	ClusterMetadata       cluster.Metadata
	ReadLevel             int64
	ReplicationReadLevel  int64
	DefaultTestCluster    PersistenceTestCluster
	VisibilityTestCluster PersistenceTestCluster
	// contains filtered or unexported fields
}

TestBase wraps the base setup needed to create workflows over persistence layer.

func NewTestBase added in v0.5.7

func NewTestBase(options *TestBaseOptions) TestBase

NewTestBase returns a persistence test base backed by either cassandra or sql

func NewTestBaseWithCassandra

func NewTestBaseWithCassandra(options *TestBaseOptions) TestBase

NewTestBaseWithCassandra returns a persistence test base backed by cassandra datastore

func NewTestBaseWithSQL

func NewTestBaseWithSQL(options *TestBaseOptions) TestBase

NewTestBaseWithSQL returns a new persistence test base backed by SQL

func (*TestBase) ClearReplicationQueue

func (s *TestBase) ClearReplicationQueue()

ClearReplicationQueue completes all tasks in replication queue

func (*TestBase) ClearTasks

func (s *TestBase) ClearTasks()

ClearTasks completes all transfer tasks and replication tasks

func (*TestBase) ClearTransferQueue

func (s *TestBase) ClearTransferQueue()

ClearTransferQueue completes all tasks in transfer queue

func (*TestBase) CompleteReplicationTask

func (s *TestBase) CompleteReplicationTask(taskID int64) error

CompleteReplicationTask is a utility method to complete a replication task

func (*TestBase) CompleteTask

func (s *TestBase) CompleteTask(domainID, taskList string, taskType int, taskID int64, ackLevel int64) error

CompleteTask is a utility method to complete a task

func (*TestBase) CompleteTimerTask

func (s *TestBase) CompleteTimerTask(ts time.Time, taskID int64) error

CompleteTimerTask is a utility method to complete a timer task

func (*TestBase) CompleteTransferTask

func (s *TestBase) CompleteTransferTask(taskID int64) error

CompleteTransferTask is a utility method to complete a transfer task

func (*TestBase) Config added in v0.5.7

func (s *TestBase) Config() config.Persistence

Config returns the persistence configuration for this test

func (*TestBase) ConflictResolveWorkflowExecution added in v0.7.0

func (s *TestBase) ConflictResolveWorkflowExecution(prevRunID string, prevLastWriteVersion int64, prevState int,
	info *p.WorkflowExecutionInfo, stats *p.ExecutionStats, replicationState *p.ReplicationState, nextEventID int64,
	activityInfos []*p.ActivityInfo, timerInfos []*p.TimerInfo, childExecutionInfos []*p.ChildExecutionInfo,
	requestCancelInfos []*p.RequestCancelInfo, signalInfos []*p.SignalInfo, ids []string) error

ConflictResolveWorkflowExecution is utility method to reset mutable state

func (*TestBase) ContinueAsNewExecution

func (s *TestBase) ContinueAsNewExecution(updatedInfo *p.WorkflowExecutionInfo, updatedStats *p.ExecutionStats, condition int64,
	newExecution workflow.WorkflowExecution, nextEventID, decisionScheduleID int64,
	prevResetPoints *workflow.ResetPoints) error

ContinueAsNewExecution is a utility method to create workflow executions

func (*TestBase) ContinueAsNewExecutionWithReplication added in v0.6.0

func (s *TestBase) ContinueAsNewExecutionWithReplication(updatedInfo *p.WorkflowExecutionInfo, updatedStats *p.ExecutionStats, condition int64,
	newExecution workflow.WorkflowExecution, nextEventID, decisionScheduleID int64,
	prevResetPoints *workflow.ResetPoints, beforeState *p.ReplicationState, afterState *p.ReplicationState) error

ContinueAsNewExecutionWithReplication is a utility method to create workflow executions

func (*TestBase) CreateActivityTasks

func (s *TestBase) CreateActivityTasks(domainID string, workflowExecution workflow.WorkflowExecution,
	activities map[int64]string) ([]int64, error)

CreateActivityTasks is a utility method to create tasks

func (*TestBase) CreateChildWorkflowExecution

func (s *TestBase) CreateChildWorkflowExecution(domainID string, workflowExecution workflow.WorkflowExecution,
	parentDomainID string, parentExecution workflow.WorkflowExecution, initiatedID int64, taskList, wType string,
	wTimeout int32, decisionTimeout int32, executionContext []byte, nextEventID int64, lastProcessedEventID int64,
	decisionScheduleID int64, timerTasks []p.Task) (*p.CreateWorkflowExecutionResponse, error)

CreateChildWorkflowExecution is a utility method to create child workflow executions

func (*TestBase) CreateDecisionTask

func (s *TestBase) CreateDecisionTask(domainID string, workflowExecution workflow.WorkflowExecution, taskList string,
	decisionScheduleID int64) (int64, error)

CreateDecisionTask is a utility method to create a task

func (*TestBase) CreateShard

func (s *TestBase) CreateShard(shardID int, owner string, rangeID int64) error

CreateShard is a utility method to create the shard using persistence layer

func (*TestBase) CreateWorkflowExecution

func (s *TestBase) CreateWorkflowExecution(domainID string, workflowExecution workflow.WorkflowExecution, taskList,
	wType string, wTimeout int32, decisionTimeout int32, executionContext []byte, nextEventID int64, lastProcessedEventID int64,
	decisionScheduleID int64, timerTasks []p.Task) (*p.CreateWorkflowExecutionResponse, error)

CreateWorkflowExecution is a utility method to create workflow executions

func (*TestBase) CreateWorkflowExecutionManyTasks

func (s *TestBase) CreateWorkflowExecutionManyTasks(domainID string, workflowExecution workflow.WorkflowExecution,
	taskList string, executionContext []byte, nextEventID int64, lastProcessedEventID int64,
	decisionScheduleIDs []int64, activityScheduleIDs []int64) (*p.CreateWorkflowExecutionResponse, error)

CreateWorkflowExecutionManyTasks is a utility method to create workflow executions

func (*TestBase) CreateWorkflowExecutionWithReplication

func (s *TestBase) CreateWorkflowExecutionWithReplication(domainID string, workflowExecution workflow.WorkflowExecution,
	taskList, wType string, wTimeout int32, decisionTimeout int32, nextEventID int64,
	lastProcessedEventID int64, decisionScheduleID int64, state *p.ReplicationState, txTasks []p.Task) (*p.CreateWorkflowExecutionResponse, error)

CreateWorkflowExecutionWithReplication is a utility method to create workflow executions

func (*TestBase) DeleteCancelState

func (s *TestBase) DeleteCancelState(updatedInfo *p.WorkflowExecutionInfo, updatedStats *p.ExecutionStats, condition int64,
	deleteCancelInfo int64) error

DeleteCancelState is a utility method to delete request cancel state from mutable state

func (*TestBase) DeleteChildExecutionsState

func (s *TestBase) DeleteChildExecutionsState(updatedInfo *p.WorkflowExecutionInfo, updatedStats *p.ExecutionStats, condition int64,
	deleteChildInfo int64) error

DeleteChildExecutionsState is a utility method to delete child execution from mutable state

func (*TestBase) DeleteCurrentWorkflowExecution added in v0.5.8

func (s *TestBase) DeleteCurrentWorkflowExecution(info *p.WorkflowExecutionInfo) error

DeleteCurrentWorkflowExecution is a utility method to delete the workflow current execution

func (*TestBase) DeleteSignalState

func (s *TestBase) DeleteSignalState(updatedInfo *p.WorkflowExecutionInfo, updatedStats *p.ExecutionStats, condition int64,
	deleteSignalInfo int64) error

DeleteSignalState is a utility method to delete request cancel state from mutable state

func (*TestBase) DeleteSignalsRequestedState

func (s *TestBase) DeleteSignalsRequestedState(updatedInfo *p.WorkflowExecutionInfo, updatedStats *p.ExecutionStats, condition int64,
	deleteSignalsRequestedID string) error

DeleteSignalsRequestedState is a utility method to delete mutable state of workflow execution

func (*TestBase) DeleteWorkflowExecution

func (s *TestBase) DeleteWorkflowExecution(info *p.WorkflowExecutionInfo) error

DeleteWorkflowExecution is a utility method to delete a workflow execution

func (*TestBase) EqualTimes

func (s *TestBase) EqualTimes(t1, t2 time.Time)

EqualTimes assertion that two times are equal within two millisecond precision

func (*TestBase) EqualTimesWithPrecision

func (s *TestBase) EqualTimesWithPrecision(t1, t2 time.Time, precision time.Duration)

EqualTimesWithPrecision assertion that two times are equal within precision

func (*TestBase) GetCurrentWorkflowRunID

func (s *TestBase) GetCurrentWorkflowRunID(domainID, workflowID string) (string, error)

GetCurrentWorkflowRunID returns the workflow run ID for the given params

func (*TestBase) GetNextSequenceNumber

func (s *TestBase) GetNextSequenceNumber() int64

GetNextSequenceNumber generates a unique sequence number for can be used for transfer queue taskId

func (*TestBase) GetReplicationReadLevel

func (s *TestBase) GetReplicationReadLevel() int64

GetReplicationReadLevel returns the current read level for shard

func (*TestBase) GetReplicationTasks

func (s *TestBase) GetReplicationTasks(batchSize int, getAll bool) ([]*p.ReplicationTaskInfo, error)

GetReplicationTasks is a utility method to get tasks from replication task queue

func (*TestBase) GetShard

func (s *TestBase) GetShard(shardID int) (*p.ShardInfo, error)

GetShard is a utility method to get the shard using persistence layer

func (*TestBase) GetTasks

func (s *TestBase) GetTasks(domainID, taskList string, taskType int, batchSize int) (*p.GetTasksResponse, error)

GetTasks is a utility method to get tasks from persistence

func (*TestBase) GetTimerIndexTasks

func (s *TestBase) GetTimerIndexTasks(batchSize int, getAll bool) ([]*p.TimerTaskInfo, error)

GetTimerIndexTasks is a utility method to get tasks from transfer task queue

func (*TestBase) GetTransferReadLevel

func (s *TestBase) GetTransferReadLevel() int64

GetTransferReadLevel returns the current read level for shard

func (*TestBase) GetTransferTasks

func (s *TestBase) GetTransferTasks(batchSize int, getAll bool) ([]*p.TransferTaskInfo, error)

GetTransferTasks is a utility method to get tasks from transfer task queue

func (*TestBase) GetWorkflowExecutionInfo

func (s *TestBase) GetWorkflowExecutionInfo(domainID string, workflowExecution workflow.WorkflowExecution) (
	*p.WorkflowMutableState, error)

GetWorkflowExecutionInfo is a utility method to retrieve execution info

func (*TestBase) GetWorkflowExecutionInfoWithStats

func (s *TestBase) GetWorkflowExecutionInfoWithStats(domainID string, workflowExecution workflow.WorkflowExecution) (
	*p.MutableStateStats, *p.WorkflowMutableState, error)

GetWorkflowExecutionInfoWithStats is a utility method to retrieve execution info with size stats

func (*TestBase) RangeCompleteTimerTask

func (s *TestBase) RangeCompleteTimerTask(inclusiveBeginTimestamp time.Time, exclusiveEndTimestamp time.Time) error

RangeCompleteTimerTask is a utility method to complete a range of timer tasks

func (*TestBase) RangeCompleteTransferTask

func (s *TestBase) RangeCompleteTransferTask(exclusiveBeginTaskID int64, inclusiveEndTaskID int64) error

RangeCompleteTransferTask is a utility method to complete a range of transfer tasks

func (*TestBase) ResetWorkflowExecution added in v0.5.2

func (s *TestBase) ResetWorkflowExecution(condition int64, info *p.WorkflowExecutionInfo,
	executionStats *p.ExecutionStats, replicationState *p.ReplicationState,
	activityInfos []*p.ActivityInfo, timerInfos []*p.TimerInfo, childExecutionInfos []*p.ChildExecutionInfo,
	requestCancelInfos []*p.RequestCancelInfo, signalInfos []*p.SignalInfo, ids []string, trasTasks, timerTasks, replTasks []p.Task,
	updateCurr bool, currInfo *p.WorkflowExecutionInfo, currExecutionStats *p.ExecutionStats, currReplicationState *p.ReplicationState,
	currTrasTasks, currTimerTasks []p.Task, forkRunID string, forkRunNextEventID int64) error

ResetWorkflowExecution is utility method to reset WF

func (*TestBase) Setup

func (s *TestBase) Setup()

Setup sets up the test base, must be called as part of SetupSuite

func (*TestBase) TearDownWorkflowStore

func (s *TestBase) TearDownWorkflowStore()

TearDownWorkflowStore to cleanup

func (*TestBase) UpdateAllMutableState

func (s *TestBase) UpdateAllMutableState(updatedMutableState *p.WorkflowMutableState, condition int64) error

UpdateAllMutableState is a utility method to update workflow execution

func (*TestBase) UpdateShard

func (s *TestBase) UpdateShard(updatedInfo *p.ShardInfo, previousRangeID int64) error

UpdateShard is a utility method to update the shard using persistence layer

func (*TestBase) UpdateWorkflowExecution

func (s *TestBase) UpdateWorkflowExecution(updatedInfo *p.WorkflowExecutionInfo, updatedStats *p.ExecutionStats, decisionScheduleIDs []int64,
	activityScheduleIDs []int64, condition int64, timerTasks []p.Task,
	upsertActivityInfos []*p.ActivityInfo, deleteActivityInfos []int64,
	upsertTimerInfos []*p.TimerInfo, deleteTimerInfos []string) error

UpdateWorkflowExecution is a utility method to update workflow execution

func (*TestBase) UpdateWorkflowExecutionAndFinish

func (s *TestBase) UpdateWorkflowExecutionAndFinish(updatedInfo *p.WorkflowExecutionInfo, updatedStats *p.ExecutionStats, condition int64) error

UpdateWorkflowExecutionAndFinish is a utility method to update workflow execution

func (*TestBase) UpdateWorkflowExecutionForBufferEvents

func (s *TestBase) UpdateWorkflowExecutionForBufferEvents(
	updatedInfo *p.WorkflowExecutionInfo, updatedStats *p.ExecutionStats, rState *p.ReplicationState, condition int64,
	bufferEvents []*workflow.HistoryEvent, clearBufferedEvents bool) error

UpdateWorkflowExecutionForBufferEvents is a utility method to update workflow execution

func (*TestBase) UpdateWorkflowExecutionForChildExecutionsInitiated

func (s *TestBase) UpdateWorkflowExecutionForChildExecutionsInitiated(
	updatedInfo *p.WorkflowExecutionInfo, updatedStats *p.ExecutionStats, condition int64, transferTasks []p.Task, childInfos []*p.ChildExecutionInfo) error

UpdateWorkflowExecutionForChildExecutionsInitiated is a utility method to update workflow execution

func (*TestBase) UpdateWorkflowExecutionForRequestCancel

func (s *TestBase) UpdateWorkflowExecutionForRequestCancel(
	updatedInfo *p.WorkflowExecutionInfo, updatedStats *p.ExecutionStats, condition int64, transferTasks []p.Task,
	upsertRequestCancelInfo []*p.RequestCancelInfo) error

UpdateWorkflowExecutionForRequestCancel is a utility method to update workflow execution

func (*TestBase) UpdateWorkflowExecutionForSignal

func (s *TestBase) UpdateWorkflowExecutionForSignal(
	updatedInfo *p.WorkflowExecutionInfo, updatedStats *p.ExecutionStats, condition int64, transferTasks []p.Task,
	upsertSignalInfos []*p.SignalInfo) error

UpdateWorkflowExecutionForSignal is a utility method to update workflow execution

func (*TestBase) UpdateWorkflowExecutionWithRangeID

func (s *TestBase) UpdateWorkflowExecutionWithRangeID(updatedInfo *p.WorkflowExecutionInfo, updatedStats *p.ExecutionStats, decisionScheduleIDs []int64,
	activityScheduleIDs []int64, rangeID, condition int64, timerTasks []p.Task,
	upsertActivityInfos []*p.ActivityInfo, deleteActivityInfos []int64, upsertTimerInfos []*p.TimerInfo,
	deleteTimerInfos []string, upsertChildInfos []*p.ChildExecutionInfo, deleteChildInfo *int64,
	upsertCancelInfos []*p.RequestCancelInfo, deleteCancelInfo *int64,
	upsertSignalInfos []*p.SignalInfo, deleteSignalInfo *int64,
	upsertSignalRequestedIDs []string, deleteSignalRequestedID string) error

UpdateWorkflowExecutionWithRangeID is a utility method to update workflow execution

func (*TestBase) UpdateWorkflowExecutionWithReplication

func (s *TestBase) UpdateWorkflowExecutionWithReplication(updatedInfo *p.WorkflowExecutionInfo, updatedStats *p.ExecutionStats,
	updatedReplicationState *p.ReplicationState, decisionScheduleIDs []int64, activityScheduleIDs []int64, rangeID,
	condition int64, timerTasks []p.Task, txTasks []p.Task, upsertActivityInfos []*p.ActivityInfo,
	deleteActivityInfos []int64, upsertTimerInfos []*p.TimerInfo, deleteTimerInfos []string,
	upsertChildInfos []*p.ChildExecutionInfo, deleteChildInfo *int64, upsertCancelInfos []*p.RequestCancelInfo,
	deleteCancelInfo *int64, upsertSignalInfos []*p.SignalInfo, deleteSignalInfo *int64, upsertSignalRequestedIDs []string,
	deleteSignalRequestedID string) error

UpdateWorkflowExecutionWithReplication is a utility method to update workflow execution

func (*TestBase) UpdateWorkflowExecutionWithTransferTasks

func (s *TestBase) UpdateWorkflowExecutionWithTransferTasks(
	updatedInfo *p.WorkflowExecutionInfo, updatedStats *p.ExecutionStats, condition int64, transferTasks []p.Task, upsertActivityInfo []*p.ActivityInfo) error

UpdateWorkflowExecutionWithTransferTasks is a utility method to update workflow execution

func (*TestBase) UpdateWorklowStateAndReplication

func (s *TestBase) UpdateWorklowStateAndReplication(updatedInfo *p.WorkflowExecutionInfo, updatedStats *p.ExecutionStats,
	updatedReplicationState *p.ReplicationState, condition int64, txTasks []p.Task) error

UpdateWorklowStateAndReplication is a utility method to update workflow execution

func (*TestBase) UpsertChildExecutionsState

func (s *TestBase) UpsertChildExecutionsState(updatedInfo *p.WorkflowExecutionInfo, updatedStats *p.ExecutionStats, condition int64,
	upsertChildInfos []*p.ChildExecutionInfo) error

UpsertChildExecutionsState is a utility method to update mutable state of workflow execution

func (*TestBase) UpsertRequestCancelState

func (s *TestBase) UpsertRequestCancelState(updatedInfo *p.WorkflowExecutionInfo, updatedStats *p.ExecutionStats, condition int64,
	upsertCancelInfos []*p.RequestCancelInfo) error

UpsertRequestCancelState is a utility method to update mutable state of workflow execution

func (*TestBase) UpsertSignalInfoState

func (s *TestBase) UpsertSignalInfoState(updatedInfo *p.WorkflowExecutionInfo, updatedStats *p.ExecutionStats, condition int64,
	upsertSignalInfos []*p.SignalInfo) error

UpsertSignalInfoState is a utility method to update mutable state of workflow execution

func (*TestBase) UpsertSignalsRequestedState

func (s *TestBase) UpsertSignalsRequestedState(updatedInfo *p.WorkflowExecutionInfo, updatedStats *p.ExecutionStats, condition int64,
	upsertSignalsRequested []string) error

UpsertSignalsRequestedState is a utility method to update mutable state of workflow execution

type TestBaseOptions

type TestBaseOptions struct {
	DBName          string
	DBPort          int              `yaml:"-"`
	StoreType       string           `yaml:"-"`
	SchemaDir       string           `yaml:"-"`
	ClusterMetadata cluster.Metadata `yaml:"-"`
}

TestBaseOptions options to configure workflow test base.

type TestTransferTaskIDGenerator

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

TestTransferTaskIDGenerator helper

func (*TestTransferTaskIDGenerator) GenerateTransferTaskID added in v0.7.0

func (g *TestTransferTaskIDGenerator) GenerateTransferTaskID() (int64, error)

GenerateTransferTaskID helper

func (*TestTransferTaskIDGenerator) GenerateTransferTaskIDs added in v0.7.0

func (g *TestTransferTaskIDGenerator) GenerateTransferTaskIDs(number int) ([]int64, error)

GenerateTransferTaskIDs helper

type TransferTaskIDGenerator

type TransferTaskIDGenerator interface {
	GenerateTransferTaskID() (int64, error)
}

TransferTaskIDGenerator generates IDs for transfer tasks written by helper methods

type VisibilityPersistenceSuite

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

VisibilityPersistenceSuite tests visibility persistence

func (*VisibilityPersistenceSuite) SetupSuite

func (s *VisibilityPersistenceSuite) SetupSuite()

SetupSuite implementation

func (*VisibilityPersistenceSuite) SetupTest

func (s *VisibilityPersistenceSuite) SetupTest()

SetupTest implementation

func (*VisibilityPersistenceSuite) TearDownSuite

func (s *VisibilityPersistenceSuite) TearDownSuite()

TearDownSuite implementation

func (*VisibilityPersistenceSuite) TestBasicVisibility

func (s *VisibilityPersistenceSuite) TestBasicVisibility()

TestBasicVisibility test

func (*VisibilityPersistenceSuite) TestBasicVisibilityTimeSkew added in v0.5.7

func (s *VisibilityPersistenceSuite) TestBasicVisibilityTimeSkew()

TestBasicVisibilityTimeSkew test

func (*VisibilityPersistenceSuite) TestClosedWithoutStarted added in v0.5.7

func (s *VisibilityPersistenceSuite) TestClosedWithoutStarted()

TestClosedWithoutStarted test

func (*VisibilityPersistenceSuite) TestDelete added in v0.5.7

func (s *VisibilityPersistenceSuite) TestDelete()

TestDelete test

func (*VisibilityPersistenceSuite) TestFilteringByCloseStatus

func (s *VisibilityPersistenceSuite) TestFilteringByCloseStatus()

TestFilteringByCloseStatus test

func (*VisibilityPersistenceSuite) TestFilteringByType

func (s *VisibilityPersistenceSuite) TestFilteringByType()

TestFilteringByType test

func (*VisibilityPersistenceSuite) TestFilteringByWorkflowID

func (s *VisibilityPersistenceSuite) TestFilteringByWorkflowID()

TestFilteringByWorkflowID test

func (*VisibilityPersistenceSuite) TestGetClosedExecution

func (s *VisibilityPersistenceSuite) TestGetClosedExecution()

TestGetClosedExecution test

func (*VisibilityPersistenceSuite) TestMultipleUpserts added in v0.5.7

func (s *VisibilityPersistenceSuite) TestMultipleUpserts()

TestMultipleUpserts test

func (*VisibilityPersistenceSuite) TestVisibilityPagination

func (s *VisibilityPersistenceSuite) TestVisibilityPagination()

TestVisibilityPagination test

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL