transport

Documentation

Overview

Package transport provides several dialers and listeners for getting qmux sessions over TCP, Unix sockets, WebSocket, and stdio.

Index

• func DialIO(out io.WriteCloser, in io.ReadCloser) (mux.Session, error)
• func DialStdio() (mux.Session, error)
• func DialTCP(addr string) (mux.Session, error)
• func DialUnix(addr string) (mux.Session, error)
• func DialWS(addr string) (mux.Session, error)
• func HandleWS(l *NetListener, ws *websocket.Conn)
• type IOListener
  • func ListenIO(out io.WriteCloser, in io.ReadCloser) (*IOListener, error)
  • func ListenStdio() (*IOListener, error)
  • func (l *IOListener) Accept() (mux.Session, error)
• type Listener
• type NetListener
  • func ListenTCP(addr string) (*NetListener, error)
  • func ListenUnix(addr string) (*NetListener, error)
  • func ListenWS(addr string) (*NetListener, error)
  • func (l *NetListener) Accept() (mux.Session, error)
  • func (l *NetListener) Close() error

Functions

func DialIO

func DialIO(out io.WriteCloser, in io.ReadCloser) (mux.Session, error)

func DialStdio

func DialStdio() (mux.Session, error)

func DialTCP

func DialTCP(addr string) (mux.Session, error)

func DialUnix

func DialUnix(addr string) (mux.Session, error)

func DialWS

func DialWS(addr string) (mux.Session, error)

func HandleWS

func HandleWS(l *NetListener, ws *websocket.Conn)

Types

type IOListener

type IOListener struct {
	io.ReadWriteCloser
}

func ListenIO

func ListenIO(out io.WriteCloser, in io.ReadCloser) (*IOListener, error)

func ListenStdio

func ListenStdio() (*IOListener, error)

func (*IOListener) Accept

func (l *IOListener) Accept() (mux.Session, error)

type Listener

type Listener interface {
	// Close closes the listener.
	// Any blocked Accept operations will be unblocked and return errors.
	Close() error

	// Accept waits for and returns the next incoming session.
	Accept() (mux.Session, error)
}

type NetListener

type NetListener struct {
	net.Listener
	// contains filtered or unexported fields
}

func ListenTCP

func ListenTCP(addr string) (*NetListener, error)

func ListenUnix

func ListenUnix(addr string) (*NetListener, error)

func ListenWS

func ListenWS(addr string) (*NetListener, error)

func (*NetListener) Accept

func (l *NetListener) Accept() (mux.Session, error)

func (*NetListener) Close

func (l *NetListener) Close() error