MCPcopy Create free account

hub / github.com/smallnest/rpcx / functions

Functions869 in github.com/smallnest/rpcx

⨍ Functions 869◇ Types & classes 179
MethodUnregister
(name string)
serverplugin/redis.go:218
MethodUnregister
(name string)
serverplugin/mdns.go:191
MethodUnregisterServerMessageChan
UnregisterServerMessageChan removes ServerMessageChan.
client/client.go:240
MethodUpdate
Update is used to update servers at runtime.
client/multiple_servers_discovery.go:71
MethodUpdateHandler
UpdateHandler 批量更新router 服务器使用plugin热更时，批量替换特定接口
server/router.go:5
MethodUpdateServer
(servers map[string]string)
client/selector.go:68
MethodUpdateServer
(servers map[string]string)
client/selector.go:104
MethodUpdateServer
(servers map[string]string)
client/selector.go:138
MethodUpdateServer
(servers map[string]string)
client/selector.go:242
MethodUpdateServer
(servers map[string]string)
client/selector.go:305
MethodUpdateServer
(servers map[string]string)
client/ping_utils.go:33
MethodVisit
(n ast.Node)
tool/xgen/parser/parser.go:33
MethodWarn
(v ...interface{})
log/dummy_logger.go:17
MethodWarn
(v ...interface{})
log/default_logger.go:86
MethodWarnf
(format string, v ...interface{})
log/dummy_logger.go:20
MethodWarnf
(format string, v ...interface{})
log/default_logger.go:90
MethodWatchService
WatchService returns a nil chan.
client/multiple_servers_discovery.go:45
MethodWatchService
WatchService returns a nil chan.
client/mdns_discovery.go:77
MethodWatchService
WatchService returns a nil chan.
client/peer2peer_discovery.go:31
MethodWatchService
WatchService returns a nil chan.
client/dns_discovery.go:58
MethodWatchService
()
client/discovery.go:80
FunctionWithAsyncWrite
WithAsyncWrite sets AsyncWrite to true.
server/option.go:58
FunctionWithBlockCrypt
WithBlockCrypt sets kcp.BlockCrypt.
server/kcp.go:25
FunctionWithCustomPool
WithCustomPool uses a custom goroutine pool.
server/option.go:51
FunctionWithPool
WithPool sets goroutine pool.
server/option.go:44
FunctionWithTCPKeepAlivePeriod
WithTCPKeepAlivePeriod sets tcp keepalive period.
server/options.go:6
MethodWrite
(ctx context.Context, oprot thrift.TProtocol)
_testutils/thrift_arith_service.go:106
MethodWrite
(ctx context.Context, oprot thrift.TProtocol)
_testutils/thrift_arith_service.go:236
FunctiondropOutput
(calldepth int, s string)
log/default_logger.go:33
FunctionencodeFixed32ArithService
(dAtA []byte, offset int, v uint32)
_testutils/arith_service.go:140
FunctionencodeFixed64ArithService
(dAtA []byte, offset int, v uint64)
_testutils/arith_service.go:129
MethodgetDoneChan
()
server/server.go:214
MethodhandleGatewayRequest
(w http.ResponseWriter, r *http.Request, params httprouter.Params)
server/gateway.go:161
Functionhttp1HeaderExist
(name string)
server/gateway.go:92
Functionhttp1Path
(prefix string)
server/gateway.go:53
Functioninit
()
client/connection_rdma.go:13
Functioninit
()
client/connection.go:22
Functioninit
()
protocol/testdata/benchmark.pb.go:482
Functioninit
()
codec/testdata/protobuf.pb.go:123
Functioninit
()
codec/testdata/thrift_colorgroup-consts.go:21
Functioninit
()
serverplugin/redis.go:20
Functioninit
()
server/listener_rdma.go:14
Functioninit
()
server/listener.go:12
Functioninit
()
server/memconn.go:9
Functioninit
()
server/listener_unix.go:12
Functioninit
()
server/quic.go:13
Functioninit
()
server/kcp.go:12
Functioninit
()
server/listener_linux.go:17
Functioninit
()
_testutils/arith_service.go:74
Functioninit
()
_testutils/thrift_arith_service-consts.go:20
Functioninit
()
util/compress.go:16
FunctioniouringMakeListener
iouringMakeListener creates a new listener using io_uring. You can use RegisterMakeListener to register a customized iouring Listener creator. experim
server/listener_linux.go:24
MethodjsonrpcHandler
(w http.ResponseWriter, r *http.Request)
server/jsonrpc2.go:20
FunctionkcpMakeListener
(s *Server, address string)
server/kcp.go:16
Functionmain
()
tool/xgen/xgen.go:22
FunctionmemconnMakeListener
(s *Server, address string)
server/memconn.go:13
FunctionnewDirectKCPConn
(c *Client, network, address string)
client/connection_kcp.go:11
FunctionnewDirectKCPConn
(c *Client, network, address string)
client/connection_nonkcp.go:10
FunctionnewDirectQuicConn
(c *Client, network, address string)
client/connection_quic.go:14
FunctionnewDirectQuicConn
(c *Client, network, address string)
client/connection_nonquic.go:11
FunctionnewIOUringConn
experimental
client/connection_iouring.go:8
FunctionnewMemuConn
(c *Client, network, address string)
client/connection_memu.go:9
FunctionnewRDMAConn
(c *Client, network, address string)
client/connection_rdma.go:17
FunctionquicMakeListener
(s *Server, address string)
server/quic.go:17
FunctionrdmaMakeListener
(s *Server, address string)
server/listener_rdma.go:18
FunctionreuseportMakeListener
(s *Server, address string)
server/listener_unix.go:17
FunctionsozArithService
(x uint64)
_testutils/arith_service.go:187
FunctionunixMakeListener
(s *Server, address string)
server/listener_unix.go:28
FunctionvalidIP4
(ipAddress string)
server/server.go:1078
← previous801–869 of 869, ranked by callers