net

Documentation

Index

• func AddMLI(mliType MliType, data []byte) []byte
• func HandleError(err error)
• type EchoServ
  • func (echoServ *EchoServ) ListenAndAccept() (err error)
• type MliType
• type NetCatClient
  • func NewNetCatClient(connectionStr string, mliType MliType) *NetCatClient
  • func (nt *NetCatClient) Close()
  • func (nt *NetCatClient) IsConnected() bool
  • func (nt *NetCatClient) OpenConnection() (err error)
  • func (nt *NetCatClient) Read(data []byte) (n int, err error)
  • func (nt *NetCatClient) ReadNextPacket() ([]byte, error)
  • func (nt *NetCatClient) Write(data []byte) (err error)
• type TcpHost
  • func NewTcpHost(mliType MliType, tcpAddr *net.TCPAddr) *TcpHost
  • func (tcpHost *TcpHost) SetHandler(handler TcpMessageHandler)
  • func (tcpHost *TcpHost) Start()
• type TcpMessageHandler

Functions

func AddMLI

func AddMLI(mliType MliType, data []byte) []byte

* This function adds a mli (length indicator) based on the type of mli - 2I, 2L etc *

func HandleError

func HandleError(err error)

Types

type EchoServ

type EchoServ struct {
	TcpAddr *net.TCPAddr
}

func (*EchoServ) ListenAndAccept

func (echoServ *EchoServ) ListenAndAccept() (err error)

type MliType

type MliType string

const (
	Mli2i MliType = "2i"
	Mli2e MliType = "2e"
)

type NetCatClient

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

func NewNetCatClient

func NewNetCatClient(connectionStr string, mliType MliType) *NetCatClient

func (*NetCatClient) Close

func (nt *NetCatClient) Close()

func (*NetCatClient) IsConnected

func (nt *NetCatClient) IsConnected() bool

func (*NetCatClient) OpenConnection

func (nt *NetCatClient) OpenConnection() (err error)

func (*NetCatClient) Read

func (nt *NetCatClient) Read(data []byte) (n int, err error)

func (*NetCatClient) ReadNextPacket

func (nt *NetCatClient) ReadNextPacket() ([]byte, error)

func (*NetCatClient) Write

func (nt *NetCatClient) Write(data []byte) (err error)

type TcpHost

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

func NewTcpHost

func NewTcpHost(mliType MliType, tcpAddr *net.TCPAddr) *TcpHost

func (*TcpHost) SetHandler

func (tcpHost *TcpHost) SetHandler(handler TcpMessageHandler)

func (*TcpHost) Start

func (tcpHost *TcpHost) Start()

type TcpMessageHandler

type TcpMessageHandler interface {
	HandleMessage(clientCon *net.TCPConn, msgData []byte)
}