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
↓ 9 callers
Function
WithAttachment
WithAttachment put a key-value pair into attachments.
protocol/invocation/rpcinvocation.go:353
↓ 9 callers
Function
WithParameterValues
WithParameterValues creates option with @parameterValues
protocol/invocation/rpcinvocation.go:311
↓ 9 callers
Function
WithPassword
WithPassword sets password for URL
common/url.go:138
↓ 9 callers
Function
WithUsername
WithUsername sets username for URL
common/url.go:131
↓ 9 callers
Function
canonicalizeContentType
(contentType string)
protocol/triple/triple_protocol/protocol.go:331
↓ 9 callers
Method
check
()
server/action.go:55
↓ 9 callers
Function
filterInvokers
filterInvokers remove invokers that match with predicate from the original input.
cluster/router/tag/match.go:155
↓ 9 callers
Function
getRouteCheckArgs
()
cluster/router/script/router_test.go:62
↓ 9 callers
Method
getUrlMap
()
server/action.go:336
↓ 9 callers
Function
gzipCompressedSize
(tb testing.TB, message proto.Message)
protocol/triple/triple_protocol/triple_ext_test.go:2161
↓ 9 callers
Method
init
todo(DMwangnima): think about the timing to initialize Registry, Protocol, Tracing
server/options.go:76
↓ 9 callers
Method
isRequest
(data []byte)
protocol/dubbo/dubbo_codec.go:191
↓ 9 callers
Function
marshalResponse
(encoder *hessian.Encoder, p DubboPackage)
protocol/dubbo/impl/hessian.go:63
↓ 9 callers
Method
operationToMap
(op *model.Operation)
protocol/triple/openapi/encoder.go:138
↓ 9 callers
Function
parseDuration
(timeout string, desc string, def time.Duration)
graceful_shutdown/common.go:38
↓ 9 callers
Method
registerServiceOptions
(serviceOptions *ServiceOptions)
server/server.go:453
↓ 8 callers
Method
Add
Add adds a listener to the set
metadata/report/zookeeper/listener.go:51
↓ 8 callers
Method
Addr
Addr implements net.Listener.
protocol/triple/triple_protocol/example_init_test.go:123
↓ 8 callers
Method
Attributes
Attributes firstly introduced on dubbo-java 2.7.6. It is used in internal invocation, that is, it's not passed between server and client.
protocol/base/invocation.go:61
↓ 8 callers
Method
CloneExceptParams
(excludeParams *gxset.HashSet)
common/url.go:958
↓ 8 callers
Function
CodeOf
CodeOf returns the error's status code if it is or wraps an [*Error] and [CodeUnknown] otherwise.
protocol/triple/triple_protocol/code.go:224
↓ 8 callers
Function
DefaultMetricsConfig
()
global/metric_config.go:68
↓ 8 callers
Function
DefaultOtelConfig
()
global/otel_config.go:35
↓ 8 callers
Method
EXPECT
EXPECT returns an object that allows the caller to indicate expected use
registry/nacos/registry_test.go:63
↓ 8 callers
Method
EXPECT
EXPECT returns an object that allows the caller to indicate expected use
filter/otel/trace/filter_test.go:71
↓ 8 callers
Function
GetAllCustomShutdownCallbacks
GetAllCustomShutdownCallbacks returns all custom shutdown callbacks
common/extension/graceful_shutdown.go:71
↓ 8 callers
Method
GetId
()
filter/generic/generalizer/example.pb.go:155
↓ 8 callers
Method
GetOpenAPI
(req *OpenAPIRequest)
protocol/triple/openapi/service.go:105
↓ 8 callers
Method
GetOptions
TODO: check if ProtocolClientConfig need get options
global/reference_config.go:74
↓ 8 callers
Method
GetProxyImpl
GetProxyImpl gets proxy.
protocol/grpc/internal/routeguide/routeguide.pb.go:755
↓ 8 callers
Method
GetServiceByServiceKey
GetServiceByServiceKey gets a service definition by protocol and service key
common/rpc_service.go:184
↓ 8 callers
Method
GetStepTimeout
()
config/graceful_shutdown_config.go:105
↓ 8 callers
Method
InvokeWithType
InvokeWithType invokes the remote method and deserializes the result into the reply struct. The reply parameter must be a non-nil pointer to the targe
filter/generic/service.go:65
↓ 8 callers
Method
IsHeartBeat
()
protocol/dubbo/impl/package.go:96
↓ 8 callers
Method
Less
Less reports whether the URL at index i should sort before the URL at index j.
common/url.go:1021
↓ 8 callers
Function
LookupGracefulShutdownCallback
LookupGracefulShutdownCallback returns a protocol graceful shutdown callback by name.
common/extension/graceful_shutdown.go:96
↓ 8 callers
Method
MergeURL
configuration > reference config >service config in this function we should merge the reference local URL config into the service URL from registry.
common/url.go:841
↓ 8 callers
Function
NewPromMetricRegistry
(reg *prom.Registry, url *common.URL)
metrics/prometheus/registry.go:58
↓ 8 callers
Function
NewRequest
NewRequest aims to create Request. The ID is auto increase.
remoting/exchange.go:65
↓ 8 callers
Method
Notify
Notify supports notifications on the service interface and the dimension of the data type. When a list of events are passed in, it's considered as a c
registry/registry.go:76
↓ 8 callers
Method
OnResponse
OnResponse deserializes the map result to the target struct if reply is provided. If inv.Reply() is a non-nil pointer to a struct, the map result will
filter/generic/filter.go:159
↓ 8 callers
Method
ParameterRawValues
ParameterRawValues gets raw invocation parameter values.
protocol/base/invocation.go:38
↓ 8 callers
Method
ReadHeader
ReadHeader uses hessian codec to read dubbo header
protocol/dubbo/hessian2/hessian_dubbo.go:121
↓ 8 callers
Method
Role
Role returns role by @RoleType
common/url.go:76
↓ 8 callers
Method
Set
Set sets the value associated with the given key in the cache.
registry/servicediscovery/store/cache_manager.go:84
↓ 8 callers
Method
SetBody
(body any)
protocol/dubbo/impl/package.go:125
↓ 8 callers
Function
SetDefaultConfigurator
SetDefaultConfigurator sets the default Configurator
common/extension/configurator.go:45
↓ 8 callers
Method
SetDynamicConfiguration
SetDynamicConfiguration sets value for dynamicConfiguration
common/config/environment.go:99
↓ 8 callers
Function
SetInvokerUnhealthyStatus
SetInvokerUnhealthyStatus add target invoker to black list
protocol/base/rpc_status.go:212
↓ 8 callers
Method
SetInvokers
Refresh invokers
cluster/router/chain.go:28
↓ 8 callers
Function
SetRegistry
SetRegistry sets the registry extension with @name
common/extension/registry.go:28
↓ 8 callers
Method
String
()
config_center/configuration_listener.go:41
↓ 8 callers
Method
ToMap
ToMap transfer URL to Map
common/url.go:788
↓ 8 callers
Method
Unsubscribe
Unsubscribe mocks base method
registry/nacos/registry_test.go:183
↓ 8 callers
Function
WithAddress
(address string)
registry/options.go:122
↓ 8 callers
Function
WithCodec
WithCodec registers a serialization method with a client or handler. Handlers may have multiple codecs registered, and use whichever the client choose
protocol/triple/triple_protocol/option.go:223
↓ 8 callers
Function
WithToken
WithToken sets token for URL
common/url.go:208
↓ 8 callers
Function
WithZookeeper
()
registry/options.go:78
↓ 8 callers
Method
applyToClient
(*clientConfig)
protocol/triple/triple_protocol/option.go:30
↓ 8 callers
Method
applyToHandler
(*handlerConfig)
protocol/triple/triple_protocol/option.go:120
↓ 8 callers
Function
clientNameID
clientNameID unique identifier id for client
config/config_utils.go:116
↓ 8 callers
Function
doTestRequest
(t *testing.T, packageType PackageType, responseStatus byte, body any)
protocol/dubbo/hessian2/hessian_dubbo_test.go:180
↓ 8 callers
Function
file_reflection_proto_rawDescGZIP
()
protocol/triple/reflection/triple_reflection/reflection.pb.go:787
↓ 8 callers
Function
grpcParseTimeout
(timeout string)
protocol/triple/triple_protocol/protocol_grpc.go:818
↓ 8 callers
Function
isExportedOrBuiltinType
Is this type exported or a builtin?
common/rpc_service.go:318
↓ 8 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/impl/hessian.go:168
↓ 8 callers
Function
mustNewURL
(t *testing.T, rawURL string)
cluster/router/polaris/router_test.go:43
↓ 8 callers
Function
newMockMappingListener
()
metadata/report/zookeeper/listener_test.go:48
↓ 8 callers
Method
saveServiceInfo
(interfaceName string, info *common.ServiceInfo, openapiGroup string, dubboGroup string, dubboVersion string)
protocol/triple/server.go:481
↓ 8 callers
Method
schemaToMap
(s *model.Schema)
protocol/triple/openapi/encoder.go:200
↓ 8 callers
Method
toSchemaName
(t reflect.Type)
protocol/triple/openapi/schema_resolver.go:45
↓ 7 callers
Function
AddPendingResponse
AddPendingResponse stores the response into map
remoting/exchange.go:171
↓ 7 callers
Method
Attachment
Attachment gets attachment by key with default value.
protocol/result/result.go:114
↓ 7 callers
Function
Benchloadbalance
(b *testing.B, lb loadbalance.LoadBalance)
cluster/loadbalance/loadbalance_benchmarks_test.go:50
↓ 7 callers
Method
Clone
()
global/metric_config.go:132
↓ 7 callers
Method
CommaSeparatedNames
Wordy, but clarifies how this is different from readOnlyCodecs.Names().
protocol/triple/triple_protocol/compression.go:171
↓ 7 callers
Function
CurrentTimeMillis
CurrentTimeMillis get current timestamp
protocol/base/rpc_status.go:182
↓ 7 callers
Function
DefaultClientProtocolConfig
DefaultClientProtocolConfig returns a default ClientProtocolConfig instance.
global/client_protocol_config.go:33
↓ 7 callers
Method
Destroy
()
common/node.go:24
↓ 7 callers
Method
Error
Error gets error.
protocol/result/result.go:68
↓ 7 callers
Method
GenerateExample
(schema *model.Schema)
protocol/triple/openapi/schema_resolver.go:252
↓ 7 callers
Method
Get
Get gets rpc service instance.
proxy/proxy.go:103
↓ 7 callers
Method
GetActive
GetActive gets active.
protocol/base/rpc_status.go:64
↓ 7 callers
Method
GetBody
()
protocol/dubbo/impl/package.go:121
↓ 7 callers
Method
GetExportedServiceURLs
GetExportedServiceURLs will return exported service urls
metadata/metadata_service.go:55
↓ 7 callers
Function
GetInvokerHealthyStatus
GetInvokerHealthyStatus get invoker's conn healthy status
protocol/base/rpc_status.go:206
↓ 7 callers
Function
GetMapGeneralizer
()
filter/generic/generalizer/map.go:49
↓ 7 callers
Method
GetMatchKey
()
metadata/info/metadata_info.go:246
↓ 7 callers
Method
GetMethodParam
GetMethodParam gets method param
common/url.go:752
↓ 7 callers
Method
GetName
()
protocol/grpc/internal/routeguide/routeguide.pb.go:193
↓ 7 callers
Method
GetNonDefaultParam
GetNonDefaultParam gets value by key, return nil,false if no value found mapping to the key
common/url.go:644
↓ 7 callers
Method
GetRule
GetRule get Router rule properties file
config_center/dynamic_configuration.go:44
↓ 7 callers
Method
GetSchemas
()
protocol/triple/openapi/schema_resolver.go:211
↓ 7 callers
Method
GetServiceNames
GetServiceNames return all listener service names
registry/service_instances_changed_listener.go:38
↓ 7 callers
Method
GetTracerProvider
()
otel/trace/exporter.go:51
↓ 7 callers
Method
Handle
(req *http.Request)
protocol/triple/openapi/handler.go:42
↓ 7 callers
Method
IsAvailable
IsAvailable gets available flag
protocol/base/base_invoker.go:93
↓ 7 callers
Method
IsGenericInvocation
IsGenericInvocation gets if this is a generic invocation
protocol/base/invocation.go:48
↓ 7 callers
Method
IsHeartbeat
()
remoting/exchange.go:91
↓ 7 callers
Method
Match
Match indicates whether a pattern is matched with the request context
cluster/router/condition/matcher/pattern_value/pattern.go:29
← previous
next →
401–500 of 7,883, ranked by callers