@@ -86,12 +86,13 @@ func run(ctx context.Context, cancel func(), conf *config.Config, stat stats.Sta
86
86
}
87
87
88
88
nodeConfig := node.Config {
89
- NodeID : uint32 (nodeID ),
90
- ClusterSize : uint32 (conf .GetInt ("clusterSize" , 1 )),
91
- TotalHashRanges : uint32 (conf .GetInt ("totalHashRanges" , node .DefaultTotalHashRanges )),
92
- MaxFilesToList : conf .GetInt64 ("maxFilesToList" , node .DefaultMaxFilesToList ),
93
- SnapshotInterval : conf .GetDuration ("snapshotInterval" , 0 , time .Nanosecond ), // node.DefaultSnapshotInterval will be used
94
- Addresses : strings .Split (nodeAddresses , "," ),
89
+ NodeID : uint32 (nodeID ),
90
+ ClusterSize : uint32 (conf .GetInt ("clusterSize" , 1 )),
91
+ TotalHashRanges : uint32 (conf .GetInt ("totalHashRanges" , node .DefaultTotalHashRanges )),
92
+ MaxFilesToList : conf .GetInt64 ("maxFilesToList" , node .DefaultMaxFilesToList ),
93
+ SnapshotInterval : conf .GetDuration ("snapshotInterval" , 0 , time .Nanosecond ), // node.DefaultSnapshotInterval will be used
94
+ GarbageCollectionInterval : conf .GetDuration ("gcInterval" , 0 , time .Nanosecond ), // node.DefaultGarbageCollectionInterval will be used
95
+ Addresses : strings .Split (nodeAddresses , "," ),
95
96
}
96
97
97
98
port := conf .GetInt ("port" , 50051 )
@@ -100,8 +101,6 @@ func run(ctx context.Context, cancel func(), conf *config.Config, stat stats.Sta
100
101
logger .NewIntField ("nodeId" , int64 (nodeConfig .NodeID )),
101
102
logger .NewIntField ("clusterSize" , int64 (nodeConfig .ClusterSize )),
102
103
logger .NewIntField ("totalHashRanges" , int64 (nodeConfig .TotalHashRanges )),
103
- logger .NewDurationField ("snapshotInterval" , nodeConfig .SnapshotInterval ),
104
- logger .NewDurationField ("gcInterval" , nodeConfig .GarbageCollectionInterval ),
105
104
logger .NewStringField ("nodeAddresses" , fmt .Sprintf ("%+v" , nodeConfig .Addresses )),
106
105
logger .NewIntField ("noOfAddresses" , int64 (len (nodeConfig .Addresses ))),
107
106
)
0 commit comments