Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/smallnest/rpcx
/ functions
Functions
869 in github.com/smallnest/rpcx
⨍
Functions
869
◇
Types & classes
179
Function
SelectModeString
SelectModeString retrieves an enum value from the enum constants string name. Throws an error if the param is not part of the enum.
client/selectmode_enumer.go:33
Function
SelectModeValues
SelectModeValues returns all values of the enum
client/selectmode_enumer.go:41
Method
SendFile
SendFile sends a local file to the server. fileName is the path of local file. rateInBytesPerSecond can limit bandwidth of sending, 0 means does not
client/xclient.go:1251
Method
SendFile
(ctx context.Context, fileName string, rateInBytesPerSecond int64, meta map[string]string)
client/oneclient.go:272
Method
SendRaw
(ctx context.Context, r *protocol.Message)
client/xclient.go:767
Method
SendRaw
(ctx context.Context, r *protocol.Message)
client/oneclient.go:198
Method
SendRaw
(ctx context.Context, r *protocol.Message)
client/client.go:106
Method
SendRaw
SendRaw sends raw messages. You don't care args and replies.
client/client.go:379
Method
ServeHTTP
ServeHTTP implements an http.Handler that answers RPC requests.
server/server.go:874
Method
ServeListener
ServeListener listens RPC requests. It is blocked until receiving connections from clients.
server/server.go:247
Method
ServeWS
(conn *websocket.Conn)
server/server.go:895
Method
ServiceMethod
ServiceMethod returns the ServiceMethod.
server/context.go:62
Method
ServicePath
ServicePath returns the ServicePath.
server/context.go:57
Method
SetCORS
SetCORS sets CORS options. for example: cors.Options{ AllowedOrigins: []string{"foo.com"}, AllowedMethods: []string{http.MethodGet, http.Met
server/jsonrpc2.go:178
Function
SetDummyLogger
()
log/logger.go:42
Method
SetFilter
SetFilter sets the filer.
client/multiple_servers_discovery.go:33
Method
SetFilter
SetFilter sets the filer.
client/mdns_discovery.go:64
Method
SetFilter
SetFilter sets the filer.
client/peer2peer_discovery.go:21
Method
SetFilter
SetFilter sets the filer.
client/dns_discovery.go:46
Method
SetFilter
(ServiceDiscoveryFilter)
client/discovery.go:21
Function
SetLogger
(logger Logger)
log/logger.go:34
Method
SetPlugins
SetPlugins sets client's plugins.
client/xclient.go:190
Method
SetPlugins
SetPlugins sets client's plugins.
client/oneclient.go:72
Method
SetSelector
SetSelector sets customized selector by users.
client/xclient.go:70
Method
SetSelector
SetSelector sets customized selector by users.
client/oneclient.go:62
Method
Start
Start starts to connect redis cluster
serverplugin/redis.go:47
Method
Start
Start starts the mdns loop.
serverplugin/mdns.go:60
Method
Stop
Stop unregister all services.
serverplugin/redis.go:124
Method
Stop
Stop unregister all services.
serverplugin/mdns.go:110
Method
Stop
()
server/stream.go:176
Method
Stop
()
server/file_transfer.go:210
Method
StopAndWait
()
server/server.go:75
Method
Stream
(ctx context.Context, meta map[string]string)
client/xclient.go:1418
Method
Stream
(ctx context.Context, meta map[string]string)
client/oneclient.go:316
Method
Stream
(ctx context.Context, args *share.StreamServiceArgs, reply *share.StreamServiceReply)
server/stream.go:70
Method
String
()
client/selectmode_enumer.go:13
Method
String
()
protocol/testdata/benchmark.pb.go:79
Method
String
()
codec/testdata/protobuf.pb.go:42
Method
String
()
codec/testdata/thrift_colorgroup.go:213
Method
String
()
_testutils/arith_service.go:40
Method
String
()
_testutils/arith_service.go:63
Method
String
()
_testutils/thrift_arith_service.go:168
Method
String
()
_testutils/thrift_arith_service.go:279
Method
Success
()
client/circuit_breaker.go:87
Method
Success
()
client/client.go:79
Function
TestChanPtr
(t *testing.T)
protocol/message_chan_test.go:35
Function
TestChanValue
(t *testing.T)
protocol/message_chan_test.go:11
Function
TestCircuitBreakerRace
(t *testing.T)
client/circuit_breaker_test.go:56
Function
TestClient_Bidirectional
(t *testing.T)
client/client_test.go:203
Function
TestClient_IT
(t *testing.T)
client/client_test.go:56
Function
TestClient_IT_Concurrency
(t *testing.T)
client/client_test.go:126
Function
TestClient_Res_Reset
(t *testing.T)
client/client_test.go:192
Function
TestConsecCircuitBreaker
(t *testing.T)
client/circuit_breaker_test.go:10
Function
TestContext
(t *testing.T)
share/context_test.go:15
Function
TestExternalIPV4
(t *testing.T)
util/net_test.go:50
Function
TestExternalIPV6
(t *testing.T)
util/net_test.go:62
Function
TestGetFreePort
(t *testing.T)
util/net_test.go:9
Function
TestHTTPRequest2RpcxRequest
(t *testing.T)
server/converter_test.go:13
Function
TestHandleRequest
(t *testing.T)
server/server_test.go:66
Function
TestHandler
(t *testing.T)
server/server_test.go:122
Function
TestLimitedPool_findPool
(t *testing.T)
util/buffer_pool_test.go:8
Function
TestLimitedPool_findPutPool
(t *testing.T)
util/buffer_pool_test.go:41
Function
TestMessage
(t *testing.T)
protocol/message_test.go:8
Function
TestMultiError_Append
(t *testing.T)
errors/error_test.go:20
Function
TestMultiError_Error
(t *testing.T)
errors/error_test.go:28
Function
TestMultiError_ErrorOrNil
(t *testing.T)
errors/error_test.go:36
Function
TestNewMultiError
(t *testing.T)
errors/error_test.go:11
Function
TestOneClientPool_GetPlugins
(t *testing.T)
client/oneclient_pool_test.go:50
Function
TestOneClientPool_SetPlugins
(t *testing.T)
client/oneclient_pool_test.go:7
Function
TestOneClientPool_SetPlugins_Concurrent
(t *testing.T)
client/oneclient_pool_test.go:95
Function
TestOption
(t *testing.T)
server/option_test.go:11
Function
TestPluginHeartbeat
TestPluginHeartbeat: go test -v -test.run TestPluginHeartbeat
server/plugin_test.go:23
Function
TestPool
(t *testing.T)
server/pool_test.go:19
Function
TestReflection_Register
(t *testing.T)
reflection/server_reflection_test.go:20
Function
TestShare
(t *testing.T)
share/share_test.go:20
Function
TestShutdownHook
(t *testing.T)
server/server_test.go:45
Function
TestUncoverError
(t *testing.T)
client/xclient_test.go:118
Function
TestWeightedRoundRobinSelector_Select
(t *testing.T)
client/selector_test.go:41
Function
TestWeightedRoundRobinSelector_UpdateServer
(t *testing.T)
client/selector_test.go:67
Function
TestWithLocalValue
(t *testing.T)
share/context_test.go:34
Function
TestWithValue
(t *testing.T)
share/context_test.go:29
Function
TestXClientPool_GetPlugins
(t *testing.T)
client/xclient_pool_test.go:55
Function
TestXClientPool_SetPlugins
(t *testing.T)
client/xclient_pool_test.go:12
Function
TestXClientPool_SetPlugins_Concurrent
(t *testing.T)
client/xclient_pool_test.go:100
Function
TestXClient_IT
(t *testing.T)
client/xclient_test.go:61
Function
TestXClient_Thrift
(t *testing.T)
client/xclient_test.go:17
Function
TestXClient_filterByStateAndGroup
(t *testing.T)
client/xclient_test.go:95
Function
TestZip
(t *testing.T)
util/compress_test.go:10
Function
Test_consistentHashSelector_Select
(t *testing.T)
client/selector_test.go:8
Function
Test_consistentHashSelector_UpdateServer
(t *testing.T)
client/selector_test.go:26
Function
Test_generateJSON
(t *testing.T)
reflection/server_reflection_test.go:37
Function
Test_isExported
(t *testing.T)
server/service_test.go:11
Function
Test_isExportedOrBuiltinType
(t *testing.T)
server/service_test.go:32
Function
Test_validIP6
(t *testing.T)
server/server_test.go:182
Method
ThriftMul
(ctx context.Context, args *testutils.ThriftArgs_, reply *testutils.ThriftReply)
client/client_test.go:40
Method
ThriftMul
(ctx context.Context, args *testutils.ThriftArgs_, reply *testutils.ThriftReply)
server/server_test.go:34
Method
TransferFile
(ctx context.Context, args *share.FileTransferArgs, reply *share.FileTransferReply)
server/file_transfer.go:80
Method
UnmarshalJSON
(data []byte)
server/jsonrpc2_wire.go:102
Method
UnmarshalJSON
(data []byte)
server/jsonrpc2_wire.go:133
Method
Unregister
(name string)
reflection/server_reflection.go:146
← previous
next →
701–800 of 869, ranked by callers