netrans

Documentation

Index

• Variables
• func MultiReadCloser(rcs ...io.ReadCloser) io.ReadCloser
• func NewChannelReader(ch chan []byte) io.Reader
• func NewChannelWriteCloser(ctx context.Context) (chan []byte, io.WriteCloser)
• func NewTimeoutConn(conn net.Conn, readTimeout, writeTimeout time.Duration) net.Conn
• func NewTimeoutReadCloser(ctx context.Context, rc io.ReadCloser, timeout time.Duration) io.ReadCloser
• func NewTimeoutReader(ctx context.Context, r io.Reader, timeout time.Duration) io.Reader
• type DataFrame
  • func NewDataFrame(data []byte) *DataFrame
  • func ReadFrame(r io.Reader) (*DataFrame, error)
  • func (d *DataFrame) MarshalBinary() []byte
• type TimeoutConn
  • func (c *TimeoutConn) Read(b []byte) (n int, err error)
  • func (c *TimeoutConn) Write(b []byte) (n int, err error)
• type TimeoutReader
  • func (r *TimeoutReader) Close() error
  • func (r *TimeoutReader) Read(b []byte) (int, error)

Variables

var ErrReadTimeout = errors.New("read timeout")

var ErrReaderClosed = errors.New("reader has been closed")

Functions

func MultiReadCloser

func MultiReadCloser(rcs ...io.ReadCloser) io.ReadCloser

func NewChannelReader

func NewChannelReader(ch chan []byte) io.Reader

func NewChannelWriteCloser

func NewChannelWriteCloser(ctx context.Context) (chan []byte, io.WriteCloser)

func NewTimeoutConn

func NewTimeoutConn(conn net.Conn, readTimeout, writeTimeout time.Duration) net.Conn

func NewTimeoutReadCloser

func NewTimeoutReadCloser(ctx context.Context, rc io.ReadCloser, timeout time.Duration) io.ReadCloser

func NewTimeoutReader

func NewTimeoutReader(ctx context.Context, r io.Reader, timeout time.Duration) io.Reader

Types

type DataFrame

type DataFrame struct {
	Length uint32
	Obs    byte
	Data   []byte
}

func NewDataFrame

func NewDataFrame(data []byte) *DataFrame

func ReadFrame

func ReadFrame(r io.Reader) (*DataFrame, error)

func (*DataFrame) MarshalBinary

func (d *DataFrame) MarshalBinary() []byte

type TimeoutConn

type TimeoutConn struct {
	net.Conn
	// contains filtered or unexported fields
}

func (*TimeoutConn) Read

func (c *TimeoutConn) Read(b []byte) (n int, err error)

func (*TimeoutConn) Write

func (c *TimeoutConn) Write(b []byte) (n int, err error)

type TimeoutReader

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

func (*TimeoutReader) Close

func (r *TimeoutReader) Close() error

func (*TimeoutReader) Read

func (r *TimeoutReader) Read(b []byte) (int, error)