GRPC C++  1.39.1
Namespaces | Data Structures | Typedefs | Enumerations | Functions | Variables
grpc_core Namespace Reference

Round Robin Policy. More...

Namespaces

 channelz
 
 chttp2
 
 internal
 
 manual_ctor_impl
 
 testing
 

Data Structures

class  ClientChannel
 
class  ClientChannelFactory
 
class  ConfigSelector
 
class  DefaultConfigSelector
 
class  SubchannelConnector
 
class  DynamicFilters
 
class  GlobalSubchannelPool
 
class  HealthCheckClient
 
class  LoadBalancingPolicy
 Interface for load balancing policies. More...
 
class  ChildPolicyHandler
 
class  GrpcLbClientStats
 
struct  GrpcLbServer
 
struct  GrpcLbResponse
 
class  SubchannelList
 
class  SubchannelData
 
class  XdsLocalityAttribute
 
class  LoadBalancingPolicyFactory
 
class  LoadBalancingPolicyRegistry
 
class  LocalSubchannelPool
 
class  ProxyMapperInterface
 
class  ProxyMapperRegistry
 
class  Resolver
 Interface for name resolution. More...
 
class  GrpcPolledFd
 
class  GrpcPolledFdFactory
 
class  FakeResolver
 
class  FakeResolverResponseSetter
 
class  FakeResolverResponseGenerator
 A mechanism for generating responses for the fake resolver. More...
 
struct  ResolverArgs
 
class  ResolverFactory
 
class  ResolverRegistry
 
class  ServerAddress
 
class  ServerAddressWeightAttribute
 
class  ServiceConfig
 
class  ServiceConfigCallData
 When a service config is applied to a call in the client_channel_filter, we create an instance of this object on the arena. More...
 
class  ServiceConfigParser
 
class  ConnectedSubchannel
 
class  SubchannelCall
 
class  Subchannel
 
class  SubchannelInterface
 
class  DelegatingSubchannel
 
class  SubchannelKey
 
class  SubchannelPoolInterface
 
class  TimerState
 
class  FaultInjectionMethodParsedConfig
 
class  FaultInjectionServiceConfigParser
 
class  ConnectivityWatcher
 
class  MessageSizeParsedConfig
 
class  MessageSizeParser
 
class  Chttp2Connector
 
class  Chttp2InsecureClientChannelFactory
 
class  Chttp2SecureClientChannelFactory
 
class  ContextList
 A list of RPC Contexts. More...
 
class  Chttp2IncomingByteStream
 
class  CertificateProviderFactory
 
class  CertificateProviderRegistry
 
class  CertificateProviderStore
 
class  FileWatcherCertificateProviderFactory
 
struct  FilterChain
 
class  XdsApi
 
class  XdsChannelCredsRegistry
 
class  XdsBootstrap
 
class  XdsCertificateProvider
 
class  XdsClient
 
class  XdsLocalityName
 
class  XdsClusterDropStats
 
class  XdsClusterLocalityStats
 
class  XdsHttpFaultFilter
 
class  XdsHttpFilterImpl
 
class  XdsHttpFilterRegistry
 
class  BackOff
 Implementation of the backoff mechanism described in doc/connection-backoff.md. More...
 
struct  HandshakerArgs
 Handshakers are used to perform initial handshakes on a connection before the client sends the initial request. More...
 
class  Handshaker
 Handshaker. More...
 
class  HandshakeManager
 
class  HandshakerFactory
 
class  HandshakerRegistry
 
class  TraceFlagList
 
class  TraceFlag
 
class  Arena
 
class  Atomic
 
class  DebugLocation
 
class  DualRefCounted
 
class  Fork
 
class  GlobalConfigEnv
 
class  GlobalConfigEnvBool
 
class  GlobalConfigEnvInt32
 
class  GlobalConfigEnvString
 
class  PolymorphicManualConstructor
 
class  ManualConstructor
 
class  DefaultDeleteChar
 
class  MultiProducerSingleConsumerQueue
 
class  LockedMultiProducerSingleConsumerQueue
 
class  Orphanable
 
class  OrphanableDelete
 
class  InternallyRefCounted
 
class  RefCount
 
class  PolymorphicRefCount
 
class  NonPolymorphicRefCount
 
class  RefCounted
 
class  RefCountedPtr
 
class  WeakRefCountedPtr
 
class  Mutex
 
class  MutexLock
 
class  ReleasableMutexLock
 
class  CondVar
 
class  MutexLockForGprMu
 
class  LockableAndReleasableMutexLock
 
class  Thread
 
struct  ConnectionMetrics
 
struct  Timestamp
 
struct  Timestamps
 
class  TracedBuffer
 TracedBuffer is a class to keep track of timestamps for a specific buffer in the TCP layer. More...
 
class  CallCombiner
 
class  CallCombinerClosureList
 
class  Closure
 
class  Combiner
 
class  ExecCtx
 Execution context. More...
 
class  ApplicationCallbackExecCtx
 Application-callback execution context. More...
 
struct  ThreadState
 
class  Executor
 
class  MPMCQueueInterface
 
class  InfLenFIFOQueue
 
class  ThreadPoolInterface
 
class  ThreadPoolWorker
 
class  ThreadPool
 
class  LockfreeEvent
 
class  RuSliceRefcount
 
class  TcpServerFdHandler
 
struct  CallbackWrapper
 
class  WorkSerializer
 
class  Json
 
class  StringMatcher
 
class  HeaderMatcher
 
class  AuthorizationEngine
 
class  EvaluateArgs
 
class  AwsExternalAccountCredentials
 
class  AwsRequestSigner
 
class  ExternalAccountCredentials
 
class  FileExternalAccountCredentials
 
class  UrlExternalAccountCredentials
 
class  StaticDataCertificateProvider
 
class  FileWatcherCertificateProvider
 
class  XdsCredentials
 
class  XdsServerCredentials
 
class  InsecureChannelSecurityConnector
 
class  InsecureServerSecurityConnector
 
class  DefaultSslRootStore
 
class  PemKeyCertPair
 
class  TlsChannelSecurityConnector
 
class  TlsServerSecurityConnector
 
class  NewSliceRefcount
 
class  NewWithLenSliceRefcount
 
class  MovedStringSliceRefCount
 grpc_slice_from_moved_(string|buffer) ref count . More...
 
class  MovedCppStringSliceRefCount
 
struct  StaticSliceRefcount
 
struct  InternedSliceRefcount
 
struct  SliceHash
 
struct  ManagedMemorySlice
 
struct  UnmanagedMemorySlice
 
struct  ExternallyManagedSlice
 
struct  StaticMetadataSlice
 
struct  InternedSlice
 
struct  RegisteredCall
 
struct  CallRegistrationTable
 
class  Server
 
class  BdpEstimator
 
class  ByteStream
 
class  SliceBufferByteStream
 
class  ByteStreamCache
 
class  ConnectivityStateWatcherInterface
 
class  AsyncConnectivityStateWatcherInterface
 
class  ConnectivityStateTracker
 
struct  UserData
 
class  StaticMetadata
 
class  RefcountedMdBase
 
class  InternedMetadata
 
class  AllocatedMetadata
 
class  PidController
 
struct  StaticMetadataCtx
 
class  URI
 

Typedefs

using HierarchicalAddressMap = std::map< std::string, ServerAddressList >
 
typedef absl::InlinedVector< ServerAddress, 1 > ServerAddressList
 
using Chttp2ServerArgsModifier = std::function< grpc_channel_args *(grpc_channel_args *, grpc_error_handle *)>
 
typedef void(* TestOnlyGlobalHttp2TransportInitCallback) ()
 
typedef void(* TestOnlyGlobalHttp2TransportDestructCallback) ()
 
typedef TraceFlag DebugOnlyTraceFlag
 
typedef std::string(* gpr_current_stack_trace_func) ()
 
typedef void(* GlobalConfigEnvErrorFunctionType) (const char *error_message)
 
template<typename T >
using UniquePtr = std::unique_ptr< T, DefaultDeleteChar >
 
template<typename T , typename Deleter = OrphanableDelete>
using OrphanablePtr = std::unique_ptr< T, Deleter >
 
typedef absl::InlinedVector< grpc_core::PemKeyCertPair, 1 > PemKeyCertPairList
 
typedef void(* destroy_user_data_func) (void *data)
 

Enumerations

enum  HandshakerType { HANDSHAKER_CLIENT = 0 , HANDSHAKER_SERVER , NUM_HANDSHAKER_TYPES }
 
enum class  MemoryOrder {
  RELAXED = static_cast<int>(std::memory_order_relaxed) , CONSUME = static_cast<int>(std::memory_order_consume) , ACQUIRE = static_cast<int>(std::memory_order_acquire) , RELEASE = static_cast<int>(std::memory_order_release) ,
  ACQ_REL = static_cast<int>(std::memory_order_acq_rel) , SEQ_CST = static_cast<int>(std::memory_order_seq_cst)
}
 
enum  UnrefBehavior { kUnrefDelete , kUnrefNoDelete , kUnrefCallDtor }
 
enum class  StatusIntProperty {
  kErrorNo , kFileLine , kStreamId , kRpcStatus ,
  kOffset , kIndex , kSize , kHttp2Error ,
  kTsiCode , kWsaError , kFd , kHttpStatus ,
  kOccurredDuringWrite , ChannelConnectivityState , kLbPolicyDrop
}
 This enum should have the same value of grpc_error_ints. More...
 
enum class  StatusStrProperty {
  kDescription , kFile , kOsError , kSyscall ,
  kTargetAddress , kGrpcMessage , kRawBytes , kTsiError ,
  kFilename , kKey , kValue
}
 This enum should have the same value of grpc_error_strs. More...
 
enum class  StatusTimeProperty { kCreated }
 This enum should have the same value of grpc_error_times. More...
 
enum class  ExecutorType { DEFAULT = 0 , RESOLVER , NUM_EXECUTORS }
 
enum class  ExecutorJobType { SHORT = 0 , LONG , NUM_JOB_TYPES }
 

Functions

const LoadBalancingPolicy::BackendMetricDataParseBackendMetricData (const grpc_slice &serialized_load_report, Arena *arena)
 
void RegisterHttpProxyMapper ()
 
std::unique_ptr< ServerAddress::AttributeInterfaceMakeHierarchicalPathAttribute (std::vector< std::string > path)
 
HierarchicalAddressMap MakeHierarchicalAddressMap (const ServerAddressList &addresses)
 
grpc_arg CreateGrpclbBalancerAddressesArg (const ServerAddressList *address_list)
 
const ServerAddressListFindGrpclbBalancerAddressesInChannelArgs (const grpc_channel_args &args)
 
grpc_channel_argsModifyGrpclbBalancerChannelArgs (grpc_channel_args *args)
 Makes any necessary modifications to args for use in the grpclb balancer channel. More...
 
grpc_channelCreateGrpclbBalancerChannel (const char *target_uri, const grpc_channel_args &args)
 
grpc_slice GrpcLbRequestCreate (const char *lb_service_name, upb_arena *arena)
 
grpc_slice GrpcLbLoadReportRequestCreate (int64_t num_calls_started, int64_t num_calls_finished, int64_t num_calls_finished_with_client_failed_to_send, int64_t num_calls_finished_known_received, const GrpcLbClientStats::DroppedCallCounts *drop_token_counts, upb_arena *arena)
 
bool GrpcLbResponseParse (const grpc_slice &serialized_response, upb_arena *arena, GrpcLbResponse *result)
 
void ParseRingHashLbConfig (const Json &json, size_t *min_ring_size, size_t *max_ring_size, std::vector< grpc_error_handle > *error_list)
 
void GrpcLbPolicyRingHashInit ()
 
void GrpcLbPolicyRingHashShutdown ()
 
std::unique_ptr< GrpcPolledFdFactoryNewGrpcPolledFdFactory (std::shared_ptr< grpc_core::WorkSerializer > work_serializer)
 
void GoogleCloud2ProdResolverInit ()
 
void GoogleCloud2ProdResolverShutdown ()
 
void FaultInjectionFilterInit (void)
 
void FaultInjectionFilterShutdown (void)
 
int GetMaxRecvSizeFromChannelArgs (const grpc_channel_args *args)
 
int GetMaxSendSizeFromChannelArgs (const grpc_channel_args *args)
 
grpc_error_handle Chttp2ServerAddPort (Server *server, const char *addr, grpc_channel_args *args, Chttp2ServerArgsModifier connection_args_modifier, int *port_num)
 Adds a port to server. More...
 
void TestOnlySetGlobalHttp2TransportInitCallback (TestOnlyGlobalHttp2TransportInitCallback callback)
 
void TestOnlySetGlobalHttp2TransportDestructCallback (TestOnlyGlobalHttp2TransportDestructCallback callback)
 
void grpc_http2_set_write_timestamps_callback (void(*fn)(void *, grpc_core::Timestamps *, grpc_error_handle error))
 
void grpc_http2_set_fn_get_copied_context (void *(*fn)(void *))
 
void FileWatcherCertificateProviderInit ()
 
void FileWatcherCertificateProviderShutdown ()
 
bool XdsAggregateAndLogicalDnsClusterEnabled ()
 
bool XdsRingHashEnabled ()
 
bool XdsSecurityEnabled ()
 
void XdsClientGlobalInit ()
 
void XdsClientGlobalShutdown () ABSL_NO_THREAD_SAFETY_ANALYSIS
 
grpc_error_handle UnixSockaddrPopulate (absl::string_view path, grpc_resolved_address *resolved_addr)
 Populate resolved_addr to be a unix socket at |path|. More...
 
grpc_error_handle UnixAbstractSockaddrPopulate (absl::string_view path, grpc_resolved_address *resolved_addr)
 Populate resolved_addr to be a unix socket in the abstract namespace at |path|. More...
 
gpr_current_stack_trace_func GetCurrentStackTraceProvider ()
 
void SetCurrentStackTraceProvider (gpr_current_stack_trace_func current_stack_trace_provider)
 
absl::optional< std::string > GetCurrentStackTrace ()
 
void SetGlobalConfigEnvErrorFunction (GlobalConfigEnvErrorFunctionType func)
 
std::string JoinHostPort (absl::string_view host, int port)
 
bool SplitHostPort (absl::string_view name, absl::string_view *host, absl::string_view *port)
 Given a name in the form "host:port" or "[ho:st]:port", split into hostname and port number. More...
 
bool SplitHostPort (absl::string_view name, std::string *host, std::string *port)
 
template<typename T , typename... Args>
OrphanablePtr< T > MakeOrphanable (Args &&... args)
 
template<typename T , typename... Args>
RefCountedPtr< T > MakeRefCounted (Args &&... args)
 
template<typename T >
bool operator< (const RefCountedPtr< T > &p1, const RefCountedPtr< T > &p2)
 
template<typename T >
bool operator< (const WeakRefCountedPtr< T > &p1, const WeakRefCountedPtr< T > &p2)
 
absl::Status GetFileModificationTime (const char *filename, time_t *timestamp)
 
absl::Status StatusCreate (absl::StatusCode code, absl::string_view msg, const DebugLocation &location, std::initializer_list< absl::Status > children) GRPC_MUST_USE_RESULT
 Creates a status with given additional information. More...
 
void StatusSetInt (absl::Status *status, StatusIntProperty key, intptr_t value)
 Sets the int property to the status. More...
 
absl::optional< intptr_t > StatusGetInt (const absl::Status &status, StatusIntProperty key) GRPC_MUST_USE_RESULT
 Gets the int property from the status. More...
 
void StatusSetStr (absl::Status *status, StatusStrProperty key, absl::string_view value)
 Sets the str property to the status. More...
 
absl::optional< std::string > StatusGetStr (const absl::Status &status, StatusStrProperty key) GRPC_MUST_USE_RESULT
 Gets the str property from the status. More...
 
void StatusSetTime (absl::Status *status, StatusTimeProperty key, absl::Time time)
 Sets the time property to the status. More...
 
absl::optional< absl::Time > StatusGetTime (const absl::Status &status, StatusTimeProperty key) GRPC_MUST_USE_RESULT
 Gets the time property from the status. More...
 
void StatusAddChild (absl::Status *status, absl::Status child)
 Adds a child status to status. More...
 
std::vector< absl::Status > StatusGetChildren (absl::Status status) GRPC_MUST_USE_RESULT
 Returns all children status from a status. More...
 
std::string StatusToString (const absl::Status &status) GRPC_MUST_USE_RESULT
 Returns a string representation from status Error status will be like STATUS[:MESSAGE] [{PAYLOADS[, children:[CHILDREN-STATUS-LISTS]]}] e.g. More...
 
gpr_muGetUnderlyingGprMu (Mutex *mutex)
 
gpr_timespec ToGprTimeSpec (absl::Duration duration)
 
gpr_timespec ToGprTimeSpec (absl::Time time)
 
absl::Duration ToAbslDuration (gpr_timespec ts)
 
absl::Time ToAbslTime (gpr_timespec ts)
 
void grpc_tcp_set_write_timestamps_callback (void(*fn)(void *, grpc_core::Timestamps *, grpc_error_handle error))
 Sets the callback function to call when timestamps for a write are collected. More...
 
 GPR_TLS_CLASS_DEF (ExecCtx::exec_ctx_)
 
 GPR_TLS_CLASS_DEF (ApplicationCallbackExecCtx::callback_exec_ctx_)
 
void grpc_executor_global_init ()
 
void grpc_errqueue_init ()
 
bool ParseDurationFromJson (const Json &field, grpc_millis *duration)
 
template<typename NumericType , typename ErrorVectorType >
bool ExtractJsonNumber (const Json &json, const std::string &field_name, NumericType *output, ErrorVectorType *error_list)
 
template<typename ErrorVectorType >
bool ExtractJsonBool (const Json &json, const std::string &field_name, bool *output, ErrorVectorType *error_list)
 
template<typename ErrorVectorType >
bool ExtractJsonString (const Json &json, const std::string &field_name, std::string *output, ErrorVectorType *error_list)
 
template<typename ErrorVectorType >
bool ExtractJsonArray (const Json &json, const std::string &field_name, const Json::Array **output, ErrorVectorType *error_list)
 
template<typename ErrorVectorType >
bool ExtractJsonObject (const Json &json, const std::string &field_name, const Json::Object **output, ErrorVectorType *error_list)
 
template<typename NumericType , typename ErrorVectorType >
bool ExtractJsonType (const Json &json, const std::string &field_name, NumericType *output, ErrorVectorType *error_list)
 
template<typename ErrorVectorType >
bool ExtractJsonType (const Json &json, const std::string &field_name, bool *output, ErrorVectorType *error_list)
 
template<typename ErrorVectorType >
bool ExtractJsonType (const Json &json, const std::string &field_name, std::string *output, ErrorVectorType *error_list)
 
template<typename ErrorVectorType >
bool ExtractJsonType (const Json &json, const std::string &field_name, const Json::Array **output, ErrorVectorType *error_list)
 
template<typename ErrorVectorType >
bool ExtractJsonType (const Json &json, const std::string &field_name, const Json::Object **output, ErrorVectorType *error_list)
 
template<typename T , typename ErrorVectorType >
bool ParseJsonObjectField (const Json::Object &object, const std::string &field_name, T *output, ErrorVectorType *error_list, bool required=true)
 
template<typename ErrorVectorType >
bool ParseJsonObjectFieldAsDuration (const Json::Object &object, const std::string &field_name, grpc_millis *output, ErrorVectorType *error_list, bool required=true)
 
absl::StatusOr< URIValidateStsCredentialsOptions (const grpc_sts_credentials_options *options)
 
bool VerifySubjectAlternativeName (absl::string_view subject_alternative_name, const std::string &matcher)
 
absl::string_view GetAuthPropertyValue (grpc_auth_context *context, const char *property_name)
 
std::vector< absl::string_view > GetAuthPropertyArray (grpc_auth_context *context, const char *property_name)
 
bool TestOnlyXdsVerifySubjectAlternativeNames (const char *const *subject_alternative_names, size_t subject_alternative_names_size, const std::vector< StringMatcher > &matchers)
 
RefCountedPtr< grpc_auth_contextTestOnlyMakeInsecureAuthContext ()
 
grpc_slice LoadSystemRootCerts ()
 
RefCountedPtr< HandshakerSecurityHandshakerCreate (tsi_handshaker *handshaker, grpc_security_connector *connector, const grpc_channel_args *args)
 Creates a security handshaker using handshaker. More...
 
void SecurityRegisterHandshakerFactories ()
 Registers security handshaker factories. More...
 
absl::string_view StringViewFromSlice (const grpc_slice &slice)
 
grpc_arg MakeLameClientErrorArg (grpc_error_handle error)
 
grpc_arg CreateAuthorityOverrideChannelArg (const char *authority)
 Returns a channel argument containing authority. More...
 
absl::string_view FindAuthorityOverrideInArgs (const grpc_channel_args *args)
 Returns the authority override from args or the empty string. More...
 
const char * ConnectivityStateName (grpc_connectivity_state state)
 
uint64_t StaticMetadataInitCanary ()
 

Variables

TraceFlag grpc_client_channel_call_trace (false, "client_channel_call")
 
TraceFlag grpc_client_channel_routing_trace (false, "client_channel_routing")
 
TraceFlag grpc_health_check_client_trace (false, "health_check_client")
 
DebugOnlyTraceFlag grpc_trace_lb_policy_refcount (false, "lb_policy_refcount")
 
const char * kHierarchicalPathAttributeKey = "hierarchical_path"
 
TraceFlag grpc_lb_glb_trace (false, "glb")
 
const char kGrpcLbClientStatsMetadataKey [] = "grpclb_client_stats"
 
const char kGrpcLbLbTokenMetadataKey [] = "lb-token"
 
const char kGrpcLbAddressAttributeKey [] = "grpclb"
 
TraceFlag grpc_lb_pick_first_trace (false, "pick_first")
 
TraceFlag grpc_lb_priority_trace (false, "priority_lb")
 
const char * kRequestRingHashAttribute = "request_ring_hash"
 
TraceFlag grpc_lb_ring_hash_trace (false, "ring_hash_lb")
 
TraceFlag grpc_lb_round_robin_trace (false, "round_robin")
 
TraceFlag grpc_lb_weighted_target_trace (false, "weighted_target_lb")
 
TraceFlag grpc_cds_lb_trace (false, "cds_lb")
 
const char * kXdsLocalityNameAttributeKey = "xds_locality_name"
 
TraceFlag grpc_xds_cluster_impl_lb_trace (false, "xds_cluster_impl_lb")
 
TraceFlag grpc_xds_cluster_manager_lb_trace (false, "xds_cluster_manager_lb")
 
TraceFlag grpc_lb_xds_cluster_resolver_trace (false, "xds_cluster_resolver_lb")
 
TraceFlag grpc_xds_resolver_trace (false, "xds_resolver")
 
const char * kXdsClusterAttribute = "xds_cluster_name"
 
const grpc_channel_filter kRetryFilterVtable
 
TraceFlag grpc_trace_subchannel (false, "subchannel")
 
DebugOnlyTraceFlag grpc_trace_subchannel_refcount (false, "subchannel_refcount")
 
TraceFlag grpc_subchannel_pool_trace (false, "subchannel_pool")
 
TraceFlag grpc_trace_client_idle_filter (false, "client_idle_filter")
 
TraceFlag grpc_fault_injection_filter_trace (false, "fault_injection_filter")
 
const grpc_channel_filter FaultInjectionFilterVtable
 
const grpc_channel_filter MessageDecompressFilter
 
TraceFlag grpc_xds_client_trace (false, "xds_client")
 
TraceFlag grpc_xds_client_refcount_trace (false, "xds_client_refcount")
 
const char * kXdsHttpFaultFilterConfigName
 
const char * kXdsHttpRouterFilterConfigName
 
TraceFlag grpc_xds_server_config_fetcher_trace (false, "xds_server_config_fetcher")
 
TraceFlag grpc_handshaker_trace (false, "handshaker")
 
gpr_current_stack_trace_func g_current_stack_trace_provider = nullptr
 
DebugOnlyTraceFlag grpc_call_combiner_trace (false, "call_combiner")
 
TraceFlag executor_trace (false, "executor")
 
DebugOnlyTraceFlag grpc_thread_pool_trace (false, "thread_pool")
 
const char * kDefaultSecurePort = "https"
 
constexpr int kDefaultSecurePortInt = 443
 
DebugOnlyTraceFlag grpc_work_serializer_trace (false, "work_serializer")
 
const char kCredentialsTypeXds [] = "Xds"
 
const char kInsecureTransportSecurityType [] = "insecure"
 
grpc_slice_refcount kNoopRefcount (grpc_slice_refcount::Type::NOP)
 
uint32_t g_hash_seed
 
TraceFlag grpc_server_channel_trace (false, "server_channel")
 
TraceFlag grpc_connectivity_state_trace (false, "connectivity_state")
 
const StaticMetadataSliceg_static_metadata_slice_table = nullptr
 
StaticSliceRefcountg_static_metadata_slice_refcounts = nullptr
 
StaticMetadatag_static_mdelem_table = nullptr
 
grpc_mdelemg_static_mdelem_manifested = nullptr
 
constexpr uint64_t kGrpcStaticMetadataInitCanary = 0xCAFEF00DC0FFEE11L
 
constexpr const char * kKeepaliveThrottlingKey
 

Detailed Description

Round Robin Policy.

Internal thread interface.

Before every pick, the get_next_ready_subchannel_index_locked function returns the p->subchannel_list->subchannels index for next subchannel, respecting the relative order of the addresses provided upon creation or updates. Note however that updates will start picking from the beginning of the updated list.

Typedef Documentation

◆ Chttp2ServerArgsModifier

◆ DebugOnlyTraceFlag

◆ destroy_user_data_func

typedef void(* grpc_core::destroy_user_data_func) (void *data)

◆ GlobalConfigEnvErrorFunctionType

typedef void(* grpc_core::GlobalConfigEnvErrorFunctionType) (const char *error_message)

◆ gpr_current_stack_trace_func

typedef std::string(* grpc_core::gpr_current_stack_trace_func) ()

◆ HierarchicalAddressMap

using grpc_core::HierarchicalAddressMap = typedef std::map<std::string, ServerAddressList>

◆ OrphanablePtr

template<typename T , typename Deleter = OrphanableDelete>
using grpc_core::OrphanablePtr = typedef std::unique_ptr<T, Deleter>

◆ PemKeyCertPairList

◆ ServerAddressList

typedef absl::InlinedVector<ServerAddress, 1> grpc_core::ServerAddressList

◆ TestOnlyGlobalHttp2TransportDestructCallback

typedef void(* grpc_core::TestOnlyGlobalHttp2TransportDestructCallback) ()

◆ TestOnlyGlobalHttp2TransportInitCallback

typedef void(* grpc_core::TestOnlyGlobalHttp2TransportInitCallback) ()

◆ UniquePtr

template<typename T >
using grpc_core::UniquePtr = typedef std::unique_ptr<T, DefaultDeleteChar>

Enumeration Type Documentation

◆ ExecutorJobType

Enumerator
SHORT 
LONG 
NUM_JOB_TYPES 

◆ ExecutorType

Enumerator
DEFAULT 
RESOLVER 
NUM_EXECUTORS 

◆ HandshakerType

Enumerator
HANDSHAKER_CLIENT 
HANDSHAKER_SERVER 
NUM_HANDSHAKER_TYPES 

◆ MemoryOrder

Enumerator
RELAXED 
CONSUME 
ACQUIRE 
RELEASE 
ACQ_REL 
SEQ_CST 

◆ StatusIntProperty

This enum should have the same value of grpc_error_ints.

Enumerator
kErrorNo 

'errno' from the operating system

kFileLine 

LINE from the call site creating the error

kStreamId 

stream identifier: for errors that are associated with an individual wire stream

kRpcStatus 

grpc status code representing this error

kOffset 

offset into some binary blob (usually represented by RAW_BYTES) where the error occurred

kIndex 

context sensitive index associated with the error

kSize 

context sensitive size associated with the error

kHttp2Error 

http2 error code associated with the error (see the HTTP2 RFC)

kTsiCode 

TSI status code associated with the error.

kWsaError 

WSAGetLastError() reported when this error occurred.

kFd 

File descriptor associated with this error.

kHttpStatus 

HTTP status (i.e. 404)

kOccurredDuringWrite 

chttp2: did the error occur while a write was in progress

ChannelConnectivityState 

channel connectivity state associated with the error

kLbPolicyDrop 

LB policy drop.

◆ StatusStrProperty

This enum should have the same value of grpc_error_strs.

Enumerator
kDescription 

top-level textual description of this error

kFile 

source file in which this error occurred

kOsError 

operating system description of this error

kSyscall 

syscall that generated this error

kTargetAddress 

peer that we were trying to communicate when this error occurred

kGrpcMessage 

grpc status message associated with this error

kRawBytes 

hex dump (or similar) with the data that generated this error

kTsiError 

tsi error string associated with this error

kFilename 

filename that we were trying to read/write when this error occurred

kKey 

key associated with the error

kValue 

value associated with the error

◆ StatusTimeProperty

This enum should have the same value of grpc_error_times.

Enumerator
kCreated 

timestamp of error creation

◆ UnrefBehavior

Enumerator
kUnrefDelete 
kUnrefNoDelete 
kUnrefCallDtor 

Function Documentation

◆ Chttp2ServerAddPort()

grpc_error_handle grpc_core::Chttp2ServerAddPort ( Server server,
const char *  addr,
grpc_channel_args args,
Chttp2ServerArgsModifier  connection_args_modifier,
int *  port_num 
)

Adds a port to server.

Sets port_num to the port number. Takes ownership of args.

◆ ConnectivityStateName()

const char * grpc_core::ConnectivityStateName ( grpc_connectivity_state  state)

◆ CreateAuthorityOverrideChannelArg()

grpc_arg grpc_core::CreateAuthorityOverrideChannelArg ( const char *  authority)

Returns a channel argument containing authority.

◆ CreateGrpclbBalancerAddressesArg()

grpc_arg grpc_core::CreateGrpclbBalancerAddressesArg ( const ServerAddressList address_list)

◆ CreateGrpclbBalancerChannel()

grpc_channel * grpc_core::CreateGrpclbBalancerChannel ( const char *  target_uri,
const grpc_channel_args args 
)

◆ ExtractJsonArray()

template<typename ErrorVectorType >
bool grpc_core::ExtractJsonArray ( const Json json,
const std::string &  field_name,
const Json::Array **  output,
ErrorVectorType *  error_list 
)
inline

◆ ExtractJsonBool()

template<typename ErrorVectorType >
bool grpc_core::ExtractJsonBool ( const Json json,
const std::string &  field_name,
bool *  output,
ErrorVectorType *  error_list 
)
inline

◆ ExtractJsonNumber()

template<typename NumericType , typename ErrorVectorType >
bool grpc_core::ExtractJsonNumber ( const Json json,
const std::string &  field_name,
NumericType *  output,
ErrorVectorType *  error_list 
)
inline

◆ ExtractJsonObject()

template<typename ErrorVectorType >
bool grpc_core::ExtractJsonObject ( const Json json,
const std::string &  field_name,
const Json::Object **  output,
ErrorVectorType *  error_list 
)
inline

◆ ExtractJsonString()

template<typename ErrorVectorType >
bool grpc_core::ExtractJsonString ( const Json json,
const std::string &  field_name,
std::string *  output,
ErrorVectorType *  error_list 
)
inline

◆ ExtractJsonType() [1/5]

template<typename ErrorVectorType >
bool grpc_core::ExtractJsonType ( const Json json,
const std::string &  field_name,
bool *  output,
ErrorVectorType *  error_list 
)
inline

◆ ExtractJsonType() [2/5]

template<typename ErrorVectorType >
bool grpc_core::ExtractJsonType ( const Json json,
const std::string &  field_name,
const Json::Array **  output,
ErrorVectorType *  error_list 
)
inline

◆ ExtractJsonType() [3/5]

template<typename ErrorVectorType >
bool grpc_core::ExtractJsonType ( const Json json,
const std::string &  field_name,
const Json::Object **  output,
ErrorVectorType *  error_list 
)
inline

◆ ExtractJsonType() [4/5]

template<typename NumericType , typename ErrorVectorType >
bool grpc_core::ExtractJsonType ( const Json json,
const std::string &  field_name,
NumericType *  output,
ErrorVectorType *  error_list 
)
inline

◆ ExtractJsonType() [5/5]

template<typename ErrorVectorType >
bool grpc_core::ExtractJsonType ( const Json json,
const std::string &  field_name,
std::string *  output,
ErrorVectorType *  error_list 
)
inline

◆ FaultInjectionFilterInit()

void grpc_core::FaultInjectionFilterInit ( void  )

◆ FaultInjectionFilterShutdown()

void grpc_core::FaultInjectionFilterShutdown ( void  )

◆ FileWatcherCertificateProviderInit()

void grpc_core::FileWatcherCertificateProviderInit ( )

◆ FileWatcherCertificateProviderShutdown()

void grpc_core::FileWatcherCertificateProviderShutdown ( )

◆ FindAuthorityOverrideInArgs()

absl::string_view grpc_core::FindAuthorityOverrideInArgs ( const grpc_channel_args args)

Returns the authority override from args or the empty string.

The return value is a string_view into the args data structure.

◆ FindGrpclbBalancerAddressesInChannelArgs()

const ServerAddressList * grpc_core::FindGrpclbBalancerAddressesInChannelArgs ( const grpc_channel_args args)

◆ GetAuthPropertyArray()

std::vector< absl::string_view > grpc_core::GetAuthPropertyArray ( grpc_auth_context context,
const char *  property_name 
)

◆ GetAuthPropertyValue()

absl::string_view grpc_core::GetAuthPropertyValue ( grpc_auth_context context,
const char *  property_name 
)

◆ GetCurrentStackTrace()

absl::optional< std::string > grpc_core::GetCurrentStackTrace ( )

◆ GetCurrentStackTraceProvider()

gpr_current_stack_trace_func grpc_core::GetCurrentStackTraceProvider ( )

◆ GetFileModificationTime()

absl::Status grpc_core::GetFileModificationTime ( const char *  filename,
time_t *  timestamp 
)

◆ GetMaxRecvSizeFromChannelArgs()

int grpc_core::GetMaxRecvSizeFromChannelArgs ( const grpc_channel_args args)

◆ GetMaxSendSizeFromChannelArgs()

int grpc_core::GetMaxSendSizeFromChannelArgs ( const grpc_channel_args args)

◆ GetUnderlyingGprMu()

gpr_mu* grpc_core::GetUnderlyingGprMu ( Mutex mutex)
inline

◆ GoogleCloud2ProdResolverInit()

void grpc_core::GoogleCloud2ProdResolverInit ( )

◆ GoogleCloud2ProdResolverShutdown()

void grpc_core::GoogleCloud2ProdResolverShutdown ( )

◆ GPR_TLS_CLASS_DEF() [1/2]

grpc_core::GPR_TLS_CLASS_DEF ( ApplicationCallbackExecCtx::callback_exec_ctx_  )

◆ GPR_TLS_CLASS_DEF() [2/2]

grpc_core::GPR_TLS_CLASS_DEF ( ExecCtx::exec_ctx_  )

◆ grpc_errqueue_init()

void grpc_core::grpc_errqueue_init ( )

◆ grpc_executor_global_init()

void grpc_core::grpc_executor_global_init ( )

◆ grpc_http2_set_fn_get_copied_context()

void grpc_core::grpc_http2_set_fn_get_copied_context ( void *(*)(void *)  fn)

◆ grpc_http2_set_write_timestamps_callback()

void grpc_core::grpc_http2_set_write_timestamps_callback ( void(*)(void *, grpc_core::Timestamps *, grpc_error_handle error fn)

◆ grpc_tcp_set_write_timestamps_callback()

void grpc_core::grpc_tcp_set_write_timestamps_callback ( void(*)(void *, grpc_core::Timestamps *, grpc_error_handle error fn)

Sets the callback function to call when timestamps for a write are collected.

The callback does not own a reference to error.

◆ GrpcLbLoadReportRequestCreate()

grpc_slice grpc_core::GrpcLbLoadReportRequestCreate ( int64_t  num_calls_started,
int64_t  num_calls_finished,
int64_t  num_calls_finished_with_client_failed_to_send,
int64_t  num_calls_finished_known_received,
const GrpcLbClientStats::DroppedCallCounts drop_token_counts,
upb_arena *  arena 
)

◆ GrpcLbPolicyRingHashInit()

void grpc_core::GrpcLbPolicyRingHashInit ( )

◆ GrpcLbPolicyRingHashShutdown()

void grpc_core::GrpcLbPolicyRingHashShutdown ( )

◆ GrpcLbRequestCreate()

grpc_slice grpc_core::GrpcLbRequestCreate ( const char *  lb_service_name,
upb_arena *  arena 
)

◆ GrpcLbResponseParse()

bool grpc_core::GrpcLbResponseParse ( const grpc_slice serialized_response,
upb_arena *  arena,
GrpcLbResponse result 
)

◆ JoinHostPort()

std::string grpc_core::JoinHostPort ( absl::string_view  host,
int  port 
)

◆ LoadSystemRootCerts()

grpc_slice grpc_core::LoadSystemRootCerts ( )

◆ MakeHierarchicalAddressMap()

HierarchicalAddressMap grpc_core::MakeHierarchicalAddressMap ( const ServerAddressList addresses)

◆ MakeHierarchicalPathAttribute()

std::unique_ptr< ServerAddress::AttributeInterface > grpc_core::MakeHierarchicalPathAttribute ( std::vector< std::string >  path)

◆ MakeLameClientErrorArg()

grpc_arg grpc_core::MakeLameClientErrorArg ( grpc_error_handle  error)

◆ MakeOrphanable()

template<typename T , typename... Args>
OrphanablePtr<T> grpc_core::MakeOrphanable ( Args &&...  args)
inline

◆ MakeRefCounted()

template<typename T , typename... Args>
RefCountedPtr<T> grpc_core::MakeRefCounted ( Args &&...  args)
inline

◆ ModifyGrpclbBalancerChannelArgs()

grpc_channel_args * grpc_core::ModifyGrpclbBalancerChannelArgs ( grpc_channel_args args)

Makes any necessary modifications to args for use in the grpclb balancer channel.

Takes ownership of args.

Caller takes ownership of the returned args.

◆ NewGrpcPolledFdFactory()

std::unique_ptr<GrpcPolledFdFactory> grpc_core::NewGrpcPolledFdFactory ( std::shared_ptr< grpc_core::WorkSerializer work_serializer)

◆ operator<() [1/2]

template<typename T >
bool grpc_core::operator< ( const RefCountedPtr< T > &  p1,
const RefCountedPtr< T > &  p2 
)

◆ operator<() [2/2]

template<typename T >
bool grpc_core::operator< ( const WeakRefCountedPtr< T > &  p1,
const WeakRefCountedPtr< T > &  p2 
)

◆ ParseBackendMetricData()

const LoadBalancingPolicy::BackendMetricData * grpc_core::ParseBackendMetricData ( const grpc_slice serialized_load_report,
Arena arena 
)

◆ ParseDurationFromJson()

bool grpc_core::ParseDurationFromJson ( const Json field,
grpc_millis duration 
)

◆ ParseJsonObjectField()

template<typename T , typename ErrorVectorType >
bool grpc_core::ParseJsonObjectField ( const Json::Object object,
const std::string &  field_name,
T *  output,
ErrorVectorType *  error_list,
bool  required = true 
)
inline

◆ ParseJsonObjectFieldAsDuration()

template<typename ErrorVectorType >
bool grpc_core::ParseJsonObjectFieldAsDuration ( const Json::Object object,
const std::string &  field_name,
grpc_millis output,
ErrorVectorType *  error_list,
bool  required = true 
)
inline

◆ ParseRingHashLbConfig()

void grpc_core::ParseRingHashLbConfig ( const Json json,
size_t *  min_ring_size,
size_t *  max_ring_size,
std::vector< grpc_error_handle > *  error_list 
)

◆ RegisterHttpProxyMapper()

void grpc_core::RegisterHttpProxyMapper ( )

◆ SecurityHandshakerCreate()

RefCountedPtr< Handshaker > grpc_core::SecurityHandshakerCreate ( tsi_handshaker handshaker,
grpc_security_connector connector,
const grpc_channel_args args 
)

Creates a security handshaker using handshaker.

◆ SecurityRegisterHandshakerFactories()

void grpc_core::SecurityRegisterHandshakerFactories ( )

Registers security handshaker factories.

◆ SetCurrentStackTraceProvider()

void grpc_core::SetCurrentStackTraceProvider ( gpr_current_stack_trace_func  current_stack_trace_provider)

◆ SetGlobalConfigEnvErrorFunction()

void grpc_core::SetGlobalConfigEnvErrorFunction ( GlobalConfigEnvErrorFunctionType  func)

◆ SplitHostPort() [1/2]

bool grpc_core::SplitHostPort ( absl::string_view  name,
absl::string_view *  host,
absl::string_view *  port 
)

Given a name in the form "host:port" or "[ho:st]:port", split into hostname and port number.

There are two variants of this method: 1) absl::string_view output: port and host are returned as views on name. 2) std::string output: port and host are copied into newly allocated strings.

Prefer variant (1) over (2), because no allocation or copy is performed in variant (1). Use (2) only when interacting with C API that mandate null-terminated strings.

Return true on success, false on failure. Guarantees *host and *port are cleared on failure.

◆ SplitHostPort() [2/2]

bool grpc_core::SplitHostPort ( absl::string_view  name,
std::string *  host,
std::string *  port 
)

◆ StaticMetadataInitCanary()

uint64_t grpc_core::StaticMetadataInitCanary ( )

◆ StatusAddChild()

void grpc_core::StatusAddChild ( absl::Status *  status,
absl::Status  child 
)

Adds a child status to status.

◆ StatusCreate()

absl::Status grpc_core::StatusCreate ( absl::StatusCode  code,
absl::string_view  msg,
const DebugLocation location,
std::initializer_list< absl::Status >  children 
)

Creates a status with given additional information.

◆ StatusGetChildren()

std::vector< absl::Status > grpc_core::StatusGetChildren ( absl::Status  status)

Returns all children status from a status.

◆ StatusGetInt()

absl::optional< intptr_t > grpc_core::StatusGetInt ( const absl::Status &  status,
StatusIntProperty  key 
)

Gets the int property from the status.

◆ StatusGetStr()

absl::optional< std::string > grpc_core::StatusGetStr ( const absl::Status &  status,
StatusStrProperty  key 
)

Gets the str property from the status.

◆ StatusGetTime()

absl::optional< absl::Time > grpc_core::StatusGetTime ( const absl::Status &  status,
StatusTimeProperty  key 
)

Gets the time property from the status.

◆ StatusSetInt()

void grpc_core::StatusSetInt ( absl::Status *  status,
StatusIntProperty  key,
intptr_t  value 
)

Sets the int property to the status.

◆ StatusSetStr()

void grpc_core::StatusSetStr ( absl::Status *  status,
StatusStrProperty  key,
absl::string_view  value 
)

Sets the str property to the status.

◆ StatusSetTime()

void grpc_core::StatusSetTime ( absl::Status *  status,
StatusTimeProperty  key,
absl::Time  time 
)

Sets the time property to the status.

◆ StatusToString()

std::string grpc_core::StatusToString ( const absl::Status &  status)

Returns a string representation from status Error status will be like STATUS[:MESSAGE] [{PAYLOADS[, children:[CHILDREN-STATUS-LISTS]]}] e.g.

CANCELLATION:SampleMessage {errno:'2021', line:'54', children:[ABORTED]}

◆ StringViewFromSlice()

absl::string_view grpc_core::StringViewFromSlice ( const grpc_slice slice)
inline

◆ TestOnlyMakeInsecureAuthContext()

RefCountedPtr< grpc_auth_context > grpc_core::TestOnlyMakeInsecureAuthContext ( )

◆ TestOnlySetGlobalHttp2TransportDestructCallback()

void grpc_core::TestOnlySetGlobalHttp2TransportDestructCallback ( TestOnlyGlobalHttp2TransportDestructCallback  callback)

◆ TestOnlySetGlobalHttp2TransportInitCallback()

void grpc_core::TestOnlySetGlobalHttp2TransportInitCallback ( TestOnlyGlobalHttp2TransportInitCallback  callback)

◆ TestOnlyXdsVerifySubjectAlternativeNames()

bool grpc_core::TestOnlyXdsVerifySubjectAlternativeNames ( const char *const *  subject_alternative_names,
size_t  subject_alternative_names_size,
const std::vector< StringMatcher > &  matchers 
)

◆ ToAbslDuration()

absl::Duration grpc_core::ToAbslDuration ( gpr_timespec  ts)

◆ ToAbslTime()

absl::Time grpc_core::ToAbslTime ( gpr_timespec  ts)

◆ ToGprTimeSpec() [1/2]

gpr_timespec grpc_core::ToGprTimeSpec ( absl::Duration  duration)

◆ ToGprTimeSpec() [2/2]

gpr_timespec grpc_core::ToGprTimeSpec ( absl::Time  time)

◆ UnixAbstractSockaddrPopulate()

grpc_error_handle grpc_core::UnixAbstractSockaddrPopulate ( absl::string_view  ,
grpc_resolved_address  
)

Populate resolved_addr to be a unix socket in the abstract namespace at |path|.

◆ UnixSockaddrPopulate()

grpc_error_handle grpc_core::UnixSockaddrPopulate ( absl::string_view  ,
grpc_resolved_address  
)

Populate resolved_addr to be a unix socket at |path|.

◆ ValidateStsCredentialsOptions()

absl::StatusOr< URI > grpc_core::ValidateStsCredentialsOptions ( const grpc_sts_credentials_options options)

◆ VerifySubjectAlternativeName()

bool grpc_core::VerifySubjectAlternativeName ( absl::string_view  subject_alternative_name,
const std::string &  matcher 
)

◆ XdsAggregateAndLogicalDnsClusterEnabled()

bool grpc_core::XdsAggregateAndLogicalDnsClusterEnabled ( )

◆ XdsClientGlobalInit()

void grpc_core::XdsClientGlobalInit ( )

◆ XdsClientGlobalShutdown()

void grpc_core::XdsClientGlobalShutdown ( )

◆ XdsRingHashEnabled()

bool grpc_core::XdsRingHashEnabled ( )

◆ XdsSecurityEnabled()

bool grpc_core::XdsSecurityEnabled ( )

Variable Documentation

◆ executor_trace

TraceFlag grpc_core::executor_trace(false, "executor") ( false  ,
"executor"   
)

◆ FaultInjectionFilterVtable

const grpc_channel_filter grpc_core::FaultInjectionFilterVtable
extern
Initial value:
= {
CallData::StartTransportStreamOpBatch,
sizeof(CallData),
CallData::Init,
CallData::Destroy,
sizeof(ChannelData),
ChannelData::Init,
ChannelData::Destroy,
"fault_injection_filter",
}
void grpc_channel_next_get_info(grpc_channel_element *elem, const grpc_channel_info *channel_info)
Definition: channel_stack.cc:243
void grpc_call_stack_ignore_set_pollset_or_pollset_set(grpc_call_element *, grpc_polling_entity *)
Definition: channel_stack.cc:218
void grpc_channel_next_op(grpc_channel_element *elem, grpc_transport_op *op)
Definition: channel_stack.cc:249

◆ g_current_stack_trace_provider

gpr_current_stack_trace_func grpc_core::g_current_stack_trace_provider = nullptr

◆ g_hash_seed

uint32_t grpc_core::g_hash_seed

◆ g_static_mdelem_manifested

grpc_mdelem * grpc_core::g_static_mdelem_manifested = nullptr

◆ g_static_mdelem_table

StaticMetadata * grpc_core::g_static_mdelem_table = nullptr

◆ g_static_metadata_slice_refcounts

StaticSliceRefcount * grpc_core::g_static_metadata_slice_refcounts = nullptr

◆ g_static_metadata_slice_table

const StaticMetadataSlice * grpc_core::g_static_metadata_slice_table = nullptr

◆ grpc_call_combiner_trace

DebugOnlyTraceFlag grpc_core::grpc_call_combiner_trace ( false  ,
"call_combiner"   
)

◆ grpc_cds_lb_trace

TraceFlag grpc_core::grpc_cds_lb_trace(false, "cds_lb") ( false  ,
"cds_lb"   
)

◆ grpc_client_channel_call_trace

TraceFlag grpc_core::grpc_client_channel_call_trace(false, "client_channel_call") ( false  ,
"client_channel_call"   
)

◆ grpc_client_channel_routing_trace

TraceFlag grpc_core::grpc_client_channel_routing_trace(false, "client_channel_routing") ( false  ,
"client_channel_routing"   
)

◆ grpc_connectivity_state_trace

TraceFlag grpc_core::grpc_connectivity_state_trace ( false  ,
"connectivity_state"   
)

◆ grpc_fault_injection_filter_trace

TraceFlag grpc_core::grpc_fault_injection_filter_trace(false, "fault_injection_filter") ( false  ,
"fault_injection_filter"   
)

◆ grpc_handshaker_trace

TraceFlag grpc_core::grpc_handshaker_trace(false, "handshaker") ( false  ,
"handshaker"   
)

◆ grpc_health_check_client_trace

TraceFlag grpc_core::grpc_health_check_client_trace(false, "health_check_client") ( false  ,
"health_check_client"   
)

◆ grpc_lb_glb_trace

TraceFlag grpc_core::grpc_lb_glb_trace(false, "glb") ( false  ,
"glb"   
)

◆ grpc_lb_pick_first_trace

TraceFlag grpc_core::grpc_lb_pick_first_trace(false, "pick_first") ( false  ,
"pick_first"   
)

◆ grpc_lb_priority_trace

TraceFlag grpc_core::grpc_lb_priority_trace(false, "priority_lb") ( false  ,
"priority_lb"   
)

◆ grpc_lb_ring_hash_trace

TraceFlag grpc_core::grpc_lb_ring_hash_trace(false, "ring_hash_lb") ( false  ,
"ring_hash_lb"   
)

◆ grpc_lb_round_robin_trace

TraceFlag grpc_core::grpc_lb_round_robin_trace(false, "round_robin") ( false  ,
"round_robin"   
)

◆ grpc_lb_weighted_target_trace

TraceFlag grpc_core::grpc_lb_weighted_target_trace(false, "weighted_target_lb") ( false  ,
"weighted_target_lb"   
)

◆ grpc_lb_xds_cluster_resolver_trace

TraceFlag grpc_core::grpc_lb_xds_cluster_resolver_trace(false, "xds_cluster_resolver_lb") ( false  ,
"xds_cluster_resolver_lb"   
)

◆ grpc_server_channel_trace

TraceFlag grpc_core::grpc_server_channel_trace ( false  ,
"server_channel"   
)

◆ grpc_subchannel_pool_trace

TraceFlag grpc_core::grpc_subchannel_pool_trace ( false  ,
"subchannel_pool"   
)

◆ grpc_thread_pool_trace

DebugOnlyTraceFlag grpc_core::grpc_thread_pool_trace ( false  ,
"thread_pool"   
)

◆ grpc_trace_client_idle_filter

TraceFlag grpc_core::grpc_trace_client_idle_filter(false, "client_idle_filter") ( false  ,
"client_idle_filter"   
)

◆ grpc_trace_lb_policy_refcount

DebugOnlyTraceFlag grpc_core::grpc_trace_lb_policy_refcount ( false  ,
"lb_policy_refcount"   
)

◆ grpc_trace_subchannel

TraceFlag grpc_core::grpc_trace_subchannel(false, "subchannel") ( false  ,
"subchannel"   
)

◆ grpc_trace_subchannel_refcount

DebugOnlyTraceFlag grpc_core::grpc_trace_subchannel_refcount(false, "subchannel_refcount") ( false  ,
"subchannel_refcount"   
)

◆ grpc_work_serializer_trace

DebugOnlyTraceFlag grpc_core::grpc_work_serializer_trace(false, "work_serializer") ( false  ,
"work_serializer"   
)

◆ grpc_xds_client_refcount_trace

TraceFlag grpc_core::grpc_xds_client_refcount_trace ( false  ,
"xds_client_refcount"   
)

◆ grpc_xds_client_trace

TraceFlag grpc_core::grpc_xds_client_trace ( false  ,
"xds_client"   
)

◆ grpc_xds_cluster_impl_lb_trace

TraceFlag grpc_core::grpc_xds_cluster_impl_lb_trace(false, "xds_cluster_impl_lb") ( false  ,
"xds_cluster_impl_lb"   
)

◆ grpc_xds_cluster_manager_lb_trace

TraceFlag grpc_core::grpc_xds_cluster_manager_lb_trace(false, "xds_cluster_manager_lb") ( false  ,
"xds_cluster_manager_lb"   
)

◆ grpc_xds_resolver_trace

TraceFlag grpc_core::grpc_xds_resolver_trace(false, "xds_resolver") ( false  ,
"xds_resolver"   
)

◆ grpc_xds_server_config_fetcher_trace

TraceFlag grpc_core::grpc_xds_server_config_fetcher_trace(false, "xds_server_config_fetcher") ( false  ,
"xds_server_config_fetcher"   
)

◆ kCredentialsTypeXds

const char grpc_core::kCredentialsTypeXds = "Xds"

◆ kDefaultSecurePort

const char * grpc_core::kDefaultSecurePort = "https"

◆ kDefaultSecurePortInt

constexpr int grpc_core::kDefaultSecurePortInt = 443
constexpr

◆ kGrpcLbAddressAttributeKey

const char grpc_core::kGrpcLbAddressAttributeKey[] = "grpclb"

◆ kGrpcLbClientStatsMetadataKey

const char grpc_core::kGrpcLbClientStatsMetadataKey = "grpclb_client_stats"

◆ kGrpcLbLbTokenMetadataKey

const char grpc_core::kGrpcLbLbTokenMetadataKey = "lb-token"

◆ kGrpcStaticMetadataInitCanary

constexpr uint64_t grpc_core::kGrpcStaticMetadataInitCanary = 0xCAFEF00DC0FFEE11L
constexpr

◆ kHierarchicalPathAttributeKey

const char * grpc_core::kHierarchicalPathAttributeKey = "hierarchical_path"

◆ kInsecureTransportSecurityType

const char grpc_core::kInsecureTransportSecurityType = "insecure"

◆ kKeepaliveThrottlingKey

constexpr const char* grpc_core::kKeepaliveThrottlingKey
constexpr
Initial value:
=
"grpc.internal.keepalive_throttling"

◆ kNoopRefcount

grpc_slice_refcount grpc_core::kNoopRefcount ( grpc_slice_refcount::Type::NOP  )

◆ kRequestRingHashAttribute

const char * grpc_core::kRequestRingHashAttribute = "request_ring_hash"

◆ kRetryFilterVtable

const grpc_channel_filter grpc_core::kRetryFilterVtable
Initial value:
= {
RetryFilter::CallData::StartTransportStreamOpBatch,
RetryFilter::StartTransportOp,
sizeof(RetryFilter::CallData),
RetryFilter::CallData::Init,
RetryFilter::CallData::SetPollent,
RetryFilter::CallData::Destroy,
sizeof(RetryFilter),
RetryFilter::Init,
RetryFilter::Destroy,
RetryFilter::GetChannelInfo,
"retry_filter",
}

◆ kXdsClusterAttribute

const char * grpc_core::kXdsClusterAttribute = "xds_cluster_name"

◆ kXdsHttpFaultFilterConfigName

const char * grpc_core::kXdsHttpFaultFilterConfigName
Initial value:
=
"envoy.extensions.filters.http.fault.v3.HTTPFault"

◆ kXdsHttpRouterFilterConfigName

const char * grpc_core::kXdsHttpRouterFilterConfigName
Initial value:
=
"envoy.extensions.filters.http.router.v3.Router"

◆ kXdsLocalityNameAttributeKey

const char * grpc_core::kXdsLocalityNameAttributeKey = "xds_locality_name"

◆ MessageDecompressFilter

const grpc_channel_filter grpc_core::MessageDecompressFilter
Initial value:
= {
DecompressStartTransportStreamOpBatch,
sizeof(CallData),
DecompressInitCallElem,
DecompressDestroyCallElem,
sizeof(ChannelData),
DecompressInitChannelElem,
DecompressDestroyChannelElem,
"message_decompress"}