message

Documentation

Index

• Constants
• Variables
• type EchoMessageReader
  • func (e EchoMessageReader) Name() string
  • func (e EchoMessageReader) ReadMessage(conn io.Reader) ([]byte, error)
• type HTTPMessageReader
  • func (H HTTPMessageReader) Name() string
  • func (H HTTPMessageReader) ReadMessage(conn io.Reader) ([]byte, error)
• type ISO8583MessageReader
  • func (I ISO8583MessageReader) Name() string
  • func (I ISO8583MessageReader) ReadMessage(conn io.Reader) ([]byte, error)
• type MPUMessageReader
  • func (M MPUMessageReader) Name() string
  • func (M MPUMessageReader) ReadMessage(conn io.Reader) ([]byte, error)
• type ModbusMessageReader
  • func (m ModbusMessageReader) Name() string
  • func (m ModbusMessageReader) ReadMessage(conn io.Reader) ([]byte, error)
• type Reader

Constants

const (
	CRLF = "\r\n"
)

Variables

var Readers map[string]Reader

Types

type EchoMessageReader

type EchoMessageReader struct {
}

func (EchoMessageReader) Name

func (e EchoMessageReader) Name() string

func (EchoMessageReader) ReadMessage

func (e EchoMessageReader) ReadMessage(conn io.Reader) ([]byte, error)

ReadMessage message is expected \n terminated

type HTTPMessageReader

type HTTPMessageReader struct {
}

func (HTTPMessageReader) Name

func (H HTTPMessageReader) Name() string

func (HTTPMessageReader) ReadMessage

func (H HTTPMessageReader) ReadMessage(conn io.Reader) ([]byte, error)

type ISO8583MessageReader

type ISO8583MessageReader struct {
}

func (ISO8583MessageReader) Name

func (I ISO8583MessageReader) Name() string

func (ISO8583MessageReader) ReadMessage

func (I ISO8583MessageReader) ReadMessage(conn io.Reader) ([]byte, error)

ReadMessage assume including a header with the length of the 8583 message http://j8583.sourceforge.net/desc8583en.html otherwise, we have to parse iso8583 message

type MPUMessageReader

type MPUMessageReader struct {
}

MPUMessageReader for reading MPU Switch format iso8583

func (MPUMessageReader) Name

func (M MPUMessageReader) Name() string

func (MPUMessageReader) ReadMessage

func (M MPUMessageReader) ReadMessage(conn io.Reader) ([]byte, error)

type ModbusMessageReader

type ModbusMessageReader struct {
}

func (ModbusMessageReader) Name

func (m ModbusMessageReader) Name() string

func (ModbusMessageReader) ReadMessage

func (m ModbusMessageReader) ReadMessage(conn io.Reader) ([]byte, error)

type Reader

type Reader interface {
	ReadMessage(conn io.Reader) ([]byte, error)
	Name() string
}

Reader read message for specified application protocol from client and target server