tests

package
v1.33.1 Latest Latest
Warning

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

 Go to latest Published: Apr 23, 2026 License: MIT Imports: 78 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ApplySchemaUpdate 

func ApplySchemaUpdate(t *testing.T, cfg *config.Cassandra, schemaFile string, logger log.Logger)

func GetSchemaFiles 

func GetSchemaFiles(t *testing.T, schemaDir string, logger log.Logger) []string

GetSchemaFiles takes a root directory which contains subdirectories whose names are semantic versions and returns the .cql files within. E.g.: //schema/cassandra/temporal/versioned Subdirectories are ordered by semantic version, but files within the same subdirectory are in arbitrary order. All .cql files are returned regardless of whether they are named in manifest.json.

func NewCassandraConfig 

func NewCassandraConfig() *config.Cassandra

NewCassandraConfig returns a new Cassandra config for test

func NewMySQLConfig 

func NewMySQLConfig() *config.SQL

NewMySQLConfig returns a new MySQL config for test

func NewPostgreSQLConfig 

func NewPostgreSQLConfig(pluginName string) *config.SQL

NewPostgreSQLConfig returns a new MySQL config for test

func RandomActivityInfo 

func RandomActivityInfo() *persistencespb.ActivityInfo

func RandomBranchToken 

func RandomBranchToken(
	namespaceID string,
	workflowID string,
	runID string,
	historyBranchUtil p.HistoryBranchUtil,
) []byte

func RandomChasmNode 

func RandomChasmNode() *persistencespb.ChasmNode

func RandomChasmNodeMap 

func RandomChasmNodeMap() map[string]*persistencespb.ChasmNode

func RandomChildExecutionInfo 

func RandomChildExecutionInfo() *persistencespb.ChildExecutionInfo

func RandomDuration 

func RandomDuration() *durationpb.Duration

func RandomExecutionInfo 

func RandomExecutionInfo(
	namespaceID string,
	workflowID string,
	eventID int64,
	lastWriteVersion int64,
	branchToken []byte,
) *persistencespb.WorkflowExecutionInfo

func RandomExecutionState 

func RandomExecutionState(
	runID string,
	state enumsspb.WorkflowExecutionState,
	status enumspb.WorkflowExecutionStatus,
	lastWriteVersion int64,
) *persistencespb.WorkflowExecutionState

func RandomHistoryEvent 

func RandomHistoryEvent(eventID int64, version int64) *historypb.HistoryEvent

func RandomInt64ActivityInfoMap 

func RandomInt64ActivityInfoMap() map[int64]*persistencespb.ActivityInfo

func RandomInt64ChildExecutionInfoMap 

func RandomInt64ChildExecutionInfoMap() map[int64]*persistencespb.ChildExecutionInfo

func RandomInt64RequestCancelInfoMap 

func RandomInt64RequestCancelInfoMap() map[int64]*persistencespb.RequestCancelInfo

func RandomInt64SignalInfoMap 

func RandomInt64SignalInfoMap() map[int64]*persistencespb.SignalInfo

func RandomMutation 

func RandomMutation(
	t *testing.T,
	namespaceID string,
	workflowID string,
	runID string,
	eventID int64,
	lastWriteVersion int64,
	state enumsspb.WorkflowExecutionState,
	status enumspb.WorkflowExecutionStatus,
	dbRecordVersion int64,
	branchToken []byte,
) (*p.WorkflowMutation, []*p.WorkflowEvents)

func RandomPayload 

func RandomPayload() *commonpb.Payload

func RandomRequestCancelInfo 

func RandomRequestCancelInfo() *persistencespb.RequestCancelInfo

func RandomResetPoints 

func RandomResetPoints() *workflowpb.ResetPoints

func RandomShardInfo 

func RandomShardInfo(
	shardID int32,
	rangeID int64,
) *persistencespb.ShardInfo

func RandomSignalInfo 

func RandomSignalInfo() *persistencespb.SignalInfo

func RandomSnapshot 

func RandomSnapshot(
	t *testing.T,
	namespaceID string,
	workflowID string,
	runID string,
	eventID int64,
	lastWriteVersion int64,
	state enumsspb.WorkflowExecutionState,
	status enumspb.WorkflowExecutionStatus,
	dbRecordVersion int64,
	branchToken []byte,
) (*p.WorkflowSnapshot, []*p.WorkflowEvents)

func RandomStringPayloadMap 

func RandomStringPayloadMap() map[string]*commonpb.Payload

func RandomStringTimerInfoMap 

func RandomStringTimerInfoMap() map[string]*persistencespb.TimerInfo

func RandomTime 

func RandomTime() *timestamppb.Timestamp

func RandomTimerInfo 

func RandomTimerInfo() *persistencespb.TimerInfo

func RandomVersionHistory 

func RandomVersionHistory(
	eventID int64,
	lastWriteVersion int64,
	branchToken []byte,
) *historyspb.VersionHistories

func RunHistoryTaskQueueManagerTestSuite 

func RunHistoryTaskQueueManagerTestSuite(t *testing.T, queue persistence.QueueV2)

RunHistoryTaskQueueManagerTestSuite runs all tests for the history task queue manager against a given queue provided by a particular database. This test suite should be re-used to test all queue implementations.

func RunNexusEndpointTestSuite 

func RunNexusEndpointTestSuite(t *testing.T, store persistence.NexusEndpointStore, tableVersion *atomic.Int64)

func RunNexusEndpointTestSuiteForSQL 

func RunNexusEndpointTestSuiteForSQL(t *testing.T, factory *sql.Factory)

func RunQueueV2TestSuite 

func RunQueueV2TestSuite(t *testing.T, q persistence.QueueV2)

RunQueueV2TestSuite executes interface-level tests for a queue persistence-layer implementation. There should be more implementation-specific tests that will not be covered by this suite elsewhere.

func RunQueueV2TestSuiteForSQL 

func RunQueueV2TestSuiteForSQL(t *testing.T, factory *sql.Factory)

func SetUpCassandraDatabase 

func SetUpCassandraDatabase(t *testing.T, cfg *config.Cassandra, logger log.Logger)

func SetUpCassandraSchema 

func SetUpCassandraSchema(t *testing.T, cfg *config.Cassandra, logger log.Logger)

func SetupMySQLDatabase 

func SetupMySQLDatabase(t *testing.T, cfg *config.SQL)

func SetupMySQLSchema 

func SetupMySQLSchema(t *testing.T, cfg *config.SQL)

func SetupPostgreSQLDatabase 

func SetupPostgreSQLDatabase(t *testing.T, cfg *config.SQL)

func SetupPostgreSQLSchema 

func SetupPostgreSQLSchema(t *testing.T, cfg *config.SQL)

func TearDownCassandraKeyspace 

func TearDownCassandraKeyspace(t *testing.T, cfg *config.Cassandra)

func TearDownMySQLDatabase 

func TearDownMySQLDatabase(t *testing.T, cfg *config.SQL)

func TearDownPostgreSQLDatabase 

func TearDownPostgreSQLDatabase(t *testing.T, cfg *config.SQL)

Types

type CassandraTestData 

type CassandraTestData struct {
	Cfg     *config.Cassandra
	Factory *cassandra.Factory
	Logger  log.Logger
}

type ExecutionMutableStateSuite 

type ExecutionMutableStateSuite struct {
	suite.Suite
	*require.Assertions
	protorequire.ProtoAssertions

	ShardID     int32
	RangeID     int64
	NamespaceID string
	WorkflowID  string
	RunID       string

	ShardManager      p.ShardManager
	ExecutionManager  p.ExecutionManager
	HistoryBranchUtil p.HistoryBranchUtil
	Logger            log.Logger

	Ctx    context.Context
	Cancel context.CancelFunc
}

func NewExecutionMutableStateSuite 

func NewExecutionMutableStateSuite(
	t *testing.T,
	shardStore p.ShardStore,
	executionStore p.ExecutionStore,
	serializer serialization.Serializer,
	logger log.Logger,
) *ExecutionMutableStateSuite

func (*ExecutionMutableStateSuite) Accumulate 

func (s *ExecutionMutableStateSuite) Accumulate(
	snapshot *p.WorkflowSnapshot,
	mutations ...*p.WorkflowMutation,
) (*persistencespb.WorkflowMutableState, int64)

func (*ExecutionMutableStateSuite) AssertHEEqualWithDB 

func (s *ExecutionMutableStateSuite) AssertHEEqualWithDB(branchToken []byte, events ...[]*p.WorkflowEvents)

func (*ExecutionMutableStateSuite) AssertHEPrefixWithDB 

func (s *ExecutionMutableStateSuite) AssertHEPrefixWithDB(branchToken []byte, events ...[]*p.WorkflowEvents)

func (*ExecutionMutableStateSuite) AssertMSEqualWithDB 

func (s *ExecutionMutableStateSuite) AssertMSEqualWithDB(
	archetypeID chasm.ArchetypeID,
	snapshot *p.WorkflowSnapshot,
	mutations ...*p.WorkflowMutation,
)

func (*ExecutionMutableStateSuite) AssertMissingFromDB 

func (s *ExecutionMutableStateSuite) AssertMissingFromDB(
	namespaceID string,
	workflowID string,
	runID string,
	archetypeID chasm.ArchetypeID,
)

func (*ExecutionMutableStateSuite) CreateCHASMExecution 

func (s *ExecutionMutableStateSuite) CreateCHASMExecution(
	lastWriteVersion int64,
	state enumsspb.WorkflowExecutionState,
	status enumspb.WorkflowExecutionStatus,
	dbRecordVersion int64,
	archetypeID chasm.ArchetypeID,
) *p.WorkflowSnapshot

func (*ExecutionMutableStateSuite) CreateWorkflow 

func (s *ExecutionMutableStateSuite) CreateWorkflow(
	lastWriteVersion int64,
	state enumsspb.WorkflowExecutionState,
	status enumspb.WorkflowExecutionStatus,
	dbRecordVersion int64,
) ([]byte, *p.WorkflowSnapshot, []*p.WorkflowEvents)

func (*ExecutionMutableStateSuite) SetupSuite 

func (s *ExecutionMutableStateSuite) SetupSuite()

func (*ExecutionMutableStateSuite) SetupTest 

func (s *ExecutionMutableStateSuite) SetupTest()

func (*ExecutionMutableStateSuite) TearDownSuite 

func (s *ExecutionMutableStateSuite) TearDownSuite()

func (*ExecutionMutableStateSuite) TearDownTest 

func (s *ExecutionMutableStateSuite) TearDownTest()

func (*ExecutionMutableStateSuite) TestArchetypeSeparateIDSpace 

func (s *ExecutionMutableStateSuite) TestArchetypeSeparateIDSpace()

func (*ExecutionMutableStateSuite) TestConflictResolve_ResetCurrent 

func (s *ExecutionMutableStateSuite) TestConflictResolve_ResetCurrent()

func (*ExecutionMutableStateSuite) TestConflictResolve_ResetCurrent_Conflict 

func (s *ExecutionMutableStateSuite) TestConflictResolve_ResetCurrent_Conflict()

func (*ExecutionMutableStateSuite) TestConflictResolve_ResetCurrent_CurrentConflict 

func (s *ExecutionMutableStateSuite) TestConflictResolve_ResetCurrent_CurrentConflict()

func (*ExecutionMutableStateSuite) TestConflictResolve_ResetCurrent_WithNew 

func (s *ExecutionMutableStateSuite) TestConflictResolve_ResetCurrent_WithNew()

func (*ExecutionMutableStateSuite) TestConflictResolve_SuppressCurrent 

func (s *ExecutionMutableStateSuite) TestConflictResolve_SuppressCurrent()

func (*ExecutionMutableStateSuite) TestConflictResolve_SuppressCurrent_Conflict_Case1 

func (s *ExecutionMutableStateSuite) TestConflictResolve_SuppressCurrent_Conflict_Case1()

func (*ExecutionMutableStateSuite) TestConflictResolve_SuppressCurrent_Conflict_Case2 

func (s *ExecutionMutableStateSuite) TestConflictResolve_SuppressCurrent_Conflict_Case2()

func (*ExecutionMutableStateSuite) TestConflictResolve_SuppressCurrent_CurrentConflict 

func (s *ExecutionMutableStateSuite) TestConflictResolve_SuppressCurrent_CurrentConflict()

func (*ExecutionMutableStateSuite) TestConflictResolve_SuppressCurrent_WithNew 

func (s *ExecutionMutableStateSuite) TestConflictResolve_SuppressCurrent_WithNew()

func (*ExecutionMutableStateSuite) TestConflictResolve_SuppressCurrent_WithNew_CHASM 

func (s *ExecutionMutableStateSuite) TestConflictResolve_SuppressCurrent_WithNew_CHASM()

func (*ExecutionMutableStateSuite) TestConflictResolve_Zombie 

func (s *ExecutionMutableStateSuite) TestConflictResolve_Zombie()

func (*ExecutionMutableStateSuite) TestConflictResolve_Zombie_Conflict 

func (s *ExecutionMutableStateSuite) TestConflictResolve_Zombie_Conflict()

func (*ExecutionMutableStateSuite) TestConflictResolve_Zombie_CurrentConflict 

func (s *ExecutionMutableStateSuite) TestConflictResolve_Zombie_CurrentConflict()

func (*ExecutionMutableStateSuite) TestConflictResolve_Zombie_WithNew 

func (s *ExecutionMutableStateSuite) TestConflictResolve_Zombie_WithNew()

func (*ExecutionMutableStateSuite) TestCreate_BrandNew 

func (s *ExecutionMutableStateSuite) TestCreate_BrandNew()

func (*ExecutionMutableStateSuite) TestCreate_BrandNew_CHASM 

func (s *ExecutionMutableStateSuite) TestCreate_BrandNew_CHASM()

func (*ExecutionMutableStateSuite) TestCreate_BrandNew_CurrentConflict 

func (s *ExecutionMutableStateSuite) TestCreate_BrandNew_CurrentConflict()

func (*ExecutionMutableStateSuite) TestCreate_ClosedWorkflow_BrandNew 

func (s *ExecutionMutableStateSuite) TestCreate_ClosedWorkflow_BrandNew()

func (*ExecutionMutableStateSuite) TestCreate_ClosedWorkflow_Bypass 

func (s *ExecutionMutableStateSuite) TestCreate_ClosedWorkflow_Bypass()

func (*ExecutionMutableStateSuite) TestCreate_ClosedWorkflow_UpdateCurrent 

func (s *ExecutionMutableStateSuite) TestCreate_ClosedWorkflow_UpdateCurrent()

func (*ExecutionMutableStateSuite) TestCreate_Conflict 

func (s *ExecutionMutableStateSuite) TestCreate_Conflict()

func (*ExecutionMutableStateSuite) TestCreate_Reuse 

func (s *ExecutionMutableStateSuite) TestCreate_Reuse()

func (*ExecutionMutableStateSuite) TestCreate_Reuse_CHASM 

func (s *ExecutionMutableStateSuite) TestCreate_Reuse_CHASM()

func (*ExecutionMutableStateSuite) TestCreate_Reuse_CurrentConflict 

func (s *ExecutionMutableStateSuite) TestCreate_Reuse_CurrentConflict()

func (*ExecutionMutableStateSuite) TestCreate_Zombie 

func (s *ExecutionMutableStateSuite) TestCreate_Zombie()

func (*ExecutionMutableStateSuite) TestDeleteCurrent_IsCurrent 

func (s *ExecutionMutableStateSuite) TestDeleteCurrent_IsCurrent()

func (*ExecutionMutableStateSuite) TestDeleteCurrent_NotCurrent 

func (s *ExecutionMutableStateSuite) TestDeleteCurrent_NotCurrent()

func (*ExecutionMutableStateSuite) TestDelete_Exists 

func (s *ExecutionMutableStateSuite) TestDelete_Exists()

func (*ExecutionMutableStateSuite) TestDelete_NotExists 

func (s *ExecutionMutableStateSuite) TestDelete_NotExists()

func (*ExecutionMutableStateSuite) TestListConcreteExecutions 

func (s *ExecutionMutableStateSuite) TestListConcreteExecutions()

func (*ExecutionMutableStateSuite) TestSet 

func (s *ExecutionMutableStateSuite) TestSet()

func (*ExecutionMutableStateSuite) TestSet_CHASM 

func (s *ExecutionMutableStateSuite) TestSet_CHASM()

func (*ExecutionMutableStateSuite) TestSet_Conflict 

func (s *ExecutionMutableStateSuite) TestSet_Conflict()

func (*ExecutionMutableStateSuite) TestSet_NotExists 

func (s *ExecutionMutableStateSuite) TestSet_NotExists()

func (*ExecutionMutableStateSuite) TestUpdate_ClosedWorkflow_IsCurrent 

func (s *ExecutionMutableStateSuite) TestUpdate_ClosedWorkflow_IsCurrent()

func (*ExecutionMutableStateSuite) TestUpdate_ClosedWorkflow_IsNonCurrent 

func (s *ExecutionMutableStateSuite) TestUpdate_ClosedWorkflow_IsNonCurrent()

func (*ExecutionMutableStateSuite) TestUpdate_NotZombie 

func (s *ExecutionMutableStateSuite) TestUpdate_NotZombie()

func (*ExecutionMutableStateSuite) TestUpdate_NotZombie_CHASM 

func (s *ExecutionMutableStateSuite) TestUpdate_NotZombie_CHASM()

func (*ExecutionMutableStateSuite) TestUpdate_NotZombie_Conflict 

func (s *ExecutionMutableStateSuite) TestUpdate_NotZombie_Conflict()

func (*ExecutionMutableStateSuite) TestUpdate_NotZombie_CurrentConflict 

func (s *ExecutionMutableStateSuite) TestUpdate_NotZombie_CurrentConflict()

func (*ExecutionMutableStateSuite) TestUpdate_NotZombie_WithNew 

func (s *ExecutionMutableStateSuite) TestUpdate_NotZombie_WithNew()

func (*ExecutionMutableStateSuite) TestUpdate_Zombie 

func (s *ExecutionMutableStateSuite) TestUpdate_Zombie()

func (*ExecutionMutableStateSuite) TestUpdate_Zombie_Conflict 

func (s *ExecutionMutableStateSuite) TestUpdate_Zombie_Conflict()

func (*ExecutionMutableStateSuite) TestUpdate_Zombie_CurrentConflict 

func (s *ExecutionMutableStateSuite) TestUpdate_Zombie_CurrentConflict()

func (*ExecutionMutableStateSuite) TestUpdate_Zombie_WithNew 

func (s *ExecutionMutableStateSuite) TestUpdate_Zombie_WithNew()

type ExecutionMutableStateTaskSuite 

type ExecutionMutableStateTaskSuite struct {
	suite.Suite
	*require.Assertions

	ShardID     int32
	RangeID     int64
	Owner       string
	WorkflowKey definition.WorkflowKey

	ShardManager     p.ShardManager
	ExecutionManager p.ExecutionManager
	Logger           log.Logger

	Ctx    context.Context
	Cancel context.CancelFunc
}

func NewExecutionMutableStateTaskSuite 

func NewExecutionMutableStateTaskSuite(
	t *testing.T,
	shardStore p.ShardStore,
	executionStore p.ExecutionStore,
	serializer serialization.Serializer,
	logger log.Logger,
) *ExecutionMutableStateTaskSuite

func (*ExecutionMutableStateTaskSuite) AddRandomTasks 

func (s *ExecutionMutableStateTaskSuite) AddRandomTasks(
	category tasks.Category,
	numTasks int,
	newTaskFn func(definition.WorkflowKey, int64, time.Time) tasks.Task,
) []tasks.Task

func (*ExecutionMutableStateTaskSuite) GetAndCompleteHistoryTask 

func (s *ExecutionMutableStateTaskSuite) GetAndCompleteHistoryTask(
	category tasks.Category,
	task tasks.Task,
)

func (*ExecutionMutableStateTaskSuite) PaginateTasks 

func (s *ExecutionMutableStateTaskSuite) PaginateTasks(
	category tasks.Category,
	inclusiveMinTaskKey tasks.Key,
	exclusiveMaxTaskKey tasks.Key,
	batchSize int,
) []tasks.Task

func (*ExecutionMutableStateTaskSuite) RandomPaginateRange 

func (s *ExecutionMutableStateTaskSuite) RandomPaginateRange(
	createdTasks []tasks.Task,
) ([]tasks.Task, tasks.Key, tasks.Key)

func (*ExecutionMutableStateTaskSuite) SetupTest 

func (s *ExecutionMutableStateTaskSuite) SetupTest()

func (*ExecutionMutableStateTaskSuite) TearDownTest 

func (s *ExecutionMutableStateTaskSuite) TearDownTest()

func (*ExecutionMutableStateTaskSuite) TestAddGetCompleteImmediateTask_Single 

func (s *ExecutionMutableStateTaskSuite) TestAddGetCompleteImmediateTask_Single()

func (*ExecutionMutableStateTaskSuite) TestAddGetCompleteReplicationTask_Single 

func (s *ExecutionMutableStateTaskSuite) TestAddGetCompleteReplicationTask_Single()

func (*ExecutionMutableStateTaskSuite) TestAddGetCompleteScheduledTask_Single 

func (s *ExecutionMutableStateTaskSuite) TestAddGetCompleteScheduledTask_Single()

func (*ExecutionMutableStateTaskSuite) TestAddGetCompleteTimerTask_Single 

func (s *ExecutionMutableStateTaskSuite) TestAddGetCompleteTimerTask_Single()

func (*ExecutionMutableStateTaskSuite) TestAddGetCompleteTransferTask_Single 

func (s *ExecutionMutableStateTaskSuite) TestAddGetCompleteTransferTask_Single()

func (*ExecutionMutableStateTaskSuite) TestAddGetCompleteVisibilityTask_Single 

func (s *ExecutionMutableStateTaskSuite) TestAddGetCompleteVisibilityTask_Single()

func (*ExecutionMutableStateTaskSuite) TestAddGetRangeCompleteImmediateTasks_Multiple 

func (s *ExecutionMutableStateTaskSuite) TestAddGetRangeCompleteImmediateTasks_Multiple()

func (*ExecutionMutableStateTaskSuite) TestAddGetRangeCompleteScheduledTasks_Multiple 

func (s *ExecutionMutableStateTaskSuite) TestAddGetRangeCompleteScheduledTasks_Multiple()

func (*ExecutionMutableStateTaskSuite) TestAddGetReplicationTasks_Multiple 

func (s *ExecutionMutableStateTaskSuite) TestAddGetReplicationTasks_Multiple()

func (*ExecutionMutableStateTaskSuite) TestAddGetTimerTasks_Multiple 

func (s *ExecutionMutableStateTaskSuite) TestAddGetTimerTasks_Multiple()

func (*ExecutionMutableStateTaskSuite) TestAddGetTransferTasks_Multiple 

func (s *ExecutionMutableStateTaskSuite) TestAddGetTransferTasks_Multiple()

func (*ExecutionMutableStateTaskSuite) TestAddGetVisibilityTasks_Multiple 

func (s *ExecutionMutableStateTaskSuite) TestAddGetVisibilityTasks_Multiple()

func (*ExecutionMutableStateTaskSuite) TestGetScheduledTasksOrdered 

func (s *ExecutionMutableStateTaskSuite) TestGetScheduledTasksOrdered()

func (*ExecutionMutableStateTaskSuite) TestGetTimerTasksOrdered 

func (s *ExecutionMutableStateTaskSuite) TestGetTimerTasksOrdered()

func (*ExecutionMutableStateTaskSuite) TestIsReplicationDLQEmpty 

func (s *ExecutionMutableStateTaskSuite) TestIsReplicationDLQEmpty()

type HistoryEventsPacket 

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

type HistoryEventsSuite 

type HistoryEventsSuite struct {
	suite.Suite
	*require.Assertions
	protorequire.ProtoAssertions

	ShardID int32

	Ctx    context.Context
	Cancel context.CancelFunc
	// contains filtered or unexported fields
}

func NewHistoryEventsSuite 

func NewHistoryEventsSuite(
	t *testing.T,
	store p.ExecutionStore,
	logger log.Logger,
) *HistoryEventsSuite

func (*HistoryEventsSuite) SetupSuite 

func (s *HistoryEventsSuite) SetupSuite()

func (*HistoryEventsSuite) SetupTest 

func (s *HistoryEventsSuite) SetupTest()

func (*HistoryEventsSuite) TearDownSuite 

func (s *HistoryEventsSuite) TearDownSuite()

func (*HistoryEventsSuite) TearDownTest 

func (s *HistoryEventsSuite) TearDownTest()

func (*HistoryEventsSuite) TestAppendBatches 

func (s *HistoryEventsSuite) TestAppendBatches()

func (*HistoryEventsSuite) TestAppendForkSelectTrim_LastBranch 

func (s *HistoryEventsSuite) TestAppendForkSelectTrim_LastBranch()

func (*HistoryEventsSuite) TestAppendForkSelectTrim_NonLastBranch 

func (s *HistoryEventsSuite) TestAppendForkSelectTrim_NonLastBranch()

func (*HistoryEventsSuite) TestAppendForkSelect_NoShadowing 

func (s *HistoryEventsSuite) TestAppendForkSelect_NoShadowing()

func (*HistoryEventsSuite) TestAppendForkSelect_Shadowing_LastBranch 

func (s *HistoryEventsSuite) TestAppendForkSelect_Shadowing_LastBranch()

func (*HistoryEventsSuite) TestAppendForkSelect_Shadowing_NonLastBranch 

func (s *HistoryEventsSuite) TestAppendForkSelect_Shadowing_NonLastBranch()

func (*HistoryEventsSuite) TestAppendSelectTrim 

func (s *HistoryEventsSuite) TestAppendSelectTrim()

func (*HistoryEventsSuite) TestAppendSelect_First 

func (s *HistoryEventsSuite) TestAppendSelect_First()

func (*HistoryEventsSuite) TestAppendSelect_NonShadowing 

func (s *HistoryEventsSuite) TestAppendSelect_NonShadowing()

func (*HistoryEventsSuite) TestAppendSelect_Shadowing 

func (s *HistoryEventsSuite) TestAppendSelect_Shadowing()

func (*HistoryEventsSuite) TestForkDeleteBranch_DeleteBaseBranchFirst 

func (s *HistoryEventsSuite) TestForkDeleteBranch_DeleteBaseBranchFirst()

func (*HistoryEventsSuite) TestForkDeleteBranch_DeleteForkedBranchFirst 

func (s *HistoryEventsSuite) TestForkDeleteBranch_DeleteForkedBranchFirst()

type MySQLTestData 

type MySQLTestData struct {
	Cfg     *config.SQL
	Factory *sql.Factory
	Logger  log.Logger
	Metrics *metricstest.Capture
}

type PostgreSQLTestData 

type PostgreSQLTestData struct {
	Cfg     *config.SQL
	Factory *sql.Factory
	Logger  log.Logger
	Metrics *metricstest.Capture
}

type ShardSuite 

type ShardSuite struct {
	suite.Suite
	*require.Assertions
	protorequire.ProtoAssertions

	ShardID int32

	ShardManager p.ShardManager
	Logger       log.Logger

	Ctx    context.Context
	Cancel context.CancelFunc
}

func NewShardSuite 

func NewShardSuite(
	t *testing.T,
	shardStore p.ShardStore,
	serializer serialization.Serializer,
	logger log.Logger,
) *ShardSuite

func (*ShardSuite) SetupSuite 

func (s *ShardSuite) SetupSuite()

func (*ShardSuite) SetupTest 

func (s *ShardSuite) SetupTest()

func (*ShardSuite) TearDownSuite 

func (s *ShardSuite) TearDownSuite()

func (*ShardSuite) TearDownTest 

func (s *ShardSuite) TearDownTest()

func (*ShardSuite) TestGetOrCreateShard_Create 

func (s *ShardSuite) TestGetOrCreateShard_Create()

func (*ShardSuite) TestGetOrCreateShard_Get 

func (s *ShardSuite) TestGetOrCreateShard_Get()

func (*ShardSuite) TestUpdateShard_OwnershipLost 

func (s *ShardSuite) TestUpdateShard_OwnershipLost()

func (*ShardSuite) TestUpdateShard_Success 

func (s *ShardSuite) TestUpdateShard_Success()

type TaskQueueFairTaskSuite 

type TaskQueueFairTaskSuite struct {
	suite.Suite
	*require.Assertions
	// contains filtered or unexported fields
}

func NewTaskQueueFairTaskSuite 

func NewTaskQueueFairTaskSuite(
	t *testing.T,
	taskStore p.TaskStore,
	logger log.Logger,
) *TaskQueueFairTaskSuite

func (*TaskQueueFairTaskSuite) SetupSuite 

func (s *TaskQueueFairTaskSuite) SetupSuite()

func (*TaskQueueFairTaskSuite) SetupTest 

func (s *TaskQueueFairTaskSuite) SetupTest()

func (*TaskQueueFairTaskSuite) TearDownSuite 

func (s *TaskQueueFairTaskSuite) TearDownSuite()

func (*TaskQueueFairTaskSuite) TearDownTest 

func (s *TaskQueueFairTaskSuite) TearDownTest()

func (*TaskQueueFairTaskSuite) TestCreateDelete_Range 

func (s *TaskQueueFairTaskSuite) TestCreateDelete_Range()

func (*TaskQueueFairTaskSuite) TestCreateGet_Order 

func (s *TaskQueueFairTaskSuite) TestCreateGet_Order()

type TaskQueueSuite 

type TaskQueueSuite struct {
	suite.Suite
	*require.Assertions
	protorequire.ProtoAssertions
	// contains filtered or unexported fields
}

func NewTaskQueueSuite 

func NewTaskQueueSuite(
	t *testing.T,
	taskStore p.TaskStore,
	logger log.Logger,
) *TaskQueueSuite

func (*TaskQueueSuite) SetupSuite 

func (s *TaskQueueSuite) SetupSuite()

func (*TaskQueueSuite) SetupTest 

func (s *TaskQueueSuite) SetupTest()

func (*TaskQueueSuite) TearDownSuite 

func (s *TaskQueueSuite) TearDownSuite()

func (*TaskQueueSuite) TearDownTest 

func (s *TaskQueueSuite) TearDownTest()

func (*TaskQueueSuite) TesList 

func (s *TaskQueueSuite) TesList()

func (*TaskQueueSuite) TestCreate_Normal 

func (s *TaskQueueSuite) TestCreate_Normal()

func (*TaskQueueSuite) TestCreate_Normal_Dup 

func (s *TaskQueueSuite) TestCreate_Normal_Dup()

func (*TaskQueueSuite) TestCreate_Sticky 

func (s *TaskQueueSuite) TestCreate_Sticky()

func (*TaskQueueSuite) TestCreate_Sticky_Dup 

func (s *TaskQueueSuite) TestCreate_Sticky_Dup()

func (*TaskQueueSuite) TestDelete 

func (s *TaskQueueSuite) TestDelete()

func (*TaskQueueSuite) TestDelete_Conflict 

func (s *TaskQueueSuite) TestDelete_Conflict()

func (*TaskQueueSuite) TestUpdate_Normal 

func (s *TaskQueueSuite) TestUpdate_Normal()

func (*TaskQueueSuite) TestUpdate_Normal_Conflict 

func (s *TaskQueueSuite) TestUpdate_Normal_Conflict()

func (*TaskQueueSuite) TestUpdate_Sticky 

func (s *TaskQueueSuite) TestUpdate_Sticky()

func (*TaskQueueSuite) TestUpdate_Sticky_Conflict 

func (s *TaskQueueSuite) TestUpdate_Sticky_Conflict()

type TaskQueueTaskSuite 

type TaskQueueTaskSuite struct {
	suite.Suite
	*require.Assertions
	// contains filtered or unexported fields
}

func NewTaskQueueTaskSuite 

func NewTaskQueueTaskSuite(
	t *testing.T,
	taskStore p.TaskStore,
	logger log.Logger,
) *TaskQueueTaskSuite

func (*TaskQueueTaskSuite) SetupSuite 

func (s *TaskQueueTaskSuite) SetupSuite()

func (*TaskQueueTaskSuite) SetupTest 

func (s *TaskQueueTaskSuite) SetupTest()

func (*TaskQueueTaskSuite) TearDownSuite 

func (s *TaskQueueTaskSuite) TearDownSuite()

func (*TaskQueueTaskSuite) TearDownTest 

func (s *TaskQueueTaskSuite) TearDownTest()

func (*TaskQueueTaskSuite) TestCreateDelete_Multiple 

func (s *TaskQueueTaskSuite) TestCreateDelete_Multiple()

func (*TaskQueueTaskSuite) TestCreateGet_Conflict 

func (s *TaskQueueTaskSuite) TestCreateGet_Conflict()

func (*TaskQueueTaskSuite) TestCreateGet_Multiple 

func (s *TaskQueueTaskSuite) TestCreateGet_Multiple()

func (*TaskQueueTaskSuite) TestCreateGet_One 

func (s *TaskQueueTaskSuite) TestCreateGet_One()

type TaskQueueUserDataSuite 

type TaskQueueUserDataSuite struct {
	suite.Suite
	*require.Assertions
	// contains filtered or unexported fields
}

func NewTaskQueueUserDataSuite 

func NewTaskQueueUserDataSuite(
	t *testing.T,
	taskStore p.TaskStore,
	logger log.Logger,
) *TaskQueueUserDataSuite

func (*TaskQueueUserDataSuite) SetupTest 

func (s *TaskQueueUserDataSuite) SetupTest()

func (*TaskQueueUserDataSuite) TearDownTest 

func (s *TaskQueueUserDataSuite) TearDownTest()

func (*TaskQueueUserDataSuite) TestSetInitialAndIncrement 

func (s *TaskQueueUserDataSuite) TestSetInitialAndIncrement()

func (*TaskQueueUserDataSuite) TestUpdateConflict 

func (s *TaskQueueUserDataSuite) TestUpdateConflict()

type VisibilityPersistenceSuite 

type VisibilityPersistenceSuite 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

	*persistencetests.TestBase
	NamespaceRegistry              namespace.Registry
	VisibilityMgr                  manager.VisibilityManager
	SearchAttributesProvider       searchattribute.Provider
	SearchAttributesMapperProvider searchattribute.MapperProvider
	CustomVisibilityStoreFactory   visibility.VisibilityStoreFactory
	// contains filtered or unexported fields
}

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) TearDownTest 

func (s *VisibilityPersistenceSuite) TearDownTest()

func (*VisibilityPersistenceSuite) TestAdvancedVisibilityPagination 

func (s *VisibilityPersistenceSuite) TestAdvancedVisibilityPagination()

TestAdvancedVisibilityPagination test

func (*VisibilityPersistenceSuite) TestBasicVisibility 

func (s *VisibilityPersistenceSuite) TestBasicVisibility()

TestBasicVisibility test

func (*VisibilityPersistenceSuite) TestBasicVisibilityShortWorkflow 

func (s *VisibilityPersistenceSuite) TestBasicVisibilityShortWorkflow()

func (*VisibilityPersistenceSuite) TestBasicVisibilityTimeSkew 

func (s *VisibilityPersistenceSuite) TestBasicVisibilityTimeSkew()

TestBasicVisibilityTimeSkew test

func (*VisibilityPersistenceSuite) TestCountGroupByWorkflowExecutions 

func (s *VisibilityPersistenceSuite) TestCountGroupByWorkflowExecutions()

func (*VisibilityPersistenceSuite) TestCountWorkflowExecutions 

func (s *VisibilityPersistenceSuite) TestCountWorkflowExecutions()

func (*VisibilityPersistenceSuite) TestDeleteWorkflow 

func (s *VisibilityPersistenceSuite) TestDeleteWorkflow()

TestDelete test

func (*VisibilityPersistenceSuite) TestFilteringByStartTime 

func (s *VisibilityPersistenceSuite) TestFilteringByStartTime()

TestFilteringByStartTime test

func (*VisibilityPersistenceSuite) TestFilteringByStatus 

func (s *VisibilityPersistenceSuite) TestFilteringByStatus()

TestFilteringByStatus test

func (*VisibilityPersistenceSuite) TestFilteringByType 

func (s *VisibilityPersistenceSuite) TestFilteringByType()

TestFilteringByType test

func (*VisibilityPersistenceSuite) TestFilteringByWorkflowID 

func (s *VisibilityPersistenceSuite) TestFilteringByWorkflowID()

TestFilteringByWorkflowID test

func (*VisibilityPersistenceSuite) TestGetWorkflowExecution 

func (s *VisibilityPersistenceSuite) TestGetWorkflowExecution()

TestGetWorkflowExecution test

func (*VisibilityPersistenceSuite) TestUpsertWorkflowExecution 

func (s *VisibilityPersistenceSuite) TestUpsertWorkflowExecution()

TestUpsertWorkflowExecution test

func (*VisibilityPersistenceSuite) TestVisibilityPagination 

func (s *VisibilityPersistenceSuite) TestVisibilityPagination()

TestVisibilityPagination test

Source Files

View all Source files

Jump to

Keyboard shortcuts

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