grpc
src
cpp
ext
filters
census
client_filter.h
Go to the documentation of this file.
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_INTERNAL_CPP_EXT_FILTERS_CENSUS_CLIENT_FILTER_H
20
#define GRPC_INTERNAL_CPP_EXT_FILTERS_CENSUS_CLIENT_FILTER_H
21
22
#include <
grpc/support/port_platform.h
>
23
24
#include "
src/core/lib/channel/channel_fwd.h
"
25
#include "
src/core/lib/channel/channel_stack.h
"
26
#include "
src/core/lib/iomgr/error.h
"
27
#include "
src/cpp/common/channel_filter.h
"
28
#include "
src/cpp/ext/filters/census/open_census_call_tracer.h
"
29
30
namespace
grpc
{
31
32
// A CallData class will be created for every grpc call within a channel. It is
33
// used to store data and methods specific to that call. CensusClientCallData is
34
// thread-compatible, however typically only 1 thread should be interacting with
35
// a call at a time.
36
class
CensusClientCallData
:
public
CallData
{
37
public
:
38
grpc_error_handle
Init
(
grpc_call_element
*
/* elem */
,
39
const
grpc_call_element_args
*
args
)
override
;
40
void
StartTransportStreamOpBatch
(
grpc_call_element
*
elem
,
41
TransportStreamOpBatch
*
op
)
override
;
42
43
private
:
44
OpenCensusCallTracer
*
tracer_
=
nullptr
;
45
};
46
47
}
// namespace grpc
48
49
#endif
/* GRPC_INTERNAL_CPP_EXT_FILTERS_CENSUS_CLIENT_FILTER_H */
channel_fwd.h
grpc
Definition:
grpcpp/alarm.h:33
elem
Timer elem
Definition:
event_engine/iomgr_event_engine/timer_heap_test.cc:109
grpc::CensusClientCallData::tracer_
OpenCensusCallTracer * tracer_
Definition:
client_filter.h:44
grpc_call_element
Definition:
channel_stack.h:194
grpc::TransportStreamOpBatch
A C++ wrapper for the grpc_transport_stream_op_batch struct.
Definition:
common/channel_filter.h:99
asyncio_get_stats.args
args
Definition:
asyncio_get_stats.py:40
grpc::CensusClientCallData::Init
grpc_error_handle Init(grpc_call_element *, const grpc_call_element_args *args) override
Initializes the call data.
Definition:
client_filter.cc:68
channel_stack.h
grpc::CallData
Represents call data.
Definition:
common/channel_filter.h:224
error.h
grpc_call_element_args
Definition:
channel_stack.h:80
grpc::CensusClientCallData::StartTransportStreamOpBatch
void StartTransportStreamOpBatch(grpc_call_element *elem, TransportStreamOpBatch *op) override
Starts a new stream operation.
Definition:
client_filter.cc:79
grpc::CensusClientCallData
Definition:
client_filter.h:36
grpc::OpenCensusCallTracer
Definition:
open_census_call_tracer.h:48
open_census_call_tracer.h
grpc_error
Definition:
error_internal.h:42
channel_filter.h
op
static grpc_op * op
Definition:
test/core/fling/client.cc:47
port_platform.h
grpc
Author(s):
autogenerated on Fri May 16 2025 02:57:55