tests

package
v1.26.2-121.2 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ApplySchemaUpdate added in v1.15.0 

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

func GetSchemaFiles added in v1.15.0 

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 added in v1.16.0 

func NewCassandraConfig() *config.Cassandra

NewCassandraConfig returns a new Cassandra config for test

func NewMySQLConfig added in v1.17.0 

func NewMySQLConfig() *config.SQL

NewMySQLConfig returns a new MySQL config for test

func NewPostgreSQLConfig added in v1.17.0 

func NewPostgreSQLConfig(pluginName string) *config.SQL

NewPostgreSQLConfig returns a new MySQL config for test

func RandomActivityInfo added in v1.15.0 

func RandomActivityInfo() *persistencespb.ActivityInfo

func RandomBranchToken added in v1.24.0 

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

func RandomChildExecutionInfo added in v1.15.0 

func RandomChildExecutionInfo() *persistencespb.ChildExecutionInfo

func RandomDuration added in v1.15.0 

func RandomDuration() *durationpb.Duration

func RandomExecutionInfo added in v1.15.0 

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

func RandomExecutionState added in v1.15.0 

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

func RandomHistoryEvent added in v1.15.0 

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

func RandomInt64ActivityInfoMap added in v1.15.0 

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

func RandomInt64ChildExecutionInfoMap added in v1.15.0 

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

func RandomInt64RequestCancelInfoMap added in v1.15.0 

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

func RandomInt64SignalInfoMap added in v1.15.0 

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

func RandomMutation added in v1.15.0 

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 added in v1.15.0 

func RandomPayload() *commonpb.Payload

func RandomRequestCancelInfo added in v1.15.0 

func RandomRequestCancelInfo() *persistencespb.RequestCancelInfo

func RandomResetPoints added in v1.15.0 

func RandomResetPoints() *workflowpb.ResetPoints

func RandomShardInfo added in v1.17.0 

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

func RandomSignalInfo added in v1.15.0 

func RandomSignalInfo() *persistencespb.SignalInfo

func RandomSnapshot added in v1.15.0 

func RandomSnapshot(
	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 added in v1.15.0 

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

func RandomStringTimerInfoMap added in v1.15.0 

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

func RandomTime added in v1.15.0 

func RandomTime() *timestamppb.Timestamp

func RandomTimerInfo added in v1.15.0 

func RandomTimerInfo() *persistencespb.TimerInfo

func RandomVersionHistory added in v1.15.0 

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

func RunHistoryTaskQueueManagerTestSuite added in v1.23.0 

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 added in v1.25.0 

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

func RunNexusEndpointTestSuiteForSQL added in v1.25.0 

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

func RunQueueV2TestSuite added in v1.23.0 

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 added in v1.23.0 

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

func SetUpCassandraDatabase added in v1.15.0 

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

func SetUpCassandraSchema added in v1.15.0 

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

func SetupMySQLDatabase added in v1.17.0 

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

func SetupMySQLSchema added in v1.17.0 

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

func SetupPostgreSQLDatabase added in v1.17.0 

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

func SetupPostgreSQLSchema added in v1.17.0 

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

func TearDownCassandraKeyspace added in v1.15.0 

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

func TearDownMySQLDatabase added in v1.17.0 

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

func TearDownPostgreSQLDatabase added in v1.17.0 

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

Types

type CassandraTestData added in v1.16.0 

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

	Logger log.Logger

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

func NewExecutionMutableStateSuite 

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

func (*ExecutionMutableStateSuite) Accumulate added in v1.15.0 

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

func (*ExecutionMutableStateSuite) AssertHEEqualWithDB added in v1.24.0 

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

func (*ExecutionMutableStateSuite) AssertMSEqualWithDB added in v1.24.0 

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

func (*ExecutionMutableStateSuite) AssertMissingFromDB added in v1.15.0 

func (s *ExecutionMutableStateSuite) AssertMissingFromDB(
	namespaceID string,
	workflowID string,
	runID string,
)

func (*ExecutionMutableStateSuite) CreateWorkflow added in v1.15.0 

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) 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_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_CurrentConflict 

func (s *ExecutionMutableStateSuite) TestCreate_BrandNew_CurrentConflict()

func (*ExecutionMutableStateSuite) TestCreate_ClosedWorkflow_BrandNew added in v1.17.0 

func (s *ExecutionMutableStateSuite) TestCreate_ClosedWorkflow_BrandNew()

func (*ExecutionMutableStateSuite) TestCreate_ClosedWorkflow_Bypass added in v1.17.0 

func (s *ExecutionMutableStateSuite) TestCreate_ClosedWorkflow_Bypass()

func (*ExecutionMutableStateSuite) TestCreate_ClosedWorkflow_UpdateCurrent added in v1.17.0 

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_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) TestSet added in v1.16.0 

func (s *ExecutionMutableStateSuite) TestSet()

func (*ExecutionMutableStateSuite) TestSet_Conflict added in v1.16.0 

func (s *ExecutionMutableStateSuite) TestSet_Conflict()

func (*ExecutionMutableStateSuite) TestSet_NotExists added in v1.16.0 

func (s *ExecutionMutableStateSuite) TestSet_NotExists()

func (*ExecutionMutableStateSuite) TestUpdate_NotZombie 

func (s *ExecutionMutableStateSuite) TestUpdate_NotZombie()

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 added in v1.16.0 

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 added in v1.16.0 

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

func (*ExecutionMutableStateTaskSuite) AddRandomTasks added in v1.16.0 

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

func (*ExecutionMutableStateTaskSuite) GetAndCompleteHistoryTask added in v1.19.0 

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

func (*ExecutionMutableStateTaskSuite) PaginateTasks added in v1.16.0 

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

func (*ExecutionMutableStateTaskSuite) RandomPaginateRange added in v1.16.0 

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

func (*ExecutionMutableStateTaskSuite) SetupTest added in v1.16.0 

func (s *ExecutionMutableStateTaskSuite) SetupTest()

func (*ExecutionMutableStateTaskSuite) TearDownTest added in v1.16.0 

func (s *ExecutionMutableStateTaskSuite) TearDownTest()

func (*ExecutionMutableStateTaskSuite) TestAddGetCompleteImmediateTask_Single added in v1.19.0 

func (s *ExecutionMutableStateTaskSuite) TestAddGetCompleteImmediateTask_Single()

func (*ExecutionMutableStateTaskSuite) TestAddGetCompleteReplicationTask_Single added in v1.19.0 

func (s *ExecutionMutableStateTaskSuite) TestAddGetCompleteReplicationTask_Single()

func (*ExecutionMutableStateTaskSuite) TestAddGetCompleteScheduledTask_Single added in v1.19.0 

func (s *ExecutionMutableStateTaskSuite) TestAddGetCompleteScheduledTask_Single()

func (*ExecutionMutableStateTaskSuite) TestAddGetCompleteTimerTask_Single added in v1.19.0 

func (s *ExecutionMutableStateTaskSuite) TestAddGetCompleteTimerTask_Single()

func (*ExecutionMutableStateTaskSuite) TestAddGetCompleteTransferTask_Single added in v1.19.0 

func (s *ExecutionMutableStateTaskSuite) TestAddGetCompleteTransferTask_Single()

func (*ExecutionMutableStateTaskSuite) TestAddGetCompleteVisibilityTask_Single added in v1.19.0 

func (s *ExecutionMutableStateTaskSuite) TestAddGetCompleteVisibilityTask_Single()

func (*ExecutionMutableStateTaskSuite) TestAddGetRangeCompleteImmediateTasks_Multiple added in v1.19.0 

func (s *ExecutionMutableStateTaskSuite) TestAddGetRangeCompleteImmediateTasks_Multiple()

func (*ExecutionMutableStateTaskSuite) TestAddGetRangeCompleteScheduledTasks_Multiple added in v1.19.0 

func (s *ExecutionMutableStateTaskSuite) TestAddGetRangeCompleteScheduledTasks_Multiple()

func (*ExecutionMutableStateTaskSuite) TestAddGetReplicationTasks_Multiple added in v1.16.0 

func (s *ExecutionMutableStateTaskSuite) TestAddGetReplicationTasks_Multiple()

func (*ExecutionMutableStateTaskSuite) TestAddGetTimerTasks_Multiple added in v1.16.0 

func (s *ExecutionMutableStateTaskSuite) TestAddGetTimerTasks_Multiple()

func (*ExecutionMutableStateTaskSuite) TestAddGetTransferTasks_Multiple added in v1.16.0 

func (s *ExecutionMutableStateTaskSuite) TestAddGetTransferTasks_Multiple()

func (*ExecutionMutableStateTaskSuite) TestAddGetVisibilityTasks_Multiple added in v1.16.0 

func (s *ExecutionMutableStateTaskSuite) TestAddGetVisibilityTasks_Multiple()

func (*ExecutionMutableStateTaskSuite) TestGetScheduledTasksOrdered added in v1.19.0 

func (s *ExecutionMutableStateTaskSuite) TestGetScheduledTasksOrdered()

func (*ExecutionMutableStateTaskSuite) TestGetTimerTasksOrdered added in v1.19.0 

func (s *ExecutionMutableStateTaskSuite) TestGetTimerTasksOrdered()

func (*ExecutionMutableStateTaskSuite) TestIsReplicationDLQEmpty added in v1.21.0 

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 added in v1.17.0 

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 added in v1.15.0 

func (s *HistoryEventsSuite) TestForkDeleteBranch_DeleteBaseBranchFirst()

func (*HistoryEventsSuite) TestForkDeleteBranch_DeleteForkedBranchFirst added in v1.15.0 

func (s *HistoryEventsSuite) TestForkDeleteBranch_DeleteForkedBranchFirst()

type MySQLTestData added in v1.17.0 

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

type PostgreSQLTestData added in v1.17.0 

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

type ShardSuite added in v1.17.0 

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 added in v1.17.0 

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

func (*ShardSuite) SetupSuite added in v1.17.0 

func (s *ShardSuite) SetupSuite()

func (*ShardSuite) SetupTest added in v1.17.0 

func (s *ShardSuite) SetupTest()

func (*ShardSuite) TearDownSuite added in v1.17.0 

func (s *ShardSuite) TearDownSuite()

func (*ShardSuite) TearDownTest added in v1.17.0 

func (s *ShardSuite) TearDownTest()

func (*ShardSuite) TestGetOrCreateShard_Create added in v1.17.0 

func (s *ShardSuite) TestGetOrCreateShard_Create()

func (*ShardSuite) TestGetOrCreateShard_Get added in v1.17.0 

func (s *ShardSuite) TestGetOrCreateShard_Get()

func (*ShardSuite) TestUpdateShard_OwnershipLost added in v1.17.0 

func (s *ShardSuite) TestUpdateShard_OwnershipLost()

func (*ShardSuite) TestUpdateShard_Success added in v1.17.0 

func (s *ShardSuite) TestUpdateShard_Success()

type TaskQueueSuite added in v1.15.0 

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

func NewTaskQueueSuite added in v1.15.0 

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

func (*TaskQueueSuite) SetupSuite added in v1.15.0 

func (s *TaskQueueSuite) SetupSuite()

func (*TaskQueueSuite) SetupTest added in v1.15.0 

func (s *TaskQueueSuite) SetupTest()

func (*TaskQueueSuite) TearDownSuite added in v1.15.0 

func (s *TaskQueueSuite) TearDownSuite()

func (*TaskQueueSuite) TearDownTest added in v1.15.0 

func (s *TaskQueueSuite) TearDownTest()

func (*TaskQueueSuite) TesList added in v1.15.0 

func (s *TaskQueueSuite) TesList()

func (*TaskQueueSuite) TestCreate_Normal added in v1.15.0 

func (s *TaskQueueSuite) TestCreate_Normal()

func (*TaskQueueSuite) TestCreate_Normal_Dup added in v1.15.0 

func (s *TaskQueueSuite) TestCreate_Normal_Dup()

func (*TaskQueueSuite) TestCreate_Sticky added in v1.15.0 

func (s *TaskQueueSuite) TestCreate_Sticky()

func (*TaskQueueSuite) TestCreate_Sticky_Dup added in v1.15.0 

func (s *TaskQueueSuite) TestCreate_Sticky_Dup()

func (*TaskQueueSuite) TestDelete added in v1.15.0 

func (s *TaskQueueSuite) TestDelete()

func (*TaskQueueSuite) TestDelete_Conflict added in v1.15.0 

func (s *TaskQueueSuite) TestDelete_Conflict()

func (*TaskQueueSuite) TestUpdate_Normal added in v1.15.0 

func (s *TaskQueueSuite) TestUpdate_Normal()

func (*TaskQueueSuite) TestUpdate_Normal_Conflict added in v1.15.0 

func (s *TaskQueueSuite) TestUpdate_Normal_Conflict()

func (*TaskQueueSuite) TestUpdate_Sticky added in v1.15.0 

func (s *TaskQueueSuite) TestUpdate_Sticky()

func (*TaskQueueSuite) TestUpdate_Sticky_Conflict added in v1.15.0 

func (s *TaskQueueSuite) TestUpdate_Sticky_Conflict()

type TaskQueueTaskSuite added in v1.15.0 

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

func NewTaskQueueTaskSuite added in v1.15.0 

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

func (*TaskQueueTaskSuite) SetupSuite added in v1.15.0 

func (s *TaskQueueTaskSuite) SetupSuite()

func (*TaskQueueTaskSuite) SetupTest added in v1.15.0 

func (s *TaskQueueTaskSuite) SetupTest()

func (*TaskQueueTaskSuite) TearDownSuite added in v1.15.0 

func (s *TaskQueueTaskSuite) TearDownSuite()

func (*TaskQueueTaskSuite) TearDownTest added in v1.15.0 

func (s *TaskQueueTaskSuite) TearDownTest()

func (*TaskQueueTaskSuite) TestCreateDelete_Multiple added in v1.15.0 

func (s *TaskQueueTaskSuite) TestCreateDelete_Multiple()

func (*TaskQueueTaskSuite) TestCreateGet_Conflict added in v1.15.0 

func (s *TaskQueueTaskSuite) TestCreateGet_Conflict()

func (*TaskQueueTaskSuite) TestCreateGet_Multiple added in v1.15.0 

func (s *TaskQueueTaskSuite) TestCreateGet_Multiple()

func (*TaskQueueTaskSuite) TestCreateGet_One added in v1.15.0 

func (s *TaskQueueTaskSuite) TestCreateGet_One()

type VisibilityPersistenceSuite added in v1.23.0 

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 added in v1.23.0 

func (s *VisibilityPersistenceSuite) SetupSuite()

SetupSuite implementation

func (*VisibilityPersistenceSuite) SetupTest added in v1.23.0 

func (s *VisibilityPersistenceSuite) SetupTest()

SetupTest implementation

func (*VisibilityPersistenceSuite) TearDownSuite added in v1.23.0 

func (s *VisibilityPersistenceSuite) TearDownSuite()

TearDownSuite implementation

func (*VisibilityPersistenceSuite) TearDownTest added in v1.23.0 

func (s *VisibilityPersistenceSuite) TearDownTest()

func (*VisibilityPersistenceSuite) TestAdvancedVisibilityPagination added in v1.23.0 

func (s *VisibilityPersistenceSuite) TestAdvancedVisibilityPagination()

TestAdvancedVisibilityPagination test

func (*VisibilityPersistenceSuite) TestBasicVisibility added in v1.23.0 

func (s *VisibilityPersistenceSuite) TestBasicVisibility()

TestBasicVisibility test

func (*VisibilityPersistenceSuite) TestBasicVisibilityShortWorkflow added in v1.23.0 

func (s *VisibilityPersistenceSuite) TestBasicVisibilityShortWorkflow()

func (*VisibilityPersistenceSuite) TestBasicVisibilityTimeSkew added in v1.23.0 

func (s *VisibilityPersistenceSuite) TestBasicVisibilityTimeSkew()

TestBasicVisibilityTimeSkew test

func (*VisibilityPersistenceSuite) TestCountGroupByWorkflowExecutions added in v1.23.0 

func (s *VisibilityPersistenceSuite) TestCountGroupByWorkflowExecutions()

func (*VisibilityPersistenceSuite) TestCountWorkflowExecutions added in v1.23.0 

func (s *VisibilityPersistenceSuite) TestCountWorkflowExecutions()

func (*VisibilityPersistenceSuite) TestDeleteWorkflow added in v1.23.0 

func (s *VisibilityPersistenceSuite) TestDeleteWorkflow()

TestDelete test

func (*VisibilityPersistenceSuite) TestFilteringByStartTime added in v1.23.0 

func (s *VisibilityPersistenceSuite) TestFilteringByStartTime()

TestFilteringByStartTime test

func (*VisibilityPersistenceSuite) TestFilteringByStatus added in v1.23.0 

func (s *VisibilityPersistenceSuite) TestFilteringByStatus()

TestFilteringByStatus test

func (*VisibilityPersistenceSuite) TestFilteringByType added in v1.23.0 

func (s *VisibilityPersistenceSuite) TestFilteringByType()

TestFilteringByType test

func (*VisibilityPersistenceSuite) TestFilteringByWorkflowID added in v1.23.0 

func (s *VisibilityPersistenceSuite) TestFilteringByWorkflowID()

TestFilteringByWorkflowID test

func (*VisibilityPersistenceSuite) TestGetWorkflowExecution added in v1.23.0 

func (s *VisibilityPersistenceSuite) TestGetWorkflowExecution()

TestGetWorkflowExecution test

func (*VisibilityPersistenceSuite) TestUpsertWorkflowExecution added in v1.23.0 

func (s *VisibilityPersistenceSuite) TestUpsertWorkflowExecution()

TestUpsertWorkflowExecution test

func (*VisibilityPersistenceSuite) TestVisibilityPagination added in v1.23.0 

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.