Skip to content

Commit 07b75b0

Browse files
authored
Rename IsReplicationEnabled to be consistent with EnableRemoteCluster… (temporalio#8737)
…Connection ## What changed? Rename to be consistent from temporalio#8658 ## Why? The inconsistent naming looks wack ## How did you test it? - [x] built - [ ] run locally and tested manually - [x] covered by existing tests - [ ] added new unit test(s) - [ ] added new functional test(s) ## Potential risks NA, field unused
1 parent 9e68634 commit 07b75b0

File tree

5 files changed

+19
-19
lines changed

5 files changed

+19
-19
lines changed

api/adminservice/v1/request_response.pb.go

Lines changed: 9 additions & 9 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

proto/internal/temporal/server/api/adminservice/v1/request_response.proto

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -285,8 +285,8 @@ message AddOrUpdateRemoteClusterRequest {
285285
string frontend_address = 1;
286286
bool enable_remote_cluster_connection = 2;
287287
string frontend_http_address = 3 [deprecated = true];
288-
// is_replication_enabled controls whether replication streams are active.
289-
bool is_replication_enabled = 4;
288+
// enable_replication controls whether replication streams are active.
289+
bool enable_replication = 4;
290290
}
291291

292292
message AddOrUpdateRemoteClusterResponse {

service/frontend/admin_handler.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1235,7 +1235,7 @@ func (adh *AdminHandler) AddOrUpdateRemoteCluster(
12351235
InitialFailoverVersion: resp.GetInitialFailoverVersion(),
12361236
IsGlobalNamespaceEnabled: resp.GetIsGlobalNamespaceEnabled(),
12371237
IsConnectionEnabled: request.GetEnableRemoteClusterConnection(),
1238-
IsReplicationEnabled: request.GetIsReplicationEnabled(),
1238+
IsReplicationEnabled: request.GetEnableReplication(),
12391239
Tags: resp.GetTags(),
12401240
},
12411241
Version: updateRequestVersion,

tests/xdc/base.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -158,7 +158,7 @@ func (s *xdcBaseSuite) setupSuite(opts ...testcore.TestClusterOption) {
158158
FrontendAddress: remoteC.Host().RemoteFrontendGRPCAddress(),
159159
FrontendHttpAddress: remoteC.Host().FrontendHTTPAddress(),
160160
EnableRemoteClusterConnection: true,
161-
IsReplicationEnabled: true,
161+
EnableReplication: true,
162162
})
163163
s.Require().NoError(err)
164164
}

tests/xdc/replication_enable_test.go

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -155,7 +155,7 @@ func (s *ReplicationEnableTestSuite) TestReplicationEnableFlow() {
155155
FrontendAddress: standbyCluster.Host().RemoteFrontendGRPCAddress(),
156156
FrontendHttpAddress: standbyCluster.Host().FrontendHTTPAddress(),
157157
EnableRemoteClusterConnection: true,
158-
IsReplicationEnabled: false,
158+
EnableReplication: false,
159159
})
160160
s.Require().NoError(err)
161161

@@ -165,7 +165,7 @@ func (s *ReplicationEnableTestSuite) TestReplicationEnableFlow() {
165165
FrontendAddress: activeCluster.Host().RemoteFrontendGRPCAddress(),
166166
FrontendHttpAddress: activeCluster.Host().FrontendHTTPAddress(),
167167
EnableRemoteClusterConnection: true,
168-
IsReplicationEnabled: false,
168+
EnableReplication: false,
169169
})
170170
s.Require().NoError(err)
171171

@@ -254,7 +254,7 @@ func (s *ReplicationEnableTestSuite) TestReplicationEnableFlow() {
254254
FrontendAddress: standbyCluster.Host().RemoteFrontendGRPCAddress(),
255255
FrontendHttpAddress: standbyCluster.Host().FrontendHTTPAddress(),
256256
EnableRemoteClusterConnection: true,
257-
IsReplicationEnabled: true, // NOW enable replication
257+
EnableReplication: true, // NOW enable replication
258258
})
259259
s.Require().NoError(err)
260260

@@ -265,7 +265,7 @@ func (s *ReplicationEnableTestSuite) TestReplicationEnableFlow() {
265265
FrontendAddress: activeCluster.Host().RemoteFrontendGRPCAddress(),
266266
FrontendHttpAddress: activeCluster.Host().FrontendHTTPAddress(),
267267
EnableRemoteClusterConnection: true,
268-
IsReplicationEnabled: true, // NOW enable replication
268+
EnableReplication: true, // NOW enable replication
269269
})
270270
s.Require().NoError(err)
271271

@@ -302,7 +302,7 @@ func (s *ReplicationEnableTestSuite) TestReplicationEnableFlow() {
302302
FrontendAddress: standbyCluster.Host().RemoteFrontendGRPCAddress(),
303303
FrontendHttpAddress: standbyCluster.Host().FrontendHTTPAddress(),
304304
EnableRemoteClusterConnection: true,
305-
IsReplicationEnabled: false, // Disable replication
305+
EnableReplication: false, // Disable replication
306306
})
307307
s.Require().NoError(err)
308308

@@ -313,7 +313,7 @@ func (s *ReplicationEnableTestSuite) TestReplicationEnableFlow() {
313313
FrontendAddress: activeCluster.Host().RemoteFrontendGRPCAddress(),
314314
FrontendHttpAddress: activeCluster.Host().FrontendHTTPAddress(),
315315
EnableRemoteClusterConnection: true,
316-
IsReplicationEnabled: false, // Disable replication
316+
EnableReplication: false, // Disable replication
317317
})
318318
s.Require().NoError(err)
319319

0 commit comments

Comments
 (0)