MCPcopy Create free account

hub / github.com/smallnest/rpcx / functions

Functions869 in github.com/smallnest/rpcx

⨍ Functions 869◇ Types & classes 179
↓ 4 callersMethodAuth
(auth string)
client/xclient.go:54
↓ 4 callersMethodCall
(ctx context.Context, serviceMethod string, args interface{}, reply interface{})
client/xclient.go:57
↓ 4 callersMethodClose
Close calls the underlying connection's Close method. If the connection is already shutting down, ErrShutdown is returned.
client/client.go:868
↓ 4 callersMethodDoClientConnected
(net.Conn)
client/plugin.go:220
↓ 4 callersMethodDoPostCall
(ctx context.Context, serviceName, methodName string, args, reply interface{}, err error)
server/plugin.go:34
↓ 4 callersMethodDoPreCall
(ctx context.Context, serviceName, methodName string, args interface{})
server/plugin.go:33
↓ 4 callersMethodGetConn
()
client/client.go:116
↓ 4 callersMethodGetPlugins
()
client/xclient.go:51
↓ 4 callersMethodIsHeartbeat
IsHeartbeat returns whether the message is heartbeat message.
protocol/message.go:147
↓ 4 callersFunctionNewMultiError
NewMultiError creates and returns an Error with error splice
errors/error.go:33
↓ 4 callersMethodParse
(fname string, isDir bool)
tool/xgen/parser/parser.go:80
↓ 4 callersMethodRead
(p []byte)
serverplugin/tee.go:34
↓ 4 callersMethodSelect
(ctx context.Context, servicePath, serviceMethod string, args interface{})
client/selector.go:22
↓ 4 callersMethodSetPlugins
(plugins PluginContainer)
client/xclient.go:50
↓ 4 callersMethodUpdateServer
SelectFunc
client/selector.go:23
↓ 4 callersFunctiongetCacheClientBuilder
(network string)
client/cache_client_builder.go:25
↓ 4 callersMethodhandleRequest
(ctx context.Context, req *protocol.Message)
server/server.go:685
↓ 4 callersMethodisShutdown
()
server/server.go:644
↓ 4 callersFunctionsovArithService
(x uint64)
_testutils/arith_service.go:177
↓ 4 callersFunctionsplitNetworkAndAddress
(server string)
client/xclient.go:479
↓ 3 callersMethodCall
Call invokes the named function, waits for it to complete, and returns its error status. It handles errors base on FailMode.
client/xclient.go:541
↓ 3 callersMethodCall
(func() error, time.Duration)
client/client.go:77
↓ 3 callersMethodClone
Clone clones from an message.
protocol/message.go:216
↓ 3 callersMethodClose
Close this pool. Please make sure it won't be used any more.
client/xclient_pool.go:105
↓ 3 callersMethodClose
Close this pool. Please make sure it won't be used any more.
client/oneclient_pool.go:97
↓ 3 callersMethodConnect
Connect connects the server via specified network.
client/connection.go:32
↓ 3 callersFunctionDebug
(v ...interface{})
log/logger.go:46
↓ 3 callersMethodDoPostConnClose
(net.Conn)
server/plugin.go:26
↓ 3 callersMethodDoPostReadRequest
(ctx context.Context, r *protocol.Message, e error)
server/plugin.go:29
↓ 3 callersMethodDoPreReadRequest
(ctx context.Context)
server/plugin.go:28
↓ 3 callersMethodEncode
Encode encodes an object into slice of bytes.
codec/codec.go:94
↓ 3 callersMethodGetServices
()
client/discovery.go:17
↓ 3 callersMethodGo
(ctx context.Context, serviceMethod string, args interface{}, reply interface{}, done chan *Call)
client/xclient.go:56
↓ 3 callersMethodIsClosing
()
client/client.go:113
↓ 3 callersFunctionNewContext
NewContext creates a server.Context for Handler.
server/context.go:21
↓ 3 callersFunctionNewLimitedPool
(minSize, maxSize int)
util/buffer_pool.go:31
↓ 3 callersFunctionNewOneClientPool
NewOneClientPool creates a fixed size OneClient pool.
client/oneclient_pool.go:27
↓ 3 callersFunctionNewPeer2PeerDiscovery
NewPeer2PeerDiscovery returns a new Peer2PeerDiscovery.
client/peer2peer_discovery.go:11
↓ 3 callersFunctionNewXClientPool
NewXClientPool creates a fixed size XClient pool.
client/xclient_pool.go:31
↓ 3 callersMethodRead
(ctx context.Context, iprot thrift.TProtocol)
codec/testdata/thrift_colorgroup.go:46
↓ 3 callersMethodRemove
(plugin Plugin)
server/plugin.go:18
↓ 3 callersMethodSendRaw
(ctx context.Context, r *protocol.Message)
client/xclient.go:62
↓ 3 callersMethodSetPlugins
SetPlugins sets client's plugins.
client/xclient_pool.go:80
↓ 3 callersMethodSetPlugins
SetPlugins sets client's plugins.
client/oneclient_pool.go:73
↓ 3 callersMethodSetVersion
SetVersion sets version for this header.
protocol/message.go:132
↓ 3 callersMethodUnregisterAll
UnregisterAll unregisters all services. You can call this method when you want to shutdown/upgrade this node.
server/service.go:345
↓ 3 callersFunctionUnzip
Unzip unzips data.
util/compress.go:29
↓ 3 callersMethodVersion
Version returns version of rpcx protocol.
protocol/message.go:127
↓ 3 callersFunctionWarn
(v ...interface{})
log/logger.go:60
↓ 3 callersMethodWatchService
return all services in the registry
client/discovery.go:18
↓ 3 callersMethodauth
(ctx context.Context, req *protocol.Message)
server/server.go:676
↓ 3 callersMethodbuildRing
()
client/selector.go:143
↓ 3 callersMethoddeleteCachedClient
(client RPCClient, k, servicePath, serviceMethod string)
client/xclient.go:383
↓ 3 callersFunctionencodeVarintArithService
(dAtA []byte, offset int, v uint64)
_testutils/arith_service.go:147
↓ 3 callersFunctiongenerateJSON
(typ reflect.Type)
reflection/server_reflection.go:207
↓ 3 callersFunctiongenerateTypeDefination
(name, pkg string, jsonValue string)
reflection/server_reflection.go:182
↓ 3 callersMethodgetCachedClient
(k string, servicePath, serviceMethod string, _ interface{})
client/xclient.go:307
↓ 3 callersMethodgetCachedClientWithoutLock
(k, servicePath, serviceMethod string)
client/xclient.go:442
↓ 3 callersFunctionnewConsistentHashSelector
(servers map[string]string)
client/selector.go:282
↓ 3 callersMethodsendResponse
(ctx *share.Context, conn net.Conn, err error, req, res *protocol.Message)
server/server.go:358
↓ 3 callersMethodserveConn
(conn net.Conn)
server/server.go:394
↓ 3 callersMethodwrapSendRaw
wrapSendRaw wrap SendRaw to support client plugins
client/xclient.go:904
↓ 2 callersMethodCall
Call Circuit function
client/circuit_breaker.go:32
↓ 2 callersMethodClose
()
client/client.go:107
↓ 2 callersMethodConfigGeoSelector
(latitude, longitude float64)
client/xclient.go:53
↓ 2 callersMethodDecode
Decode decodes a message from reader.
protocol/message.go:416
↓ 2 callersMethodDoClientConnectionClose
(net.Conn)
client/plugin.go:221
↓ 2 callersMethodDoRegister
(name string, rcvr interface{}, metadata string)
server/plugin.go:21
↓ 2 callersMethodDoRegisterFunction
(serviceName, fname string, fn interface{}, metadata string)
server/plugin.go:22
↓ 2 callersMethodEncode
Encode encodes an object into slice of bytes.
codec/codec.go:50
↓ 2 callersMethodEncode
(i interface{})
codec/codec.go:119
↓ 2 callersMethodError
Error returns the message of the actual error
errors/error.go:15
↓ 2 callersMethodGet
Get returns value for key.
server/context.go:26
↓ 2 callersFunctionGetFreePort
GetFreePort gets a free port.
util/net.go:14
↓ 2 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/xclient.go:504
↓ 2 callersFunctionHTTPRequest2RpcxRequest
HTTPRequest2RpcxRequest converts a http request to a rpcx request.
server/converter.go:29
↓ 2 callersMethodInfo
(v ...interface{})
log/logger.go:18
↓ 2 callersFunctionIsShareContext
IsShareContext checks whether a context is share.Context.
share/context.go:106
↓ 2 callersMethodMessageStatusType
MessageStatusType returns the message status type.
protocol/message.go:186
↓ 2 callersMethodMuxMatch
(m cmux.CMux)
server/plugin.go:128
↓ 2 callersFunctionNewBidirectionalXClient
NewBidirectionalXClient creates a new xclient that can receive notifications from servers.
client/xclient.go:152
↓ 2 callersFunctionNewConsecCircuitBreaker
NewConsecCircuitBreaker returns a new ConsecCircuitBreaker.
client/circuit_breaker.go:24
↓ 2 callersMethodPanic
(v ...interface{})
log/logger.go:30
↓ 2 callersMethodPanicf
(format string, v ...interface{})
log/logger.go:31
↓ 2 callersMethodPostCall
(ctx context.Context, serviceName, methodName string, args, reply interface{}, err error)
server/plugin.go:99
↓ 2 callersMethodPreCall
(ctx context.Context, serviceName, methodName string, args interface{})
server/plugin.go:95
↓ 2 callersFunctionRead
Read reads a message from r.
protocol/message.go:406
↓ 2 callersMethodRegisterServerMessageChan
(ch chan<- *protocol.Message)
client/client.go:110
↓ 2 callersMethodRemoveWatcher
watch the change of services, it's a golang channel
client/discovery.go:19
↓ 2 callersMethodSetSelector
(s Selector)
client/xclient.go:52
↓ 2 callersMethodSize
()
_testutils/arith_service.go:156
↓ 2 callersFunctionSliceByteToString
(b []byte)
util/converter.go:7
↓ 2 callersMethodSubmit
(task func())
server/server.go:72
↓ 2 callersFunctionWithReadTimeout
WithReadTimeout sets readTimeout.
server/option.go:30
↓ 2 callersFunctionWithWriteTimeout
WithWriteTimeout sets writeTimeout.
server/option.go:37
↓ 2 callersMethodWriteError
(err error)
server/context.go:140
↓ 2 callersMethodZip
([]byte)
protocol/compressor.go:13
↓ 2 callersMethodZip
(data []byte)
protocol/compressor.go:21
↓ 2 callersMethodZip
(data []byte)
protocol/compressor.go:32
↓ 2 callersMethodZip
(data []byte)
protocol/compressor.go:44
← previousnext →101–200 of 869, ranked by callers