host

package
v0.22.0 Latest Latest
Warning

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

 Go to latest Published: Aug 20, 2021 License: MIT Imports: 86 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var TestFlags struct {
	FrontendAddr          string
	PersistenceType       string
	SQLPluginName         string
	TestClusterConfigFile string
}

TestFlags contains the feature flags for integration tests

Functions

func NewClusterMetadata added in v0.20.0 

func NewClusterMetadata(options *TestClusterConfig, logger log.Logger) cluster.Metadata

NewClusterMetadata returns cluster metdata from config

func NewPersistenceTestCluster added in v0.20.0 

func NewPersistenceTestCluster(clusterConfig *TestClusterConfig) persistencetests.PersistenceTestCluster

func RunSequentialWorkflow added in v0.21.0 

func RunSequentialWorkflow(
	s *IntegrationSuite,
	workflowId string,
	workflowTypeStr string,
	taskListStr string,
	delayStartSeconds int32,
)

Types

type AdminClient added in v0.5.0 

type AdminClient interface {
	admin.Client
}

AdminClient is the interface exposed by admin service client

func NewAdminClient added in v0.5.0 

func NewAdminClient(d *yarpc.Dispatcher) AdminClient

NewAdminClient creates a client to cadence admin client

type ArchiverBase added in v0.7.0 

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

ArchiverBase is a base struct for archiver provider being used in integration tests

type Cadence 

type Cadence interface {
	Start() error
	Stop()
	GetAdminClient() adminClient.Client
	GetFrontendClient() frontendClient.Client
	FrontendAddress() string
	GetHistoryClient() historyClient.Client
	GetExecutionManagerFactory() persistence.ExecutionManagerFactory
}

Cadence hosts all of cadence services in one process

func NewCadence 

func NewCadence(params *CadenceParams) Cadence

NewCadence returns an instance that hosts full cadence in one process

type CadenceParams added in v0.5.7 

type CadenceParams struct {
	ClusterMetadata               cluster.Metadata
	PersistenceConfig             config.Persistence
	DispatcherProvider            client.DispatcherProvider
	MessagingClient               messaging.Client
	DomainManager                 persistence.DomainManager
	HistoryV2Mgr                  persistence.HistoryManager
	ExecutionMgrFactory           persistence.ExecutionManagerFactory
	DomainReplicationQueue        domain.ReplicationQueue
	Logger                        log.Logger
	ClusterNo                     int
	ArchiverMetadata              carchiver.ArchivalMetadata
	ArchiverProvider              provider.ArchiverProvider
	EnableReadHistoryFromArchival bool
	HistoryConfig                 *HistoryConfig
	ESConfig                      *config.ElasticSearchConfig
	ESClient                      elasticsearch.GenericClient
	WorkerConfig                  *WorkerConfig
	MockAdminClient               map[string]adminClient.Client
	DomainReplicationTaskExecutor domain.ReplicationTaskExecutor
}

CadenceParams contains everything needed to bootstrap Cadence

type ClientIntegrationSuite added in v0.20.0 

type ClientIntegrationSuite 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
	IntegrationBase
	// contains filtered or unexported fields
}

func (*ClientIntegrationSuite) SetupSuite added in v0.20.0 

func (s *ClientIntegrationSuite) SetupSuite()

func (*ClientIntegrationSuite) SetupTest added in v0.20.0 

func (s *ClientIntegrationSuite) SetupTest()

func (*ClientIntegrationSuite) TearDownSuite added in v0.20.0 

func (s *ClientIntegrationSuite) TearDownSuite()

func (*ClientIntegrationSuite) TestClientDataConverter added in v0.20.0 

func (s *ClientIntegrationSuite) TestClientDataConverter()

func (*ClientIntegrationSuite) TestClientDataConverter_Failed added in v0.20.0 

func (s *ClientIntegrationSuite) TestClientDataConverter_Failed()

func (*ClientIntegrationSuite) TestClientDataConverter_WithChild added in v0.20.0 

func (s *ClientIntegrationSuite) TestClientDataConverter_WithChild()

type FrontendClient added in v0.5.0 

type FrontendClient interface {
	frontend.Client
}

FrontendClient is the interface exposed by frontend service client

func NewFrontendClient added in v0.5.0 

func NewFrontendClient(d *yarpc.Dispatcher) FrontendClient

NewFrontendClient creates a client to cadence frontend client

type HistoryClient added in v0.9.3 

type HistoryClient interface {
	history.Client
}

HistoryClient is the interface exposed by history service client

func NewHistoryClient added in v0.9.3 

func NewHistoryClient(d *yarpc.Dispatcher) HistoryClient

NewHistoryClient creates a client to cadence history service client

type HistoryConfig added in v0.5.7 

type HistoryConfig struct {
	NumHistoryShards       int
	NumHistoryHosts        int
	HistoryCountLimitError int
	HistoryCountLimitWarn  int
}

HistoryConfig contains configs for history service

type IntegrationBase added in v0.4.0 

type IntegrationBase struct {
	suite.Suite

	Logger log.Logger
	// contains filtered or unexported fields
}

IntegrationBase is a base struct for integration tests

func NewIntegrationBase added in v0.20.0 

func NewIntegrationBase(params IntegrationBaseParams) IntegrationBase

type IntegrationBaseParams added in v0.20.0 

type IntegrationBaseParams struct {
	DefaultTestCluster    pt.PersistenceTestCluster
	VisibilityTestCluster pt.PersistenceTestCluster
	TestClusterConfig     *TestClusterConfig
}

type IntegrationSuite added in v0.20.0 

type IntegrationSuite 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
	IntegrationBase
}

func (*IntegrationSuite) SetupSuite added in v0.20.0 

func (s *IntegrationSuite) SetupSuite()

func (*IntegrationSuite) SetupTest added in v0.20.0 

func (s *IntegrationSuite) SetupTest()

func (*IntegrationSuite) TearDownSuite added in v0.20.0 

func (s *IntegrationSuite) TearDownSuite()

func (*IntegrationSuite) TestActivityCancellation added in v0.20.0 

func (s *IntegrationSuite) TestActivityCancellation()

func (*IntegrationSuite) TestActivityCancellationNotStarted added in v0.20.0 

func (s *IntegrationSuite) TestActivityCancellationNotStarted()

func (*IntegrationSuite) TestActivityHeartBeatWorkflow_Success added in v0.20.0 

func (s *IntegrationSuite) TestActivityHeartBeatWorkflow_Success()

func (*IntegrationSuite) TestActivityHeartBeatWorkflow_Timeout added in v0.20.0 

func (s *IntegrationSuite) TestActivityHeartBeatWorkflow_Timeout()

func (*IntegrationSuite) TestActivityHeartbeatDetailsDuringRetry added in v0.20.0 

func (s *IntegrationSuite) TestActivityHeartbeatDetailsDuringRetry()

func (*IntegrationSuite) TestActivityHeartbeatTimeouts added in v0.20.0 

func (s *IntegrationSuite) TestActivityHeartbeatTimeouts()

func (*IntegrationSuite) TestActivityRetry added in v0.20.0 

func (s *IntegrationSuite) TestActivityRetry()

func (*IntegrationSuite) TestActivityTimeouts added in v0.20.0 

func (s *IntegrationSuite) TestActivityTimeouts()

func (*IntegrationSuite) TestArchival_ArchiverWorker added in v0.20.0 

func (s *IntegrationSuite) TestArchival_ArchiverWorker()

func (*IntegrationSuite) TestArchival_ContinueAsNew added in v0.20.0 

func (s *IntegrationSuite) TestArchival_ContinueAsNew()

func (*IntegrationSuite) TestArchival_TimerQueueProcessor added in v0.20.0 

func (s *IntegrationSuite) TestArchival_TimerQueueProcessor()

func (*IntegrationSuite) TestBufferedEvents added in v0.20.0 

func (s *IntegrationSuite) TestBufferedEvents()

func (*IntegrationSuite) TestBufferedEventsOutOfOrder added in v0.20.0 

func (s *IntegrationSuite) TestBufferedEventsOutOfOrder()

func (*IntegrationSuite) TestCancelTimer added in v0.20.0 

func (s *IntegrationSuite) TestCancelTimer()

func (*IntegrationSuite) TestCancelTimer_CancelFiredAndBuffered added in v0.20.0 

func (s *IntegrationSuite) TestCancelTimer_CancelFiredAndBuffered()

func (*IntegrationSuite) TestChildWorkflowExecution added in v0.20.0 

func (s *IntegrationSuite) TestChildWorkflowExecution()

func (*IntegrationSuite) TestChildWorkflowWithContinueAsNew added in v0.20.0 

func (s *IntegrationSuite) TestChildWorkflowWithContinueAsNew()

func (*IntegrationSuite) TestCompleteDecisionTaskAndCreateNewOne added in v0.20.0 

func (s *IntegrationSuite) TestCompleteDecisionTaskAndCreateNewOne()

func (*IntegrationSuite) TestContinueAsNewWorkflow added in v0.20.0 

func (s *IntegrationSuite) TestContinueAsNewWorkflow()

func (*IntegrationSuite) TestContinueAsNewWorkflow_Timeout added in v0.20.0 

func (s *IntegrationSuite) TestContinueAsNewWorkflow_Timeout()

func (*IntegrationSuite) TestCronChildWorkflowExecution added in v0.20.0 

func (s *IntegrationSuite) TestCronChildWorkflowExecution()

func (*IntegrationSuite) TestCronWorkflow added in v0.20.0 

func (s *IntegrationSuite) TestCronWorkflow()

func (*IntegrationSuite) TestCronWorkflowTimeout added in v0.20.0 

func (s *IntegrationSuite) TestCronWorkflowTimeout()

func (*IntegrationSuite) TestDecisionAndActivityTimeoutsWorkflow added in v0.20.0 

func (s *IntegrationSuite) TestDecisionAndActivityTimeoutsWorkflow()

func (*IntegrationSuite) TestDecisionHeartbeatingWithEmptyResult added in v0.20.0 

func (s *IntegrationSuite) TestDecisionHeartbeatingWithEmptyResult()

func (*IntegrationSuite) TestDecisionHeartbeatingWithLocalActivitiesResult added in v0.20.0 

func (s *IntegrationSuite) TestDecisionHeartbeatingWithLocalActivitiesResult()

func (*IntegrationSuite) TestDecisionTaskFailed added in v0.20.0 

func (s *IntegrationSuite) TestDecisionTaskFailed()

func (*IntegrationSuite) TestDelayStartWorkflow added in v0.21.0 

func (s *IntegrationSuite) TestDelayStartWorkflow()

func (*IntegrationSuite) TestDescribeTaskList added in v0.20.0 

func (s *IntegrationSuite) TestDescribeTaskList()

func (*IntegrationSuite) TestDescribeWorkflowExecution added in v0.20.0 

func (s *IntegrationSuite) TestDescribeWorkflowExecution()

func (*IntegrationSuite) TestExternalRequestCancelWorkflowExecution added in v0.20.0 

func (s *IntegrationSuite) TestExternalRequestCancelWorkflowExecution()

func (*IntegrationSuite) TestNoTransientDecisionAfterFlushBufferedEvents added in v0.20.0 

func (s *IntegrationSuite) TestNoTransientDecisionAfterFlushBufferedEvents()

func (*IntegrationSuite) TestQueryWorkflow_BeforeFirstDecision added in v0.20.0 

func (s *IntegrationSuite) TestQueryWorkflow_BeforeFirstDecision()

func (*IntegrationSuite) TestQueryWorkflow_Consistent_BlockedByStarted_NonSticky added in v0.20.0 

func (s *IntegrationSuite) TestQueryWorkflow_Consistent_BlockedByStarted_NonSticky()

func (*IntegrationSuite) TestQueryWorkflow_Consistent_NewDecisionTask_Sticky added in v0.20.0 

func (s *IntegrationSuite) TestQueryWorkflow_Consistent_NewDecisionTask_Sticky()

func (*IntegrationSuite) TestQueryWorkflow_Consistent_PiggybackQuery added in v0.20.0 

func (s *IntegrationSuite) TestQueryWorkflow_Consistent_PiggybackQuery()

func (*IntegrationSuite) TestQueryWorkflow_Consistent_Timeout added in v0.20.0 

func (s *IntegrationSuite) TestQueryWorkflow_Consistent_Timeout()

func (*IntegrationSuite) TestQueryWorkflow_NonSticky added in v0.20.0 

func (s *IntegrationSuite) TestQueryWorkflow_NonSticky()

func (*IntegrationSuite) TestQueryWorkflow_Sticky added in v0.20.0 

func (s *IntegrationSuite) TestQueryWorkflow_Sticky()

func (*IntegrationSuite) TestQueryWorkflow_StickyTimeout added in v0.20.0 

func (s *IntegrationSuite) TestQueryWorkflow_StickyTimeout()

func (*IntegrationSuite) TestRateLimitBufferedEvents added in v0.20.0 

func (s *IntegrationSuite) TestRateLimitBufferedEvents()

func (*IntegrationSuite) TestRelayDecisionTimeout added in v0.20.0 

func (s *IntegrationSuite) TestRelayDecisionTimeout()

func (*IntegrationSuite) TestRequestCancelWorkflowDecisionExecution added in v0.20.0 

func (s *IntegrationSuite) TestRequestCancelWorkflowDecisionExecution()

func (*IntegrationSuite) TestRequestCancelWorkflowDecisionExecution_UnKnownTarget added in v0.20.0 

func (s *IntegrationSuite) TestRequestCancelWorkflowDecisionExecution_UnKnownTarget()

func (*IntegrationSuite) TestResetWorkflow added in v0.20.0 

func (s *IntegrationSuite) TestResetWorkflow()

func (*IntegrationSuite) TestResetWorkflow_NoDecisionTaskCompleted added in v0.20.0 

func (s *IntegrationSuite) TestResetWorkflow_NoDecisionTaskCompleted()

func (*IntegrationSuite) TestSequentialWorkflow added in v0.20.0 

func (s *IntegrationSuite) TestSequentialWorkflow()

func (*IntegrationSuite) TestSequential_UserTimers added in v0.20.0 

func (s *IntegrationSuite) TestSequential_UserTimers()

func (*IntegrationSuite) TestSignalExternalWorkflowDecision added in v0.20.0 

func (s *IntegrationSuite) TestSignalExternalWorkflowDecision()

func (*IntegrationSuite) TestSignalExternalWorkflowDecision_SignalSelf added in v0.20.0 

func (s *IntegrationSuite) TestSignalExternalWorkflowDecision_SignalSelf()

func (*IntegrationSuite) TestSignalExternalWorkflowDecision_UnKnownTarget added in v0.20.0 

func (s *IntegrationSuite) TestSignalExternalWorkflowDecision_UnKnownTarget()

func (*IntegrationSuite) TestSignalExternalWorkflowDecision_WithoutRunID added in v0.20.0 

func (s *IntegrationSuite) TestSignalExternalWorkflowDecision_WithoutRunID()

func (*IntegrationSuite) TestSignalWithStartWithMemo added in v0.20.0 

func (s *IntegrationSuite) TestSignalWithStartWithMemo()

func (*IntegrationSuite) TestSignalWithStartWorkflow added in v0.20.0 

func (s *IntegrationSuite) TestSignalWithStartWorkflow()

func (*IntegrationSuite) TestSignalWithStartWorkflow_IDReusePolicy added in v0.20.0 

func (s *IntegrationSuite) TestSignalWithStartWorkflow_IDReusePolicy()

func (*IntegrationSuite) TestSignalWorkflow added in v0.20.0 

func (s *IntegrationSuite) TestSignalWorkflow()

func (*IntegrationSuite) TestSignalWorkflow_Cron_NoDecisionTaskCreated added in v0.20.0 

func (s *IntegrationSuite) TestSignalWorkflow_Cron_NoDecisionTaskCreated()

func (*IntegrationSuite) TestSignalWorkflow_DuplicateRequest added in v0.20.0 

func (s *IntegrationSuite) TestSignalWorkflow_DuplicateRequest()

func (*IntegrationSuite) TestStartWithMemo added in v0.20.0 

func (s *IntegrationSuite) TestStartWithMemo()

func (*IntegrationSuite) TestStartWorkflowExecution added in v0.20.0 

func (s *IntegrationSuite) TestStartWorkflowExecution()

func (*IntegrationSuite) TestStartWorkflowExecution_IDReusePolicy added in v0.20.0 

func (s *IntegrationSuite) TestStartWorkflowExecution_IDReusePolicy()

func (*IntegrationSuite) TestStickyTasklistResetThenTimeout added in v0.20.0 

func (s *IntegrationSuite) TestStickyTasklistResetThenTimeout()

func (*IntegrationSuite) TestStickyTimeout_NonTransientDecision added in v0.20.0 

func (s *IntegrationSuite) TestStickyTimeout_NonTransientDecision()

func (*IntegrationSuite) TestTaskProcessingProtectionForRateLimitError added in v0.20.0 

func (s *IntegrationSuite) TestTaskProcessingProtectionForRateLimitError()

func (*IntegrationSuite) TestTerminateWorkflow added in v0.20.0 

func (s *IntegrationSuite) TestTerminateWorkflow()

func (*IntegrationSuite) TestTransientDecisionTimeout added in v0.20.0 

func (s *IntegrationSuite) TestTransientDecisionTimeout()

func (*IntegrationSuite) TestVisibility added in v0.20.0 

func (s *IntegrationSuite) TestVisibility()

func (*IntegrationSuite) TestVisibilityArchival added in v0.20.0 

func (s *IntegrationSuite) TestVisibilityArchival()

func (*IntegrationSuite) TestWorkflowContinueAsNew_TaskID added in v0.20.0 

func (s *IntegrationSuite) TestWorkflowContinueAsNew_TaskID()

func (*IntegrationSuite) TestWorkflowRetry added in v0.20.0 

func (s *IntegrationSuite) TestWorkflowRetry()

func (*IntegrationSuite) TestWorkflowRetryFailures added in v0.20.0 

func (s *IntegrationSuite) TestWorkflowRetryFailures()

func (*IntegrationSuite) TestWorkflowTerminationSignalAfterRegularDecisionStarted added in v0.20.0 

func (s *IntegrationSuite) TestWorkflowTerminationSignalAfterRegularDecisionStarted()

func (*IntegrationSuite) TestWorkflowTerminationSignalAfterRegularDecisionStartedAndFailDecision added in v0.20.0 

func (s *IntegrationSuite) TestWorkflowTerminationSignalAfterRegularDecisionStartedAndFailDecision()

func (*IntegrationSuite) TestWorkflowTerminationSignalAfterTransientDecisionStarted added in v0.20.0 

func (s *IntegrationSuite) TestWorkflowTerminationSignalAfterTransientDecisionStarted()

func (*IntegrationSuite) TestWorkflowTerminationSignalAfterTransientDecisionStartedAndFailDecision added in v0.20.0 

func (s *IntegrationSuite) TestWorkflowTerminationSignalAfterTransientDecisionStartedAndFailDecision()

func (*IntegrationSuite) TestWorkflowTerminationSignalBeforeRegularDecisionStarted added in v0.20.0 

func (s *IntegrationSuite) TestWorkflowTerminationSignalBeforeRegularDecisionStarted()

func (*IntegrationSuite) TestWorkflowTerminationSignalBeforeTransientDecisionStarted added in v0.20.0 

func (s *IntegrationSuite) TestWorkflowTerminationSignalBeforeTransientDecisionStarted()

func (*IntegrationSuite) TestWorkflowTimeout added in v0.20.0 

func (s *IntegrationSuite) TestWorkflowTimeout()

type MessagingClientConfig added in v0.5.7 

type MessagingClientConfig struct {
	UseMock     bool
	KafkaConfig *config.KafkaConfig
}

MessagingClientConfig is the config for messaging config

type SizeLimitIntegrationSuite added in v0.20.0 

type SizeLimitIntegrationSuite 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
	IntegrationBase
}

func (*SizeLimitIntegrationSuite) SetupSuite added in v0.20.0 

func (s *SizeLimitIntegrationSuite) SetupSuite()

This cluster use customized threshold for history config

func (*SizeLimitIntegrationSuite) SetupTest added in v0.20.0 

func (s *SizeLimitIntegrationSuite) SetupTest()

func (*SizeLimitIntegrationSuite) TearDownSuite added in v0.20.0 

func (s *SizeLimitIntegrationSuite) TearDownSuite()

func (*SizeLimitIntegrationSuite) TestTerminateWorkflowCausedBySizeLimit added in v0.20.0 

func (s *SizeLimitIntegrationSuite) TestTerminateWorkflowCausedBySizeLimit()

type TaskPoller added in v0.4.0 

type TaskPoller struct {
	Engine                              FrontendClient
	Domain                              string
	TaskList                            *types.TaskList
	StickyTaskList                      *types.TaskList
	StickyScheduleToStartTimeoutSeconds *int32
	Identity                            string
	DecisionHandler                     decisionTaskHandler
	ActivityHandler                     activityTaskHandler
	QueryHandler                        queryHandler
	Logger                              log.Logger
	T                                   *testing.T
}

TaskPoller is used in integration tests to poll decision or activity tasks

func (*TaskPoller) HandlePartialDecision added in v0.4.0 

func (p *TaskPoller) HandlePartialDecision(response *types.PollForDecisionTaskResponse) (
	*types.RespondDecisionTaskCompletedResponse, error)

HandlePartialDecision for decision task

func (*TaskPoller) PollAndProcessActivityTask added in v0.4.0 

func (p *TaskPoller) PollAndProcessActivityTask(dropTask bool) error

PollAndProcessActivityTask for activity tasks

func (*TaskPoller) PollAndProcessActivityTaskWithID added in v0.4.0 

func (p *TaskPoller) PollAndProcessActivityTaskWithID(dropTask bool) error

PollAndProcessActivityTaskWithID is similar to PollAndProcessActivityTask but using RespondActivityTask...ByID

func (*TaskPoller) PollAndProcessDecisionTask added in v0.4.0 

func (p *TaskPoller) PollAndProcessDecisionTask(dumpHistory bool, dropTask bool) (isQueryTask bool, err error)

PollAndProcessDecisionTask for decision tasks

func (*TaskPoller) PollAndProcessDecisionTaskWithAttempt added in v0.4.0 

func (p *TaskPoller) PollAndProcessDecisionTaskWithAttempt(
	dumpHistory bool,
	dropTask bool,
	pollStickyTaskList bool,
	respondStickyTaskList bool,
	decisionAttempt int64,
) (isQueryTask bool, err error)

PollAndProcessDecisionTaskWithAttempt for decision tasks

func (*TaskPoller) PollAndProcessDecisionTaskWithAttemptAndRetry added in v0.4.0 

func (p *TaskPoller) PollAndProcessDecisionTaskWithAttemptAndRetry(
	dumpHistory bool,
	dropTask bool,
	pollStickyTaskList bool,
	respondStickyTaskList bool,
	decisionAttempt int64,
	retryCount int,
) (isQueryTask bool, err error)

PollAndProcessDecisionTaskWithAttemptAndRetry for decision tasks

func (*TaskPoller) PollAndProcessDecisionTaskWithAttemptAndRetryAndForceNewDecision added in v0.4.0 

func (p *TaskPoller) PollAndProcessDecisionTaskWithAttemptAndRetryAndForceNewDecision(
	dumpHistory bool,
	dropTask bool,
	pollStickyTaskList bool,
	respondStickyTaskList bool,
	decisionAttempt int64,
	retryCount int,
	forceCreateNewDecision bool,
	queryResult *types.WorkflowQueryResult,
) (isQueryTask bool, newTask *types.RespondDecisionTaskCompletedResponse, err error)

PollAndProcessDecisionTaskWithAttemptAndRetryAndForceNewDecision for decision tasks

func (*TaskPoller) PollAndProcessDecisionTaskWithSticky added in v0.4.0 

func (p *TaskPoller) PollAndProcessDecisionTaskWithSticky(dumpHistory bool, dropTask bool) (isQueryTask bool, err error)

PollAndProcessDecisionTaskWithSticky for decision tasks

func (*TaskPoller) PollAndProcessDecisionTaskWithoutRetry added in v0.4.0 

func (p *TaskPoller) PollAndProcessDecisionTaskWithoutRetry(dumpHistory bool, dropTask bool) (isQueryTask bool, err error)

PollAndProcessDecisionTaskWithoutRetry for decision tasks

type TestCluster added in v0.5.7 

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

TestCluster is a base struct for integration tests

func NewCluster added in v0.5.7 

func NewCluster(options *TestClusterConfig, logger log.Logger, params persistencetests.TestBaseParams) (*TestCluster, error)

NewCluster creates and sets up the test cluster

func (*TestCluster) GetAdminClient added in v0.5.7 

func (tc *TestCluster) GetAdminClient() AdminClient

GetAdminClient returns an admin client from the test cluster

func (*TestCluster) GetExecutionManagerFactory added in v0.11.0 

func (tc *TestCluster) GetExecutionManagerFactory() persistence.ExecutionManagerFactory

GetExecutionManagerFactory returns an execution manager factory from the test cluster

func (*TestCluster) GetFrontendClient added in v0.5.7 

func (tc *TestCluster) GetFrontendClient() FrontendClient

GetFrontendClient returns a frontend client from the test cluster

func (*TestCluster) GetHistoryClient added in v0.9.3 

func (tc *TestCluster) GetHistoryClient() HistoryClient

GetHistoryClient returns a history client from the test cluster

func (*TestCluster) TearDownCluster added in v0.5.7 

func (tc *TestCluster) TearDownCluster()

TearDownCluster tears down the test cluster

type TestClusterConfig added in v0.5.7 

type TestClusterConfig struct {
	FrontendAddress       string
	EnableArchival        bool
	IsPrimaryCluster      bool
	ClusterNo             int
	ClusterMetadata       config.ClusterMetadata
	MessagingClientConfig *MessagingClientConfig
	Persistence           persistencetests.TestBaseOptions
	HistoryConfig         *HistoryConfig
	ESConfig              *config.ElasticSearchConfig
	WorkerConfig          *WorkerConfig
	MockAdminClient       map[string]adminClient.Client
}

TestClusterConfig are config for a test cluster

func GetTestClusterConfig added in v0.5.7 

func GetTestClusterConfig(configFile string) (*TestClusterConfig, error)

GetTestClusterConfig return test cluster config

func GetTestClusterConfigs added in v0.20.0 

func GetTestClusterConfigs(configFile string) ([]*TestClusterConfig, error)

GetTestClusterConfigs return test cluster configs

type WorkerConfig added in v0.5.7 

type WorkerConfig struct {
	EnableArchiver   bool
	EnableIndexer    bool
	EnableReplicator bool
}

WorkerConfig is the config for enabling/disabling cadence worker

Source Files

View all Source files

Directories

Path Synopsis

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.