stdio

package

v0.2.0 Latest Latest Go to latest Published: Feb 3, 2025 License: MIT Imports: 8 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Transport struct {
	// contains filtered or unexported fields
}

Transport is a Transport implementation that reads from an io.ReadCloser and writes to an io.WriteCloser using the jsonrpc2 library.

func NewTransport(stdin io.ReadCloser, stdout io.WriteCloser) *Transport

NewTransport constructs a transport from a read/write pair (usually pipes).

func (t *Transport) Close() error

Close closes the connection and signals done, but also waits for the goroutine.

func (t *Transport) Done() <-chan struct{}

Done is closed once this transport is fully closed

func (t *Transport) GetRouter() *transport.MessageRouter

GetRouter returns this transport's MessageRouter

func (t *Transport) Logf(format string, args ...interface{})

Logf logs if we have a logger

func (t *Transport) Send(ctx context.Context, msg *types.Message) error

Send sends a single JSON-RPC message. If it’s a request, we wait for a response.

func (t *Transport) SetLogger(l logger.Logger)

SetLogger sets the logger for debug printing

func (t *Transport) Start(ctx context.Context) error

Start kicks off the jsonrpc2 listener in a background goroutine.