Connector is the interface used to connect to a server.
type Connector interface {
Connect(context.Context) jsonrpc2.Conn
}
PipeServer is a test server that handles connections over io.Pipes.
type PipeServer struct {
// contains filtered or unexported fields
}
func NewPipeServer(server jsonrpc2.StreamServer, framer jsonrpc2.Framer) *PipeServer
NewPipeServer returns a test server that can be connected to via io.Pipes.
func (l PipeServer) Close() error
func (s *PipeServer) Connect(ctx context.Context) jsonrpc2.Conn
Connect creates new io.Pipes and binds them to the underlying StreamServer.
TCPServer is a helper for executing tests against a remote jsonrpc2 connection. Once initialized, its Addr field may be used to connect a jsonrpc2 client.
type TCPServer struct {
Addr string
// contains filtered or unexported fields
}
func NewTCPServer(ctx context.Context, server jsonrpc2.StreamServer, framer jsonrpc2.Framer) *TCPServer
NewTCPServer returns a new test server listening on local tcp port and serving incoming jsonrpc2 streams using the provided stream server. It panics on any error.
func (l TCPServer) Close() error
func (s *TCPServer) Connect(_ context.Context) jsonrpc2.Conn
Connect dials the test server and returns a jsonrpc2 Connection that is ready for use.