|
1 | 1 | package io.netifi.proteus.admin.tracing; |
2 | 2 |
|
3 | 3 | import io.netifi.proteus.admin.connection.ConnectionManager; |
4 | | -import io.netifi.proteus.frames.admin.AdminFrameHeaderFlyweight; |
5 | | -import io.netifi.proteus.frames.admin.AdminFrameType; |
6 | | -import io.netifi.proteus.frames.admin.AdminTraceMetadataFlyweight; |
7 | | -import io.netifi.proteus.frames.admin.AdminTraceType; |
8 | 4 | import io.netifi.proteus.admin.om.Notice; |
9 | 5 | import io.netifi.proteus.admin.tracing.internal.Connection; |
10 | 6 | import io.netifi.proteus.admin.tracing.internal.Metrics; |
11 | 7 | import io.netifi.proteus.admin.tracing.internal.Node; |
12 | 8 | import io.netifi.proteus.frames.RouteDestinationFlyweight; |
13 | 9 | import io.netifi.proteus.frames.RouteType; |
14 | 10 | import io.netifi.proteus.frames.RoutingFlyweight; |
| 11 | +import io.netifi.proteus.frames.admin.AdminFrameHeaderFlyweight; |
| 12 | +import io.netifi.proteus.frames.admin.AdminFrameType; |
| 13 | +import io.netifi.proteus.frames.admin.AdminTraceMetadataFlyweight; |
| 14 | +import io.netifi.proteus.frames.admin.AdminTraceType; |
15 | 15 | import io.netifi.proteus.util.TimebasedIdGenerator; |
16 | 16 | import io.netty.buffer.ByteBuf; |
17 | 17 | import io.netty.buffer.ByteBufAllocator; |
18 | 18 | import io.netty.buffer.Unpooled; |
19 | 19 | import io.rsocket.Closeable; |
20 | 20 | import io.rsocket.Payload; |
21 | 21 | import io.rsocket.util.ByteBufPayload; |
22 | | -import java.time.Duration; |
23 | | -import java.util.ArrayList; |
24 | | -import java.util.Collections; |
25 | | -import java.util.List; |
26 | | -import java.util.stream.Collectors; |
27 | 22 | import org.slf4j.Logger; |
28 | 23 | import org.slf4j.LoggerFactory; |
29 | 24 | import reactor.core.publisher.Flux; |
30 | 25 | import reactor.core.publisher.Mono; |
31 | 26 | import reactor.core.publisher.MonoProcessor; |
32 | 27 | import reactor.core.scheduler.Schedulers; |
33 | 28 |
|
| 29 | +import java.time.Duration; |
| 30 | +import java.util.ArrayList; |
| 31 | +import java.util.Collections; |
| 32 | +import java.util.List; |
| 33 | +import java.util.stream.Collectors; |
| 34 | + |
34 | 35 | public class DefaultAdminTraceService implements AdminTraceService, Closeable { |
35 | 36 | private static final Logger logger = LoggerFactory.getLogger(DefaultAdminTraceService.class); |
36 | 37 | private final MonoProcessor<Void> onClose; |
@@ -185,6 +186,7 @@ private Node createRootNode() { |
185 | 186 | node.setConnections(new ArrayList<>()); |
186 | 187 | node.setName("edge"); |
187 | 188 | node.setRenderer("region"); |
| 189 | + node.setMaxVolume(5000D); |
188 | 190 | return node; |
189 | 191 | } |
190 | 192 |
|
@@ -214,7 +216,7 @@ private io.netifi.proteus.admin.om.Node translateNode(Node node) { |
214 | 216 | .setClass_(node.getClazz() == null ? "" : node.getClazz()) |
215 | 217 | .setUpdated(node.getUpdated() == null ? 0 : node.getUpdated()) |
216 | 218 | .addAllNodes(nodes) |
217 | | - .addAllConnection(connections) |
| 219 | + .addAllConnections(connections) |
218 | 220 | .setDisplayName(node.getDisplayName() == null ? "" : node.getDisplayName()) |
219 | 221 | .addAllMetadata(node.getMetadata() == null ? Collections.EMPTY_LIST : node.getMetadata()) |
220 | 222 | .setMetrics(metrics) |
|
0 commit comments