transmitter

Documentation

Overview

Package transmitter

packet layer:

+---------------------------------------------------------------+
|  symbol(2) | blank(1) | length(2) | blank(1) | payload(n) ... |
+---------------------------------------------------------------+
|<-                 header(6)                ->|--  data(n)   ->|
+---------------------------------------------------------------+
|<-                       packet(6+n)                         ->|
+---------------------------------------------------------------+

Index

• Variables
• type ConcurrencyIO
  • func WrapConcurrentConn(conn net.Conn) *ConcurrencyIO
  • func (io *ConcurrencyIO) Close() error
  • func (io *ConcurrencyIO) LocalAddr() net.Addr
  • func (io *ConcurrencyIO) Read(p []byte) (n int, err error)
  • func (io *ConcurrencyIO) ReadOnePacket() (p []byte, n int, err error)
  • func (io *ConcurrencyIO) RemoteAddr() net.Addr
  • func (io *ConcurrencyIO) SetDeadline(t time.Time) error
  • func (io *ConcurrencyIO) SetReadDeadline(t time.Time) error
  • func (io *ConcurrencyIO) SetWriteDeadline(t time.Time) error
  • func (io *ConcurrencyIO) Write(p []byte) (n int, err error)
• type IO
  • func WrapConn(conn net.Conn) *IO
  • func (io *IO) Close() error
  • func (io *IO) LocalAddr() net.Addr
  • func (io *IO) Read(p []byte) (n int, err error)
  • func (io *IO) ReadOnePacket() (p []byte, n int, err error)
  • func (io *IO) RemoteAddr() net.Addr
  • func (io *IO) SetDeadline(t time.Time) error
  • func (io *IO) SetReadDeadline(t time.Time) error
  • func (io *IO) SetWriteDeadline(t time.Time) error
  • func (io *IO) Write(p []byte) (n int, err error)

Variables

var (
	ErrBadPacket = errors.New("bad packet")
	ErrBadHeader = errors.New("bad header")
)

var (
	DefaultSymbol = []byte{255, 254}
	Empty         = make([]byte, 0)
	Blank         = byte(0)
)

Types

type ConcurrencyIO

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

func WrapConcurrentConn

func WrapConcurrentConn(conn net.Conn) *ConcurrencyIO

func (*ConcurrencyIO) Close

func (io *ConcurrencyIO) Close() error

func (*ConcurrencyIO) LocalAddr

func (io *ConcurrencyIO) LocalAddr() net.Addr

func (*ConcurrencyIO) Read

func (io *ConcurrencyIO) Read(p []byte) (n int, err error)

func (*ConcurrencyIO) ReadOnePacket

func (io *ConcurrencyIO) ReadOnePacket() (p []byte, n int, err error)

func (*ConcurrencyIO) RemoteAddr

func (io *ConcurrencyIO) RemoteAddr() net.Addr

func (*ConcurrencyIO) SetDeadline

func (io *ConcurrencyIO) SetDeadline(t time.Time) error

func (*ConcurrencyIO) SetReadDeadline

func (io *ConcurrencyIO) SetReadDeadline(t time.Time) error

func (*ConcurrencyIO) SetWriteDeadline

func (io *ConcurrencyIO) SetWriteDeadline(t time.Time) error

func (*ConcurrencyIO) Write

func (io *ConcurrencyIO) Write(p []byte) (n int, err error)

type IO

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

func WrapConn

func WrapConn(conn net.Conn) *IO

func (*IO) Close

func (io *IO) Close() error

func (*IO) LocalAddr

func (io *IO) LocalAddr() net.Addr

func (*IO) Read

func (io *IO) Read(p []byte) (n int, err error)

func (*IO) ReadOnePacket

func (io *IO) ReadOnePacket() (p []byte, n int, err error)

func (*IO) RemoteAddr

func (io *IO) RemoteAddr() net.Addr

func (*IO) SetDeadline

func (io *IO) SetDeadline(t time.Time) error

func (*IO) SetReadDeadline

func (io *IO) SetReadDeadline(t time.Time) error

func (*IO) SetWriteDeadline

func (io *IO) SetWriteDeadline(t time.Time) error

func (*IO) Write

func (io *IO) Write(p []byte) (n int, err error)