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 io.ReadWriteCloser) *ConcurrencyIO
  • func (io *ConcurrencyIO) Close() error
  • func (io *ConcurrencyIO) Read() (p []byte, n int, err error)
  • func (io *ConcurrencyIO) Write(p []byte) (n int, err error)
• type IO
  • func WrapConn(conn io.ReadWriteCloser) *IO
  • func (io *IO) Close() error
  • func (io *IO) Read() (p []byte, n int, err 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 io.ReadWriteCloser) *ConcurrencyIO

func (*ConcurrencyIO) Close

func (io *ConcurrencyIO) Close() error

func (*ConcurrencyIO) Read

func (io *ConcurrencyIO) Read() (p []byte, n int, err 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 io.ReadWriteCloser) *IO

func (*IO) Close

func (io *IO) Close() error

func (*IO) Read

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

func (*IO) Write

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