nmserial

Documentation

Index

• type Packet
  • func NewPacket(expectedLen uint16) (*Packet, error)
  • func (pkt *Packet) AddBytes(bytes []byte) bool
  • func (pkt *Packet) GetBytes() []byte
  • func (pkt *Packet) TrimEnd(count int)
• type SerialSesn
  • func NewSerialSesn(sx *SerialXport, cfg sesn.SesnCfg) (*SerialSesn, error)
  • func (s *SerialSesn) AbortRx(seq uint8) error
  • func (s *SerialSesn) Close() error
  • func (s *SerialSesn) CoapIsTcp() bool
  • func (s *SerialSesn) Filters() (nmcoap.TxMsgFilter, nmcoap.RxMsgFilter)
  • func (s *SerialSesn) IsOpen() bool
  • func (s *SerialSesn) ListenCoap(mc nmcoap.MsgCriteria) (*nmcoap.Listener, error)
  • func (s *SerialSesn) MgmtProto() sesn.MgmtProto
  • func (s *SerialSesn) MtuIn() int
  • func (s *SerialSesn) MtuOut() int
  • func (s *SerialSesn) Open() error
  • func (s *SerialSesn) RxAccept() (sesn.Sesn, *sesn.SesnCfg, error)
  • func (s *SerialSesn) RxCoap(opt sesn.TxOptions) (coap.Message, error)
  • func (s *SerialSesn) SetFilters(txFilter nmcoap.TxMsgFilter, rxFilter nmcoap.RxMsgFilter)
  • func (s *SerialSesn) StopListenCoap(mc nmcoap.MsgCriteria)
  • func (s *SerialSesn) TxCoap(m coap.Message) error
  • func (s *SerialSesn) TxRxMgmt(m *nmp.NmpMsg, timeout time.Duration) (nmp.NmpRsp, error)
  • func (s *SerialSesn) TxRxMgmtAsync(m *nmp.NmpMsg, timeout time.Duration, ch chan nmp.NmpRsp, errc chan error) error
• type SerialXport
  • func NewSerialXport(cfg *XportCfg) *SerialXport
  • func (sx *SerialXport) BuildSesn(cfg sesn.SesnCfg) (sesn.Sesn, error)
  • func (sx *SerialXport) Rx() ([]byte, error)
  • func (sx *SerialXport) Start() error
  • func (sx *SerialXport) Stop() error
  • func (sx *SerialXport) Tx(bytes []byte) error
• type XportCfg
  • func NewXportCfg() *XportCfg

Types

type Packet

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

func NewPacket

func NewPacket(expectedLen uint16) (*Packet, error)

func (*Packet) AddBytes

func (pkt *Packet) AddBytes(bytes []byte) bool

func (*Packet) GetBytes

func (pkt *Packet) GetBytes() []byte

func (*Packet) TrimEnd

func (pkt *Packet) TrimEnd(count int)

type SerialSesn

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

func NewSerialSesn

func NewSerialSesn(sx *SerialXport, cfg sesn.SesnCfg) (*SerialSesn, error)

func (*SerialSesn) AbortRx

func (s *SerialSesn) AbortRx(seq uint8) error

func (*SerialSesn) Close

func (s *SerialSesn) Close() error

func (*SerialSesn) CoapIsTcp

func (s *SerialSesn) CoapIsTcp() bool

func (*SerialSesn) Filters

func (s *SerialSesn) Filters() (nmcoap.TxMsgFilter, nmcoap.RxMsgFilter)

func (*SerialSesn) IsOpen

func (s *SerialSesn) IsOpen() bool

func (*SerialSesn) ListenCoap

func (s *SerialSesn) ListenCoap(
	mc nmcoap.MsgCriteria) (*nmcoap.Listener, error)

func (*SerialSesn) MgmtProto

func (s *SerialSesn) MgmtProto() sesn.MgmtProto

func (*SerialSesn) MtuIn

func (s *SerialSesn) MtuIn() int

func (*SerialSesn) MtuOut

func (s *SerialSesn) MtuOut() int

func (*SerialSesn) Open

func (s *SerialSesn) Open() error

func (*SerialSesn) RxAccept

func (s *SerialSesn) RxAccept() (sesn.Sesn, *sesn.SesnCfg, error)

func (*SerialSesn) RxCoap

func (s *SerialSesn) RxCoap(opt sesn.TxOptions) (coap.Message, error)

func (*SerialSesn) SetFilters

func (s *SerialSesn) SetFilters(txFilter nmcoap.TxMsgFilter,
	rxFilter nmcoap.RxMsgFilter)

func (*SerialSesn) StopListenCoap

func (s *SerialSesn) StopListenCoap(mc nmcoap.MsgCriteria)

func (*SerialSesn) TxCoap

func (s *SerialSesn) TxCoap(m coap.Message) error

func (*SerialSesn) TxRxMgmt

func (s *SerialSesn) TxRxMgmt(m *nmp.NmpMsg,
	timeout time.Duration) (nmp.NmpRsp, error)

func (*SerialSesn) TxRxMgmtAsync

func (s *SerialSesn) TxRxMgmtAsync(m *nmp.NmpMsg,
	timeout time.Duration, ch chan nmp.NmpRsp, errc chan error) error

type SerialXport

type SerialXport struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewSerialXport

func NewSerialXport(cfg *XportCfg) *SerialXport

func (*SerialXport) BuildSesn

func (sx *SerialXport) BuildSesn(cfg sesn.SesnCfg) (sesn.Sesn, error)

func (*SerialXport) Rx

func (sx *SerialXport) Rx() ([]byte, error)

Blocking receive.

func (*SerialXport) Start

func (sx *SerialXport) Start() error

func (*SerialXport) Stop

func (sx *SerialXport) Stop() error

func (*SerialXport) Tx

func (sx *SerialXport) Tx(bytes []byte) error

type XportCfg

type XportCfg struct {
	DevPath     string
	Baud        int
	Mtu         int
	ReadTimeout time.Duration
}

func NewXportCfg

func NewXportCfg() *XportCfg