MCPcopy Create free account

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

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

↓ 12 callersMethodString
()
registry/nacos/service_discovery.go:410
↓ 12 callersMethodgetClientManager
()
protocol/triple/triple_invoker.go:61
↓ 12 callersFunctionisGeneric
isGeneric receives a generic field from url of invoker to determine whether the service is generic or not
filter/generic/util.go:54
↓ 12 callersFunctionnewMockMetricRegistry
()
metrics/api_test.go:37
↓ 12 callersFunctionnewTestServiceInfo
helper to create a basic ServiceInfo
protocol/triple/openapi/service_test.go:43
↓ 12 callersFunctionnormalRegistryDir
(noMockEvent ...bool)
registry/directory/directory_test.go:258
↓ 12 callersMethodprocessImplementation
(identifier string, implementation StreamingHandlerFunc)
protocol/triple/triple_protocol/handler.go:297
↓ 11 callersMethodBlockUntilResponseReady
()
protocol/triple/triple_protocol/duplex_http_call.go:255
↓ 11 callersMethodClose
()
remoting/exchange_client.go:54
↓ 11 callersMethodCopy
Copy will return a instance with different port
registry/service_instance.go:68
↓ 11 callersMethodDetails
Details returns the error's details.
protocol/triple/triple_protocol/error.go:187
↓ 11 callersMethodDoSelect
(lb loadbalance.LoadBalance, invocation base.Invocation, invokers []base.Invoker, invoked []base.Invoker)
cluster/cluster/base/cluster_invoker.go:92
↓ 11 callersFunctionEnsureResponsePayload
(body any)
protocol/dubbo/impl/response.go:38
↓ 11 callersMethodGetChildren
GetChildren gets children nodes under a path
tools/dubbogo-cli/metadata/zookeeper/zookeeper.go:85
↓ 11 callersMethodGetInvoker
(url *common.URL)
proxy/proxy_factory.go:28
↓ 11 callersMethodGetParamByIntValue
GetParamByIntValue gets int value by @key
common/url.go:716
↓ 11 callersMethodGetServiceInfo
()
protocol/triple/server.go:539
↓ 11 callersMethodGetServiceOptions
GetServiceOptions retrieves the ServiceOptions for a service by its name/ID
server/server.go:464
↓ 11 callersFunctionIsEquals
IsEquals compares if two URLs equals with each other. Excludes are all parameter keys which should ignored.
common/url.go:981
↓ 11 callersMethodNewClient
(*protocolClientParams)
protocol/triple/triple_protocol/protocol.go:64
↓ 11 callersFunctionNewGenericService
NewGenericService returns a GenericService instance
filter/generic/service.go:40
↓ 11 callersFunctionNewLoaderConf
(opts ...LoaderConfOption)
config/config_loader_options.go:49
↓ 11 callersFunctionNewPendingResponse
NewPendingResponse aims to create PendingResponse. ID is always from ID of Request
remoting/exchange.go:146
↓ 11 callersFunctionNewReportOptions
(opts ...ReportOption)
metadata/options.go:188
↓ 11 callersFunctionNewResponse
NewResponse wraps a generated response message.
protocol/triple/triple_protocol/triple.go:215
↓ 11 callersMethodResolve
(interfaceName string, info *serviceInfo)
protocol/triple/openapi/definition_resolver.go:41
↓ 11 callersFunctionSetCluster
SetCluster sets the cluster fault-tolerant mode with @name For example: available/failfast/broadcast/failfast/failsafe/...
common/extension/cluster.go:37
↓ 11 callersMethodSetServingStatus
(service string, status grpc_health_v1.HealthCheckResponse_ServingStatus)
protocol/grpc/server.go:164
↓ 11 callersFunctionWithGroup
(group string)
config_center/options.go:95
↓ 11 callersFunctionZero
Zero asserts that the value is its type's zero value.
protocol/triple/triple_protocol/internal/assert/assert.go:76
↓ 11 callersFunctionbuildCorsPolicy
buildCorsPolicy processes the CorsConfig with handlers and returns a configured CorsConfig.
protocol/triple/triple_protocol/cors.go:62
↓ 11 callersFunctionnewRegistryProtocol
()
registry/protocol/protocol.go:76
↓ 11 callersFunctionnewTestTripleInvoker
newTestTripleInvoker creates a TripleInvoker for testing without network connection
protocol/triple/triple_invoker_test.go:182
↓ 11 callersFunctionreport
(tb testing.TB, got, want any, desc string, showWant bool, options ...Option)
protocol/triple/triple_protocol/internal/assert/assert.go:185
↓ 11 callersFunctionunmarshalResponseBody
(body []byte, p *DubboPackage)
protocol/dubbo/impl/hessian.go:274
↓ 10 callersFunctionAddCustomizers
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 callersMethodCheckInvokers
CheckInvokers checks invokers' status if is available or not
cluster/cluster/base/cluster_invoker.go:72
↓ 10 callersMethodCheckValidity
CheckValidity confirm client params.
remoting/getty/config.go:208
↓ 10 callersMethodCreate
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 callersMethodDebug
(args ...any)
logger/base.go:33
↓ 10 callersFunctionGetCompareURLEqualFunc
()
common/url.go:1040
↓ 10 callersMethodGetRawParam
GetRawParam gets raw param
common/url.go:669
↓ 10 callersFunctionIsEmpty
IsEmpty verify whether the inputted string is empty
filter/auth/sign_util.go:70
↓ 10 callersMethodLen
Len returns the number of customizers.
common/extension/service_instance_customizer.go:56
↓ 10 callersFunctionLoad
(opts ...LoaderConfOption)
config/config_loader.go:54
↓ 10 callersMethodMustGet
(name string)
common/extension/registry_type.go:51
↓ 10 callersFunctionNewConditionStateRouter
(url *common.URL)
cluster/router/condition/route.go:56
↓ 10 callersFunctionNewRequestPayload
(args any, atta map[string]any)
protocol/dubbo/impl/request.go:25
↓ 10 callersFunctionNewServiceDiscovery
NewServiceDiscovery the constructor of service discovery
remoting/zookeeper/curator_discovery/service_discovery.go:60
↓ 10 callersMethodRemoveListener
(string, ConfigurationListener, ...Option)
config_center/dynamic_configuration.go:39
↓ 10 callersMethodSetExporterMap
SetExporterMap set @exporter with @key to local memory.
protocol/base/base_protocol.go:59
↓ 10 callersFunctionSetRootConfig
(r RootConfig)
config/root_config.go:66
↓ 10 callersMethodSetSerializer
(serializer Serializer)
protocol/dubbo/impl/package.go:153
↓ 10 callersMethodString
()
registry/servicediscovery/service_discovery_registry_test.go:187
↓ 10 callersMethodSub
(labels map[string]string, v float64)
metrics/api.go:214
↓ 10 callersFunctionSubscribe
Subscribe subscribes to events of the given type.
metrics/bus.go:49
↓ 10 callersMethodSubscribe
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 callersMethodUnmarshal
(binary []byte, message any)
protocol/triple/triple_protocol/codec.go:390
↓ 10 callersMethodUnregister
Unregister will unregister this instance from registry
registry/service_discovery.go:46
↓ 10 callersMethodWith
(tags map[string]string)
metrics/prometheus/rt_vec.go:170
↓ 10 callersFunctionbuildInvokers
()
cluster/router/condition/router_test.go:948
↓ 10 callersFunctionfile_proto_connect_ping_v1_ping_proto_rawDescGZIP
()
protocol/triple/triple_protocol/internal/gen/proto/connect/ping/v1/ping.pb.go:602
↓ 10 callersFunctiongetGeneralizer
(generic string)
filter/generic/util.go:61
↓ 10 callersMethodinit
(opts ...ClientOption)
client/options.go:563
↓ 10 callersFunctionisSupportResponseAttachment
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 callersFunctionnewTestHandler
helper to create a handler with a registered service
protocol/triple/openapi/handler_test.go:33
↓ 10 callersFunctionnewUrl
(url string)
cluster/router/condition/router_test.go:1068
↓ 10 callersFunctionversion2Int
(ver any)
protocol/dubbo/hessian2/hessian_response.go:424
↓ 9 callersFunctionAddCustomShutdownCallback
** * 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 callersMethodArgsType
ArgsType gets @m.argsType.
common/rpc_service.go:126
↓ 9 callersMethodAttachment
(string, any)
protocol/result/result.go:49
↓ 9 callersMethodConfigure
(url *common.URL)
config_center/configurator.go:27
↓ 9 callersMethodDec
(labels map[string]string)
metrics/api.go:212
↓ 9 callersMethodDone
for wait group control, zk client listener & zk client container
remoting/zookeeper/facade.go:39
↓ 9 callersFunctionExtractFromOutgoingContext
(ctx context.Context)
protocol/triple/triple_protocol/header.go:158
↓ 9 callersMethodGetAttachmentWithDefaultValue
(key string, defaultValue string)
protocol/invocation/rpcinvocation.go:208
↓ 9 callersMethodGetFailedElapsed
GetFailedElapsed gets failed elapsed.
protocol/base/rpc_status.go:84
↓ 9 callersFunctionGetFilter
GetFilter finds the filter extension with @name
common/extension/filter.go:40
↓ 9 callersMethodGetMethodMetrics
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 callersFunctionGetProxyFactory
GetProxyFactory finds the ProxyFactory extension with @name
common/extension/proxy_factory.go:36
↓ 9 callersMethodGetTotalElapsed
GetTotalElapsed gets total elapsed.
protocol/base/rpc_status.go:79
↓ 9 callersFunctionHandleRegisterIPAndPort
(url *URL)
common/host_util.go:63
↓ 9 callersMethodHeader
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 callersMethodInit
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 callersMethodIsHealthy
IsHealthy will return the value represent the instance whether healthy or not
registry/service_instance.go:56
↓ 9 callersMethodMeta
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 callersFunctionNewMockINamingClient
NewMockINamingClient creates a new mock instance
registry/nacos/registry_test.go:56
↓ 9 callersFunctionNewServer
NewServer creates a new TRIPLE server.
protocol/triple/server.go:64
↓ 9 callersFunctionNewServiceInfoWithURL
(url *common.URL)
metadata/info/metadata_info.go:179
↓ 9 callersMethodRangeParams
RangeParams will iterate the params
common/url.go:617
↓ 9 callersMethodRecord
(labels map[string]string, v float64)
metrics/api.go:253
↓ 9 callersMethodServe
()
server/server.go:290
↓ 9 callersMethodSetAttachments
SetAttachments replaces the existing attachments with the specified param.
protocol/result/result.go:93
↓ 9 callersMethodSetFormat
(format string)
protocol/triple/openapi/model/schema.go:57
↓ 9 callersMethodSetName
(name string)
config/protocol_config.go:68
↓ 9 callersMethodSetTimeout
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 callersMethodStateCount
(total, succ, fail *MetricKey, level MetricLevel, succed bool)
metrics/api.go:171
↓ 9 callersMethodString
()
protocol/dubbo/hessian2/hessian_request_test.go:55
↓ 9 callersMethodUseAsMetadataReport
()
global/registry_config.go:99
↓ 9 callersFunctionWithAddress
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
← previousnext →301–400 of 7,883, ranked by callers