transport

Documentation

Index

• type ApplicationDataUnit
• type ErrorCheck
• type FrameBuilder
• type Header
• type NetworkHeader
• type NilTransport
  • func (t *NilTransport) Close() error
  • func (t *NilTransport) Flush(context.Context) error
  • func (t *NilTransport) ReadRequest(context.Context) (ApplicationDataUnit, error)
  • func (t *NilTransport) ReadResponse(context.Context) (ApplicationDataUnit, error)
  • func (t *NilTransport) Write([]byte) error
  • func (t *NilTransport) WriteFrame(ApplicationDataUnit) error
• type ProtocolDataUnit
  • func NewProtocolDataUnit(op data.ModbusOperation) *ProtocolDataUnit
  • func (pdu *ProtocolDataUnit) Bytes() []byte
  • func (pdu *ProtocolDataUnit) FunctionCode() data.FunctionCode
  • func (pdu ProtocolDataUnit) MarshalLogObject(encoder zapcore.ObjectEncoder) error
  • func (pdu *ProtocolDataUnit) Operation() data.ModbusOperation
• type SerialHeader
• type TransactionManager
• type Transport

Types

type ApplicationDataUnit

type ApplicationDataUnit interface {
	zapcore.ObjectMarshaler
	Bytes() []byte
	Header() Header
	PDU() *ProtocolDataUnit
	Checksum() ErrorCheck
}

type ErrorCheck

type ErrorCheck []byte

type FrameBuilder

type FrameBuilder interface {
	BuildResponseFrame(header Header, response *ProtocolDataUnit) (ApplicationDataUnit, error)
}

type Header

type Header interface {
	zapcore.ObjectMarshaler
	Bytes() []byte
}

type NetworkHeader

type NetworkHeader interface {
	Header
	TransactionID() []byte
	ProtocolID() []byte
	UnitID() byte
}

type NilTransport

type NilTransport struct{}

func (*NilTransport) Close

func (t *NilTransport) Close() error

func (*NilTransport) Flush

func (t *NilTransport) Flush(context.Context) error

func (*NilTransport) ReadRequest

func (t *NilTransport) ReadRequest(context.Context) (ApplicationDataUnit, error)

func (*NilTransport) ReadResponse

func (t *NilTransport) ReadResponse(context.Context) (ApplicationDataUnit, error)

func (*NilTransport) Write

func (t *NilTransport) Write([]byte) error

func (*NilTransport) WriteFrame

func (t *NilTransport) WriteFrame(ApplicationDataUnit) error

type ProtocolDataUnit

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

func NewProtocolDataUnit

func NewProtocolDataUnit(op data.ModbusOperation) *ProtocolDataUnit

func (*ProtocolDataUnit) Bytes

func (pdu *ProtocolDataUnit) Bytes() []byte

func (*ProtocolDataUnit) FunctionCode

func (pdu *ProtocolDataUnit) FunctionCode() data.FunctionCode

func (ProtocolDataUnit) MarshalLogObject

func (pdu ProtocolDataUnit) MarshalLogObject(encoder zapcore.ObjectEncoder) error

func (*ProtocolDataUnit) Operation

func (pdu *ProtocolDataUnit) Operation() data.ModbusOperation

type SerialHeader

type SerialHeader interface {
	Header
	Address() uint16
}

type TransactionManager

type TransactionManager interface {
	SendRequest(ctx context.Context, frame ApplicationDataUnit) (ApplicationDataUnit, error)
	WriteResponse(adu ApplicationDataUnit, pdu *ProtocolDataUnit) error
	Close() error
}

type Transport

type Transport interface {
	Flush(context.Context) error
	ReadRequest(context.Context) (ApplicationDataUnit, error)
	ReadResponse(context.Context, ApplicationDataUnit) (ApplicationDataUnit, error)
	WriteRequestFrame(uint16, *ProtocolDataUnit) (ApplicationDataUnit, error)
	WriteResponseFrame(Header, *ProtocolDataUnit) error
	Close() error
}