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
Method
All
()
client/plugin.go:216
Method
All
()
server/plugin.go:158
Function
AllowAllCORSOptions
AllowAllCORSOptions returns a option that allows access.
server/jsonrpc2.go:154
Method
Auth
Auth sets s token for Authentication.
client/xclient_pool.go:70
Method
Auth
Auth sets s token for Authentication.
client/xclient.go:206
Method
Auth
Auth sets s token for Authentication.
client/oneclient.go:100
Method
Auth
Auth sets s token for Authentication.
client/oneclient_pool.go:64
Function
BenchmarkChanPtr
(b *testing.B)
protocol/message_chan_test.go:78
Function
BenchmarkChanValue
(b *testing.B)
protocol/message_chan_test.go:60
Function
BenchmarkGetFreePort_New
(b *testing.B)
util/net_test.go:44
Function
BenchmarkGetFreePort_Old
(b *testing.B)
util/net_test.go:38
Function
BenchmarkGzipCompressor_Unzip
(b *testing.B)
protocol/compressor_test.go:74
Function
BenchmarkGzipCompressor_Zip
(b *testing.B)
protocol/compressor_test.go:38
Function
BenchmarkJSONCodec_Decode
(b *testing.B)
codec/codec_test.go:75
Function
BenchmarkJSONCodec_Encode
(b *testing.B)
codec/codec_test.go:21
Function
BenchmarkMsgpackCodec_Decode
(b *testing.B)
codec/codec_test.go:97
Function
BenchmarkMsgpackCodec_Encode
(b *testing.B)
codec/codec_test.go:47
Function
BenchmarkPBCodec_Decode
(b *testing.B)
codec/codec_test.go:86
Function
BenchmarkPBCodec_Encode
(b *testing.B)
codec/codec_test.go:32
Function
BenchmarkRawDataCompressor_Unzip
(b *testing.B)
protocol/compressor_test.go:87
Function
BenchmarkRawDataCompressor_Zip
(b *testing.B)
protocol/compressor_test.go:50
Function
BenchmarkSnappyCompressor_Unzip
(b *testing.B)
protocol/compressor_test.go:100
Function
BenchmarkSnappyCompressor_Zip
(b *testing.B)
protocol/compressor_test.go:62
Function
BenchmarkThriftCodec_Decode
(b *testing.B)
codec/codec_test.go:108
Function
BenchmarkThriftCodec_Encode
(b *testing.B)
codec/codec_test.go:58
Function
BenchmarkUnzip
(b *testing.B)
util/compress_test.go:41
Function
BenchmarkUnzip_Old
(b *testing.B)
util/compress_test.go:88
Function
BenchmarkWeightedRoundRobinSelector_Select
(b *testing.B)
client/selector_test.go:96
Function
BenchmarkZip
(b *testing.B)
util/compress_test.go:28
Method
Broadcast
Broadcast sends requests to all servers and Success only when all servers return OK. FailMode and SelectMode are meanless for this method. Please set
client/xclient.go:932
Method
Broadcast
Broadcast sends requests to all servers and Success only when all servers return OK. FailMode and SelectMode are meanless for this method. Please set
client/oneclient.go:226
Function
CacheDiscovery
CacheDiscovery caches the services in a file, it will return the cached services if the number of services is greater than threshold. It is very usefu
client/discovery.go:38
Method
Call
Call invokes the named function, waits for it to complete, and returns its error status. It handles errors base on FailMode.
client/oneclient.go:176
Method
Call
(ctx context.Context, servicePath, serviceMethod string, args interface{}, reply interface{})
client/client.go:105
Method
Clone
Clone clones this ServiceDiscovery with new servicePath.
client/multiple_servers_discovery.go:28
Method
Clone
Clone clones this ServiceDiscovery with new servicePath.
client/mdns_discovery.go:59
Method
Clone
Clone clones this ServiceDiscovery with new servicePath.
client/peer2peer_discovery.go:16
Method
Clone
Clone clones this ServiceDiscovery with new servicePath.
client/dns_discovery.go:41
Method
Clone
Clone clones this DownloadFileArgs.
share/share.go:69
Method
Clone
Clone clones this DownloadFileArgs.
share/share.go:95
Method
Close
()
client/mdns_discovery.go:186
Method
Close
()
client/peer2peer_discovery.go:37
Method
Close
()
client/dns_discovery.go:141
Method
Close
set customized filter to filter services
client/discovery.go:22
Method
Close
Close closes this client and its underlying connections to services.
client/xclient.go:1388
Method
Close
Close closes all xclients and its underlying connections to services.
client/oneclient.go:339
Method
Close
()
server/listener_linux.go:53
Method
ConfigGeoSelector
ConfigGeoSelector sets location of client's latitude and longitude, and use newGeoSelector.
client/xclient.go:200
Method
ConfigGeoSelector
ConfigGeoSelector sets location of client's latitude and longitude, and use newGeoSelector.
client/oneclient.go:87
Method
ConsumingOperation
(ctx context.Context, args *testutils.ThriftArgs_, reply *testutils.ThriftReply)
server/server_test.go:39
Function
ConvertMap2String
(meta map[string]string)
util/net.go:62
Function
ConvertMeta2Map
(meta string)
util/net.go:44
Function
CopyMeta
(src, dst map[string]string)
util/converter.go:17
Method
Debug
(v ...interface{})
log/dummy_logger.go:5
Method
Debug
(v ...interface{})
log/default_logger.go:70
Method
Debugf
(format string, v ...interface{})
log/dummy_logger.go:8
Method
Debugf
(format string, v ...interface{})
log/default_logger.go:74
Method
Decode
Decode returns raw slice of bytes.
codec/codec.go:41
Method
Decode
(data []byte, i interface{})
share/share_test.go:16
Method
DeleteKey
DeleteKey delete the kv pair by key.
share/context.go:61
Method
DeleteKey
DeleteKey delete the kv pair by key.
server/context.go:39
Method
Descriptor
Deprecated: Use BenchmarkMessage.ProtoReflect.Descriptor instead.
protocol/testdata/benchmark.pb.go:98
Method
Descriptor
Deprecated: Use ProtoColorGroup.ProtoReflect.Descriptor instead.
codec/testdata/protobuf.pb.go:61
Method
Descriptor
()
_testutils/arith_service.go:42
Method
Descriptor
()
_testutils/arith_service.go:65
Method
DoClientAfterDecode
DoClientAfterDecode is called when requests are decoded and received.
client/plugin.go:141
Method
DoClientBeforeEncode
DoClientBeforeEncode is called when requests are encoded and sent.
client/plugin.go:127
Method
DoClientConnected
DoClientConnected is called in case of connected.
client/plugin.go:99
Method
DoClientConnectionClose
DoClientConnectionClose is called in case of connection close.
client/plugin.go:113
Method
DoConnCreateFailed
DoConnCreateFailed is called in case of client connection create failed.
client/plugin.go:90
Method
DoConnCreated
DoConnCreated is called in case of client connection created.
client/plugin.go:76
Method
DoHeartbeatRequest
DoHeartbeatRequest invokes HeartbeatRequest plugin.
server/plugin.go:388
Method
DoPostCall
DoPostCall executes after call
client/plugin.go:63
Method
DoPostCall
(ctx context.Context, servicePath, serviceMethod string, args interface{}, reply interface{}, err error)
client/plugin.go:224
Method
DoPostCall
DoPostCall invokes PostCallPlugin plugin.
server/plugin.go:317
Method
DoPostConnAccept
DoPostConnAccept handles accepted conn
server/plugin.go:217
Method
DoPostConnClose
DoPostConnClose handles closed conn
server/plugin.go:232
Method
DoPostHTTPRequest
DoPostHTTPRequest invokes PostHTTPRequest plugin.
server/plugin.go:274
Method
DoPostReadRequest
DoPostReadRequest invokes PostReadRequest plugin.
server/plugin.go:260
Method
DoPostWriteRequest
DoPostWriteRequest invokes PostWriteRequest plugin.
server/plugin.go:374
Method
DoPostWriteResponse
DoPostWriteResponse invokes PostWriteResponse plugin.
server/plugin.go:346
Method
DoPreCall
DoPreCall executes before call
client/plugin.go:49
Method
DoPreCall
(ctx context.Context, servicePath, serviceMethod string, args interface{})
client/plugin.go:223
Method
DoPreCall
DoPreCall invokes PreCallPlugin plugin.
server/plugin.go:302
Method
DoPreHandleRequest
DoPreHandleRequest invokes PreHandleRequest plugin.
server/plugin.go:288
Method
DoPreReadRequest
DoPreReadRequest invokes PreReadRequest plugin.
server/plugin.go:246
Method
DoPreWriteRequest
DoPreWriteRequest invokes PreWriteRequest plugin.
server/plugin.go:360
Method
DoPreWriteResponse
DoPreWriteResponse invokes PreWriteResponse plugin.
server/plugin.go:332
Method
DoRegister
DoRegister invokes DoRegister plugin.
server/plugin.go:163
Method
DoRegisterFunction
DoRegisterFunction invokes DoRegisterFunction plugin.
server/plugin.go:181
Method
DoUnregister
DoUnregister invokes RegisterPlugin.
server/plugin.go:199
Method
DoWrapSelect
DoWrapSelect is called when select a node.
client/plugin.go:155
Method
DownloadFile
(ctx context.Context, requestFileName string, saveTo io.Writer, meta map[string]string)
client/xclient.go:1332
Method
DownloadFile
(ctx context.Context, requestFileName string, saveTo io.Writer, meta map[string]string)
client/oneclient.go:294
Method
DownloadFile
(ctx context.Context, args *share.DownloadFileArgs, reply *share.FileTransferReply)
server/file_transfer.go:101
Method
EnableFileTransfer
EnableFileTransfer supports filetransfer service in this server.
server/file_transfer.go:72
Method
EnableStreamService
EnableStreamService supports stream service in this server.
server/stream.go:62
Method
Encode
Encode encodes messages.
protocol/message.go:227
Method
Encode
Encode returns raw slice of bytes.
codec/codec.go:29
Method
Encode
(i interface{})
share/share_test.go:12
← previous
next →
401–500 of 869, ranked by callers