@@ -907,13 +907,13 @@ func (m *Metrics) String() string {
907
907
// LSM level metrics.
908
908
cur := wb .At (0 , 0 )
909
909
cur = cur .WriteString (levelMetricsTableTopHeader ).NewlineReturn ()
910
- cur = levelMetricsTable .Render (cur , table.RenderOptions {}, m .LevelMetricsIter ())
910
+ cur = levelMetricsTable .Render (cur , table.RenderOptions {}, slices . Collect ( m .LevelMetricsIter ()) ... )
911
911
cur .Offset (- 1 , 0 ).WriteString ("total" )
912
912
cur = cur .NewlineReturn ()
913
913
914
914
// Compaction level metrics.
915
915
cur = cur .WriteString (levelCompactionMetricsTableTopHeader ).NewlineReturn ()
916
- cur = compactionLevelMetricsTable .Render (cur , table.RenderOptions {}, m .LevelMetricsIter ())
916
+ cur = compactionLevelMetricsTable .Render (cur , table.RenderOptions {}, slices . Collect ( m .LevelMetricsIter ()) ... )
917
917
cur .Offset (- 1 , 0 ).WriteString ("total" )
918
918
919
919
cur = cur .NewlineReturn ()
@@ -929,7 +929,7 @@ func (m *Metrics) String() string {
929
929
{k : "multi" , v : m .Compact .MultiLevelCount },
930
930
{k : "blob" , v : m .Compact .BlobFileRewriteCount },
931
931
}
932
- cur = compactionKindTable .Render (cur , table.RenderOptions {Orientation : table .Horizontally }, slices . Values ( compactionKindContents ) )
932
+ cur = compactionKindTable .Render (cur , table.RenderOptions {Orientation : table .Horizontally }, compactionKindContents ... )
933
933
cur = cur .NewlineReturn ()
934
934
935
935
commitPipelineInfoContents := commitPipelineInfo {
@@ -947,7 +947,7 @@ func (m *Metrics) String() string {
947
947
}
948
948
cur = cur .WriteString (commitPipelineInfoTableTopHeader ).NewlineReturn ()
949
949
cur = cur .WriteString (commitPipelineInfoTableSubHeader ).NewlineReturn ()
950
- cur = commitPipelineInfoTable .Render (cur , table.RenderOptions {}, oneItemIter ( commitPipelineInfoContents ) )
950
+ cur = commitPipelineInfoTable .Render (cur , table.RenderOptions {}, commitPipelineInfoContents )
951
951
cur = cur .NewlineReturn ()
952
952
953
953
iteratorInfoContents := iteratorInfo {
@@ -961,7 +961,7 @@ func (m *Metrics) String() string {
961
961
}
962
962
cur = cur .WriteString (iteratorInfoTableTopHeader ).NewlineReturn ()
963
963
cur = cur .WriteString (iteratorInfoTableSubHeader ).NewlineReturn ()
964
- cur = iteratorInfoTable .Render (cur , table.RenderOptions {}, oneItemIter ( iteratorInfoContents ) )
964
+ cur = iteratorInfoTable .Render (cur , table.RenderOptions {}, iteratorInfoContents )
965
965
cur = cur .NewlineReturn ()
966
966
967
967
status := fmt .Sprintf ("%s pending" , humanizeCount (m .Table .PendingStatsCollectionCount ))
@@ -986,7 +986,7 @@ func (m *Metrics) String() string {
986
986
blobInfo : blobInfoContents ,
987
987
}
988
988
cur = cur .WriteString (fileInfoTableHeader ).NewlineReturn ()
989
- cur = fileInfoTable .Render (cur , table.RenderOptions {}, oneItemIter ( fileInfoContents ) )
989
+ cur = fileInfoTable .Render (cur , table.RenderOptions {}, fileInfoContents )
990
990
cur = cur .NewlineReturn ()
991
991
992
992
var inUseTotal uint64
@@ -1006,7 +1006,7 @@ func (m *Metrics) String() string {
1006
1006
memtablesTot : humanizeBytes (inUse (manual .MemTable )),
1007
1007
}
1008
1008
cur = cur .WriteString (cgoMemInfoTableHeader ).NewlineReturn ()
1009
- cur = cgoMemInfoTable .Render (cur , table.RenderOptions {}, oneItemIter ( cgoMemInfoContents ) )
1009
+ cur = cgoMemInfoTable .Render (cur , table.RenderOptions {}, cgoMemInfoContents )
1010
1010
cur = cur .NewlineReturn ()
1011
1011
1012
1012
compactionMetricsInfoContents := compactionMetricsInfo {
@@ -1019,7 +1019,7 @@ func (m *Metrics) String() string {
1019
1019
problemSpans : fmt .Sprintf ("%d%s" , m .Compact .NumProblemSpans , ifNonZero (m .Compact .NumProblemSpans , "!!" )),
1020
1020
}
1021
1021
cur = cur .WriteString (compactionInfoTableTopHeader ).NewlineReturn ()
1022
- cur = compactionInfoTable .Render (cur , table.RenderOptions {}, oneItemIter ( compactionMetricsInfoContents ) )
1022
+ cur = compactionInfoTable .Render (cur , table.RenderOptions {}, compactionMetricsInfoContents )
1023
1023
cur = cur .NewlineReturn ()
1024
1024
1025
1025
keysInfoContents := keysInfo {
@@ -1030,7 +1030,7 @@ func (m *Metrics) String() string {
1030
1030
rangeDels : humanizeBytes (m .Table .Garbage .RangeDeletionsBytesEstimate ),
1031
1031
}
1032
1032
cur = cur .WriteString (keysInfoTableTopHeader ).NewlineReturn ()
1033
- cur = keysInfoTable .Render (cur , table.RenderOptions {}, oneItemIter ( keysInfoContents ) )
1033
+ cur = keysInfoTable .Render (cur , table.RenderOptions {}, keysInfoContents )
1034
1034
cur = cur .NewlineReturn ()
1035
1035
1036
1036
cur = cur .WriteString (compressionTableHeader ).NewlineReturn ()
@@ -1053,7 +1053,7 @@ func (m *Metrics) String() string {
1053
1053
compressionContents = slices .DeleteFunc (compressionContents , func (i compressionInfo ) bool {
1054
1054
return i .tables == "" && i .blobFiles == ""
1055
1055
})
1056
- compressionTable .Render (cur , table.RenderOptions {}, slices . Values ( compressionContents ) )
1056
+ compressionTable .Render (cur , table.RenderOptions {}, compressionContents ... )
1057
1057
1058
1058
return wb .String ()
1059
1059
}
@@ -1153,9 +1153,3 @@ func humanizeBytesOrEmpty[T crhumanize.Integer](value T) string {
1153
1153
}
1154
1154
return crhumanize .Bytes (value , crhumanize .Compact , crhumanize .OmitI ).String ()
1155
1155
}
1156
-
1157
- func oneItemIter [T any ](v T ) iter.Seq [T ] {
1158
- return func (yield func (T ) bool ) {
1159
- yield (v )
1160
- }
1161
- }
0 commit comments