Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/apache/dubbo-go
/ functions
Functions
7,883 in github.com/apache/dubbo-go
⨍
Functions
7,883
◇
Types & classes
1,328
↓ 7 callers
Method
Names
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 callers
Function
NewCacheManager
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 callers
Function
NewDirectory
NewDirectory Create BaseDirectory with URL
cluster/directory/base/directory.go:45
↓ 7 callers
Function
NewExchangeClient
NewExchangeClient returns a ExchangeClient.
remoting/exchange_client.go:69
↓ 7 callers
Function
NewGaugeVec
NewGaugeVec create a GaugeVec default implementation.
metrics/api.go:218
↓ 7 callers
Function
NewMetadataInfo
(app, tag string)
metadata/info/metadata_info.go:71
↓ 7 callers
Function
NewOptions
(opts ...Option)
registry/options.go:42
↓ 7 callers
Function
NewOptions
(opts ...Option)
config_center/options.go:40
↓ 7 callers
Function
NewResponse
NewResponse create to a new Response.
remoting/exchange.go:84
↓ 7 callers
Function
NewResponsePayload
NewResponsePayload create a new ResponsePayload
protocol/dubbo/impl/response.go:27
↓ 7 callers
Method
Parser
()
config_center/dynamic_configuration.go:36
↓ 7 callers
Method
Register
Register assemble invoker chains like ProviderConfig.Load, init a service per call
server/server.go:75
↓ 7 callers
Function
RegisterProtocol
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 callers
Function
RegistryCodec
(protocol string, codecTmp Codec)
remoting/codec.go:39
↓ 7 callers
Method
Scrape
()
metrics/prometheus/registry.go:202
↓ 7 callers
Method
SetAttachment
(key string, value any)
protocol/invocation/rpcinvocation.go:182
↓ 7 callers
Method
SetAttribute
(key string, value any)
protocol/invocation/rpcinvocation.go:215
↓ 7 callers
Method
SetResult
(any)
protocol/result/result.go:44
↓ 7 callers
Function
SetRouterFactory
SetRouterFactory sets create router factory function with @name
common/extension/router_factory.go:29
↓ 7 callers
Function
SetTpsLimitStrategy
SetTpsLimitStrategy sets the TpsLimitStrategyCreator with @name
common/extension/tps_limit.go:49
↓ 7 callers
Method
String
()
tools/dubbogo-cli/cmd/testGenCode/template/newApp/api/api.pb.go:114
↓ 7 callers
Method
String
()
metadata/triple_api/proto/metadata_service_v2.pb.go:176
↓ 7 callers
Method
TagKeys
()
metrics/api.go:124
↓ 7 callers
Function
ToMapStringInterface
(origin map[any]any)
protocol/dubbo/impl/hessian.go:539
↓ 7 callers
Function
UnregisterGracefulShutdownCallback
UnregisterGracefulShutdownCallback removes a protocol graceful shutdown callback by name.
common/extension/graceful_shutdown.go:104
↓ 7 callers
Method
Update
Update will update the data of the instance in registry
registry/service_discovery.go:43
↓ 7 callers
Method
WaitGroup
()
remoting/etcdv3/facade.go:38
↓ 7 callers
Function
WithInterface
---------- 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 callers
Function
classifyError
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 callers
Function
createServiceInfoWithReflection
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 callers
Method
destroy
destroy stops the cache dump routine, clears the cache and removes the cache file.
registry/servicediscovery/store/cache_manager.go:188
↓ 7 callers
Function
doTestResponse
(t *testing.T, packageType PackageType, responseStatus byte, body any, decodedResponse *DubboResponse, assertF
protocol/dubbo/hessian2/hessian_dubbo_test.go:83
↓ 7 callers
Function
exporterNormal
(t *testing.T, regProtocol *registryProtocol)
registry/protocol/protocol_test.go:125
↓ 7 callers
Function
internalReady
()
metrics/probe/state.go:46
↓ 7 callers
Function
internalStartup
()
metrics/probe/state.go:53
↓ 7 callers
Function
isClosingError
(err error)
filter/graceful_shutdown/consumer_filter.go:215
↓ 7 callers
Function
isExported
Is this an exported - upper case - name
common/rpc_service.go:312
↓ 7 callers
Function
mergeImports
(m map[string][]string)
tools/imports-formatter/main.go:431
↓ 7 callers
Function
newPolarisRouter
(url *common.URL)
cluster/router/polaris/router.go:54
↓ 7 callers
Function
newServiceDiscoveryRegistry
(url *common.URL)
registry/servicediscovery/service_discovery_registry.go:70
↓ 7 callers
Function
removeMinus
(strArr []string)
config/config_utils.go:58
↓ 7 callers
Function
setupEnvironment
setupEnvironment initializes the test environment.
registry/servicediscovery/service_discovery_registry_test.go:152
↓ 7 callers
Function
translateIds
translateIds string "nacos,zk" => ["nacos","zk"]
config/config_utils.go:94
↓ 6 callers
Method
AddAttachment
(string, any)
protocol/result/result.go:48
↓ 6 callers
Method
AddParam
(key, value string)
config/remote_config.go:141
↓ 6 callers
Method
AddSchema
(name string, schema *Schema)
protocol/triple/openapi/model/openapi.go:147
↓ 6 callers
Method
Attachments
Attachments gets all attachments
protocol/result/result.go:98
↓ 6 callers
Method
CallUnary
CallUnary calls a request-response procedure.
protocol/triple/triple_protocol/client.go:129
↓ 6 callers
Function
DefaultHttp3Config
DefaultHttp3Config returns a default Http3Config instance.
global/http3_config.go:41
↓ 6 callers
Method
Export
Export method is to export service for remote invocation
protocol/base/base_protocol.go:31
↓ 6 callers
Method
Fail
Fail always fails.
protocol/triple/triple_protocol/internal/gen/proto/connect/ping/v1/pingv1connect/ping.connect.go:68
↓ 6 callers
Method
Get
Get retrieves the value associated with the given key from the cache.
registry/servicediscovery/store/cache_manager.go:79
↓ 6 callers
Function
GetCluster
GetCluster finds the cluster fault-tolerant mode with @name
common/extension/cluster.go:42
↓ 6 callers
Function
GetConfigResolver
GetConfigResolver get config resolver
config/config_resolver.go:41
↓ 6 callers
Function
GetDefaultConfiguratorFunc
GetDefaultConfiguratorFunc gets default configurator function
common/extension/configurator.go:55
↓ 6 callers
Method
GetDefineValue
(key string, default_value any)
config/custom_config.go:47
↓ 6 callers
Method
GetDirectoryUrl
GetDirectoryUrl Get URL instance
cluster/directory/base/directory.go:71
↓ 6 callers
Function
GetLocalHostName
()
common/host_util.go:51
↓ 6 callers
Method
GetMetadataInfo
GetMetadataInfo will return metadata info
metadata/metadata_service.go:60
↓ 6 callers
Function
GetMetadataReport
()
metadata/report_instance.go:54
↓ 6 callers
Method
GetName
()
tools/dubbogo-cli/cmd/testGenCode/template/newApp/api/api.pb.go:137
↓ 6 callers
Method
GetPath
GetPath get path
config_center/file/impl.go:181
↓ 6 callers
Function
GetShutDown
()
config/root_config.go:100
↓ 6 callers
Method
GetURL
GetURL Get URL
cluster/directory/base/directory.go:66
↓ 6 callers
Function
GetWeight
GetWeight returns the weight for the load‑balancing strategy.
cluster/loadbalance/util.go:30
↓ 6 callers
Method
Handle
()
remoting/exchange.go:95
↓ 6 callers
Method
HandleClosingEvent
(event ClosingEvent)
graceful_shutdown/closing_registry.go:129
↓ 6 callers
Method
Implement
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 callers
Function
InitRegistryMetadataReport
(registries map[string]*global.RegistryConfig)
metadata/options.go:114
↓ 6 callers
Method
InitWith
InitWith will init BaseConfigurationListener by @key+@Listener+@f
registry/base_configuration_listener.go:47
↓ 6 callers
Method
Invoke
(ctx context.Context, invoker base.Invoker, inv base.Invocation)
filter/generic/service_filter.go:63
↓ 6 callers
Method
Invoker
Attachments gets all attachments Invoker gets the invoker in current context.
protocol/base/invocation.go:46
↓ 6 callers
Method
ListenServiceEvent
ListenServiceEvent is invoked by etcdv3 ConsumerRegistry::Registe/ etcdv3 ConsumerRegistry::get/etcdv3 ConsumerRegistry::getListener registry.go:Liste
remoting/etcdv3/listener.go:178
↓ 6 callers
Function
LoadRegistries
(registryIds []string, registries map[string]*global.RegistryConfig, roleType common.RoleType)
internal/config.go:41
↓ 6 callers
Function
LoadRegistries
(registryIds []string, registries map[string]*RegistryConfig, roleType common.RoleType)
config/registry_config.go:206
↓ 6 callers
Function
NewCacheListener
NewCacheListener creates a new CacheListener
metadata/report/zookeeper/listener.go:93
↓ 6 callers
Function
NewComponents
()
protocol/triple/openapi/model/openapi.go:141
↓ 6 callers
Function
NewHessianCodec
NewHessianCodec generate a new hessian codec instance
protocol/dubbo/hessian2/hessian_dubbo.go:74
↓ 6 callers
Function
NewNacosListenerWithServiceName
NewNacosListenerWithServiceName creates a data listener for nacos
registry/nacos/listener.go:66
↓ 6 callers
Function
NewOptions
(opts ...Option)
metadata/options.go:55
↓ 6 callers
Function
NewRandomLoadBalance
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 callers
Function
NewShutDownConfigBuilder
()
config/graceful_shutdown_config.go:160
↓ 6 callers
Function
NewZkEventListener
NewZkEventListener returns a EventListener instance
remoting/zookeeper/listener.go:59
↓ 6 callers
Method
OnResponse
(context.Context, result.Result, base.Invoker, base.Invocation)
filter/filter.go:35
↓ 6 callers
Method
ParameterValues
ParameterValues gets invocation parameter values.
protocol/base/invocation.go:36
↓ 6 callers
Function
ParseArgumentsByExpression
ParseArgumentsByExpression follow https://goessner.net/articles/JsonPath/ { "store":{ "book":[ { "catego
remoting/polaris/parser/parser.go:78
↓ 6 callers
Method
PathParameter
PathParameter get the path parameter by name
protocol/rest/server/rest_server.go:60
↓ 6 callers
Method
Priority
Priority returns Priority in ConditionMatcherFactory 0 to ^int(0) is better, smaller value by better priority.
cluster/router/condition/matcher/matcher.go:32
↓ 6 callers
Method
ReadBody
ReadBody uses hessian codec to read response body
protocol/dubbo/hessian2/hessian_dubbo.go:204
↓ 6 callers
Function
RegisterLiveness
RegisterLiveness registers a liveness check.
metrics/probe/probe.go:40
↓ 6 callers
Method
Request
(request *Request, timeout time.Duration, response *PendingResponse)
remoting/exchange_client.go:55
↓ 6 callers
Method
SetInvokers
SetInvokers sets invoker into local memory
protocol/base/base_protocol.go:69
↓ 6 callers
Method
SetProtocol
(protocol string)
config/remote_config.go:111
↓ 6 callers
Method
SetStaticConfig
(cfg *global.RouterConfig)
cluster/router/router.go:66
↓ 6 callers
Method
Snapshot
()
common/extension/registry_type.go:67
↓ 6 callers
Method
Start
Start gRPC server with @url
protocol/grpc/server.go:84
↓ 6 callers
Method
Stop
Stop gRPC server
protocol/grpc/server.go:257
↓ 6 callers
Method
String
()
protocol/grpc/internal/routeguide/routeguide.pb.go:66
↓ 6 callers
Method
Tags
()
metrics/common.go:35
↓ 6 callers
Method
Trailer
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
← previous
next →
501–600 of 7,883, ranked by callers