# Functions
AcceptMuxedListener accepts incoming connections from a net.Listener.
CheckStripPrefix checks if the string has any of the given prefixes and strips the matched prefix if any.
Dial dials a remote server using TCP with the default muxed conn type.
Listen listens for incoming connections with TCP on the given address with the default muxed conn type.
NewCallCancelPacket constructs a new CallCancel packet with cancel.
NewCallDataPacket constructs a new CallData packet.
NewCallStartPacket constructs a new CallStart packet.
NewClient constructs a client with a OpenStreamFunc.
NewClientRPC constructs a new ClientRPC session and writes CallStart.
NewClientSet constructs a new client set.
NewClientWithConn constructs the muxer and the client.
NewClientWithMuxedConn constructs a new client with a MuxedConn.
NewHTTPServer builds a http server / handler.
NewMsgStream constructs a new Stream with a ClientRPC.
NewMux constructs a new Mux.
NewMuxedConn constructs a new MuxedConn from a net.Conn.
NewMuxedConnWithRwc builds a new MuxedConn with a io.ReadWriteCloser.
NewOpenStreamWithMuxedConn constructs a OpenStream func with a MuxedConn.
NewPacketDataHandler wraps a PacketHandler with a decoding step.
NewPacketReadWriter constructs a new read/writer.
NewPacketWriterWithClose wraps a PacketWriter with a close function to call when Close is called.
NewPipeStream constructs a new in-memory stream.
NewPrefixClient constructs a new PrefixClient.
NewPrefixInvoker constructs a new PrefixInvoker.
NewRawMessage constructs a new raw message.
NewRwcConn constructs a new packet conn and starts the rx pump.
NewServer constructs a new SRPC server.
NewServerPipe constructs a open stream func which creates an in-memory Pipe Stream with the given Server.
NewServerRPC constructs a new ServerRPC session.
NewStreamRwc constructs a new stream read write closer.
NewStreamWithClose wraps a Stream with a close function to call when Close is called.
NewVClient constructs a new verbose client wrapper.
NewVMux constructs a verbose logging wrapper for a Mux.
NewWebSocketConn wraps a websocket into a MuxedConn.
NewYamuxConfig builds the default yamux configuration.
# Variables
ErrCompleted is returned if a message is received after the rpc was completed.
ErrEmptyMethodID is returned if the method id was empty.
ErrEmptyPacket is returned if nothing is specified in a packet.
ErrEmptyServiceID is returned if the service id was empty.
ErrInvalidMessage indicates the message failed to parse.
ErrNilWriter is returned if the rpc writer is nil.
ErrNoAvailableClients is returned if no clients were available.
ErrUnimplemented is returned if the RPC method was not implemented.
ErrUnrecognizedPacket is returned if the packet type was not recognized.
# Structs
CallData contains a message in a streaming RPC sequence.
CallStart requests starting a new RPC call.
ClientRPC represents the client side of an on-going RPC call message stream.
ClientSet wraps a list of clients into one Client.
HTTPServer implements the SRPC HTTP/WebSocket server.
MsgStream implements the stream interface passed to implementations.
Packet is a message sent over a srpc packet connection.
No description provided by the author
No description provided by the author
No description provided by the author
PacketReadWriter reads and writes packets from a io.ReadWriter.
PrefixClient checks for and strips a set of prefixes from a Client.
PrefixInvoker checks for and strips a set of prefixes from a Invoker.
RawMessage is a raw protobuf message container.
RwcConn implements a Conn with a buffered ReadWriteCloser.
Server handles incoming RPC streams with a mux.
ServerRPC represents the server side of an on-going RPC call message stream.
StreamRwc implements an io.ReadWriteCloser with a srpc.Stream.
VClient implements a verbose SRPC client which can log RPC streams.
VMux implements a verbose logging wrapper for a Mux.
# Interfaces
Client implements a SRPC client which can initiate RPC streams.
Handler describes a SRPC call handler implementation.
Invoker is a function for invoking SRPC service methods.
MsgStreamRw is the read-write interface for MsgStream.
Mux contains a set of <service, method> handlers.
PacketWriter is the interface used to write messages to a PacketStream.
Stream is a handle to an on-going bi-directional or one-directional stream RPC handle.
StreamRecv is a stream that can receive typed messages.
StreamSend is a stream that can send typed messages.
StreamSendAndClose is a stream that can send typed messages, closing after.
# Type aliases
CloseHandler handles the stream closing with an optional error.
InvokerFunc is a function implementing InvokeMethod.
InvokerSlice is a list of invokers.
Message is the vtprotobuf message interface.
OpenStreamFunc opens a stream with a remote.
PacketDataHandler handles a packet before it is parsed.
PacketHandler handles a packet.