MCPcopy Create free account

hub / github.com/apache/dubbo-go / functions

Functions7,883 in github.com/apache/dubbo-go

↓ 7 callersMethodNames
Names returns a copy of the registered codec names. The returned slice is safe for the caller to mutate.
protocol/triple/triple_protocol/codec.go:429
↓ 7 callersFunctionNewCacheManager
NewCacheManager creates a new CacheManager instance. It initializes the cache manager with the provided parameters and starts a routine for cache dump
registry/servicediscovery/store/cache_manager.go:50
↓ 7 callersFunctionNewDirectory
NewDirectory Create BaseDirectory with URL
cluster/directory/base/directory.go:45
↓ 7 callersFunctionNewExchangeClient
NewExchangeClient returns a ExchangeClient.
remoting/exchange_client.go:69
↓ 7 callersFunctionNewGaugeVec
NewGaugeVec create a GaugeVec default implementation.
metrics/api.go:218
↓ 7 callersFunctionNewMetadataInfo
(app, tag string)
metadata/info/metadata_info.go:71
↓ 7 callersFunctionNewOptions
(opts ...Option)
registry/options.go:42
↓ 7 callersFunctionNewOptions
(opts ...Option)
config_center/options.go:40
↓ 7 callersFunctionNewResponse
NewResponse create to a new Response.
remoting/exchange.go:84
↓ 7 callersFunctionNewResponsePayload
NewResponsePayload create a new ResponsePayload
protocol/dubbo/impl/response.go:27
↓ 7 callersMethodParser
()
config_center/dynamic_configuration.go:36
↓ 7 callersMethodRegister
Register assemble invoker chains like ProviderConfig.Load, init a service per call
server/server.go:75
↓ 7 callersFunctionRegisterProtocol
RegisterProtocol registers protocol which would be destroyed before shutdown. Please make sure that the Init function has been invoked before, otherwi
graceful_shutdown/shutdown.go:124
↓ 7 callersFunctionRegistryCodec
(protocol string, codecTmp Codec)
remoting/codec.go:39
↓ 7 callersMethodScrape
()
metrics/prometheus/registry.go:202
↓ 7 callersMethodSetAttachment
(key string, value any)
protocol/invocation/rpcinvocation.go:182
↓ 7 callersMethodSetAttribute
(key string, value any)
protocol/invocation/rpcinvocation.go:215
↓ 7 callersMethodSetResult
(any)
protocol/result/result.go:44
↓ 7 callersFunctionSetRouterFactory
SetRouterFactory sets create router factory function with @name
common/extension/router_factory.go:29
↓ 7 callersFunctionSetTpsLimitStrategy
SetTpsLimitStrategy sets the TpsLimitStrategyCreator with @name
common/extension/tps_limit.go:49
↓ 7 callersMethodString
()
tools/dubbogo-cli/cmd/testGenCode/template/newApp/api/api.pb.go:114
↓ 7 callersMethodString
()
metadata/triple_api/proto/metadata_service_v2.pb.go:176
↓ 7 callersMethodTagKeys
()
metrics/api.go:124
↓ 7 callersFunctionToMapStringInterface
(origin map[any]any)
protocol/dubbo/impl/hessian.go:539
↓ 7 callersFunctionUnregisterGracefulShutdownCallback
UnregisterGracefulShutdownCallback removes a protocol graceful shutdown callback by name.
common/extension/graceful_shutdown.go:104
↓ 7 callersMethodUpdate
Update will update the data of the instance in registry
registry/service_discovery.go:43
↓ 7 callersMethodWaitGroup
()
remoting/etcdv3/facade.go:38
↓ 7 callersFunctionWithInterface
---------- For user ---------- WithInterface sets the interface name for the service being exposed. As a functional option, it is passed to a service
server/options.go:610
↓ 7 callersFunctionclassifyError
classifyError classifies an error based on triple protocol error codes. This function supports triple and gRPC protocol errors.
metrics/rpc/error_classifier.go:48
↓ 7 callersFunctioncreateServiceInfoWithReflection
createServiceInfoWithReflection is for non-idl scenario. It makes use of reflection to extract method parameters information and create ServiceInfo. A
protocol/triple/server.go:567
↓ 7 callersMethoddestroy
destroy stops the cache dump routine, clears the cache and removes the cache file.
registry/servicediscovery/store/cache_manager.go:188
↓ 7 callersFunctiondoTestResponse
(t *testing.T, packageType PackageType, responseStatus byte, body any, decodedResponse *DubboResponse, assertF
protocol/dubbo/hessian2/hessian_dubbo_test.go:83
↓ 7 callersFunctionexporterNormal
(t *testing.T, regProtocol *registryProtocol)
registry/protocol/protocol_test.go:125
↓ 7 callersFunctioninternalReady
()
metrics/probe/state.go:46
↓ 7 callersFunctioninternalStartup
()
metrics/probe/state.go:53
↓ 7 callersFunctionisClosingError
(err error)
filter/graceful_shutdown/consumer_filter.go:215
↓ 7 callersFunctionisExported
Is this an exported - upper case - name
common/rpc_service.go:312
↓ 7 callersFunctionmergeImports
(m map[string][]string)
tools/imports-formatter/main.go:431
↓ 7 callersFunctionnewPolarisRouter
(url *common.URL)
cluster/router/polaris/router.go:54
↓ 7 callersFunctionnewServiceDiscoveryRegistry
(url *common.URL)
registry/servicediscovery/service_discovery_registry.go:70
↓ 7 callersFunctionremoveMinus
(strArr []string)
config/config_utils.go:58
↓ 7 callersFunctionsetupEnvironment
setupEnvironment initializes the test environment.
registry/servicediscovery/service_discovery_registry_test.go:152
↓ 7 callersFunctiontranslateIds
translateIds string "nacos,zk" => ["nacos","zk"]
config/config_utils.go:94
↓ 6 callersMethodAddAttachment
(string, any)
protocol/result/result.go:48
↓ 6 callersMethodAddParam
(key, value string)
config/remote_config.go:141
↓ 6 callersMethodAddSchema
(name string, schema *Schema)
protocol/triple/openapi/model/openapi.go:147
↓ 6 callersMethodAttachments
Attachments gets all attachments
protocol/result/result.go:98
↓ 6 callersMethodCallUnary
CallUnary calls a request-response procedure.
protocol/triple/triple_protocol/client.go:129
↓ 6 callersFunctionDefaultHttp3Config
DefaultHttp3Config returns a default Http3Config instance.
global/http3_config.go:41
↓ 6 callersMethodExport
Export method is to export service for remote invocation
protocol/base/base_protocol.go:31
↓ 6 callersMethodFail
Fail always fails.
protocol/triple/triple_protocol/internal/gen/proto/connect/ping/v1/pingv1connect/ping.connect.go:68
↓ 6 callersMethodGet
Get retrieves the value associated with the given key from the cache.
registry/servicediscovery/store/cache_manager.go:79
↓ 6 callersFunctionGetCluster
GetCluster finds the cluster fault-tolerant mode with @name
common/extension/cluster.go:42
↓ 6 callersFunctionGetConfigResolver
GetConfigResolver get config resolver
config/config_resolver.go:41
↓ 6 callersFunctionGetDefaultConfiguratorFunc
GetDefaultConfiguratorFunc gets default configurator function
common/extension/configurator.go:55
↓ 6 callersMethodGetDefineValue
(key string, default_value any)
config/custom_config.go:47
↓ 6 callersMethodGetDirectoryUrl
GetDirectoryUrl Get URL instance
cluster/directory/base/directory.go:71
↓ 6 callersFunctionGetLocalHostName
()
common/host_util.go:51
↓ 6 callersMethodGetMetadataInfo
GetMetadataInfo will return metadata info
metadata/metadata_service.go:60
↓ 6 callersFunctionGetMetadataReport
()
metadata/report_instance.go:54
↓ 6 callersMethodGetName
()
tools/dubbogo-cli/cmd/testGenCode/template/newApp/api/api.pb.go:137
↓ 6 callersMethodGetPath
GetPath get path
config_center/file/impl.go:181
↓ 6 callersFunctionGetShutDown
()
config/root_config.go:100
↓ 6 callersMethodGetURL
GetURL Get URL
cluster/directory/base/directory.go:66
↓ 6 callersFunctionGetWeight
GetWeight returns the weight for the load‑balancing strategy.
cluster/loadbalance/util.go:30
↓ 6 callersMethodHandle
()
remoting/exchange.go:95
↓ 6 callersMethodHandleClosingEvent
(event ClosingEvent)
graceful_shutdown/closing_registry.go:129
↓ 6 callersMethodImplement
Implement proxy implement In consumer, RPCService like: type XxxProvider struct { Yyy func(ctx context.Context, args []any, rsp *Zzz) error
proxy/proxy.go:95
↓ 6 callersFunctionInitRegistryMetadataReport
(registries map[string]*global.RegistryConfig)
metadata/options.go:114
↓ 6 callersMethodInitWith
InitWith will init BaseConfigurationListener by @key+@Listener+@f
registry/base_configuration_listener.go:47
↓ 6 callersMethodInvoke
(ctx context.Context, invoker base.Invoker, inv base.Invocation)
filter/generic/service_filter.go:63
↓ 6 callersMethodInvoker
Attachments gets all attachments Invoker gets the invoker in current context.
protocol/base/invocation.go:46
↓ 6 callersMethodListenServiceEvent
ListenServiceEvent is invoked by etcdv3 ConsumerRegistry::Registe/ etcdv3 ConsumerRegistry::get/etcdv3 ConsumerRegistry::getListener registry.go:Liste
remoting/etcdv3/listener.go:178
↓ 6 callersFunctionLoadRegistries
(registryIds []string, registries map[string]*global.RegistryConfig, roleType common.RoleType)
internal/config.go:41
↓ 6 callersFunctionLoadRegistries
(registryIds []string, registries map[string]*RegistryConfig, roleType common.RoleType)
config/registry_config.go:206
↓ 6 callersFunctionNewCacheListener
NewCacheListener creates a new CacheListener
metadata/report/zookeeper/listener.go:93
↓ 6 callersFunctionNewComponents
()
protocol/triple/openapi/model/openapi.go:141
↓ 6 callersFunctionNewHessianCodec
NewHessianCodec generate a new hessian codec instance
protocol/dubbo/hessian2/hessian_dubbo.go:74
↓ 6 callersFunctionNewNacosListenerWithServiceName
NewNacosListenerWithServiceName creates a data listener for nacos
registry/nacos/listener.go:66
↓ 6 callersFunctionNewOptions
(opts ...Option)
metadata/options.go:55
↓ 6 callersFunctionNewRandomLoadBalance
NewRandomLoadBalance returns a random load balance instance. Set random probabilities by weight, and the request will be sent to provider randomly.
cluster/loadbalance/random/loadbalance.go:40
↓ 6 callersFunctionNewShutDownConfigBuilder
()
config/graceful_shutdown_config.go:160
↓ 6 callersFunctionNewZkEventListener
NewZkEventListener returns a EventListener instance
remoting/zookeeper/listener.go:59
↓ 6 callersMethodOnResponse
(context.Context, result.Result, base.Invoker, base.Invocation)
filter/filter.go:35
↓ 6 callersMethodParameterValues
ParameterValues gets invocation parameter values.
protocol/base/invocation.go:36
↓ 6 callersFunctionParseArgumentsByExpression
ParseArgumentsByExpression follow https://goessner.net/articles/JsonPath/ { "store":{ "book":[ { "catego
remoting/polaris/parser/parser.go:78
↓ 6 callersMethodPathParameter
PathParameter get the path parameter by name
protocol/rest/server/rest_server.go:60
↓ 6 callersMethodPriority
Priority returns Priority in ConditionMatcherFactory 0 to ^int(0) is better, smaller value by better priority.
cluster/router/condition/matcher/matcher.go:32
↓ 6 callersMethodReadBody
ReadBody uses hessian codec to read response body
protocol/dubbo/hessian2/hessian_dubbo.go:204
↓ 6 callersFunctionRegisterLiveness
RegisterLiveness registers a liveness check.
metrics/probe/probe.go:40
↓ 6 callersMethodRequest
(request *Request, timeout time.Duration, response *PendingResponse)
remoting/exchange_client.go:55
↓ 6 callersMethodSetInvokers
SetInvokers sets invoker into local memory
protocol/base/base_protocol.go:69
↓ 6 callersMethodSetProtocol
(protocol string)
config/remote_config.go:111
↓ 6 callersMethodSetStaticConfig
(cfg *global.RouterConfig)
cluster/router/router.go:66
↓ 6 callersMethodSnapshot
()
common/extension/registry_type.go:67
↓ 6 callersMethodStart
Start gRPC server with @url
protocol/grpc/server.go:84
↓ 6 callersMethodStop
Stop gRPC server
protocol/grpc/server.go:257
↓ 6 callersMethodString
()
protocol/grpc/internal/routeguide/routeguide.pb.go:66
↓ 6 callersMethodTags
()
metrics/common.go:35
↓ 6 callersMethodTrailer
Trailer returns the trailers for this response. Depending on the underlying RPC protocol, trailers may be sent as HTTP trailers or a protocol-specific
protocol/triple/triple_protocol/triple.go:247
← previousnext →501–600 of 7,883, ranked by callers