Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/smallnest/rpcx
/ types & classes
Types & classes
179 in github.com/smallnest/rpcx
⨍
Functions
869
◇
Types & classes
179
↓ 5 callers
TypeAlias
strErr
client/client.go:51
↓ 3 callers
TypeAlias
SerializeType
SerializeType defines serialization type of payload.
protocol/message.go:81
↓ 2 callers
TypeAlias
CompressType
CompressType defines decompression type.
protocol/message.go:71
↓ 2 callers
TypeAlias
ContextKey
ContextKey defines key type in context.
share/share.go:53
↓ 1 callers
TypeAlias
FailMode
FailMode decides how clients action when clients fail to invoke services
client/mode.go:4
↓ 1 callers
TypeAlias
Header
Header is the first part of Message and has fixed size. Format:
protocol/message.go:119
↓ 1 callers
TypeAlias
Level
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 callers
TypeAlias
MessageStatusType
MessageStatusType is status of messages.
protocol/message.go:61
↓ 1 callers
TypeAlias
MessageType
MessageType is message type of requests and responses.
protocol/message.go:51
↓ 1 callers
TypeAlias
PBArith
reflection/server_reflection_test.go:13
↓ 1 callers
TypeAlias
SelectMode
SelectMode defines the algorithm of selecting a services from candidates.
client/mode.go:18
Struct
AliasPlugin
AliasPlugin can be used to set aliases for services
serverplugin/alias.go:16
Struct
Args
client/client_test.go:17
Struct
Args
reflection/server_reflection_test.go:31
Struct
Args
serverplugin/registry_test.go:5
Struct
Args
server/server_test.go:18
TypeAlias
Arith
client/client_test.go:26
TypeAlias
Arith
serverplugin/registry_test.go:14
TypeAlias
Arith
server/server_test.go:27
Struct
BenchmarkMessage
protocol/testdata/benchmark.pb.go:23
Struct
Bidirectional
client/client_test.go:45
Struct
BlacklistPlugin
BlacklistPlugin is a plugin that control only ip addresses in blacklist can **NOT** access services.
serverplugin/blacklist.go:6
Interface
Breaker
Breaker is a CircuitBreaker interface.
client/client.go:76
Struct
ByteCodec
ByteCodec uses raw slice pf bytes and don't encode/decode.
codec/codec.go:26
Interface
CMuxPlugin
server/plugin.go:127
Interface
CacheClientBuilder
CacheClientBuilder defines builder interface to generate RPCCient.
client/cache_client_builder.go:6
Struct
Call
Call represents an active RPC.
client/client.go:208
Struct
Client
Client represents a RPC client.
client/client.go:120
Interface
ClientAfterDecodePlugin
ClientAfterDecodePlugin is invoked when the message is decoded.
client/plugin.go:202
Interface
ClientBeforeEncodePlugin
ClientBeforeEncodePlugin is invoked when the message is encoded and sent.
client/plugin.go:197
Interface
ClientConnectedPlugin
ClientConnectedPlugin is invoked when the client has connected the server.
client/plugin.go:187
Interface
ClientConnectionClosePlugin
ClientConnectionClosePlugin is invoked when the connection is closing.
client/plugin.go:192
Interface
Codec
Codec defines the interface that decode/encode payload.
codec/codec.go:20
Struct
ColorGroup
codec/codec_test.go:9
Interface
Compressor
Compressor defines a common compression interface.
protocol/compressor.go:12
Interface
ConnCreateFailedPlugin
client/plugin.go:182
Interface
ConnCreatedPlugin
ConnCreatedPlugin is invoked when the client connection has created.
client/plugin.go:178
FuncType
ConnFactoryFn
func(c *Client, network, address string) (net.Conn, error)
client/connection.go:18
Struct
ConsecCircuitBreaker
ConsecCircuitBreaker is window sliding CircuitBreaker with failure threshold.
client/circuit_breaker.go:15
FuncType
ConsistentAddrStrFunction
ConsistentFunction define a hash function Return service address, like "tcp@127.0.0.1:8970"
client/hash_utils.go:37
Struct
Context
var _ context.Context = &Context{} Context is a rpcx customized Context that can contains multiple values.
share/context.go:13
Struct
Context
Context represents a rpcx FastCall context.
server/context.go:12
Struct
DNSDiscovery
DNSDiscovery is based on DNS a record. You must set port and network info when you create the DNSDiscovery.
client/dns_discovery.go:15
Struct
DownloadFileArgs
DownloadFileArgs args from clients.
share/share.go:89
FuncType
DownloadFileHandler
DownloadFileHandler handles downloading file. Must close the connection after it finished.
server/file_transfer.go:20
Struct
Elem
server/pool_test.go:10
Struct
FileTransfer
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
Struct
FileTransferArgs
FileTransferArgs args from clients.
share/share.go:62
FuncType
FileTransferHandler
FileTransferHandler handles uploading file. Must close the connection after it finished.
server/file_transfer.go:17
Struct
FileTransferReply
FileTransferReply response to token and addr to clients.
share/share.go:83
Struct
FileTransferService
server/file_transfer.go:49
Struct
GzipCompressor
GzipCompressor implements gzip compressor.
protocol/compressor.go:18
FuncType
Handler
func(ctx *Context) error
server/server.go:69
FuncType
HashServiceAndArgs
HashServiceAndArgs define a hash function
client/hash_utils.go:33
Struct
HeartbeatHandler
server/plugin_test.go:14
Interface
HeartbeatPlugin
HeartbeatPlugin is .
server/plugin.go:123
Struct
ID
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
Struct
JSONCodec
JSONCodec uses json marshaler and unmarshaler.
codec/codec.go:47
Struct
JSONRPCError
JSONRPCError represents a structured error in a jsonrpcRespone.
server/jsonrpc2_wire.go:63
Struct
KVPair
KVPair contains a key and a string.
client/xclient.go:78
Struct
LimitedPool
util/buffer_pool.go:25
Interface
Logger
log/logger.go:14
Struct
MDNSDiscovery
MDNSDiscovery is a mdns service discovery. It always returns the registered servers in mdns.
client/mdns_discovery.go:22
Struct
MDNSRegisterPlugin
MDNSRegisterPlugin implements mdns/dns-sd registry.
serverplugin/mdns.go:26
FuncType
MakeListener
MakeListener defines a listener generator.
server/listener.go:27
Struct
Message
Message is the generic type of Request and Response.
protocol/message.go:98
Struct
MethodInfo
MethodInfo method info
reflection/server_reflection.go:31
Struct
MetricsPlugin
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
Struct
MockCodec
share/share_test.go:10
Struct
MsgpackCodec
MsgpackCodec uses messagepack marshaler and unmarshaler.
codec/codec.go:91
Struct
MultiError
MultiError holds multiple errors
errors/error.go:9
Struct
MultipleServersDiscovery
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
Struct
OneClient
OneClient wraps servicesPath and XClients. Users can use a shared oneclient to access multiple services.
client/oneclient.go:18
Struct
OneClientPool
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
Struct
Option
Option contains all options for creating clients.
client/client.go:157
FuncType
OptionFn
OptionFn configures options of server.
server/option.go:11
TypeAlias
PBArith
client/client_test.go:33
Struct
PBCodec
PBCodec uses protobuf marshaler and unmarshaler.
codec/codec.go:62
Struct
Parser
tool/xgen/parser/parser.go:14
Struct
Peer2PeerDiscovery
Peer2PeerDiscovery is a peer-to-peer service discovery. It always returns the static server.
client/peer2peer_discovery.go:5
Interface
Plugin
Plugin is the client plugin interface.
client/plugin.go:20
Interface
Plugin
Plugin is the server plugin interface.
server/plugin.go:48
Interface
PluginContainer
PluginContainer represents a plugin container that defines all methods to manage plugins. And it also defines all extension points.
client/plugin.go:213
Interface
PluginContainer
PluginContainer represents a plugin container that defines all methods to manage plugins. And it also defines all extension points.
server/plugin.go:16
Interface
PostCallPlugin
PostCallPlugin is invoked after the client calls a server.
client/plugin.go:173
Interface
PostCallPlugin
server/plugin.go:98
Interface
PostConnAcceptPlugin
PostConnAcceptPlugin represents connection accept plugin. if returns false, it means subsequent IPostConnAcceptPlugins should not continue to handle t
server/plugin.go:65
Interface
PostConnClosePlugin
PostConnClosePlugin represents client connection close plugin.
server/plugin.go:70
Interface
PostHTTPRequestPlugin
PostHTTPRequestPlugin represents .
server/plugin.go:85
Interface
PostReadRequestPlugin
PostReadRequestPlugin represents .
server/plugin.go:80
Interface
PostWriteRequestPlugin
PostWriteRequestPlugin represents .
server/plugin.go:118
Interface
PostWriteResponsePlugin
PostWriteResponsePlugin represents .
server/plugin.go:108
Interface
PreCallPlugin
PreCallPlugin is invoked before the client calls a server.
client/plugin.go:168
Interface
PreCallPlugin
server/plugin.go:94
Interface
PreHandleRequestPlugin
PreHandleRequestPlugin represents .
server/plugin.go:90
Interface
PreReadRequestPlugin
PreReadRequestPlugin represents .
server/plugin.go:75
Interface
PreWriteRequestPlugin
PreWriteRequestPlugin represents .
server/plugin.go:113
Interface
PreWriteResponsePlugin
PreWriteResponsePlugin represents .
server/plugin.go:103
Struct
ProtoArgs
please upgrade the proto package
_testutils/arith_service.go:34
Struct
ProtoColorGroup
codec/testdata/protobuf.pb.go:23
next →
1–100 of 179, ranked by callers