MCPcopy Create free account

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

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

↓ 1,432 callersMethodEqual
(target Version)
cluster/utils/version.go:63
↓ 753 callersMethodRun
(rawScript string, invokers []base.Invoker, invocation base.Invocation)
cluster/router/script/instance/instances_pool.go:38
↓ 719 callersMethodErrorf
(template string, args ...any)
logger/base.go:40
↓ 425 callersMethodEqual
(t *ConditionRule)
config/router_config.go:201
↓ 421 callersFunctionNewURL
NewURL will create a new URL the urlString should not be empty
common/url.go:252
↓ 391 callersMethodGetParam
GetParam gets value by key
common/url.go:628
↓ 366 callersMethodError
(args ...any)
logger/base.go:39
↓ 320 callersMethodP
P forwards to g.gen.P.
protocol/grpc/protoc-gen-dubbo/plugin/dubbo/dubbo.go:79
↓ 271 callersMethodGetURL
()
common/node.go:22
↓ 268 callersFunctionWithParamsValue
WithParamsValue sets params field for URL
common/url.go:159
↓ 258 callersMethodSet
(labels map[string]string, v float64)
metrics/api.go:210
↓ 243 callersMethodUnlock
()
common/url.go:89
↓ 239 callersMethodWarnf
(template string, args ...any)
logger/base.go:38
↓ 238 callersMethodLock
Lock is a no-op used by -copylocks checker from `go vet`.
common/url.go:88
↓ 234 callersFunctionEqual
Equal asserts that two values are equal.
protocol/triple/triple_protocol/internal/assert/assert.go:36
↓ 226 callersFunctionNewBaseInvoker
NewBaseInvoker creates a new BaseInvoker
protocol/base/base_invoker.go:74
↓ 223 callersMethodContains
(string)
protocol/triple/triple_protocol/compression.go:169
↓ 221 callersMethodSet
(name string, config any)
config/config_setter.go:21
↓ 216 callersMethodError
()
protocol/result/result.go:43
↓ 215 callersMethodLoad
()
config/consumer_config.go:119
↓ 214 callersFunctionNil
Nil asserts that the value is nil.
protocol/triple/triple_protocol/internal/assert/assert.go:56
↓ 208 callersMethodLen
Len returns the number of URLs in the slice.
common/url.go:1016
↓ 201 callersMethodAdd
(labels map[string]string, v float64)
metrics/api.go:213
↓ 183 callersMethodGet
Get gets the Codec with the given name.
protocol/triple/triple_protocol/codec.go:419
↓ 173 callersMethodEqual
Equal checks if two ConditionRule instances are equal.
global/router_config.go:61
↓ 173 callersFunctionNewURLWithOptions
NewURLWithOptions will create a new URL with options
common/url.go:241
↓ 164 callersMethodInfof
(template string, args ...any)
logger/base.go:36
↓ 162 callersMethodFatalf
(fmt string, args ...any)
logger/base.go:42
↓ 158 callersFunctionNewRPCInvocation
NewRPCInvocation creates a RPC invocation.
protocol/invocation/rpcinvocation.go:58
↓ 116 callersMethodDebugf
(template string, args ...any)
logger/base.go:34
↓ 114 callersMethodJoin
(directory.Directory)
cluster/cluster/cluster.go:27
↓ 108 callersMethodAny
()
protocol/triple/triple_protocol/triple.go:196
↓ 102 callersMethodSetParam
SetParam will put the key-value pair into URL usually it should only be invoked when you want to initialized an URL
common/url.go:558
↓ 98 callersMethodEncode
(openAPI *model.OpenAPI, format string, pretty bool)
protocol/triple/openapi/encoder.go:39
↓ 94 callersFunctionNewMetricKey
(name string, desc string)
metrics/common.go:30
↓ 90 callersFunctionWithParams
WithParams deep copy the params in the argument into params of the target URL
common/url.go:152
↓ 88 callersMethodClient
()
remoting/etcdv3/facade.go:35
↓ 88 callersMethodString
()
common/url.go:395
↓ 83 callersMethodHeader
()
protocol/triple/triple_protocol/triple.go:199
↓ 82 callersMethodNewRequest
NewRequest creates a new HTTP request with @service ,@method and @arguments.
protocol/jsonrpc/http.go:97
↓ 81 callersMethodCall
Call makes a HTTP call with @ctx , @service ,@req and @rsp
protocol/jsonrpc/http.go:110
↓ 81 callersMethodClose
Close flushes any buffered data to the underlying sink, then closes the Compressor. It must not close the underlying sink.
protocol/triple/triple_protocol/compression.go:52
↓ 81 callersMethodMethodName
MethodName gets invocation method name.
protocol/base/invocation.go:28
↓ 81 callersFunctionNewRPCInvocationWithOptions
NewRPCInvocationWithOptions creates a RPC invocation with @opts.
protocol/invocation/rpcinvocation.go:68
↓ 80 callersMethodInterface
Interface get interface
common/url.go:331
↓ 78 callersMethodDone
for wait group control, etcd client listener & etcd client container
remoting/etcdv3/facade.go:39
↓ 77 callersMethodIsAvailable
()
common/node.go:23
↓ 75 callersMethodDo
(request *RestClientRequest, res any)
protocol/rest/client/rest_client.go:43
↓ 75 callersMethodEXPECT
EXPECT returns an object that allows the caller to indicate expected use.
protocol/mock/mock_invoker.go:58
↓ 75 callersMethodInvoke
Invoke is the core function of a cluster interceptor, it determines the process of the interceptor
cluster/cluster/cluster_interceptor.go:31
↓ 72 callersMethodGetAttribute
(key string)
protocol/base/invocation.go:63
↓ 71 callersFunctionNotNil
NotNil asserts that the value isn't nil.
protocol/triple/triple_protocol/internal/assert/assert.go:66
↓ 71 callersMethodRegister
Register is used for service provider calling, register services to registry. And it is also used for service consumer calling, register services care
registry/registry.go:32
↓ 69 callersMethodFatal
(args ...any)
logger/base.go:41
↓ 69 callersMethodInvoke
(context.Context, base.Invoker, base.Invocation)
filter/filter.go:34
↓ 63 callersFunctiondefaultServerOptions
()
server/options.go:64
↓ 63 callersFunctiondefaultServiceOptions
()
server/options.go:508
↓ 61 callersFunctionNewDubboPackage
(data *bytes.Buffer)
protocol/dubbo/impl/package.go:157
↓ 61 callersFunctionNewError
NewError annotates any Go error with a status code.
protocol/triple/triple_protocol/error.go:122
↓ 61 callersMethodServiceKey
ServiceKey gets a unique key of a service.
common/url.go:431
↓ 60 callersMethodHandle
Handle registers the handler in the exact mux and the lowercase-first-method fallback index. If two patterns collide after fallback normalization, the
protocol/triple/triple_protocol/method_route_mux.go:55
↓ 59 callersFunctionWithProtocol
WithProtocol sets protocol for URL
common/url.go:166
↓ 59 callersMethodWrite
(*Request)
tools/dubbogo-cli/internal/protocol/protocol.go:26
↓ 58 callersFunctionTrue
True asserts that "got" is true.
protocol/triple/triple_protocol/internal/assert/assert.go:142
↓ 57 callersMethodAttachments
()
protocol/result/result.go:47
↓ 57 callersMethodSend
Send, RequestHeader, and CloseRequest may race with each other, but must be safe to call concurrently with all other methods.
protocol/triple/triple_protocol/triple.go:124
↓ 57 callersMethodWait
()
tools/dubbogo-cli/generator/sample/hessian/pool.go:53
↓ 56 callersFunctionGetRootConfig
()
config/root_config.go:76
↓ 56 callersMethodType
()
metrics/event.go:22
↓ 56 callersFunctionerrorf
errorf calls fmt.Errorf with the supplied template and arguments, then wraps the resulting error.
protocol/triple/triple_protocol/error.go:224
↓ 55 callersMethodArguments
Arguments gets arguments.
protocol/base/invocation.go:40
↓ 54 callersMethodBuild
()
config/tls_config.go:144
↓ 53 callersFunctionWithPath
WithPath sets path for URL
common/url.go:187
↓ 52 callersMethodAddParam
AddParam will add the key-value pair
common/url.go:537
↓ 51 callersFunctionDefaultOpenAPIConfig
()
global/openapi_config.go:41
↓ 51 callersMethodGetParam
GetParam will return the value of the key. If not found, def will be return; def => default value
config/remote_config.go:67
↓ 50 callersFunctionNewMockInvoker
NewMockInvoker creates a new mock instance.
protocol/mock/mock_invoker.go:51
↓ 50 callersFunctionNewPingServiceClient
NewPingServiceClient constructs a client for the connect.ping.v1.PingService service. By default, it uses the Connect protocol with the binary Protobu
protocol/triple/triple_protocol/internal/gen/proto/connect/ping/v1/pingv1connect/ping.connect.go:84
↓ 48 callersMethodClone
Clone will copy the URL
common/url.go:944
↓ 48 callersMethodString
()
protocol/triple/triple_protocol/code.go:113
↓ 47 callersMethodUnmarshal
([]byte, *DubboPackage)
protocol/dubbo/impl/serialize.go:26
↓ 46 callersMethodClose
Close closes this listener
registry/registry.go:89
↓ 46 callersMethodDecode
(data []byte)
remoting/codec.go:29
↓ 46 callersMethodLen
()
cluster/router/chain/chain.go:217
↓ 46 callersMethodMarshal
(p DubboPackage)
protocol/dubbo/impl/serialize.go:25
↓ 45 callersMethodDelete
Delete removes the value associated with the given key from the cache.
registry/servicediscovery/store/cache_manager.go:89
↓ 45 callersMethodPing
Ping sends a ping to the server to determine if it's reachable.
protocol/triple/triple_protocol/internal/gen/proto/connect/ping/v1/pingv1connect/ping.connect.go:66
↓ 45 callersMethodReceive
Receive, ResponseHeader, ResponseTrailer, and CloseResponse may race with each other, but must be safe to call concurrently with all other methods.
protocol/triple/triple_protocol/triple.go:130
↓ 44 callersMethodSetAttribute
(key string, value any)
protocol/base/invocation.go:62
↓ 43 callersMethodResult
()
protocol/result/result.go:45
↓ 42 callersMethodMarshal
Marshal marshals the given message. Marshal may expect a specific type of message, and will error if this type is not given.
protocol/triple/triple_protocol/codec.go:66
↓ 42 callersFunctionWithMethodName
WithMethodName creates option with @methodName.
protocol/invocation/rpcinvocation.go:285
↓ 41 callersMethodInc
(labels map[string]string)
metrics/api.go:211
↓ 41 callersMethodIsAllowable
(*common.URL, base.Invocation)
filter/tps_limiter.go:53
↓ 41 callersFunctiongetArgType
(v any)
protocol/dubbo/impl/hessian.go:425
↓ 40 callersMethodUnmarshal
Unmarshal unmarshals the given message. Unmarshal may expect a specific type of message, and will error if this type is not given.
protocol/triple/triple_protocol/codec.go:71
↓ 37 callersFunctionNewSchema
()
protocol/triple/openapi/model/schema.go:46
↓ 37 callersFunctionSetSerializer
(name string, serializer Serializer)
protocol/dubbo/impl/serialization.go:40
↓ 37 callersMethodSetType
(t SchemaType)
protocol/triple/openapi/model/schema.go:52
↓ 36 callersMethodName
Name returns the name of the Codec. This may be used as part of the Content-Type within HTTP. For example, with gRPC this is the content subtype, so
protocol/triple/triple_protocol/codec.go:61
next →1–100 of 7,883, ranked by callers