udp

Documentation

Index

• Constants
• func Listen(peerString string, dispatchCb func(data []byte)) (*net.UDPConn, *net.UDPAddr, error)
• type UdpSesn
  • func NewUdpSesn(cfg sesn.SesnCfg) (*UdpSesn, error)
  • func (s *UdpSesn) AbortRx(seq uint8) error
  • func (s *UdpSesn) Close() error
  • func (s *UdpSesn) CoapIsTcp() bool
  • func (s *UdpSesn) Filters() (nmcoap.TxMsgFilter, nmcoap.RxMsgFilter)
  • func (s *UdpSesn) IsOpen() bool
  • func (s *UdpSesn) ListenCoap(mc nmcoap.MsgCriteria) (*nmcoap.Listener, error)
  • func (s *UdpSesn) MgmtProto() sesn.MgmtProto
  • func (s *UdpSesn) MtuIn() int
  • func (s *UdpSesn) MtuOut() int
  • func (s *UdpSesn) Open() error
  • func (s *UdpSesn) RxAccept() (sesn.Sesn, *sesn.SesnCfg, error)
  • func (s *UdpSesn) RxCoap(opt sesn.TxOptions) (coap.Message, error)
  • func (s *UdpSesn) SetFilters(txFilter nmcoap.TxMsgFilter, rxFilter nmcoap.RxMsgFilter)
  • func (s *UdpSesn) StopListenCoap(mc nmcoap.MsgCriteria)
  • func (s *UdpSesn) TxCoap(m coap.Message) error
  • func (s *UdpSesn) TxRxMgmt(m *nmp.NmpMsg, timeout time.Duration) (nmp.NmpRsp, error)
  • func (s *UdpSesn) TxRxMgmtAsync(m *nmp.NmpMsg, timeout time.Duration, ch chan nmp.NmpRsp, errc chan error) error
• type UdpXport
  • func NewUdpXport() *UdpXport
  • func (ux *UdpXport) BuildSesn(cfg sesn.SesnCfg) (sesn.Sesn, error)
  • func (ux *UdpXport) Start() error
  • func (ux *UdpXport) Stop() error
  • func (ux *UdpXport) Tx(bytes []byte) error

Constants

const MAX_PACKET_SIZE = 2048

Functions

func Listen

func Listen(peerString string, dispatchCb func(data []byte)) (
	*net.UDPConn, *net.UDPAddr, error)

Types

type UdpSesn

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

func NewUdpSesn

func NewUdpSesn(cfg sesn.SesnCfg) (*UdpSesn, error)

func (*UdpSesn) AbortRx

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

func (*UdpSesn) Close

func (s *UdpSesn) Close() error

func (*UdpSesn) CoapIsTcp

func (s *UdpSesn) CoapIsTcp() bool

func (*UdpSesn) Filters

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

func (*UdpSesn) IsOpen

func (s *UdpSesn) IsOpen() bool

func (*UdpSesn) ListenCoap

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

func (*UdpSesn) MgmtProto

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

func (*UdpSesn) MtuIn

func (s *UdpSesn) MtuIn() int

func (*UdpSesn) MtuOut

func (s *UdpSesn) MtuOut() int

func (*UdpSesn) Open

func (s *UdpSesn) Open() error

func (*UdpSesn) RxAccept

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

func (*UdpSesn) RxCoap

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

func (*UdpSesn) SetFilters

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

func (*UdpSesn) StopListenCoap

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

func (*UdpSesn) TxCoap

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

func (*UdpSesn) TxRxMgmt

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

func (*UdpSesn) TxRxMgmtAsync

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

type UdpXport

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

func NewUdpXport

func NewUdpXport() *UdpXport

func (*UdpXport) BuildSesn

func (ux *UdpXport) BuildSesn(cfg sesn.SesnCfg) (sesn.Sesn, error)

func (*UdpXport) Start

func (ux *UdpXport) Start() error

func (*UdpXport) Stop

func (ux *UdpXport) Stop() error

func (*UdpXport) Tx

func (ux *UdpXport) Tx(bytes []byte) error