Versions in this module Expand all Collapse all v0 v0.1.11 Feb 4, 2022 v0.1.10 Feb 4, 2022 Changes in this version + const AutoNetwork + func ConnectToRemote(ctx context.Context, addr string) (net.Conn, error) + func ExecuteCommand(ctx context.Context, addr string, id string, request, result interface{}) error + func ParseAddr(listen string) (network string, address string) + type AutoDialer struct + func NewAutoDialer(rawAddr string, argFunc func(network, addr string) []string) (*AutoDialer, error) + func (d *AutoDialer) Dial(ctx context.Context) (io.ReadWriteCloser, error) + type BinderFunc func(ctx context.Context, conn *jsonrpc2_v2.Connection) (jsonrpc2_v2.ConnectionOptions, error) + func (f BinderFunc) Bind(ctx context.Context, conn *jsonrpc2_v2.Connection) (jsonrpc2_v2.ConnectionOptions, error) + type ClientBinder struct + func NewClientBinder(newClient ClientFunc) *ClientBinder + func (b *ClientBinder) Bind(ctx context.Context, conn *jsonrpc2_v2.Connection) (jsonrpc2_v2.ConnectionOptions, error) + type ClientFunc func(context.Context, protocol.Server) protocol.Client + type ClientSession struct + DebugAddr string + Logfile string + SessionID string + type ForwardBinder struct + func NewForwardBinder(dialer jsonrpc2_v2.Dialer) *ForwardBinder + func (b *ForwardBinder) Bind(ctx context.Context, conn *jsonrpc2_v2.Connection) (opts jsonrpc2_v2.ConnectionOptions, _ error) + type Forwarder struct + func NewForwarder(rawAddr string, argFunc func(network, address string) []string) (*Forwarder, error) + func (f *Forwarder) ServeStream(ctx context.Context, clientConn jsonrpc2.Conn) error + type HandlerMiddleware func(jsonrpc2_v2.Handler) jsonrpc2_v2.Handler + type Handshaker struct + Metadata Metadata + func (h *Handshaker) ClientHandshake(ctx context.Context, conn *jsonrpc2_v2.Connection) + func (h *Handshaker) Middleware(inner jsonrpc2_v2.Binder) jsonrpc2_v2.Binder + func (h *Handshaker) Peers() []PeerInfo + type Metadata map[string]interface + type Middleware func(jsonrpc2_v2.Binder) jsonrpc2_v2.Binder + func BindHandler(hmw HandlerMiddleware) Middleware + func CommandInterceptor(command string, run func(*protocol.ExecuteCommandParams) (interface{}, error)) Middleware + func GoEnvMiddleware() (Middleware, error) + type PeerInfo struct + IsClient bool + LocalID int64 + Metadata Metadata + RemoteID int64 + type ServerBinder struct + func NewServerBinder(newServer ServerFunc) *ServerBinder + func (b *ServerBinder) Bind(ctx context.Context, conn *jsonrpc2_v2.Connection) (jsonrpc2_v2.ConnectionOptions, error) + type ServerFunc func(context.Context, protocol.ClientCloser) protocol.Server + type ServerState struct + Clients []ClientSession + CurrentClientID string + DebugAddr string + GoplsPath string + Logfile string + func QueryServerState(ctx context.Context, addr string) (*ServerState, error) + type StreamServer struct + func NewStreamServer(cache *cache.Cache, daemon bool) *StreamServer + func (s *StreamServer) Binder() *ServerBinder + func (s *StreamServer) ServeStream(ctx context.Context, conn jsonrpc2.Conn) error