MCPcopy Create free account

hub / github.com/smallnest/rpcx / functions

Functions869 in github.com/smallnest/rpcx

⨍ Functions 869◇ Types & classes 179
↓ 2 callersMethodbrowse
()
client/mdns_discovery.go:138
↓ 2 callersMethodcall
(ctx context.Context, mtype *methodType, argv, replyv reflect.Value)
server/service.go:371
↓ 2 callersMethodcallForFunction
(ctx context.Context, ft *functionType, argv, replyv reflect.Value)
server/service.go:400
↓ 2 callersMethodcloseConn
(conn net.Conn)
server/server.go:648
↓ 2 callersMethodcloseDoneChanLocked
()
server/server.go:1065
↓ 2 callersFunctionconvertRes2Raw
(res *protocol.Message)
client/client.go:488
↓ 2 callersFunctioncreateGeoServer
(servers map[string]string)
client/selector.go:247
↓ 2 callersFunctioncreateICMPWeighted
(servers map[string]string)
client/ping_utils.go:40
↓ 2 callersFunctionencodeMetadata
len,string,len,string,......
protocol/message.go:362
↓ 2 callersMethodfail
()
client/circuit_breaker.go:82
↓ 2 callersMethodfindPool
(size int)
util/buffer_pool.go:50
↓ 2 callersMethodfindPutPool
(size int)
util/buffer_pool.go:64
↓ 2 callersFunctiongenKey
(options ...interface{})
client/hash_utils.go:39
↓ 2 callersMethodgenerateClient
(k, servicePath, serviceMethod string)
client/xclient.go:416
↓ 2 callersMethodhandleJSONRPCRequest
(ctx context.Context, r *jsonrpcRequest, header http.Header)
server/jsonrpc2.go:54
↓ 2 callersMethodhandleServerRequest
(msg *protocol.Message)
client/client.go:806
↓ 2 callersFunctionhsin
(theta float64)
client/geo_utils.go:23
↓ 2 callersMethodinitMDNS
()
serverplugin/mdns.go:118
↓ 2 callersFunctionisExportedOrBuiltinType
(t reflect.Type)
reflection/server_reflection.go:219
↓ 2 callersMethodlookup
()
client/dns_discovery.go:83
↓ 2 callersFunctionmatchHTTP1Field
(r io.Reader, name string, matches func(string) bool)
server/gateway.go:105
↓ 2 callersFunctionnewDirectConn
(c *Client, network, address string)
client/connection.go:87
↓ 2 callersFunctionnewLevelPool
(size int)
util/buffer_pool.go:13
↓ 2 callersFunctionnewRandomSelector
(servers map[string]string)
client/selector.go:50
↓ 2 callersFunctionnewSelector
(selectMode SelectMode, servers map[string]string)
client/selector.go:26
↓ 2 callersMethodprocessOneRequest
(ctx *share.Context, req *protocol.Message, conn net.Conn)
server/server.go:525
↓ 2 callersMethodready
()
client/circuit_breaker.go:67
↓ 2 callersMethodregister
(rcvr interface{}, name string, useName bool)
server/service.go:148
↓ 2 callersMethodregisterFunction
(servicePath string, fn interface{}, name string, useName bool)
server/service.go:191
↓ 2 callersMethodreset
()
client/circuit_breaker.go:99
↓ 2 callersMethodserveByHTTP
serveByHTTP serves by HTTP. if rpcPath is an empty string, use share.DefaultRPCPath.
server/server.go:332
↓ 2 callersMethodserveListener
serveListener accepts incoming connections on the Listener ln, creating a new service goroutine for each. The service goroutines read requests and the
server/server.go:264
↓ 2 callersMethodsetCachedClient
(client RPCClient, k, servicePath, serviceMethod string)
client/xclient.go:364
↓ 2 callersFunctionskipArithService
(dAtA []byte)
_testutils/arith_service.go:347
↓ 2 callersMethodstartGateway
(network string, ln net.Listener)
server/gateway.go:23
↓ 2 callersMethodstoreCached
(kvPairs []*KVPair)
client/discovery.go:123
↓ 2 callersMethodsuccess
()
client/circuit_breaker.go:78
↓ 2 callersFunctionsuitableMethods
suitableMethods returns suitable Rpc methods of typ, it will report error using log if reportErr is true.
server/service.go:271
↓ 2 callersFunctionvalidIP6
(ipAddress string)
server/server.go:1086
↓ 2 callersMethodwatch
watch changes of service and update cached clients.
client/xclient.go:211
↓ 2 callersFunctionwriteResponse
(w http.ResponseWriter, res *jsonrpcRespone)
server/jsonrpc2.go:140
↓ 1 callersMethodBind
Bind parses the body data and stores the result to v.
server/context.go:67
↓ 1 callersMethodBroadcast
(ctx context.Context, serviceMethod string, args interface{}, reply interface{})
client/xclient.go:59
↓ 1 callersFunctionCalculateWeight
CalculateWeight converts the rtt to weighted by: 1. weight=191 if t <= 10 2. weight=201 -t if 10 < t <=200 3. weight=1 if 200 < t < 1000 4. weight = 0
client/ping_utils.go:88
↓ 1 callersMethodCheckMagicNumber
CheckMagicNumber checks whether header starts rpcx magic number.
protocol/message.go:122
↓ 1 callersMethodClientAfterDecode
(*protocol.Message)
client/plugin.go:203
↓ 1 callersMethodClientBeforeEncode
(*protocol.Message)
client/plugin.go:198
↓ 1 callersMethodClientConnected
(net.Conn)
client/plugin.go:188
↓ 1 callersMethodClientConnectionClose
(net.Conn)
client/plugin.go:193
↓ 1 callersMethodConnCreateFailed
(network, address string)
client/plugin.go:183
↓ 1 callersMethodConnCreated
(net.Conn)
client/plugin.go:179
↓ 1 callersMethodConnect
(network, address string)
client/client.go:103
↓ 1 callersMethodDebug
(v ...interface{})
log/logger.go:15
↓ 1 callersMethodDebugf
(format string, v ...interface{})
log/logger.go:16
↓ 1 callersMethodDecode
Decode decodes an object from slice of bytes.
codec/codec.go:55
↓ 1 callersMethodDecode
Decode decodes an object from slice of bytes.
codec/codec.go:78
↓ 1 callersMethodDecode
Decode decodes an object from slice of bytes.
codec/codec.go:106
↓ 1 callersMethodDecode
(data []byte, i interface{})
codec/codec.go:134
↓ 1 callersMethodDeleteCachedClient
(client RPCClient, k, servicePath, serviceMethod string)
client/cache_client_builder.go:9
↓ 1 callersMethodDoClientAfterDecode
(*protocol.Message)
client/plugin.go:227
↓ 1 callersMethodDoClientBeforeEncode
(*protocol.Message)
client/plugin.go:226
↓ 1 callersMethodDoConnCreateFailed
(network, address string)
client/plugin.go:219
↓ 1 callersMethodDoConnCreated
(net.Conn)
client/plugin.go:218
↓ 1 callersMethodDoHeartbeatRequest
(ctx context.Context, req *protocol.Message)
server/plugin.go:42
↓ 1 callersMethodDoPostConnAccept
(net.Conn)
server/plugin.go:25
↓ 1 callersMethodDoPostHTTPRequest
(ctx context.Context, r *http.Request, params httprouter.Params)
server/plugin.go:30
↓ 1 callersMethodDoPostWriteRequest
(ctx context.Context, r *protocol.Message, e error)
server/plugin.go:40
↓ 1 callersMethodDoPreHandleRequest
(ctx context.Context, req *protocol.Message)
server/plugin.go:32
↓ 1 callersMethodDoPreWriteRequest
(ctx context.Context)
server/plugin.go:39
↓ 1 callersMethodDoUnregister
(name string)
server/plugin.go:23
↓ 1 callersMethodDoWrapSelect
(SelectFunc)
client/plugin.go:229
↓ 1 callersMethodDownloadFile
(ctx context.Context, requestFileName string, saveTo io.Writer, meta map[string]string)
client/xclient.go:64
↓ 1 callersMethodError
Error returns the error message.
server/service.go:27
↓ 1 callersFunctionExternalIPV4
ExternalIPV4 gets external IPv4 address of this server.
util/net.go:83
↓ 1 callersFunctionExternalIPV6
ExternalIPV6 gets external IPv6 address of this server.
util/net.go:121
↓ 1 callersMethodFail
()
client/client.go:78
↓ 1 callersMethodFindCachedClient
(k, servicePath, serviceMethod string)
client/cache_client_builder.go:8
↓ 1 callersMethodFork
(ctx context.Context, serviceMethod string, args interface{}, reply interface{})
client/xclient.go:60
↓ 1 callersMethodGenerateClient
(k, servicePath, serviceMethod string)
client/cache_client_builder.go:10
↓ 1 callersMethodGet
Get returns a OneClient. It does not remove this OneClient from its cache so you don't need to put it back. Don't close this OneClient because maybe o
client/oneclient_pool.go:89
↓ 1 callersFunctionGetLogger
()
log/logger.go:38
↓ 1 callersMethodGo
Go invokes the function asynchronously. It returns the Call structure representing the invocation. The done channel will signal when the call is compl
client/client.go:262
↓ 1 callersMethodHandleConnAccept
(net.Conn)
server/plugin.go:66
↓ 1 callersMethodHandleConnClose
(net.Conn)
server/plugin.go:71
↓ 1 callersFunctionHash
Hash consistently chooses a hash bucket number in the range [0, numBuckets) for the given key. numBuckets must be >= 1.
client/hash_utils.go:9
↓ 1 callersFunctionHashString
HashString get a hash value of a string
client/hash_utils.go:26
↓ 1 callersMethodHeartbeatRequest
(ctx context.Context, req *protocol.Message)
server/plugin.go:124
↓ 1 callersMethodInfof
(format string, v ...interface{})
log/logger.go:19
↓ 1 callersMethodIsClosing
IsClosing client is closing or not.
client/client.go:245
↓ 1 callersMethodIsShutdown
IsShutdown client is shutdown or not.
client/client.go:252
↓ 1 callersFunctionMagicNumber
()
protocol/message.go:32
↓ 1 callersMethodMarshalTo
(dAtA []byte)
_testutils/arith_service.go:88
↓ 1 callersMethodMarshalTo
(dAtA []byte)
_testutils/arith_service.go:116
↓ 1 callersMethodMessageType
MessageType returns the message type.
protocol/message.go:137
↓ 1 callersFunctionNew
()
reflection/server_reflection.go:63
↓ 1 callersFunctionNewBidirectionalOneClient
NewBidirectionalOneClient creates a new xclient that can receive notifications from servers.
client/oneclient.go:49
↓ 1 callersFunctionNewDNSDiscovery
NewDNSDiscovery returns a new DNSDiscovery.
client/dns_discovery.go:33
↓ 1 callersFunctionNewDefaultLogger
(out io.Writer, prefix string, flag int, lv Level)
log/default_logger.go:42
↓ 1 callersFunctionNewMDNSDiscovery
NewMDNSDiscovery returns a new MDNSDiscovery. If domain is empty, use "local." in default.
client/mdns_discovery.go:40
↓ 1 callersFunctionNewOneClient
NewOneClient creates a OneClient that supports service discovery and service governance.
client/oneclient.go:37
← previousnext →201–300 of 869, ranked by callers