persistencetests

package

Go to main page

Versions in this module

v0

v0.8.6

Aug 27, 2019

v0.8.5

Aug 27, 2019

v0.8.4

Aug 26, 2019

v0.8.3

Aug 14, 2019

v0.8.2

Aug 13, 2019

v0.8.1

Aug 12, 2019

v0.8.0

Aug 12, 2019

v0.7.3

Aug 8, 2019

v0.7.2

Aug 8, 2019

v0.7.1

Aug 6, 2019

v0.7.0

Jul 30, 2019

Changes in this version

type ExecutionManagerSuite

+ func (s *ExecutionManagerSuite) TestConflictResolveWorkflowExecutionCurrentIsNotSelf()

+ func (s *ExecutionManagerSuite) TestConflictResolveWorkflowExecutionCurrentIsSelf()

+ func (s *ExecutionManagerSuite) TestConflictResolveWorkflowExecutionMismatch()

type TestBase

+ func (s *TestBase) ConflictResolveWorkflowExecution(prevRunID string, prevLastWriteVersion int64, prevState int, ...) error

type TestTransferTaskIDGenerator

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

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

type TransferTaskIDGenerator

+ GenerateTransferTaskID func() (int64, error)

v0.6.1

Jul 26, 2019

v0.6.0

Jul 24, 2019

Changes in this version

type TestBase

+ func (s *TestBase) ContinueAsNewExecutionWithReplication(updatedInfo *p.WorkflowExecutionInfo, condition int64, ...) error

v0.5.9

Jun 17, 2019

Changes in this version

type ExecutionManagerSuite

+ func (s *ExecutionManagerSuite) TestCreateWorkflowExecutionStateCloseStatus()

+ func (s *ExecutionManagerSuite) TestResetMutableStateMismatch()

+ func (s *ExecutionManagerSuite) TestUpdateWorkflowExecutionStateCloseStatus()

v0.5.8

May 14, 2019

Changes in this version

type TestBase

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

v0.5.7

May 8, 2019

Changes in this version

type HistoryV2PersistenceSuite

+ func (s *HistoryV2PersistenceSuite) TestReadBranchByPagination()

type MatchingPersistenceSuite

+ func (s *MatchingPersistenceSuite) TestGetTasksWithNoMaxReadLevel()

type TestBase

+ func NewTestBase(options *TestBaseOptions) TestBase

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

type TestBaseOptions

+ DBPort int

+ SchemaDir string

+ StoreType string

type VisibilityPersistenceSuite

+ func (s *VisibilityPersistenceSuite) TestBasicVisibilityTimeSkew()

+ func (s *VisibilityPersistenceSuite) TestClosedWithoutStarted()

+ func (s *VisibilityPersistenceSuite) TestDelete()

+ func (s *VisibilityPersistenceSuite) TestMultipleUpserts()

v0.5.5

Mar 12, 2019

Changes in this version

type VisibilityPersistenceSuite

+ func (s *VisibilityPersistenceSuite) TestBasicVisibility_TimeSkew()

v0.5.4

Mar 8, 2019

Changes in this version

type MatchingPersistenceSuite

+ func (s *MatchingPersistenceSuite) TestCompleteTasksLessThan()

+ func (s *MatchingPersistenceSuite) TestListWithMultipleTaskList()

+ func (s *MatchingPersistenceSuite) TestListWithOneTaskList()

type TestTransferTaskIDGenerator

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

v0.5.3

Feb 19, 2019

Changes in this version

type ExecutionManagerSuite

+ func (s *ExecutionManagerSuite) TestUpdateDeleteWorkflow()

v0.5.2

Feb 12, 2019

Changes in this version

type ExecutionManagerSuiteForEventsV2

+ func (s *ExecutionManagerSuiteForEventsV2) TestWorkflowResetNoCurrNoReplicate()

+ func (s *ExecutionManagerSuiteForEventsV2) TestWorkflowResetNoCurrWithReplicate()

+ func (s *ExecutionManagerSuiteForEventsV2) TestWorkflowResetWithCurrWithReplicate()

type TestBase

+ func (s *TestBase) ResetWorkflowExecution(condition int64, info *p.WorkflowExecutionInfo, ...) error

v0.5.1

Jan 18, 2019

v0.5.0

Jan 7, 2019

Changes in this version

+ type ExecutionManagerSuiteForEventsV2 struct

+ func (s *ExecutionManagerSuiteForEventsV2) SetupSuite()

+ func (s *ExecutionManagerSuiteForEventsV2) SetupTest()

+ func (s *ExecutionManagerSuiteForEventsV2) TearDownSuite()

+ func (s *ExecutionManagerSuiteForEventsV2) TestContinueAsNew()

+ func (s *ExecutionManagerSuiteForEventsV2) TestWorkflowCreation()

+ func (s *ExecutionManagerSuiteForEventsV2) TestWorkflowMutableStateBufferedReplicationTasks()

+ func (s *ExecutionManagerSuiteForEventsV2) TestWorkflowWithReplicationState()

+ type HistoryPerfSuite struct

+ func (s *HistoryPerfSuite) SetupSuite()

+ func (s *HistoryPerfSuite) SetupTest()

+ func (s *HistoryPerfSuite) TearDownSuite()

+ func (s *HistoryPerfSuite) TestPerf()

type HistoryPersistenceSuite

+ func (s *HistoryPersistenceSuite) TestAppendAndGetByBatch()

+ type HistoryV2PersistenceSuite struct

+ func (s *HistoryV2PersistenceSuite) SetupSuite()

+ func (s *HistoryV2PersistenceSuite) SetupTest()

+ func (s *HistoryV2PersistenceSuite) TearDownSuite()

+ func (s *HistoryV2PersistenceSuite) TestConcurrentlyCreateAndAppendBranches()

+ func (s *HistoryV2PersistenceSuite) TestConcurrentlyForkAndAppendBranches()

+ func (s *HistoryV2PersistenceSuite) TestGenUUIDs()

type TestBase

+ HistoryV2Mgr p.HistoryV2Manager

v0.4.0

Oct 19, 2018

Changes in this version

+ const TimePrecision

+ func GenerateRandomDBName(n int) string

+ type ExecutionManagerSuite struct

+ func (s *ExecutionManagerSuite) SetupSuite()

+ func (s *ExecutionManagerSuite) SetupTest()

+ func (s *ExecutionManagerSuite) TearDownSuite()

+ func (s *ExecutionManagerSuite) TestCancelTransferTaskTasks()

+ func (s *ExecutionManagerSuite) TestContinueAsNew()

+ func (s *ExecutionManagerSuite) TestCreateGetShardBackfill()

+ func (s *ExecutionManagerSuite) TestCreateGetUpdateGetShard()

+ func (s *ExecutionManagerSuite) TestCreateWorkflowExecutionBrandNew()

+ func (s *ExecutionManagerSuite) TestCreateWorkflowExecutionConcurrentCreate()

+ func (s *ExecutionManagerSuite) TestCreateWorkflowExecutionRunIDReuseWithReplication()

+ func (s *ExecutionManagerSuite) TestCreateWorkflowExecutionRunIDReuseWithoutReplication()

+ func (s *ExecutionManagerSuite) TestDeleteCurrentWorkflow()

+ func (s *ExecutionManagerSuite) TestDeleteWorkflow()

+ func (s *ExecutionManagerSuite) TestGetCurrentWorkflow()

+ func (s *ExecutionManagerSuite) TestGetWorkflow()

+ func (s *ExecutionManagerSuite) TestPersistenceStartWorkflow()

+ func (s *ExecutionManagerSuite) TestPersistenceStartWorkflowWithReplicationState()

+ func (s *ExecutionManagerSuite) TestReplicationTasks()

+ func (s *ExecutionManagerSuite) TestReplicationTransferTaskTasks()

+ func (s *ExecutionManagerSuite) TestResetMutableStateCurrentIsNotSelf()

+ func (s *ExecutionManagerSuite) TestResetMutableStateCurrentIsSelf()

+ func (s *ExecutionManagerSuite) TestSignalTransferTaskTasks()

+ func (s *ExecutionManagerSuite) TestTimerTasksComplete()

+ func (s *ExecutionManagerSuite) TestTimerTasksRangeComplete()

+ func (s *ExecutionManagerSuite) TestTransferTasksComplete()

+ func (s *ExecutionManagerSuite) TestTransferTasksRangeComplete()

+ func (s *ExecutionManagerSuite) TestTransferTasksThroughUpdate()

+ func (s *ExecutionManagerSuite) TestUpdateAndClearBufferedEvents()

+ func (s *ExecutionManagerSuite) TestUpdateWorkflow()

+ func (s *ExecutionManagerSuite) TestWorkflowMutableStateActivities()

+ func (s *ExecutionManagerSuite) TestWorkflowMutableStateBufferedReplicationTasks()

+ func (s *ExecutionManagerSuite) TestWorkflowMutableStateChildExecutions()

+ func (s *ExecutionManagerSuite) TestWorkflowMutableStateInfo()

+ func (s *ExecutionManagerSuite) TestWorkflowMutableStateRequestCancel()

+ func (s *ExecutionManagerSuite) TestWorkflowMutableStateSignalInfo()

+ func (s *ExecutionManagerSuite) TestWorkflowMutableStateSignalRequested()

+ func (s *ExecutionManagerSuite) TestWorkflowMutableStateTimers()

+ func (s *ExecutionManagerSuite) TestWorkflowReplicationState()

+ type HistoryPersistenceSuite struct

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

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

+ func (s *HistoryPersistenceSuite) GetWorkflowExecutionHistory(domainID string, workflowExecution gen.WorkflowExecution, ...) (*gen.History, []byte, error)

+ func (s *HistoryPersistenceSuite) SetupSuite()

+ func (s *HistoryPersistenceSuite) SetupTest()

+ func (s *HistoryPersistenceSuite) TearDownSuite()

+ func (s *HistoryPersistenceSuite) TestAppendAndGet()

+ func (s *HistoryPersistenceSuite) TestAppendHistoryEvents()

+ func (s *HistoryPersistenceSuite) TestDeleteHistoryEvents()

+ func (s *HistoryPersistenceSuite) TestGetHistoryEvents()

+ func (s *HistoryPersistenceSuite) TestGetHistoryEventsCompatibility()

+ func (s *HistoryPersistenceSuite) TestOverwriteAndShadowingHistoryEvents()

+ type MatchingPersistenceSuite struct

+ func (s *MatchingPersistenceSuite) SetupSuite()

+ func (s *MatchingPersistenceSuite) SetupTest()

+ func (s *MatchingPersistenceSuite) TearDownSuite()

+ func (s *MatchingPersistenceSuite) TestCompleteDecisionTask()

+ func (s *MatchingPersistenceSuite) TestCreateTask()

+ func (s *MatchingPersistenceSuite) TestGetDecisionTasks()

+ func (s *MatchingPersistenceSuite) TestLeaseAndUpdateTaskList()

+ func (s *MatchingPersistenceSuite) TestLeaseAndUpdateTaskListSticky()

+ type MetadataPersistenceSuite struct

+ func (m *MetadataPersistenceSuite) CreateDomain(info *p.DomainInfo, config *p.DomainConfig, ...) (*p.CreateDomainResponse, error)

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

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

+ func (m *MetadataPersistenceSuite) SetupSuite()

+ func (m *MetadataPersistenceSuite) SetupTest()

+ func (m *MetadataPersistenceSuite) TearDownSuite()

+ func (m *MetadataPersistenceSuite) TestConcurrentCreateDomain()

+ func (m *MetadataPersistenceSuite) TestConcurrentUpdateDomain()

+ func (m *MetadataPersistenceSuite) TestCreateDomain()

+ func (m *MetadataPersistenceSuite) TestDeleteDomain()

+ func (m *MetadataPersistenceSuite) TestGetDomain()

+ func (m *MetadataPersistenceSuite) TestUpdateDomain()

+ func (m *MetadataPersistenceSuite) UpdateDomain(info *p.DomainInfo, config *p.DomainConfig, ...) error

+ type MetadataPersistenceSuiteV2 struct

+ func (m *MetadataPersistenceSuiteV2) CreateDomain(info *p.DomainInfo, config *p.DomainConfig, ...) (*p.CreateDomainResponse, error)

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

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

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

+ func (m *MetadataPersistenceSuiteV2) SetupSuite()

+ func (m *MetadataPersistenceSuiteV2) SetupTest()

+ func (m *MetadataPersistenceSuiteV2) TearDownSuite()

+ func (m *MetadataPersistenceSuiteV2) TearDownTest()

+ func (m *MetadataPersistenceSuiteV2) TestConcurrentCreateDomain()

+ func (m *MetadataPersistenceSuiteV2) TestConcurrentUpdateDomain()

+ func (m *MetadataPersistenceSuiteV2) TestCreateDomain()

+ func (m *MetadataPersistenceSuiteV2) TestDeleteDomain()

+ func (m *MetadataPersistenceSuiteV2) TestGetDomain()

+ func (m *MetadataPersistenceSuiteV2) TestListDomains()

+ func (m *MetadataPersistenceSuiteV2) TestUpdateDomain()

+ func (m *MetadataPersistenceSuiteV2) UpdateDomain(info *p.DomainInfo, config *p.DomainConfig, ...) error

+ type PersistenceTestCluster interface

+ Config func() config.Persistence

+ CreateSession func()

+ DatabaseName func() string

+ DropDatabase func()

+ LoadSchema func(fileNames []string, schemaDir string)

+ LoadVisibilitySchema func(fileNames []string, schemaDir string)

+ SetupTestDatabase func()

+ TearDownTestDatabase func()

+ type ShardPersistenceSuite struct

+ func (s *ShardPersistenceSuite) SetupSuite()

+ func (s *ShardPersistenceSuite) SetupTest()

+ func (s *ShardPersistenceSuite) TearDownSuite()

+ func (s *ShardPersistenceSuite) TestCreateShard()

+ func (s *ShardPersistenceSuite) TestGetShard()

+ func (s *ShardPersistenceSuite) TestUpdateShard()

+ type TestBase struct

+ ClusterMetadata cluster.Metadata

+ DefaultTestCluster PersistenceTestCluster

+ ExecutionManager p.ExecutionManager

+ ExecutionMgrFactory pfactory.Factory

+ HistoryMgr p.HistoryManager

+ MetadataManager p.MetadataManager

+ MetadataManagerV2 p.MetadataManager

+ MetadataProxy p.MetadataManager

+ ReadLevel int64

+ ReplicationReadLevel int64

+ ShardInfo *p.ShardInfo

+ ShardMgr p.ShardManager

+ TaskIDGenerator TransferTaskIDGenerator

+ TaskMgr p.TaskManager

+ VisibilityMgr p.VisibilityManager

+ VisibilityTestCluster PersistenceTestCluster

+ func NewTestBaseWithCassandra(options *TestBaseOptions) TestBase

+ func NewTestBaseWithSQL(options *TestBaseOptions) TestBase

+ func (s *TestBase) ClearReplicationQueue()

+ func (s *TestBase) ClearTasks()

+ func (s *TestBase) ClearTransferQueue()

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

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

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

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

+ func (s *TestBase) ContinueAsNewExecution(updatedInfo *p.WorkflowExecutionInfo, condition int64, ...) error

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

+ func (s *TestBase) CreateChildWorkflowExecution(domainID string, workflowExecution workflow.WorkflowExecution, ...) (*p.CreateWorkflowExecutionResponse, error)

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

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

+ func (s *TestBase) CreateWorkflowExecution(domainID string, workflowExecution workflow.WorkflowExecution, ...) (*p.CreateWorkflowExecutionResponse, error)

+ func (s *TestBase) CreateWorkflowExecutionManyTasks(domainID string, workflowExecution workflow.WorkflowExecution, taskList string, ...) (*p.CreateWorkflowExecutionResponse, error)

+ func (s *TestBase) CreateWorkflowExecutionWithReplication(domainID string, workflowExecution workflow.WorkflowExecution, ...) (*p.CreateWorkflowExecutionResponse, error)

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

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

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

+ func (s *TestBase) DeleteSignalsRequestedState(updatedInfo *p.WorkflowExecutionInfo, condition int64, ...) error

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

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

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

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

+ func (s *TestBase) GetNextSequenceNumber() int64

+ func (s *TestBase) GetReplicationReadLevel() int64

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

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

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

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

+ func (s *TestBase) GetTransferReadLevel() int64

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

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

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

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

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

+ func (s *TestBase) ResetMutableState(prevRunID string, info *p.WorkflowExecutionInfo, ...) error

+ func (s *TestBase) Setup()

+ func (s *TestBase) TearDownWorkflowStore()

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

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

+ func (s *TestBase) UpdateWorkflowExecution(updatedInfo *p.WorkflowExecutionInfo, decisionScheduleIDs []int64, ...) error

+ func (s *TestBase) UpdateWorkflowExecutionAndFinish(updatedInfo *p.WorkflowExecutionInfo, condition int64, retentionSecond int32) error

+ func (s *TestBase) UpdateWorkflowExecutionForBufferEvents(updatedInfo *p.WorkflowExecutionInfo, rState *p.ReplicationState, ...) error

+ func (s *TestBase) UpdateWorkflowExecutionForChildExecutionsInitiated(updatedInfo *p.WorkflowExecutionInfo, condition int64, transferTasks []p.Task, ...) error

+ func (s *TestBase) UpdateWorkflowExecutionForRequestCancel(updatedInfo *p.WorkflowExecutionInfo, condition int64, transferTasks []p.Task, ...) error

+ func (s *TestBase) UpdateWorkflowExecutionForSignal(updatedInfo *p.WorkflowExecutionInfo, condition int64, transferTasks []p.Task, ...) error

+ func (s *TestBase) UpdateWorkflowExecutionWithRangeID(updatedInfo *p.WorkflowExecutionInfo, decisionScheduleIDs []int64, ...) error

+ func (s *TestBase) UpdateWorkflowExecutionWithReplication(updatedInfo *p.WorkflowExecutionInfo, ...) error

+ func (s *TestBase) UpdateWorkflowExecutionWithTransferTasks(updatedInfo *p.WorkflowExecutionInfo, condition int64, transferTasks []p.Task, ...) error

+ func (s *TestBase) UpdateWorklowStateAndReplication(updatedInfo *p.WorkflowExecutionInfo, ...) error

+ func (s *TestBase) UpsertChildExecutionsState(updatedInfo *p.WorkflowExecutionInfo, condition int64, ...) error

+ func (s *TestBase) UpsertRequestCancelState(updatedInfo *p.WorkflowExecutionInfo, condition int64, ...) error

+ func (s *TestBase) UpsertSignalInfoState(updatedInfo *p.WorkflowExecutionInfo, condition int64, ...) error

+ func (s *TestBase) UpsertSignalsRequestedState(updatedInfo *p.WorkflowExecutionInfo, condition int64, ...) error

+ type TestBaseOptions struct

+ Cassandra struct{ ... }

+ ClusterMetadata cluster.Metadata

+ DBName string

+ EnableGlobalDomain bool

+ IsMasterCluster bool

+ SQL struct{ ... }

+ type TestTransferTaskIDGenerator struct

+ func (g *TestTransferTaskIDGenerator) GetNextTransferTaskID() (int64, error)

+ type TransferTaskIDGenerator interface

+ GetNextTransferTaskID func() (int64, error)

+ type VisibilityPersistenceSuite struct

+ func (s *VisibilityPersistenceSuite) SetupSuite()

+ func (s *VisibilityPersistenceSuite) SetupTest()

+ func (s *VisibilityPersistenceSuite) TearDownSuite()

+ func (s *VisibilityPersistenceSuite) TestBasicVisibility()

+ func (s *VisibilityPersistenceSuite) TestFilteringByCloseStatus()

+ func (s *VisibilityPersistenceSuite) TestFilteringByType()

+ func (s *VisibilityPersistenceSuite) TestFilteringByWorkflowID()

+ func (s *VisibilityPersistenceSuite) TestGetClosedExecution()

+ func (s *VisibilityPersistenceSuite) TestVisibilityPagination()

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