From a0e2f62d7e00a9f8b366b81f5838b6467585a1c9 Mon Sep 17 00:00:00 2001 From: Sergey Cherepanov Date: Sat, 4 Feb 2023 19:45:11 +0300 Subject: [PATCH] expose chash params --- nodeconf/configuration_test.go | 4 ++-- nodeconf/service.go | 8 ++++---- 2 files changed, 6 insertions(+), 6 deletions(-) diff --git a/nodeconf/configuration_test.go b/nodeconf/configuration_test.go index 757a5bc3..fee5eefb 100644 --- a/nodeconf/configuration_test.go +++ b/nodeconf/configuration_test.go @@ -17,8 +17,8 @@ func TestReplKey(t *testing.T) { func TestConfiguration_NodeIds(t *testing.T) { ch, err := chash.New(chash.Config{ - PartitionCount: partitionCount, - ReplicationFactor: replicationFactor, + PartitionCount: PartitionCount, + ReplicationFactor: ReplicationFactor, }) require.NoError(t, err) conf := &configuration{ diff --git a/nodeconf/service.go b/nodeconf/service.go index 00bd3632..279f35bc 100644 --- a/nodeconf/service.go +++ b/nodeconf/service.go @@ -13,8 +13,8 @@ import ( const CName = "common.nodeconf" const ( - partitionCount = 3000 - replicationFactor = 3 + PartitionCount = 3000 + ReplicationFactor = 3 ) var log = logger.NewNamed(CName) @@ -58,8 +58,8 @@ func (s *service) Init(a *app.App) (err error) { accountId: s.accountId, } if fileConfig.chash, err = chash.New(chash.Config{ - PartitionCount: partitionCount, - ReplicationFactor: replicationFactor, + PartitionCount: PartitionCount, + ReplicationFactor: ReplicationFactor, }); err != nil { return }