ndc

Documentation

Index

• type NDCIntegrationTestSuite
  • func NewNDCIntegrationTestSuite(params NDCIntegrationTestSuiteParams) *NDCIntegrationTestSuite
  • func (s *NDCIntegrationTestSuite) GetReplicationMessagesMock(ctx context.Context, request *types.GetReplicationMessagesRequest, ...) (*types.GetReplicationMessagesResponse, error)
  • func (s *NDCIntegrationTestSuite) SetupSuite()
  • func (s *NDCIntegrationTestSuite) SetupTest()
  • func (s *NDCIntegrationTestSuite) TearDownSuite()
  • func (s *NDCIntegrationTestSuite) TestAdminGetWorkflowExecutionRawHistoryV2()
  • func (s *NDCIntegrationTestSuite) TestEventsReapply_UpdateNonCurrentBranch()
  • func (s *NDCIntegrationTestSuite) TestEventsReapply_ZombieWorkflow()
  • func (s *NDCIntegrationTestSuite) TestHandcraftedMultipleBranches()
  • func (s *NDCIntegrationTestSuite) TestHandcraftedMultipleBranchesWithZombieContinueAsNew()
  • func (s *NDCIntegrationTestSuite) TestMultipleBranches()
  • func (s *NDCIntegrationTestSuite) TestReplicationMessageApplication()
  • func (s *NDCIntegrationTestSuite) TestReplicationMessageDLQ()
  • func (s *NDCIntegrationTestSuite) TestSingleBranch()
• type NDCIntegrationTestSuiteParams

Types

type NDCIntegrationTestSuite

type NDCIntegrationTestSuite 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
	suite.Suite
	// contains filtered or unexported fields
}

func NewNDCIntegrationTestSuite

func NewNDCIntegrationTestSuite(params NDCIntegrationTestSuiteParams) *NDCIntegrationTestSuite

func (*NDCIntegrationTestSuite) GetReplicationMessagesMock

func (s *NDCIntegrationTestSuite) GetReplicationMessagesMock(
	ctx context.Context,
	request *types.GetReplicationMessagesRequest,
	opts ...yarpc.CallOption,
) (*types.GetReplicationMessagesResponse, error)

func (*NDCIntegrationTestSuite) SetupSuite

func (s *NDCIntegrationTestSuite) SetupSuite()

func (*NDCIntegrationTestSuite) SetupTest

func (s *NDCIntegrationTestSuite) SetupTest()

func (*NDCIntegrationTestSuite) TearDownSuite

func (s *NDCIntegrationTestSuite) TearDownSuite()

func (*NDCIntegrationTestSuite) TestAdminGetWorkflowExecutionRawHistoryV2

func (s *NDCIntegrationTestSuite) TestAdminGetWorkflowExecutionRawHistoryV2()

func (*NDCIntegrationTestSuite) TestEventsReapply_UpdateNonCurrentBranch

func (s *NDCIntegrationTestSuite) TestEventsReapply_UpdateNonCurrentBranch()

func (*NDCIntegrationTestSuite) TestEventsReapply_ZombieWorkflow

func (s *NDCIntegrationTestSuite) TestEventsReapply_ZombieWorkflow()

func (*NDCIntegrationTestSuite) TestHandcraftedMultipleBranches

func (s *NDCIntegrationTestSuite) TestHandcraftedMultipleBranches()

func (*NDCIntegrationTestSuite) TestHandcraftedMultipleBranchesWithZombieContinueAsNew

func (s *NDCIntegrationTestSuite) TestHandcraftedMultipleBranchesWithZombieContinueAsNew()

func (*NDCIntegrationTestSuite) TestMultipleBranches

func (s *NDCIntegrationTestSuite) TestMultipleBranches()

func (*NDCIntegrationTestSuite) TestReplicationMessageApplication

func (s *NDCIntegrationTestSuite) TestReplicationMessageApplication()

func (*NDCIntegrationTestSuite) TestReplicationMessageDLQ

func (s *NDCIntegrationTestSuite) TestReplicationMessageDLQ()

func (*NDCIntegrationTestSuite) TestSingleBranch

func (s *NDCIntegrationTestSuite) TestSingleBranch()

type NDCIntegrationTestSuiteParams

type NDCIntegrationTestSuiteParams struct {
	ClusterConfigs        []*host.TestClusterConfig
	DefaultTestCluster    pt.PersistenceTestCluster
	VisibilityTestCluster pt.PersistenceTestCluster
}