Searched refs:ChannelStats (Results 1 – 14 of 14) sorted by relevance
24 import io.grpc.InternalChannelz.ChannelStats;149 static final class TestChannel implements InternalInstrumented<ChannelStats> {152 ChannelStats stats = new ChannelStats.Builder()164 public ListenableFuture<ChannelStats> getStats() { in getStats()165 SettableFuture<ChannelStats> ret = SettableFuture.create(); in getStats()
36 import io.grpc.InternalChannelz.ChannelStats;668 Collections.<InternalInstrumented<ChannelStats>>emptyList(), true))); in toGetTopChannelsResponse()678 ImmutableList.<InternalInstrumented<ChannelStats>>of(channel), false))); in toGetTopChannelsResponse()689 ImmutableList.<InternalInstrumented<ChannelStats>>of(channel), true))); in toGetTopChannelsResponse()702 ImmutableList.<InternalInstrumented<ChannelStats>>of(channel, channel2), true))); in toGetTopChannelsResponse()853 ChannelStats stats = toBuilder(channel.stats) in channelTrace_withoutEvents()879 ChannelStats stats = in channelTrace_withEvents()913 private static ChannelStats.Builder toBuilder(ChannelStats stats) { in toBuilder()914 ChannelStats.Builder builder = new ChannelStats.Builder() in toBuilder()
31 import io.grpc.InternalChannelz.ChannelStats;58 InternalInstrumented<ChannelStats> root1 = create(); in getRootChannels_onePage()67 InternalInstrumented<ChannelStats> root1 = create(); in getRootChannels_onePage_multi()68 InternalInstrumented<ChannelStats> root2 = create(); in getRootChannels_onePage_multi()78 InternalInstrumented<ChannelStats> root1 = create(); in getRootChannels_paginate()79 InternalInstrumented<ChannelStats> root2 = create(); in getRootChannels_paginate()93 InternalInstrumented<ChannelStats> root1 = create(); in getRootChannels_remove()103 InternalInstrumented<ChannelStats> root1 = create(); in getRootChannels_addAfterLastPage()111 InternalInstrumented<ChannelStats> root2 = create(); in getRootChannels_addAfterLastPage()195 InternalInstrumented<ChannelStats> root = create(); in getChannel()[all …]
54 private final ConcurrentNavigableMap<Long, InternalInstrumented<ChannelStats>> rootChannels55 = new ConcurrentSkipListMap<Long, InternalInstrumented<ChannelStats>>();56 private final ConcurrentMap<Long, InternalInstrumented<ChannelStats>> subchannels57 = new ConcurrentHashMap<Long, InternalInstrumented<ChannelStats>>();86 public void addSubchannel(InternalInstrumented<ChannelStats> subchannel) { in addSubchannel()91 public void addRootChannel(InternalInstrumented<ChannelStats> rootChannel) { in addRootChannel()120 public void removeSubchannel(InternalInstrumented<ChannelStats> subchannel) { in removeSubchannel()124 public void removeRootChannel(InternalInstrumented<ChannelStats> channel) { in removeRootChannel()146 List<InternalInstrumented<ChannelStats>> channelList in getRootChannels()147 = new ArrayList<InternalInstrumented<ChannelStats>>(); in getRootChannels()[all …]
34 import io.grpc.InternalChannelz.ChannelStats;66 final class OobChannel extends ManagedChannel implements InternalInstrumented<ChannelStats> {157 InternalInstrumented<ChannelStats> getInternalSubchannel() { in setSubchannel()292 public ListenableFuture<ChannelStats> getStats() { in getStats()293 final SettableFuture<ChannelStats> ret = SettableFuture.create(); in getStats()294 final ChannelStats.Builder builder = new ChannelStats.Builder(); in getStats()
20 import io.grpc.InternalChannelz.ChannelStats;42 abstract InternalInstrumented<ChannelStats> getInternalSubchannel(); in getInternalSubchannel()
21 import io.grpc.InternalChannelz.ChannelStats;51 void updateBuilder(ChannelStats.Builder builder) { in updateBuilder()
22 import io.grpc.InternalChannelz.ChannelStats;80 void updateBuilder(ChannelStats.Builder builder) { in updateBuilder()
39 import io.grpc.InternalChannelz.ChannelStats;66 final class InternalSubchannel implements InternalInstrumented<ChannelStats> {497 public ListenableFuture<ChannelStats> getStats() { in getStats()498 SettableFuture<ChannelStats> ret = SettableFuture.create(); in getStats()499 ChannelStats.Builder builder = new ChannelStats.Builder(); in getStats()
48 import io.grpc.InternalChannelz.ChannelStats;90 InternalInstrumented<ChannelStats> {299 public ListenableFuture<ChannelStats> getStats() { in getStats()300 final SettableFuture<ChannelStats> ret = SettableFuture.create(); in getStats()305 ChannelStats.Builder builder = new InternalChannelz.ChannelStats.Builder(); in getStats()1393 InternalInstrumented<ChannelStats> getInternalSubchannel() { in getInternalSubchannel()
21 import io.grpc.InternalChannelz.ChannelStats;50 ChannelStats.Builder builder = new ChannelStats.Builder(); in reportEvents()61 ChannelStats stats = builder.build(); in reportEvents()
73 import io.grpc.InternalChannelz.ChannelStats;2948 private static ChannelStats getStats(AbstractSubchannel subchannel) throws Exception { in getStats()2952 private static ChannelStats getStats( in getStats()2953 InternalInstrumented<ChannelStats> instrumented) throws Exception { in getStats()
22 import io.grpc.InternalChannelz.ChannelStats;79 InternalInstrumented<ChannelStats> s = channelz.getRootChannel(request.getChannelId()); in getChannel()107 InternalInstrumented<ChannelStats> s = channelz.getSubchannel(request.getSubchannelId()); in getSubchannel()
28 import io.grpc.InternalChannelz.ChannelStats;342 static Channel toChannel(InternalInstrumented<ChannelStats> channel) { in toChannel()343 ChannelStats stats = getFuture(channel.getStats()); in toChannel()355 static ChannelData extractChannelData(InternalChannelz.ChannelStats stats) { in extractChannelData()410 static Subchannel toSubchannel(InternalInstrumented<ChannelStats> subchannel) { in toSubchannel()411 ChannelStats stats = getFuture(subchannel.getStats()); in toSubchannel()430 for (InternalInstrumented<ChannelStats> c : rootChannels.channels) { in toGetTopChannelResponse()