Skip to content

Commit

Permalink
Add integration tests for xdc (uber#1078)
Browse files Browse the repository at this point in the history
* Add domain failover integration test

* Add integration tests for xdc

* Fix lint and merge conflict
  • Loading branch information
vancexu authored Aug 28, 2018
1 parent faa8421 commit 1a49292
Show file tree
Hide file tree
Showing 7 changed files with 1,299 additions and 1,020 deletions.
2 changes: 1 addition & 1 deletion common/util.go
Original file line number Diff line number Diff line change
Expand Up @@ -28,7 +28,7 @@ import (
"go.uber.org/yarpc/yarpcerrors"
"golang.org/x/net/context"

farm "github.com/dgryski/go-farm"
"github.com/dgryski/go-farm"
"github.com/uber-common/bark"

"math/rand"
Expand Down
2 changes: 1 addition & 1 deletion host/client_integration_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -167,7 +167,7 @@ func (s *clientIntegrationSuite) setupSuite(enableGlobalDomain bool, isMasterClu
s.mockProducer = &mocks.KafkaProducer{}
s.mockMessagingClient = mocks.NewMockMessagingClient(s.mockProducer, nil)

s.host = NewCadence(s.ClusterMetadata, s.mockMessagingClient, s.MetadataProxy, s.ShardMgr, s.HistoryMgr, s.ExecutionMgrFactory, s.TaskMgr,
s.host = NewCadence(s.ClusterMetadata, s.mockMessagingClient, s.MetadataProxy, s.MetadataManagerV2, s.ShardMgr, s.HistoryMgr, s.ExecutionMgrFactory, s.TaskMgr,
s.VisibilityMgr, testNumberOfHistoryShards, testNumberOfHistoryHosts, s.logger, 0, false)
s.host.Start()

Expand Down
2 changes: 1 addition & 1 deletion host/integration_cross_dc_domain_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -105,7 +105,7 @@ func (s *integrationCrossDCSuite) setupTest(enableGlobalDomain bool, isMasterClu
s.mockProducer = &mocks.KafkaProducer{}
s.mockMessagingClient = mocks.NewMockMessagingClient(s.mockProducer, nil)

s.host = NewCadence(s.ClusterMetadata, s.mockMessagingClient, s.MetadataProxy, s.ShardMgr, s.HistoryMgr, s.ExecutionMgrFactory, s.TaskMgr,
s.host = NewCadence(s.ClusterMetadata, s.mockMessagingClient, s.MetadataProxy, s.MetadataManagerV2, s.ShardMgr, s.HistoryMgr, s.ExecutionMgrFactory, s.TaskMgr,
s.VisibilityMgr, testNumberOfHistoryShards, testNumberOfHistoryHosts, s.logger, 0, false)

s.host.Start()
Expand Down
Loading

0 comments on commit 1a49292

Please sign in to comment.