drpcmigrate

Mar 3, 2021

Changes in this version

+ var Closed = errs.New("listener closed")

+ var DRPCHeader = "DRPC!!!1"

+ func DialWithHeader(ctx context.Context, network, address string, header string) (net.Conn, error)

+ type HeaderConn struct

+ func NewHeaderConn(conn net.Conn, header string) *HeaderConn

+ func (d *HeaderConn) Write(buf []byte) (n int, err error)

+ type HeaderDialer struct

+ Header string

+ func (d *HeaderDialer) Dial(network, address string) (net.Conn, error)

+ func (d *HeaderDialer) DialContext(ctx context.Context, network, address string) (net.Conn, error)

+ type ListenMux struct

+ func NewListenMux(base net.Listener, prefixLen int) *ListenMux

+ func (m *ListenMux) Default() net.Listener

+ func (m *ListenMux) Route(prefix string) net.Listener

+ func (m *ListenMux) Run(ctx context.Context) error