Imported Upstream version 1.22.0
[platform/upstream/grpc.git] / src / core / ext / filters / client_channel / client_channel_channelz.h
1 /*
2  *
3  * Copyright 2018 gRPC authors.
4  *
5  * Licensed under the Apache License, Version 2.0 (the "License");
6  * you may not use this file except in compliance with the License.
7  * You may obtain a copy of the License at
8  *
9  *     http://www.apache.org/licenses/LICENSE-2.0
10  *
11  * Unless required by applicable law or agreed to in writing, software
12  * distributed under the License is distributed on an "AS IS" BASIS,
13  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
14  * See the License for the specific language governing permissions and
15  * limitations under the License.
16  *
17  */
18
19 #ifndef GRPC_CORE_EXT_FILTERS_CLIENT_CHANNEL_CLIENT_CHANNEL_CHANNELZ_H
20 #define GRPC_CORE_EXT_FILTERS_CLIENT_CHANNEL_CLIENT_CHANNEL_CHANNELZ_H
21
22 #include <grpc/support/port_platform.h>
23
24 #include "src/core/lib/channel/channel_args.h"
25 #include "src/core/lib/channel/channel_stack.h"
26 #include "src/core/lib/channel/channel_trace.h"
27 #include "src/core/lib/channel/channelz.h"
28
29 namespace grpc_core {
30
31 class Subchannel;
32
33 namespace channelz {
34
35 class SubchannelNode : public BaseNode {
36  public:
37   SubchannelNode(Subchannel* subchannel, size_t channel_tracer_max_nodes);
38   ~SubchannelNode() override;
39
40   void MarkSubchannelDestroyed() {
41     GPR_ASSERT(subchannel_ != nullptr);
42     subchannel_ = nullptr;
43   }
44
45   grpc_json* RenderJson() override;
46
47   // proxy methods to composed classes.
48   void AddTraceEvent(ChannelTrace::Severity severity, const grpc_slice& data) {
49     trace_.AddTraceEvent(severity, data);
50   }
51   void AddTraceEventWithReference(ChannelTrace::Severity severity,
52                                   const grpc_slice& data,
53                                   RefCountedPtr<BaseNode> referenced_channel) {
54     trace_.AddTraceEventWithReference(severity, data,
55                                       std::move(referenced_channel));
56   }
57   void RecordCallStarted() { call_counter_.RecordCallStarted(); }
58   void RecordCallFailed() { call_counter_.RecordCallFailed(); }
59   void RecordCallSucceeded() { call_counter_.RecordCallSucceeded(); }
60
61  private:
62   void PopulateConnectivityState(grpc_json* json);
63
64   Subchannel* subchannel_;
65   UniquePtr<char> target_;
66   CallCountingHelper call_counter_;
67   ChannelTrace trace_;
68 };
69
70 }  // namespace channelz
71 }  // namespace grpc_core
72
73 #endif /* GRPC_CORE_EXT_FILTERS_CLIENT_CHANNEL_CLIENT_CHANNEL_CHANNELZ_H */