Welcome to mirror list, hosted at ThFree Co, Russian Federation.

gitlab.com/gitlab-org/gitaly.git - Unnamed repository; edit this file 'description' to name the repository.
summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorJames Fargher <proglottis@gmail.com>2021-04-08 02:17:25 +0300
committerJames Fargher <proglottis@gmail.com>2021-04-08 02:17:25 +0300
commit98bc69b160d4376ae2932626bcc7c34aba207ff7 (patch)
treedc7e582938fdbf6f48d4d5239bf29085eeace97b /internal/praefect/coordinator_test.go
parent49ea46dfefa59f5e4b31d0d2e6143d5e0470229b (diff)
parent3e05485c631886f48b6ddc914fadaaf0edc94b76 (diff)
Merge branch 'smh-inject-backchannel-deps' into 'master'
Inject backchannel dependencies to components See merge request gitlab-org/gitaly!3339
Diffstat (limited to 'internal/praefect/coordinator_test.go')
-rw-r--r--internal/praefect/coordinator_test.go14
1 files changed, 7 insertions, 7 deletions
diff --git a/internal/praefect/coordinator_test.go b/internal/praefect/coordinator_test.go
index 98cc85502..a58413009 100644
--- a/internal/praefect/coordinator_test.go
+++ b/internal/praefect/coordinator_test.go
@@ -161,7 +161,7 @@ func TestStreamDirectorMutator(t *testing.T) {
entry := testhelper.DiscardTestEntry(t)
- nodeMgr, err := nodes.NewManager(entry, conf, nil, nil, promtest.NewMockHistogramVec(), protoregistry.GitalyProtoPreregistered, nil)
+ nodeMgr, err := nodes.NewManager(entry, conf, nil, nil, promtest.NewMockHistogramVec(), protoregistry.GitalyProtoPreregistered, nil, nil)
require.NoError(t, err)
nodeMgr.Start(0, time.Hour)
@@ -256,7 +256,7 @@ func TestStreamDirectorMutator_StopTransaction(t *testing.T) {
RelativePath: "/path/to/hashed/storage",
}
- nodeMgr, err := nodes.NewManager(testhelper.DiscardTestEntry(t), conf, nil, nil, promtest.NewMockHistogramVec(), protoregistry.GitalyProtoPreregistered, nil)
+ nodeMgr, err := nodes.NewManager(testhelper.DiscardTestEntry(t), conf, nil, nil, promtest.NewMockHistogramVec(), protoregistry.GitalyProtoPreregistered, nil, nil)
require.NoError(t, err)
nodeMgr.Start(0, time.Hour)
@@ -386,7 +386,7 @@ func TestStreamDirectorAccessor(t *testing.T) {
entry := testhelper.DiscardTestEntry(t)
rs := datastore.MockRepositoryStore{}
- nodeMgr, err := nodes.NewManager(entry, conf, nil, rs, promtest.NewMockHistogramVec(), protoregistry.GitalyProtoPreregistered, nil)
+ nodeMgr, err := nodes.NewManager(entry, conf, nil, rs, promtest.NewMockHistogramVec(), protoregistry.GitalyProtoPreregistered, nil, nil)
require.NoError(t, err)
nodeMgr.Start(0, time.Minute)
@@ -502,7 +502,7 @@ func TestCoordinatorStreamDirector_distributesReads(t *testing.T) {
},
}
- nodeMgr, err := nodes.NewManager(entry, conf, nil, repoStore, promtest.NewMockHistogramVec(), protoregistry.GitalyProtoPreregistered, nil)
+ nodeMgr, err := nodes.NewManager(entry, conf, nil, repoStore, promtest.NewMockHistogramVec(), protoregistry.GitalyProtoPreregistered, nil, nil)
require.NoError(t, err)
nodeMgr.Start(0, time.Minute)
@@ -847,7 +847,7 @@ func TestStreamDirector_repo_creation(t *testing.T) {
healthySecondaryNode.Address = "unix://" + gitalySocket1
unhealthySecondaryNode.Address = "unix://" + gitalySocket1
- nodeMgr, err := nodes.NewManager(testhelper.DiscardTestEntry(t), conf, nil, nil, promtest.NewMockHistogramVec(), protoregistry.GitalyProtoPreregistered, nil)
+ nodeMgr, err := nodes.NewManager(testhelper.DiscardTestEntry(t), conf, nil, nil, promtest.NewMockHistogramVec(), protoregistry.GitalyProtoPreregistered, nil, nil)
require.NoError(t, err)
nodeMgr.Start(0, time.Hour)
@@ -1042,7 +1042,7 @@ func TestAbsentCorrelationID(t *testing.T) {
entry := testhelper.DiscardTestEntry(t)
- nodeMgr, err := nodes.NewManager(entry, conf, nil, nil, promtest.NewMockHistogramVec(), protoregistry.GitalyProtoPreregistered, nil)
+ nodeMgr, err := nodes.NewManager(entry, conf, nil, nil, promtest.NewMockHistogramVec(), protoregistry.GitalyProtoPreregistered, nil, nil)
require.NoError(t, err)
nodeMgr.Start(0, time.Hour)
@@ -1168,7 +1168,7 @@ func TestStreamDirectorStorageScope(t *testing.T) {
rs := datastore.MockRepositoryStore{}
- nodeMgr, err := nodes.NewManager(testhelper.DiscardTestEntry(t), conf, nil, nil, promtest.NewMockHistogramVec(), protoregistry.GitalyProtoPreregistered, nil)
+ nodeMgr, err := nodes.NewManager(testhelper.DiscardTestEntry(t), conf, nil, nil, promtest.NewMockHistogramVec(), protoregistry.GitalyProtoPreregistered, nil, nil)
require.NoError(t, err)
nodeMgr.Start(0, time.Second)
coordinator := NewCoordinator(