MCPcopy Create free account

hub / github.com/smallnest/rpcx / functions

Functions869 in github.com/smallnest/rpcx

⨍ Functions 869◇ Types & classes 179
↓ 1 callersFunctionPing
Ping gets network traffic by ICMP
client/ping_utils.go:56
↓ 1 callersMethodPostHTTPRequest
(ctx context.Context, r *http.Request, params httprouter.Params)
server/plugin.go:86
↓ 1 callersMethodPostReadRequest
(ctx context.Context, r *protocol.Message, e error)
server/plugin.go:81
↓ 1 callersMethodPostWriteRequest
(ctx context.Context, r *protocol.Message, e error)
server/plugin.go:119
↓ 1 callersMethodPostWriteResponse
(context.Context, *protocol.Message, *protocol.Message, error)
server/plugin.go:109
↓ 1 callersMethodPreHandleRequest
(ctx context.Context, r *protocol.Message)
server/plugin.go:91
↓ 1 callersMethodPreReadRequest
(ctx context.Context)
server/plugin.go:76
↓ 1 callersMethodPreWriteRequest
(ctx context.Context)
server/plugin.go:114
↓ 1 callersMethodPreWriteResponse
(context.Context, *protocol.Message, *protocol.Message, error)
server/plugin.go:104
↓ 1 callersMethodReadField1
(ctx context.Context, iprot thrift.TProtocol)
codec/testdata/thrift_colorgroup.go:104
↓ 1 callersMethodReadField1
(ctx context.Context, iprot thrift.TProtocol)
_testutils/thrift_arith_service.go:88
↓ 1 callersMethodReadField1
(ctx context.Context, iprot thrift.TProtocol)
_testutils/thrift_arith_service.go:227
↓ 1 callersMethodReadField2
(ctx context.Context, iprot thrift.TProtocol)
codec/testdata/thrift_colorgroup.go:113
↓ 1 callersMethodReadField2
(ctx context.Context, iprot thrift.TProtocol)
_testutils/thrift_arith_service.go:97
↓ 1 callersMethodReadField3
(ctx context.Context, iprot thrift.TProtocol)
codec/testdata/thrift_colorgroup.go:122
↓ 1 callersMethodReady
()
client/client.go:80
↓ 1 callersMethodRegister
Register handles registering event. this service is registered at BASE/serviceName/thisIpAddress node
serverplugin/mdns.go:162
↓ 1 callersMethodRegister
Register publishes in the server the set of methods of the receiver value that satisfy the following conditions: - exported method of exported type -
server/service.go:101
↓ 1 callersFunctionRegisterCodec
RegisterCodec register customized codec.
share/share.go:48
↓ 1 callersMethodRegisterFunction
(serviceName, fname string, fn interface{}, metadata string)
server/plugin.go:59
↓ 1 callersMethodRegisterOnShutdown
RegisterOnShutdown registers a function to call on Shutdown. This can be used to gracefully shutdown connections.
server/server.go:929
↓ 1 callersMethodSendFile
(ctx context.Context, fileName string, rateInBytesPerSecond int64, meta map[string]string)
client/xclient.go:63
↓ 1 callersMethodSendMessage
SendMessage a request to the specified client. The client is designated by the conn. conn can be gotten from context in services: ctx.Value(RemoteCo
server/server.go:189
↓ 1 callersMethodSetCachedClient
(client RPCClient, k, servicePath, serviceMethod string)
client/cache_client_builder.go:7
↓ 1 callersMethodSetValue
SetValue sets the kv pair.
server/context.go:31
↓ 1 callersMethodSize
()
_testutils/arith_service.go:168
↓ 1 callersMethodStart
()
server/stream.go:95
↓ 1 callersMethodStart
()
server/file_transfer.go:123
↓ 1 callersMethodStopAndWaitFor
(deadline time.Duration)
server/server.go:73
↓ 1 callersMethodStream
(ctx context.Context, meta map[string]string)
client/xclient.go:65
↓ 1 callersMethodUnmarshal
(dAtA []byte)
_testutils/arith_service.go:278
↓ 1 callersMethodUnregister
(name string)
server/plugin.go:54
↓ 1 callersMethodUnregisterServerMessageChan
()
client/client.go:111
↓ 1 callersMethodUnzip
([]byte)
protocol/compressor.go:14
↓ 1 callersMethodUnzip
(data []byte)
protocol/compressor.go:25
↓ 1 callersMethodUnzip
(data []byte)
protocol/compressor.go:36
↓ 1 callersMethodUnzip
(data []byte)
protocol/compressor.go:64
↓ 1 callersMethodUpdate
Update can start a stream copy by setting a non-nil w. If you set a nil w, it doesn't copy stream.
serverplugin/tee.go:19
↓ 1 callersMethodWarn
(v ...interface{})
log/logger.go:21
↓ 1 callersMethodWarnf
(format string, v ...interface{})
log/logger.go:22
↓ 1 callersFunctionWithTLSConfig
WithOptions sets multiple options. func WithOptions(ops map[string]interface{}) OptionFn { return func(s *Server) { for k, v := range ops { s.op
server/option.go:23
↓ 1 callersMethodWrapSelect
(SelectFunc)
client/plugin.go:208
↓ 1 callersMethodWriteTo
WriteTo writes message to writers.
protocol/message.go:291
↓ 1 callersMethodcall
(ctx context.Context, servicePath, serviceMethod string, args interface{}, reply interface{})
client/client.go:323
↓ 1 callersMethodcheckProcessMsg
()
server/server.go:1059
↓ 1 callersMethodcloseHTTP1APIGateway
(ctx context.Context)
server/gateway.go:151
↓ 1 callersMethodcloseJSONRPC2
(ctx context.Context)
server/jsonrpc2.go:208
↓ 1 callersFunctioncreateWeighted
(servers map[string]string)
client/selector.go:178
↓ 1 callersFunctiondecodeMetadata
(l uint32, data []byte)
protocol/message.go:377
↓ 1 callersFunctionfile_benchmark_proto_init
()
protocol/testdata/benchmark.pb.go:483
↓ 1 callersFunctionfile_benchmark_proto_rawDescGZIP
()
protocol/testdata/benchmark.pb.go:463
↓ 1 callersFunctionfile_protobuf_proto_init
()
codec/testdata/protobuf.pb.go:124
↓ 1 callersFunctionfile_protobuf_proto_rawDescGZIP
()
codec/testdata/protobuf.pb.go:104
↓ 1 callersFunctiongenerate
(parsers []*parser.Parser)
tool/xgen/xgen.go:77
↓ 1 callersFunctiongetDistanceFrom
https://gist.github.com/cdipaolo/d3f8db3848278b49db68
client/geo_utils.go:8
↓ 1 callersMethodhandleRequestForFunction
(ctx context.Context, req *protocol.Message)
server/server.go:783
↓ 1 callersMethodheartbeat
()
client/client.go:828
↓ 1 callersMethodinput
()
client/client.go:660
↓ 1 callersFunctionisExported
(name string)
reflection/server_reflection.go:214
↓ 1 callersFunctionisExported
(name string)
tool/xgen/parser/parser.go:28
↓ 1 callersMethodloadCached
()
client/discovery.go:128
↓ 1 callersMethodmakeListener
block can be nil if the caller wishes to skip encryption in kcp. tlsConfig can be nil iff we are not using network "quic".
server/listener.go:31
↓ 1 callersFunctionnewDirectHTTPConn
(c *Client, network, address string)
client/connection.go:118
↓ 1 callersFunctionnewDirectWSConn
(c *Client, network, address string)
client/connection.go:176
↓ 1 callersFunctionnewGeoSelector
(servers map[string]string, latitude, longitude float64)
client/selector.go:212
↓ 1 callersFunctionnewRoundRobinSelector
(servers map[string]string)
client/selector.go:83
↓ 1 callersFunctionnewWeightedICMPSelector
(servers map[string]string)
client/ping_utils.go:18
↓ 1 callersMethodnext
()
client/selector.go:155
↓ 1 callersFunctionoldUnzip
(data []byte)
util/compress_test.go:59
↓ 1 callersFunctionparseRequestLine
grabbed from net/http.
server/gateway.go:82
↓ 1 callersFunctionparseServerTimeout
(ctx *share.Context, req *protocol.Message)
server/server.go:624
↓ 1 callersMethodreadRequest
(ctx context.Context, r io.Reader)
server/server.go:658
↓ 1 callersFunctionresetHeader
(h *Header)
protocol/message.go:527
↓ 1 callersFunctionrpcxPrefixByteMatcher
()
server/gateway.go:114
↓ 1 callersFunctionsafeCloseClient
(client RPCClient)
client/xclient.go:295
↓ 1 callersMethodsend
(ctx context.Context, call *Call)
client/client.go:534
↓ 1 callersMethodserveByWS
(ln net.Listener, rpcPath string)
server/server.go:345
↓ 1 callersMethodstart
()
server/stream.go:103
↓ 1 callersMethodstart
()
server/file_transfer.go:131
↓ 1 callersMethodstartHTTP1APIGateway
(ln net.Listener)
server/gateway.go:123
↓ 1 callersMethodstartJSONRPC2
(ln net.Listener)
server/jsonrpc2.go:182
↓ 1 callersMethodstartProcess
()
server/server.go:1036
↓ 1 callersFunctiontestSendRaw
(t *testing.T, client *Client, seq uint64, x, y int32, wg *sync.WaitGroup)
client/client_test.go:157
↓ 1 callersFunctiontoString
(obj interface{})
client/hash_utils.go:53
↓ 1 callersMethodunregisterAll
()
server/service.go:354
↓ 1 callersFunctionurlencode
(data map[string]string)
client/client.go:516
↓ 1 callersMethodwatch
()
client/mdns_discovery.go:102
↓ 1 callersMethodwatch
()
client/dns_discovery.go:127
↓ 1 callersMethodwriteField1
(ctx context.Context, oprot thrift.TProtocol)
codec/testdata/thrift_colorgroup.go:159
↓ 1 callersMethodwriteField1
(ctx context.Context, oprot thrift.TProtocol)
_testutils/thrift_arith_service.go:127
↓ 1 callersMethodwriteField1
(ctx context.Context, oprot thrift.TProtocol)
_testutils/thrift_arith_service.go:254
↓ 1 callersMethodwriteField2
(ctx context.Context, oprot thrift.TProtocol)
codec/testdata/thrift_colorgroup.go:169
↓ 1 callersMethodwriteField2
(ctx context.Context, oprot thrift.TProtocol)
_testutils/thrift_arith_service.go:140
↓ 1 callersMethodwriteField3
(ctx context.Context, oprot thrift.TProtocol)
codec/testdata/thrift_colorgroup.go:179
MethodActiveClientConn
ActiveClientConn returns active connections.
server/server.go:172
MethodAdd
Add adds a plugin.
client/plugin.go:23
MethodAdd
Add adds a plugin.
server/plugin.go:138
MethodAddHandler
(servicePath, serviceMethod string, handler func(*Context) error)
server/server.go:167
MethodAlias
Alias sets a alias for the serviceMethod. For example Alias("anewpath&method", "Arith.mul")
serverplugin/alias.go:23
MethodAll
All returns all plugins
client/plugin.go:44
← previousnext →301–400 of 869, ranked by callers