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
↓ 12 callers
Method
String
()
registry/nacos/service_discovery.go:410
↓ 12 callers
Method
getClientManager
()
protocol/triple/triple_invoker.go:61
↓ 12 callers
Function
isGeneric
isGeneric receives a generic field from url of invoker to determine whether the service is generic or not
filter/generic/util.go:54
↓ 12 callers
Function
newMockMetricRegistry
()
metrics/api_test.go:37
↓ 12 callers
Function
newTestServiceInfo
helper to create a basic ServiceInfo
protocol/triple/openapi/service_test.go:43
↓ 12 callers
Function
normalRegistryDir
(noMockEvent ...bool)
registry/directory/directory_test.go:258
↓ 12 callers
Method
processImplementation
(identifier string, implementation StreamingHandlerFunc)
protocol/triple/triple_protocol/handler.go:297
↓ 11 callers
Method
BlockUntilResponseReady
()
protocol/triple/triple_protocol/duplex_http_call.go:255
↓ 11 callers
Method
Close
()
remoting/exchange_client.go:54
↓ 11 callers
Method
Copy
Copy will return a instance with different port
registry/service_instance.go:68
↓ 11 callers
Method
Details
Details returns the error's details.
protocol/triple/triple_protocol/error.go:187
↓ 11 callers
Method
DoSelect
(lb loadbalance.LoadBalance, invocation base.Invocation, invokers []base.Invoker, invoked []base.Invoker)
cluster/cluster/base/cluster_invoker.go:92
↓ 11 callers
Function
EnsureResponsePayload
(body any)
protocol/dubbo/impl/response.go:38
↓ 11 callers
Method
GetChildren
GetChildren gets children nodes under a path
tools/dubbogo-cli/metadata/zookeeper/zookeeper.go:85
↓ 11 callers
Method
GetInvoker
(url *common.URL)
proxy/proxy_factory.go:28
↓ 11 callers
Method
GetParamByIntValue
GetParamByIntValue gets int value by @key
common/url.go:716
↓ 11 callers
Method
GetServiceInfo
()
protocol/triple/server.go:539
↓ 11 callers
Method
GetServiceOptions
GetServiceOptions retrieves the ServiceOptions for a service by its name/ID
server/server.go:464
↓ 11 callers
Function
IsEquals
IsEquals compares if two URLs equals with each other. Excludes are all parameter keys which should ignored.
common/url.go:981
↓ 11 callers
Method
NewClient
(*protocolClientParams)
protocol/triple/triple_protocol/protocol.go:64
↓ 11 callers
Function
NewGenericService
NewGenericService returns a GenericService instance
filter/generic/service.go:40
↓ 11 callers
Function
NewLoaderConf
(opts ...LoaderConfOption)
config/config_loader_options.go:49
↓ 11 callers
Function
NewPendingResponse
NewPendingResponse aims to create PendingResponse. ID is always from ID of Request
remoting/exchange.go:146
↓ 11 callers
Function
NewReportOptions
(opts ...ReportOption)
metadata/options.go:188
↓ 11 callers
Function
NewResponse
NewResponse wraps a generated response message.
protocol/triple/triple_protocol/triple.go:215
↓ 11 callers
Method
Resolve
(interfaceName string, info *serviceInfo)
protocol/triple/openapi/definition_resolver.go:41
↓ 11 callers
Function
SetCluster
SetCluster sets the cluster fault-tolerant mode with @name For example: available/failfast/broadcast/failfast/failsafe/...
common/extension/cluster.go:37
↓ 11 callers
Method
SetServingStatus
(service string, status grpc_health_v1.HealthCheckResponse_ServingStatus)
protocol/grpc/server.go:164
↓ 11 callers
Function
WithGroup
(group string)
config_center/options.go:95
↓ 11 callers
Function
Zero
Zero asserts that the value is its type's zero value.
protocol/triple/triple_protocol/internal/assert/assert.go:76
↓ 11 callers
Function
buildCorsPolicy
buildCorsPolicy processes the CorsConfig with handlers and returns a configured CorsConfig.
protocol/triple/triple_protocol/cors.go:62
↓ 11 callers
Function
newRegistryProtocol
()
registry/protocol/protocol.go:76
↓ 11 callers
Function
newTestTripleInvoker
newTestTripleInvoker creates a TripleInvoker for testing without network connection
protocol/triple/triple_invoker_test.go:182
↓ 11 callers
Function
report
(tb testing.TB, got, want any, desc string, showWant bool, options ...Option)
protocol/triple/triple_protocol/internal/assert/assert.go:185
↓ 11 callers
Function
unmarshalResponseBody
(body []byte, p *DubboPackage)
protocol/dubbo/impl/hessian.go:274
↓ 10 callers
Function
AddCustomizers
AddCustomizers will put the customizer into slices and then sort them; this method will be invoked several time, so we sort them here.
common/extension/service_instance_customizer.go:34
↓ 10 callers
Method
CheckInvokers
CheckInvokers checks invokers' status if is available or not
cluster/cluster/base/cluster_invoker.go:72
↓ 10 callers
Method
CheckValidity
CheckValidity confirm client params.
remoting/getty/config.go:208
↓ 10 callers
Method
Create
Create will create an instance of TpsLimitStrategy It will be a little hard to understand this method. The unit of interval is ms for example, if the
filter/tps_strategy.go:34
↓ 10 callers
Method
Debug
(args ...any)
logger/base.go:33
↓ 10 callers
Function
GetCompareURLEqualFunc
()
common/url.go:1040
↓ 10 callers
Method
GetRawParam
GetRawParam gets raw param
common/url.go:669
↓ 10 callers
Function
IsEmpty
IsEmpty verify whether the inputted string is empty
filter/auth/sign_util.go:70
↓ 10 callers
Method
Len
Len returns the number of customizers.
common/extension/service_instance_customizer.go:56
↓ 10 callers
Function
Load
(opts ...LoaderConfOption)
config/config_loader.go:54
↓ 10 callers
Method
MustGet
(name string)
common/extension/registry_type.go:51
↓ 10 callers
Function
NewConditionStateRouter
(url *common.URL)
cluster/router/condition/route.go:56
↓ 10 callers
Function
NewRequestPayload
(args any, atta map[string]any)
protocol/dubbo/impl/request.go:25
↓ 10 callers
Function
NewServiceDiscovery
NewServiceDiscovery the constructor of service discovery
remoting/zookeeper/curator_discovery/service_discovery.go:60
↓ 10 callers
Method
RemoveListener
(string, ConfigurationListener, ...Option)
config_center/dynamic_configuration.go:39
↓ 10 callers
Method
SetExporterMap
SetExporterMap set @exporter with @key to local memory.
protocol/base/base_protocol.go:59
↓ 10 callers
Function
SetRootConfig
(r RootConfig)
config/root_config.go:66
↓ 10 callers
Method
SetSerializer
(serializer Serializer)
protocol/dubbo/impl/package.go:153
↓ 10 callers
Method
String
()
registry/servicediscovery/service_discovery_registry_test.go:187
↓ 10 callers
Method
Sub
(labels map[string]string, v float64)
metrics/api.go:214
↓ 10 callers
Function
Subscribe
Subscribe subscribes to events of the given type.
metrics/bus.go:49
↓ 10 callers
Method
Subscribe
Subscribe is required to support the contract: When creating new registry extension, pls select one of the following modes. Will remove in dubbogo ver
registry/registry.go:53
↓ 10 callers
Method
Unmarshal
(binary []byte, message any)
protocol/triple/triple_protocol/codec.go:390
↓ 10 callers
Method
Unregister
Unregister will unregister this instance from registry
registry/service_discovery.go:46
↓ 10 callers
Method
With
(tags map[string]string)
metrics/prometheus/rt_vec.go:170
↓ 10 callers
Function
buildInvokers
()
cluster/router/condition/router_test.go:948
↓ 10 callers
Function
file_proto_connect_ping_v1_ping_proto_rawDescGZIP
()
protocol/triple/triple_protocol/internal/gen/proto/connect/ping/v1/ping.pb.go:602
↓ 10 callers
Function
getGeneralizer
(generic string)
filter/generic/util.go:61
↓ 10 callers
Method
init
(opts ...ClientOption)
client/options.go:563
↓ 10 callers
Function
isSupportResponseAttachment
https://github.com/apache/dubbo/blob/dubbo-2.7.1/dubbo-common/src/main/java/org/apache/dubbo/common/Version.java#L96 isSupportResponseAttachment is fo
protocol/dubbo/hessian2/hessian_response.go:407
↓ 10 callers
Function
newTestHandler
helper to create a handler with a registered service
protocol/triple/openapi/handler_test.go:33
↓ 10 callers
Function
newUrl
(url string)
cluster/router/condition/router_test.go:1068
↓ 10 callers
Function
version2Int
(ver any)
protocol/dubbo/hessian2/hessian_response.go:424
↓ 9 callers
Function
AddCustomShutdownCallback
** * AddCustomShutdownCallback * you should not make any assumption about the order. * For example, if you have more than one callbacks, and you wi
common/extension/graceful_shutdown.go:64
↓ 9 callers
Method
ArgsType
ArgsType gets @m.argsType.
common/rpc_service.go:126
↓ 9 callers
Method
Attachment
(string, any)
protocol/result/result.go:49
↓ 9 callers
Method
Configure
(url *common.URL)
config_center/configurator.go:27
↓ 9 callers
Method
Dec
(labels map[string]string)
metrics/api.go:212
↓ 9 callers
Method
Done
for wait group control, zk client listener & zk client container
remoting/zookeeper/facade.go:39
↓ 9 callers
Function
ExtractFromOutgoingContext
(ctx context.Context)
protocol/triple/triple_protocol/header.go:158
↓ 9 callers
Method
GetAttachmentWithDefaultValue
(key string, defaultValue string)
protocol/invocation/rpcinvocation.go:208
↓ 9 callers
Method
GetFailedElapsed
GetFailedElapsed gets failed elapsed.
protocol/base/rpc_status.go:84
↓ 9 callers
Function
GetFilter
GetFilter finds the filter extension with @name
common/extension/filter.go:40
↓ 9 callers
Method
GetMethodMetrics
GetMethodMetrics returns method-level metrics, the format of key is "{instance key}.{invoker key}.{method key}.{key}" url is invoker's url, which cont
cluster/metrics/metrics.go:37
↓ 9 callers
Function
GetProxyFactory
GetProxyFactory finds the ProxyFactory extension with @name
common/extension/proxy_factory.go:36
↓ 9 callers
Method
GetTotalElapsed
GetTotalElapsed gets total elapsed.
protocol/base/rpc_status.go:79
↓ 9 callers
Function
HandleRegisterIPAndPort
(url *URL)
common/host_util.go:63
↓ 9 callers
Method
Header
Header returns the HTTP headers for this response. Headers beginning with "Triple-" and "Grpc-" are reserved for use by the Triple and gRPC protocols:
protocol/triple/triple_protocol/triple.go:233
↓ 9 callers
Method
Init
Init is to start dubbo-go framework, load local configuration, or read configuration from config-center if necessary. It's deprecated for user to call
config/root_config.go:130
↓ 9 callers
Method
IsHealthy
IsHealthy will return the value represent the instance whether healthy or not
registry/service_instance.go:56
↓ 9 callers
Method
Meta
Meta allows the error to carry additional information as key-value pairs. Metadata attached to errors returned by unary handlers is always sent as HT
protocol/triple/triple_protocol/error.go:207
↓ 9 callers
Function
NewMockINamingClient
NewMockINamingClient creates a new mock instance
registry/nacos/registry_test.go:56
↓ 9 callers
Function
NewServer
NewServer creates a new TRIPLE server.
protocol/triple/server.go:64
↓ 9 callers
Function
NewServiceInfoWithURL
(url *common.URL)
metadata/info/metadata_info.go:179
↓ 9 callers
Method
RangeParams
RangeParams will iterate the params
common/url.go:617
↓ 9 callers
Method
Record
(labels map[string]string, v float64)
metrics/api.go:253
↓ 9 callers
Method
Serve
()
server/server.go:290
↓ 9 callers
Method
SetAttachments
SetAttachments replaces the existing attachments with the specified param.
protocol/result/result.go:93
↓ 9 callers
Method
SetFormat
(format string)
protocol/triple/openapi/model/schema.go:57
↓ 9 callers
Method
SetName
(name string)
config/protocol_config.go:68
↓ 9 callers
Method
SetTimeout
SetTimeout runs before NewStream. Implementations may inspect the HTTP request, parse any timeout set by the client, and return a modified context and
protocol/triple/triple_protocol/protocol.go:101
↓ 9 callers
Method
StateCount
(total, succ, fail *MetricKey, level MetricLevel, succed bool)
metrics/api.go:171
↓ 9 callers
Method
String
()
protocol/dubbo/hessian2/hessian_request_test.go:55
↓ 9 callers
Method
UseAsMetadataReport
()
global/registry_config.go:99
↓ 9 callers
Function
WithAddress
WithAddress address metadata report will to use, if a URL schema is set,this will also set the protocol, such as WithAddress("zookeeper://127.0.0.1")
metadata/options.go:224
← previous
next →
301–400 of 7,883, ranked by callers