MCPcopy Create free account

hub / github.com/smallnest/rpcx / types & classes

Types & classes179 in github.com/smallnest/rpcx

↓ 5 callersTypeAliasstrErr
client/client.go:51
↓ 3 callersTypeAliasSerializeType
SerializeType defines serialization type of payload.
protocol/message.go:81
↓ 2 callersTypeAliasCompressType
CompressType defines decompression type.
protocol/message.go:71
↓ 2 callersTypeAliasContextKey
ContextKey defines key type in context.
share/share.go:53
↓ 1 callersTypeAliasFailMode
FailMode decides how clients action when clients fail to invoke services
client/mode.go:4
↓ 1 callersTypeAliasHeader
Header is the first part of Message and has fixed size. Format:
protocol/message.go:119
↓ 1 callersTypeAliasLevel
The default logger output at level error, to turn everything on like this: export RPCX_LOG_LEVEL=99 type of log level
log/default_logger.go:17
↓ 1 callersTypeAliasMessageStatusType
MessageStatusType is status of messages.
protocol/message.go:61
↓ 1 callersTypeAliasMessageType
MessageType is message type of requests and responses.
protocol/message.go:51
↓ 1 callersTypeAliasPBArith
reflection/server_reflection_test.go:13
↓ 1 callersTypeAliasSelectMode
SelectMode defines the algorithm of selecting a services from candidates.
client/mode.go:18
StructAliasPlugin
AliasPlugin can be used to set aliases for services
serverplugin/alias.go:16
StructArgs
client/client_test.go:17
StructArgs
reflection/server_reflection_test.go:31
StructArgs
serverplugin/registry_test.go:5
StructArgs
server/server_test.go:18
TypeAliasArith
client/client_test.go:26
TypeAliasArith
serverplugin/registry_test.go:14
TypeAliasArith
server/server_test.go:27
StructBenchmarkMessage
protocol/testdata/benchmark.pb.go:23
StructBidirectional
client/client_test.go:45
StructBlacklistPlugin
BlacklistPlugin is a plugin that control only ip addresses in blacklist can **NOT** access services.
serverplugin/blacklist.go:6
InterfaceBreaker
Breaker is a CircuitBreaker interface.
client/client.go:76
StructByteCodec
ByteCodec uses raw slice pf bytes and don't encode/decode.
codec/codec.go:26
InterfaceCMuxPlugin
server/plugin.go:127
InterfaceCacheClientBuilder
CacheClientBuilder defines builder interface to generate RPCCient.
client/cache_client_builder.go:6
StructCall
Call represents an active RPC.
client/client.go:208
StructClient
Client represents a RPC client.
client/client.go:120
InterfaceClientAfterDecodePlugin
ClientAfterDecodePlugin is invoked when the message is decoded.
client/plugin.go:202
InterfaceClientBeforeEncodePlugin
ClientBeforeEncodePlugin is invoked when the message is encoded and sent.
client/plugin.go:197
InterfaceClientConnectedPlugin
ClientConnectedPlugin is invoked when the client has connected the server.
client/plugin.go:187
InterfaceClientConnectionClosePlugin
ClientConnectionClosePlugin is invoked when the connection is closing.
client/plugin.go:192
InterfaceCodec
Codec defines the interface that decode/encode payload.
codec/codec.go:20
StructColorGroup
codec/codec_test.go:9
InterfaceCompressor
Compressor defines a common compression interface.
protocol/compressor.go:12
InterfaceConnCreateFailedPlugin
client/plugin.go:182
InterfaceConnCreatedPlugin
ConnCreatedPlugin is invoked when the client connection has created.
client/plugin.go:178
FuncTypeConnFactoryFn
func(c *Client, network, address string) (net.Conn, error)
client/connection.go:18
StructConsecCircuitBreaker
ConsecCircuitBreaker is window sliding CircuitBreaker with failure threshold.
client/circuit_breaker.go:15
FuncTypeConsistentAddrStrFunction
ConsistentFunction define a hash function Return service address, like "tcp@127.0.0.1:8970"
client/hash_utils.go:37
StructContext
var _ context.Context = &Context{} Context is a rpcx customized Context that can contains multiple values.
share/context.go:13
StructContext
Context represents a rpcx FastCall context.
server/context.go:12
StructDNSDiscovery
DNSDiscovery is based on DNS a record. You must set port and network info when you create the DNSDiscovery.
client/dns_discovery.go:15
StructDownloadFileArgs
DownloadFileArgs args from clients.
share/share.go:89
FuncTypeDownloadFileHandler
DownloadFileHandler handles downloading file. Must close the connection after it finished.
server/file_transfer.go:20
StructElem
server/pool_test.go:10
StructFileTransfer
FileTransfer support transfer files from clients. It registers a file transfer service and listens a on the given port. Clients will invokes this serv
server/file_transfer.go:35
StructFileTransferArgs
FileTransferArgs args from clients.
share/share.go:62
FuncTypeFileTransferHandler
FileTransferHandler handles uploading file. Must close the connection after it finished.
server/file_transfer.go:17
StructFileTransferReply
FileTransferReply response to token and addr to clients.
share/share.go:83
StructFileTransferService
server/file_transfer.go:49
StructGzipCompressor
GzipCompressor implements gzip compressor.
protocol/compressor.go:18
FuncTypeHandler
func(ctx *Context) error
server/server.go:69
FuncTypeHashServiceAndArgs
HashServiceAndArgs define a hash function
client/hash_utils.go:33
StructHeartbeatHandler
server/plugin_test.go:14
InterfaceHeartbeatPlugin
HeartbeatPlugin is .
server/plugin.go:123
StructID
ID is a jsonrpcRequest identifier. Only one of either the Name or Number members will be set, using the number form if the Name is the empty string.
server/jsonrpc2_wire.go:81
StructJSONCodec
JSONCodec uses json marshaler and unmarshaler.
codec/codec.go:47
StructJSONRPCError
JSONRPCError represents a structured error in a jsonrpcRespone.
server/jsonrpc2_wire.go:63
StructKVPair
KVPair contains a key and a string.
client/xclient.go:78
StructLimitedPool
util/buffer_pool.go:25
InterfaceLogger
log/logger.go:14
StructMDNSDiscovery
MDNSDiscovery is a mdns service discovery. It always returns the registered servers in mdns.
client/mdns_discovery.go:22
StructMDNSRegisterPlugin
MDNSRegisterPlugin implements mdns/dns-sd registry.
serverplugin/mdns.go:26
FuncTypeMakeListener
MakeListener defines a listener generator.
server/listener.go:27
StructMessage
Message is the generic type of Request and Response.
protocol/message.go:98
StructMethodInfo
MethodInfo method info
reflection/server_reflection.go:31
StructMetricsPlugin
MetricsPlugin has an issue. It changes seq of requests and it is wrong!!!! we should use other methods to map requests and responses not but seq. Metr
serverplugin/metrics.go:19
StructMockCodec
share/share_test.go:10
StructMsgpackCodec
MsgpackCodec uses messagepack marshaler and unmarshaler.
codec/codec.go:91
StructMultiError
MultiError holds multiple errors
errors/error.go:9
StructMultipleServersDiscovery
MultipleServersDiscovery is a multiple servers service discovery. It always returns the current servers and users can change servers dynamically.
client/multiple_servers_discovery.go:12
StructOneClient
OneClient wraps servicesPath and XClients. Users can use a shared oneclient to access multiple services.
client/oneclient.go:18
StructOneClientPool
OneClientPool is a oneclient pool with fixed size. It uses roundrobin algorithm to call its xclients. All oneclients share the same configurations suc
client/oneclient_pool.go:12
StructOption
Option contains all options for creating clients.
client/client.go:157
FuncTypeOptionFn
OptionFn configures options of server.
server/option.go:11
TypeAliasPBArith
client/client_test.go:33
StructPBCodec
PBCodec uses protobuf marshaler and unmarshaler.
codec/codec.go:62
StructParser
tool/xgen/parser/parser.go:14
StructPeer2PeerDiscovery
Peer2PeerDiscovery is a peer-to-peer service discovery. It always returns the static server.
client/peer2peer_discovery.go:5
InterfacePlugin
Plugin is the client plugin interface.
client/plugin.go:20
InterfacePlugin
Plugin is the server plugin interface.
server/plugin.go:48
InterfacePluginContainer
PluginContainer represents a plugin container that defines all methods to manage plugins. And it also defines all extension points.
client/plugin.go:213
InterfacePluginContainer
PluginContainer represents a plugin container that defines all methods to manage plugins. And it also defines all extension points.
server/plugin.go:16
InterfacePostCallPlugin
PostCallPlugin is invoked after the client calls a server.
client/plugin.go:173
InterfacePostCallPlugin
server/plugin.go:98
InterfacePostConnAcceptPlugin
PostConnAcceptPlugin represents connection accept plugin. if returns false, it means subsequent IPostConnAcceptPlugins should not continue to handle t
server/plugin.go:65
InterfacePostConnClosePlugin
PostConnClosePlugin represents client connection close plugin.
server/plugin.go:70
InterfacePostHTTPRequestPlugin
PostHTTPRequestPlugin represents .
server/plugin.go:85
InterfacePostReadRequestPlugin
PostReadRequestPlugin represents .
server/plugin.go:80
InterfacePostWriteRequestPlugin
PostWriteRequestPlugin represents .
server/plugin.go:118
InterfacePostWriteResponsePlugin
PostWriteResponsePlugin represents .
server/plugin.go:108
InterfacePreCallPlugin
PreCallPlugin is invoked before the client calls a server.
client/plugin.go:168
InterfacePreCallPlugin
server/plugin.go:94
InterfacePreHandleRequestPlugin
PreHandleRequestPlugin represents .
server/plugin.go:90
InterfacePreReadRequestPlugin
PreReadRequestPlugin represents .
server/plugin.go:75
InterfacePreWriteRequestPlugin
PreWriteRequestPlugin represents .
server/plugin.go:113
InterfacePreWriteResponsePlugin
PreWriteResponsePlugin represents .
server/plugin.go:103
StructProtoArgs
please upgrade the proto package
_testutils/arith_service.go:34
StructProtoColorGroup
codec/testdata/protobuf.pb.go:23
next →1–100 of 179, ranked by callers