MCPcopy Create free account

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

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

↓ 36 callersMethodService
(ctx context.Context, in *FirstRequest, opts ...grpc.CallOption)
protocol/grpc/internal/multiprotos/first.pb.go:163
↓ 36 callersMethodValue
Value uses the Protobuf runtime's package-global registry to unmarshal the Detail into a strongly-typed message. Typically, clients use Go type assert
protocol/triple/triple_protocol/error.go:90
↓ 35 callersMethodKey
Key gets key
common/url.go:409
↓ 35 callersMethodServiceKey
()
protocol/invocation/rpcinvocation.go:177
↓ 34 callersFunctionNewSchemaResolver
(config *global.OpenAPIConfig)
protocol/triple/openapi/schema_resolver.go:37
↓ 33 callersFunctionNewPingServiceHandler
NewPingServiceHandler builds an HTTP handler from the service implementation. It returns the path on which to mount the handler and the handler itself
protocol/triple/triple_protocol/internal/gen/proto/connect/ping/v1/pingv1connect/ping.connect.go:146
↓ 33 callersFunctionSprintf
Sprintf adds a user-defined message to the assertion's output. The arguments are passed directly to fmt.Sprintf for formatting. If Sprintf is passed
protocol/triple/triple_protocol/internal/assert/assert.go:173
↓ 32 callersMethodNewServer
NewServer is like server.NewServer, but inject configurations from RootConfig.
dubbo.go:132
↓ 32 callersMethodRoute
(*common.URL, base.Invocation)
cluster/router/chain.go:26
↓ 32 callersMethodSpec
()
protocol/triple/triple_protocol/triple.go:197
↓ 31 callersMethodGetAttachmentWithDefaultValue
(key string, defaultValue string)
protocol/base/invocation.go:54
↓ 31 callersMethodPeer
()
protocol/triple/triple_protocol/triple.go:198
↓ 31 callersFunctionmergeHeaders
(into, from http.Header)
protocol/triple/triple_protocol/header.go:51
↓ 30 callersMethodGetMetadata
GetMetadata will return the metadata
registry/service_instance.go:59
↓ 30 callersMethodInvoke
Invoke the invocation and return result.
protocol/base/base_invoker.go:58
↓ 30 callersFunctionLoadSerializer
(p *DubboPackage)
protocol/dubbo/impl/serialize.go:29
↓ 30 callersFunctionWithAttribute
WithAttribute sets attribute for URL
common/url.go:222
↓ 30 callersFunctionWithMethods
WithMethods sets methods for URL
common/url.go:145
↓ 29 callersMethodEXPECT
EXPECT returns an object that allows the caller to indicate expected use
filter/otel/trace/filter_test.go:446
↓ 29 callersFunctionGetProtocol
GetProtocol finds the protocol extension with @name
common/extension/protocol.go:32
↓ 29 callersMethodInfo
(args ...any)
logger/base.go:35
↓ 29 callersMethodRequestHeader
()
protocol/triple/triple_protocol/triple.go:125
↓ 29 callersMethodSelect
([]base.Invoker, base.Invocation)
cluster/loadbalance/loadbalance.go:25
↓ 29 callersFunctionServiceKey
(intf string, group string, version string)
common/url.go:438
↓ 29 callersMethodSetAttachment
(key string, value any)
protocol/base/invocation.go:51
↓ 28 callersFunctionGetJavaName
GetJavaName returns java name of an object
protocol/dubbo/hessian2/java_class.go:40
↓ 28 callersMethodName
Name return the Poolable's name.
cluster/router/router.go:79
↓ 27 callersMethodExport
add a metric num to a rt
metrics/api.go:84
↓ 27 callersMethodGetInvoker
GetInvoker method is to get invoker.
protocol/base/base_exporter.go:31
↓ 27 callersFunctionSetProtocol
SetProtocol sets the protocol extension with @name
common/extension/protocol.go:27
↓ 26 callersFunctionCheckCompleteInequality
(t *testing.T, origin any, clone any)
global/config_test.go:253
↓ 26 callersMethodErr
()
protocol/triple/health/triple_health/health.triple.go:119
↓ 26 callersMethodGetURL
()
remoting/zookeeper/facade.go:41
↓ 26 callersFunctionInitCheckCompleteInequality
(t *testing.T, origin any)
global/config_test.go:205
↓ 26 callersMethodSetAttribute
(key string, value any)
common/url.go:583
↓ 26 callersMethodWriteHeader
(code int)
protocol/triple/triple_protocol/triple_ext_test.go:2159
↓ 26 callersMethodadd
(rule string)
cluster/router/condition/router_test.go:1050
↓ 25 callersMethodDestroy
Destroy method will destroy all invokers and exporters, so it only is called once.
protocol/base/base_protocol.go:35
↓ 25 callersMethodGetParamBool
GetParamBool judge whether @key exists or not
common/url.go:689
↓ 25 callersMethodReply
Reply gets response of request
protocol/base/invocation.go:42
↓ 25 callersMethodWarn
(args ...any)
logger/base.go:37
↓ 25 callersFunctionWithLocation
WithLocation sets location for URL
common/url.go:201
↓ 24 callersMethodDo
(*http.Request)
protocol/triple/triple_protocol/triple.go:278
↓ 24 callersMethodGeneralize
Generalize generalizes the object to a general struct. For example: map, the type of the `obj` allows a basic type, e.g. string, and a complicated typ
filter/generic/generalizer/generalizer.go:30
↓ 24 callersMethodKey
Key generates the key for service.Key(). It is cached once.
registry/event.go:70
↓ 24 callersFunctionPublish
Publish publishes an event to all subscribers of the same type.
metrics/bus.go:35
↓ 24 callersFunctionSetFilter
SetFilter sets the filter extension with @name For example: metrics/token/tracing/limit/...
common/extension/filter.go:35
↓ 24 callersMethodURLEqual
URLEqual judge @URL and @c is equal or not.
common/url.go:349
↓ 24 callersMethodUnRegister
UnRegister is required to support the contract: 1. If it is the persistent stored data of dynamic=false, the registration data can not be found, then
registry/registry.go:41
↓ 24 callersFunctiongetArgType
Definitions from dubbogo/grpc-go
protocol/triple/triple_protocol/codec.go:469
↓ 23 callersMethodClone
Clone a new TLSConfig
global/tls_config.go:38
↓ 23 callersMethodExporterMap
ExporterMap gets exporter map.
protocol/base/base_protocol.go:64
↓ 23 callersMethodGetAttachment
(key string)
protocol/base/invocation.go:52
↓ 23 callersMethodGetServiceName
GetServiceName will return the serviceName
registry/service_instance.go:44
↓ 23 callersFunctionNewEncoder
()
protocol/triple/openapi/encoder.go:35
↓ 23 callersFunctionNewServer
(opts ...ServerOption)
server/server.go:429
↓ 23 callersMethodSetError
SetError sets error.
protocol/result/result.go:63
↓ 23 callersMethodString
()
filter/generic/generalizer/example.pb.go:132
↓ 23 callersFunctionWithPort
WithPort sets port for URL
common/url.go:180
↓ 23 callersFunctiongetHeaderCanonical
getCanonicalHeader is a shortcut for Header.Get() which bypasses the CanonicalMIMEHeaderKey operation when we know the key is already in canonical for
protocol/triple/triple_protocol/header.go:60
↓ 22 callersMethodBytes
Bytes returns a copy of the Protobuf-serialized detail.
protocol/triple/triple_protocol/error.go:81
↓ 22 callersFunctionNewDefaultService
(cfg *global.OpenAPIConfig)
protocol/triple/openapi/service.go:76
↓ 22 callersFunctionNewMetricIdByLabels
NewMetricIdByLabels create a MetricId by key and labels
metrics/api.go:137
↓ 22 callersFunctionNewTagPriorityRouter
()
cluster/router/tag/router.go:45
↓ 22 callersMethodParse
(string)
config_center/parser/configuration_parser.go:47
↓ 22 callersMethodSetParams
SetParams copies all key-value pairs into URL. 1. if there already has same key, the value will be override 2. this method acquires a write lock and d
common/url.go:770
↓ 22 callersMethodStop
()
remoting/exchange_server.go:33
↓ 21 callersMethodCloseResponse
()
protocol/triple/triple_protocol/triple.go:133
↓ 21 callersMethodEncode
(p DubboPackage)
protocol/dubbo/impl/codec.go:131
↓ 21 callersMethodGetParams
GetParams gets values
common/url.go:657
↓ 21 callersFunctionNewDefinitionResolver
(cfg *global.OpenAPIConfig)
protocol/triple/openapi/definition_resolver.go:35
↓ 21 callersFunctionNewOptions
(opts ...Option)
metrics/options.go:37
↓ 21 callersFunctionNewOptions
(opts ...Option)
otel/trace/options.go:32
↓ 21 callersMethodPut
(buffer *bytes.Buffer)
protocol/triple/triple_protocol/buffer_pool.go:48
↓ 21 callersMethodResponseTrailer
()
protocol/triple/triple_protocol/triple.go:132
↓ 21 callersFunctionWithArguments
WithArguments creates option with @arguments function.
protocol/invocation/rpcinvocation.go:325
↓ 21 callersFunctionWithIp
WithIp sets ip for URL
common/url.go:173
↓ 21 callersFunctionprocessNewClientCases
(t *testing.T, cases []newClientCase)
client/options_test.go:42
↓ 20 callersMethodCloseRequest
()
protocol/triple/triple_protocol/triple.go:126
↓ 20 callersMethodCode
Code returns the error's status code.
protocol/triple/triple_protocol/error.go:182
↓ 20 callersFunctionGetBeanGeneralizer
()
filter/generic/generalizer/bean.go:69
↓ 20 callersMethodHeader
Header returns the HTTP headers for this request. Headers beginning with "Triple-" and "Grpc-" are reserved for use by the Triple and gRPC protocols:
protocol/triple/triple_protocol/triple.go:175
↓ 20 callersFunctionNewDirectory
NewDirectory Create a new staticDirectory with invokers
cluster/directory/static/directory.go:39
↓ 20 callersFunctionNewOpenAPI
()
protocol/triple/openapi/model/openapi.go:170
↓ 20 callersMethodPrefix
()
common/extension/config.go:25
↓ 20 callersMethodRegisterService
(interfaceName string, info *common.ServiceInfo, openapiGroup string, dubboGroup string, dubboVersion string)
protocol/triple/openapi/service.go:90
↓ 20 callersMethodVersion
()
metadata/metadata_service.go:58
↓ 20 callersFunctionnewClientManager
newClientManager extracts configurations from url and builds clientManager
protocol/triple/client.go:110
↓ 19 callersMethodCumSum
CumSum determines the cumulative sum of all the numbers sent on the stream.
protocol/triple/triple_protocol/internal/gen/proto/connect/ping/v1/pingv1connect/ping.connect.go:74
↓ 19 callersFunctionErrorIs
ErrorIs asserts that "want" is in "got's" error chain. See the standard library's errors package for details on error chains. On failure, output is id
protocol/triple/triple_protocol/internal/assert/assert.go:122
↓ 19 callersFunctionGetEnvInstance
GetEnvInstance gets env instance by singleton
common/config/environment.go:50
↓ 19 callersFunctionGetLocalIp
()
common/host_util.go:43
↓ 19 callersMethodGetParamDuration
GetParamDuration get duration if param is invalid or missing default value will return 3s
common/url.go:1045
↓ 19 callersFunctionGetReference
GetReference return the reference id of the service. If the service implemented the ReferencedRPCService interface, it will call the Reference method.
common/rpc_service.go:58
↓ 19 callersMethodInit
()
metadata/options.go:63
↓ 19 callersMethodProcess
Process the notification event once there's any change happens on the config
config_center/configuration_listener.go:31
↓ 19 callersMethodRefer
Refer method is to refer a remote service
protocol/base/base_protocol.go:33
↓ 18 callersMethodAddListener
(string, ConfigurationListener, ...Option)
config_center/dynamic_configuration.go:38
↓ 18 callersFunctionDefaultShutdownConfig
()
global/shutdown_config.go:78
↓ 18 callersMethodGauge
add or update a counter
metrics/api.go:80
← previousnext →101–200 of 7,883, ranked by callers