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
↓ 36 callers
Method
Service
(ctx context.Context, in *FirstRequest, opts ...grpc.CallOption)
protocol/grpc/internal/multiprotos/first.pb.go:163
↓ 36 callers
Method
Value
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 callers
Method
Key
Key gets key
common/url.go:409
↓ 35 callers
Method
ServiceKey
()
protocol/invocation/rpcinvocation.go:177
↓ 34 callers
Function
NewSchemaResolver
(config *global.OpenAPIConfig)
protocol/triple/openapi/schema_resolver.go:37
↓ 33 callers
Function
NewPingServiceHandler
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 callers
Function
Sprintf
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 callers
Method
NewServer
NewServer is like server.NewServer, but inject configurations from RootConfig.
dubbo.go:132
↓ 32 callers
Method
Route
(*common.URL, base.Invocation)
cluster/router/chain.go:26
↓ 32 callers
Method
Spec
()
protocol/triple/triple_protocol/triple.go:197
↓ 31 callers
Method
GetAttachmentWithDefaultValue
(key string, defaultValue string)
protocol/base/invocation.go:54
↓ 31 callers
Method
Peer
()
protocol/triple/triple_protocol/triple.go:198
↓ 31 callers
Function
mergeHeaders
(into, from http.Header)
protocol/triple/triple_protocol/header.go:51
↓ 30 callers
Method
GetMetadata
GetMetadata will return the metadata
registry/service_instance.go:59
↓ 30 callers
Method
Invoke
Invoke the invocation and return result.
protocol/base/base_invoker.go:58
↓ 30 callers
Function
LoadSerializer
(p *DubboPackage)
protocol/dubbo/impl/serialize.go:29
↓ 30 callers
Function
WithAttribute
WithAttribute sets attribute for URL
common/url.go:222
↓ 30 callers
Function
WithMethods
WithMethods sets methods for URL
common/url.go:145
↓ 29 callers
Method
EXPECT
EXPECT returns an object that allows the caller to indicate expected use
filter/otel/trace/filter_test.go:446
↓ 29 callers
Function
GetProtocol
GetProtocol finds the protocol extension with @name
common/extension/protocol.go:32
↓ 29 callers
Method
Info
(args ...any)
logger/base.go:35
↓ 29 callers
Method
RequestHeader
()
protocol/triple/triple_protocol/triple.go:125
↓ 29 callers
Method
Select
([]base.Invoker, base.Invocation)
cluster/loadbalance/loadbalance.go:25
↓ 29 callers
Function
ServiceKey
(intf string, group string, version string)
common/url.go:438
↓ 29 callers
Method
SetAttachment
(key string, value any)
protocol/base/invocation.go:51
↓ 28 callers
Function
GetJavaName
GetJavaName returns java name of an object
protocol/dubbo/hessian2/java_class.go:40
↓ 28 callers
Method
Name
Name return the Poolable's name.
cluster/router/router.go:79
↓ 27 callers
Method
Export
add a metric num to a rt
metrics/api.go:84
↓ 27 callers
Method
GetInvoker
GetInvoker method is to get invoker.
protocol/base/base_exporter.go:31
↓ 27 callers
Function
SetProtocol
SetProtocol sets the protocol extension with @name
common/extension/protocol.go:27
↓ 26 callers
Function
CheckCompleteInequality
(t *testing.T, origin any, clone any)
global/config_test.go:253
↓ 26 callers
Method
Err
()
protocol/triple/health/triple_health/health.triple.go:119
↓ 26 callers
Method
GetURL
()
remoting/zookeeper/facade.go:41
↓ 26 callers
Function
InitCheckCompleteInequality
(t *testing.T, origin any)
global/config_test.go:205
↓ 26 callers
Method
SetAttribute
(key string, value any)
common/url.go:583
↓ 26 callers
Method
WriteHeader
(code int)
protocol/triple/triple_protocol/triple_ext_test.go:2159
↓ 26 callers
Method
add
(rule string)
cluster/router/condition/router_test.go:1050
↓ 25 callers
Method
Destroy
Destroy method will destroy all invokers and exporters, so it only is called once.
protocol/base/base_protocol.go:35
↓ 25 callers
Method
GetParamBool
GetParamBool judge whether @key exists or not
common/url.go:689
↓ 25 callers
Method
Reply
Reply gets response of request
protocol/base/invocation.go:42
↓ 25 callers
Method
Warn
(args ...any)
logger/base.go:37
↓ 25 callers
Function
WithLocation
WithLocation sets location for URL
common/url.go:201
↓ 24 callers
Method
Do
(*http.Request)
protocol/triple/triple_protocol/triple.go:278
↓ 24 callers
Method
Generalize
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 callers
Method
Key
Key generates the key for service.Key(). It is cached once.
registry/event.go:70
↓ 24 callers
Function
Publish
Publish publishes an event to all subscribers of the same type.
metrics/bus.go:35
↓ 24 callers
Function
SetFilter
SetFilter sets the filter extension with @name For example: metrics/token/tracing/limit/...
common/extension/filter.go:35
↓ 24 callers
Method
URLEqual
URLEqual judge @URL and @c is equal or not.
common/url.go:349
↓ 24 callers
Method
UnRegister
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 callers
Function
getArgType
Definitions from dubbogo/grpc-go
protocol/triple/triple_protocol/codec.go:469
↓ 23 callers
Method
Clone
Clone a new TLSConfig
global/tls_config.go:38
↓ 23 callers
Method
ExporterMap
ExporterMap gets exporter map.
protocol/base/base_protocol.go:64
↓ 23 callers
Method
GetAttachment
(key string)
protocol/base/invocation.go:52
↓ 23 callers
Method
GetServiceName
GetServiceName will return the serviceName
registry/service_instance.go:44
↓ 23 callers
Function
NewEncoder
()
protocol/triple/openapi/encoder.go:35
↓ 23 callers
Function
NewServer
(opts ...ServerOption)
server/server.go:429
↓ 23 callers
Method
SetError
SetError sets error.
protocol/result/result.go:63
↓ 23 callers
Method
String
()
filter/generic/generalizer/example.pb.go:132
↓ 23 callers
Function
WithPort
WithPort sets port for URL
common/url.go:180
↓ 23 callers
Function
getHeaderCanonical
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 callers
Method
Bytes
Bytes returns a copy of the Protobuf-serialized detail.
protocol/triple/triple_protocol/error.go:81
↓ 22 callers
Function
NewDefaultService
(cfg *global.OpenAPIConfig)
protocol/triple/openapi/service.go:76
↓ 22 callers
Function
NewMetricIdByLabels
NewMetricIdByLabels create a MetricId by key and labels
metrics/api.go:137
↓ 22 callers
Function
NewTagPriorityRouter
()
cluster/router/tag/router.go:45
↓ 22 callers
Method
Parse
(string)
config_center/parser/configuration_parser.go:47
↓ 22 callers
Method
SetParams
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 callers
Method
Stop
()
remoting/exchange_server.go:33
↓ 21 callers
Method
CloseResponse
()
protocol/triple/triple_protocol/triple.go:133
↓ 21 callers
Method
Encode
(p DubboPackage)
protocol/dubbo/impl/codec.go:131
↓ 21 callers
Method
GetParams
GetParams gets values
common/url.go:657
↓ 21 callers
Function
NewDefinitionResolver
(cfg *global.OpenAPIConfig)
protocol/triple/openapi/definition_resolver.go:35
↓ 21 callers
Function
NewOptions
(opts ...Option)
metrics/options.go:37
↓ 21 callers
Function
NewOptions
(opts ...Option)
otel/trace/options.go:32
↓ 21 callers
Method
Put
(buffer *bytes.Buffer)
protocol/triple/triple_protocol/buffer_pool.go:48
↓ 21 callers
Method
ResponseTrailer
()
protocol/triple/triple_protocol/triple.go:132
↓ 21 callers
Function
WithArguments
WithArguments creates option with @arguments function.
protocol/invocation/rpcinvocation.go:325
↓ 21 callers
Function
WithIp
WithIp sets ip for URL
common/url.go:173
↓ 21 callers
Function
processNewClientCases
(t *testing.T, cases []newClientCase)
client/options_test.go:42
↓ 20 callers
Method
CloseRequest
()
protocol/triple/triple_protocol/triple.go:126
↓ 20 callers
Method
Code
Code returns the error's status code.
protocol/triple/triple_protocol/error.go:182
↓ 20 callers
Function
GetBeanGeneralizer
()
filter/generic/generalizer/bean.go:69
↓ 20 callers
Method
Header
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 callers
Function
NewDirectory
NewDirectory Create a new staticDirectory with invokers
cluster/directory/static/directory.go:39
↓ 20 callers
Function
NewOpenAPI
()
protocol/triple/openapi/model/openapi.go:170
↓ 20 callers
Method
Prefix
()
common/extension/config.go:25
↓ 20 callers
Method
RegisterService
(interfaceName string, info *common.ServiceInfo, openapiGroup string, dubboGroup string, dubboVersion string)
protocol/triple/openapi/service.go:90
↓ 20 callers
Method
Version
()
metadata/metadata_service.go:58
↓ 20 callers
Function
newClientManager
newClientManager extracts configurations from url and builds clientManager
protocol/triple/client.go:110
↓ 19 callers
Method
CumSum
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 callers
Function
ErrorIs
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 callers
Function
GetEnvInstance
GetEnvInstance gets env instance by singleton
common/config/environment.go:50
↓ 19 callers
Function
GetLocalIp
()
common/host_util.go:43
↓ 19 callers
Method
GetParamDuration
GetParamDuration get duration if param is invalid or missing default value will return 3s
common/url.go:1045
↓ 19 callers
Function
GetReference
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 callers
Method
Init
()
metadata/options.go:63
↓ 19 callers
Method
Process
Process the notification event once there's any change happens on the config
config_center/configuration_listener.go:31
↓ 19 callers
Method
Refer
Refer method is to refer a remote service
protocol/base/base_protocol.go:33
↓ 18 callers
Method
AddListener
(string, ConfigurationListener, ...Option)
config_center/dynamic_configuration.go:38
↓ 18 callers
Function
DefaultShutdownConfig
()
global/shutdown_config.go:78
↓ 18 callers
Method
Gauge
add or update a counter
metrics/api.go:80
← previous
next →
101–200 of 7,883, ranked by callers