GRPC C++
1.39.1
|
Round Robin Policy. More...
Namespaces | |
channelz | |
chttp2 | |
internal | |
manual_ctor_impl | |
testing | |
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::BackendMetricData * | ParseBackendMetricData (const grpc_slice &serialized_load_report, Arena *arena) |
void | RegisterHttpProxyMapper () |
std::unique_ptr< ServerAddress::AttributeInterface > | MakeHierarchicalPathAttribute (std::vector< std::string > path) |
HierarchicalAddressMap | MakeHierarchicalAddressMap (const ServerAddressList &addresses) |
grpc_arg | CreateGrpclbBalancerAddressesArg (const ServerAddressList *address_list) |
const ServerAddressList * | FindGrpclbBalancerAddressesInChannelArgs (const grpc_channel_args &args) |
grpc_channel_args * | ModifyGrpclbBalancerChannelArgs (grpc_channel_args *args) |
Makes any necessary modifications to args for use in the grpclb balancer channel. More... | |
grpc_channel * | CreateGrpclbBalancerChannel (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< GrpcPolledFdFactory > | NewGrpcPolledFdFactory (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_mu * | GetUnderlyingGprMu (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< URI > | ValidateStsCredentialsOptions (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_context > | TestOnlyMakeInsecureAuthContext () |
grpc_slice | LoadSystemRootCerts () |
RefCountedPtr< Handshaker > | SecurityHandshakerCreate (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 () |
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.
using grpc_core::Chttp2ServerArgsModifier = typedef std::function<grpc_channel_args*(grpc_channel_args*, grpc_error_handle*)> |
typedef void(* grpc_core::destroy_user_data_func) (void *data) |
typedef void(* grpc_core::GlobalConfigEnvErrorFunctionType) (const char *error_message) |
typedef std::string(* grpc_core::gpr_current_stack_trace_func) () |
using grpc_core::HierarchicalAddressMap = typedef std::map<std::string, ServerAddressList> |
using grpc_core::OrphanablePtr = typedef std::unique_ptr<T, Deleter> |
typedef absl::InlinedVector<grpc_core::PemKeyCertPair, 1> grpc_core::PemKeyCertPairList |
typedef absl::InlinedVector<ServerAddress, 1> grpc_core::ServerAddressList |
typedef void(* grpc_core::TestOnlyGlobalHttp2TransportDestructCallback) () |
typedef void(* grpc_core::TestOnlyGlobalHttp2TransportInitCallback) () |
using grpc_core::UniquePtr = typedef std::unique_ptr<T, DefaultDeleteChar> |
|
strong |
|
strong |
|
strong |
|
strong |
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. |
|
strong |
This enum should have the same value of grpc_error_strs.
|
strong |
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.
const char * grpc_core::ConnectivityStateName | ( | grpc_connectivity_state | state | ) |
grpc_arg grpc_core::CreateAuthorityOverrideChannelArg | ( | const char * | authority | ) |
Returns a channel argument containing authority.
grpc_arg grpc_core::CreateGrpclbBalancerAddressesArg | ( | const ServerAddressList * | address_list | ) |
grpc_channel * grpc_core::CreateGrpclbBalancerChannel | ( | const char * | target_uri, |
const grpc_channel_args & | args | ||
) |
|
inline |
|
inline |
|
inline |
|
inline |
|
inline |
|
inline |
|
inline |
|
inline |
|
inline |
|
inline |
void grpc_core::FaultInjectionFilterInit | ( | void | ) |
void grpc_core::FaultInjectionFilterShutdown | ( | void | ) |
void grpc_core::FileWatcherCertificateProviderInit | ( | ) |
void grpc_core::FileWatcherCertificateProviderShutdown | ( | ) |
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.
const ServerAddressList * grpc_core::FindGrpclbBalancerAddressesInChannelArgs | ( | const grpc_channel_args & | args | ) |
std::vector< absl::string_view > grpc_core::GetAuthPropertyArray | ( | grpc_auth_context * | context, |
const char * | property_name | ||
) |
absl::string_view grpc_core::GetAuthPropertyValue | ( | grpc_auth_context * | context, |
const char * | property_name | ||
) |
absl::optional< std::string > grpc_core::GetCurrentStackTrace | ( | ) |
gpr_current_stack_trace_func grpc_core::GetCurrentStackTraceProvider | ( | ) |
absl::Status grpc_core::GetFileModificationTime | ( | const char * | filename, |
time_t * | timestamp | ||
) |
int grpc_core::GetMaxRecvSizeFromChannelArgs | ( | const grpc_channel_args * | args | ) |
int grpc_core::GetMaxSendSizeFromChannelArgs | ( | const grpc_channel_args * | args | ) |
void grpc_core::GoogleCloud2ProdResolverInit | ( | ) |
void grpc_core::GoogleCloud2ProdResolverShutdown | ( | ) |
grpc_core::GPR_TLS_CLASS_DEF | ( | ApplicationCallbackExecCtx::callback_exec_ctx_ | ) |
grpc_core::GPR_TLS_CLASS_DEF | ( | ExecCtx::exec_ctx_ | ) |
void grpc_core::grpc_errqueue_init | ( | ) |
void grpc_core::grpc_executor_global_init | ( | ) |
void grpc_core::grpc_http2_set_fn_get_copied_context | ( | void *(*)(void *) | fn | ) |
void grpc_core::grpc_http2_set_write_timestamps_callback | ( | void(*)(void *, grpc_core::Timestamps *, grpc_error_handle error) | fn | ) |
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.
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 | ||
) |
void grpc_core::GrpcLbPolicyRingHashInit | ( | ) |
void grpc_core::GrpcLbPolicyRingHashShutdown | ( | ) |
grpc_slice grpc_core::GrpcLbRequestCreate | ( | const char * | lb_service_name, |
upb_arena * | arena | ||
) |
bool grpc_core::GrpcLbResponseParse | ( | const grpc_slice & | serialized_response, |
upb_arena * | arena, | ||
GrpcLbResponse * | result | ||
) |
std::string grpc_core::JoinHostPort | ( | absl::string_view | host, |
int | port | ||
) |
grpc_slice grpc_core::LoadSystemRootCerts | ( | ) |
HierarchicalAddressMap grpc_core::MakeHierarchicalAddressMap | ( | const ServerAddressList & | addresses | ) |
std::unique_ptr< ServerAddress::AttributeInterface > grpc_core::MakeHierarchicalPathAttribute | ( | std::vector< std::string > | path | ) |
grpc_arg grpc_core::MakeLameClientErrorArg | ( | grpc_error_handle | error | ) |
|
inline |
|
inline |
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.
std::unique_ptr<GrpcPolledFdFactory> grpc_core::NewGrpcPolledFdFactory | ( | std::shared_ptr< grpc_core::WorkSerializer > | work_serializer | ) |
bool grpc_core::operator< | ( | const RefCountedPtr< T > & | p1, |
const RefCountedPtr< T > & | p2 | ||
) |
bool grpc_core::operator< | ( | const WeakRefCountedPtr< T > & | p1, |
const WeakRefCountedPtr< T > & | p2 | ||
) |
const LoadBalancingPolicy::BackendMetricData * grpc_core::ParseBackendMetricData | ( | const grpc_slice & | serialized_load_report, |
Arena * | arena | ||
) |
bool grpc_core::ParseDurationFromJson | ( | const Json & | field, |
grpc_millis * | duration | ||
) |
|
inline |
|
inline |
void grpc_core::ParseRingHashLbConfig | ( | const Json & | json, |
size_t * | min_ring_size, | ||
size_t * | max_ring_size, | ||
std::vector< grpc_error_handle > * | error_list | ||
) |
void grpc_core::RegisterHttpProxyMapper | ( | ) |
RefCountedPtr< Handshaker > grpc_core::SecurityHandshakerCreate | ( | tsi_handshaker * | handshaker, |
grpc_security_connector * | connector, | ||
const grpc_channel_args * | args | ||
) |
Creates a security handshaker using handshaker.
void grpc_core::SecurityRegisterHandshakerFactories | ( | ) |
Registers security handshaker factories.
void grpc_core::SetCurrentStackTraceProvider | ( | gpr_current_stack_trace_func | current_stack_trace_provider | ) |
void grpc_core::SetGlobalConfigEnvErrorFunction | ( | GlobalConfigEnvErrorFunctionType | func | ) |
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.
bool grpc_core::SplitHostPort | ( | absl::string_view | name, |
std::string * | host, | ||
std::string * | port | ||
) |
uint64_t grpc_core::StaticMetadataInitCanary | ( | ) |
void grpc_core::StatusAddChild | ( | absl::Status * | status, |
absl::Status | child | ||
) |
Adds a child status to status.
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.
std::vector< absl::Status > grpc_core::StatusGetChildren | ( | absl::Status | status | ) |
Returns all children status from a status.
absl::optional< intptr_t > grpc_core::StatusGetInt | ( | const absl::Status & | status, |
StatusIntProperty | key | ||
) |
Gets the int property from the status.
absl::optional< std::string > grpc_core::StatusGetStr | ( | const absl::Status & | status, |
StatusStrProperty | key | ||
) |
Gets the str property from the status.
absl::optional< absl::Time > grpc_core::StatusGetTime | ( | const absl::Status & | status, |
StatusTimeProperty | key | ||
) |
Gets the time property from the status.
void grpc_core::StatusSetInt | ( | absl::Status * | status, |
StatusIntProperty | key, | ||
intptr_t | value | ||
) |
Sets the int property to the status.
void grpc_core::StatusSetStr | ( | absl::Status * | status, |
StatusStrProperty | key, | ||
absl::string_view | value | ||
) |
Sets the str property to the status.
void grpc_core::StatusSetTime | ( | absl::Status * | status, |
StatusTimeProperty | key, | ||
absl::Time | time | ||
) |
Sets the time property to the status.
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]}
|
inline |
RefCountedPtr< grpc_auth_context > grpc_core::TestOnlyMakeInsecureAuthContext | ( | ) |
void grpc_core::TestOnlySetGlobalHttp2TransportDestructCallback | ( | TestOnlyGlobalHttp2TransportDestructCallback | callback | ) |
void grpc_core::TestOnlySetGlobalHttp2TransportInitCallback | ( | TestOnlyGlobalHttp2TransportInitCallback | callback | ) |
bool grpc_core::TestOnlyXdsVerifySubjectAlternativeNames | ( | const char *const * | subject_alternative_names, |
size_t | subject_alternative_names_size, | ||
const std::vector< StringMatcher > & | matchers | ||
) |
absl::Duration grpc_core::ToAbslDuration | ( | gpr_timespec | ts | ) |
absl::Time grpc_core::ToAbslTime | ( | gpr_timespec | ts | ) |
gpr_timespec grpc_core::ToGprTimeSpec | ( | absl::Duration | duration | ) |
gpr_timespec grpc_core::ToGprTimeSpec | ( | absl::Time | time | ) |
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|.
grpc_error_handle grpc_core::UnixSockaddrPopulate | ( | absl::string_view | , |
grpc_resolved_address * | |||
) |
Populate resolved_addr to be a unix socket at |path|.
absl::StatusOr< URI > grpc_core::ValidateStsCredentialsOptions | ( | const grpc_sts_credentials_options * | options | ) |
bool grpc_core::VerifySubjectAlternativeName | ( | absl::string_view | subject_alternative_name, |
const std::string & | matcher | ||
) |
bool grpc_core::XdsAggregateAndLogicalDnsClusterEnabled | ( | ) |
void grpc_core::XdsClientGlobalInit | ( | ) |
void grpc_core::XdsClientGlobalShutdown | ( | ) |
bool grpc_core::XdsRingHashEnabled | ( | ) |
bool grpc_core::XdsSecurityEnabled | ( | ) |
TraceFlag grpc_core::executor_trace(false, "executor") | ( | false | , |
"executor" | |||
) |
|
extern |
gpr_current_stack_trace_func grpc_core::g_current_stack_trace_provider = nullptr |
uint32_t grpc_core::g_hash_seed |
grpc_mdelem * grpc_core::g_static_mdelem_manifested = nullptr |
StaticMetadata * grpc_core::g_static_mdelem_table = nullptr |
StaticSliceRefcount * grpc_core::g_static_metadata_slice_refcounts = nullptr |
const StaticMetadataSlice * grpc_core::g_static_metadata_slice_table = nullptr |
DebugOnlyTraceFlag grpc_core::grpc_call_combiner_trace | ( | false | , |
"call_combiner" | |||
) |
TraceFlag grpc_core::grpc_cds_lb_trace(false, "cds_lb") | ( | false | , |
"cds_lb" | |||
) |
TraceFlag grpc_core::grpc_client_channel_call_trace(false, "client_channel_call") | ( | false | , |
"client_channel_call" | |||
) |
TraceFlag grpc_core::grpc_client_channel_routing_trace(false, "client_channel_routing") | ( | false | , |
"client_channel_routing" | |||
) |
TraceFlag grpc_core::grpc_connectivity_state_trace | ( | false | , |
"connectivity_state" | |||
) |
TraceFlag grpc_core::grpc_fault_injection_filter_trace(false, "fault_injection_filter") | ( | false | , |
"fault_injection_filter" | |||
) |
TraceFlag grpc_core::grpc_handshaker_trace(false, "handshaker") | ( | false | , |
"handshaker" | |||
) |
TraceFlag grpc_core::grpc_health_check_client_trace(false, "health_check_client") | ( | false | , |
"health_check_client" | |||
) |
TraceFlag grpc_core::grpc_lb_glb_trace(false, "glb") | ( | false | , |
"glb" | |||
) |
TraceFlag grpc_core::grpc_lb_pick_first_trace(false, "pick_first") | ( | false | , |
"pick_first" | |||
) |
TraceFlag grpc_core::grpc_lb_priority_trace(false, "priority_lb") | ( | false | , |
"priority_lb" | |||
) |
TraceFlag grpc_core::grpc_lb_ring_hash_trace(false, "ring_hash_lb") | ( | false | , |
"ring_hash_lb" | |||
) |
TraceFlag grpc_core::grpc_lb_round_robin_trace(false, "round_robin") | ( | false | , |
"round_robin" | |||
) |
TraceFlag grpc_core::grpc_lb_weighted_target_trace(false, "weighted_target_lb") | ( | false | , |
"weighted_target_lb" | |||
) |
TraceFlag grpc_core::grpc_lb_xds_cluster_resolver_trace(false, "xds_cluster_resolver_lb") | ( | false | , |
"xds_cluster_resolver_lb" | |||
) |
TraceFlag grpc_core::grpc_server_channel_trace | ( | false | , |
"server_channel" | |||
) |
TraceFlag grpc_core::grpc_subchannel_pool_trace | ( | false | , |
"subchannel_pool" | |||
) |
DebugOnlyTraceFlag grpc_core::grpc_thread_pool_trace | ( | false | , |
"thread_pool" | |||
) |
TraceFlag grpc_core::grpc_trace_client_idle_filter(false, "client_idle_filter") | ( | false | , |
"client_idle_filter" | |||
) |
DebugOnlyTraceFlag grpc_core::grpc_trace_lb_policy_refcount | ( | false | , |
"lb_policy_refcount" | |||
) |
TraceFlag grpc_core::grpc_trace_subchannel(false, "subchannel") | ( | false | , |
"subchannel" | |||
) |
DebugOnlyTraceFlag grpc_core::grpc_trace_subchannel_refcount(false, "subchannel_refcount") | ( | false | , |
"subchannel_refcount" | |||
) |
DebugOnlyTraceFlag grpc_core::grpc_work_serializer_trace(false, "work_serializer") | ( | false | , |
"work_serializer" | |||
) |
TraceFlag grpc_core::grpc_xds_client_refcount_trace | ( | false | , |
"xds_client_refcount" | |||
) |
TraceFlag grpc_core::grpc_xds_client_trace | ( | false | , |
"xds_client" | |||
) |
TraceFlag grpc_core::grpc_xds_cluster_impl_lb_trace(false, "xds_cluster_impl_lb") | ( | false | , |
"xds_cluster_impl_lb" | |||
) |
TraceFlag grpc_core::grpc_xds_cluster_manager_lb_trace(false, "xds_cluster_manager_lb") | ( | false | , |
"xds_cluster_manager_lb" | |||
) |
TraceFlag grpc_core::grpc_xds_resolver_trace(false, "xds_resolver") | ( | false | , |
"xds_resolver" | |||
) |
TraceFlag grpc_core::grpc_xds_server_config_fetcher_trace(false, "xds_server_config_fetcher") | ( | false | , |
"xds_server_config_fetcher" | |||
) |
const char grpc_core::kCredentialsTypeXds = "Xds" |
const char * grpc_core::kDefaultSecurePort = "https" |
|
constexpr |
const char grpc_core::kGrpcLbAddressAttributeKey[] = "grpclb" |
const char grpc_core::kGrpcLbClientStatsMetadataKey = "grpclb_client_stats" |
const char grpc_core::kGrpcLbLbTokenMetadataKey = "lb-token" |
|
constexpr |
const char * grpc_core::kHierarchicalPathAttributeKey = "hierarchical_path" |
const char grpc_core::kInsecureTransportSecurityType = "insecure" |
|
constexpr |
grpc_slice_refcount grpc_core::kNoopRefcount | ( | grpc_slice_refcount::Type::NOP | ) |
const char * grpc_core::kRequestRingHashAttribute = "request_ring_hash" |
const grpc_channel_filter grpc_core::kRetryFilterVtable |
const char * grpc_core::kXdsClusterAttribute = "xds_cluster_name" |
const char * grpc_core::kXdsHttpFaultFilterConfigName |
const char * grpc_core::kXdsHttpRouterFilterConfigName |
const char * grpc_core::kXdsLocalityNameAttributeKey = "xds_locality_name" |
const grpc_channel_filter grpc_core::MessageDecompressFilter |