mgmt

Documentation

Index

• func EncodeMgmt(s sesn.Sesn, m *nmp.NmpMsg) ([]byte, error)
• type Transceiver
  • func NewTransceiver(txFilter nmcoap.TxMsgFilter, rxFilter nmcoap.RxMsgFilter, isTcp bool, ...) (*Transceiver, error)
  • func (t *Transceiver) AbortRx(seq uint8)
  • func (t *Transceiver) DispatchCoap(data []byte)
  • func (t *Transceiver) DispatchNmpRsp(data []byte)
  • func (t *Transceiver) ErrorAll(err error)
  • func (t *Transceiver) ErrorOne(seq uint8, err error)
  • func (t *Transceiver) Filters() (nmcoap.TxMsgFilter, nmcoap.RxMsgFilter)
  • func (t *Transceiver) ListenCoap(mc nmcoap.MsgCriteria) (*nmcoap.Listener, error)
  • func (t *Transceiver) MgmtProto() sesn.MgmtProto
  • func (t *Transceiver) ProcessCoapReq(data []byte) (coap.Message, error)
  • func (t *Transceiver) SetFilters(txFilter nmcoap.TxMsgFilter, rxFilter nmcoap.RxMsgFilter)
  • func (t *Transceiver) Stop()
  • func (t *Transceiver) StopListenCoap(mc nmcoap.MsgCriteria)
  • func (t *Transceiver) TxCoap(txCb TxFn, req coap.Message, mtu int) error
  • func (t *Transceiver) TxRxMgmt(txCb TxFn, req *nmp.NmpMsg, mtu int, timeout time.Duration) (nmp.NmpRsp, error)
  • func (t *Transceiver) TxRxMgmtAsync(txCb TxFn, req *nmp.NmpMsg, mtu int, timeout time.Duration, ch chan nmp.NmpRsp, ...) error
• type TxFn

Functions

func EncodeMgmt

func EncodeMgmt(s sesn.Sesn, m *nmp.NmpMsg) ([]byte, error)

Types

type Transceiver

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

func NewTransceiver

func NewTransceiver(txFilter nmcoap.TxMsgFilter, rxFilter nmcoap.RxMsgFilter, isTcp bool,
	mgmtProto sesn.MgmtProto, logDepth int) (*Transceiver, error)

func (*Transceiver) AbortRx

func (t *Transceiver) AbortRx(seq uint8)

func (*Transceiver) DispatchCoap

func (t *Transceiver) DispatchCoap(data []byte)

func (*Transceiver) DispatchNmpRsp

func (t *Transceiver) DispatchNmpRsp(data []byte)

func (*Transceiver) ErrorAll

func (t *Transceiver) ErrorAll(err error)

func (*Transceiver) ErrorOne

func (t *Transceiver) ErrorOne(seq uint8, err error)

func (*Transceiver) Filters

func (t *Transceiver) Filters() (nmcoap.TxMsgFilter, nmcoap.RxMsgFilter)

func (*Transceiver) ListenCoap

func (t *Transceiver) ListenCoap(
	mc nmcoap.MsgCriteria) (*nmcoap.Listener, error)

func (*Transceiver) MgmtProto

func (t *Transceiver) MgmtProto() sesn.MgmtProto

func (*Transceiver) ProcessCoapReq

func (t *Transceiver) ProcessCoapReq(data []byte) (coap.Message, error)

func (*Transceiver) SetFilters

func (t *Transceiver) SetFilters(txFilter nmcoap.TxMsgFilter,
	rxFilter nmcoap.RxMsgFilter)

func (*Transceiver) Stop

func (t *Transceiver) Stop()

func (*Transceiver) StopListenCoap

func (t *Transceiver) StopListenCoap(mc nmcoap.MsgCriteria)

func (*Transceiver) TxCoap

func (t *Transceiver) TxCoap(txCb TxFn, req coap.Message, mtu int) error

func (*Transceiver) TxRxMgmt

func (t *Transceiver) TxRxMgmt(txCb TxFn, req *nmp.NmpMsg, mtu int,
	timeout time.Duration) (nmp.NmpRsp, error)

func (*Transceiver) TxRxMgmtAsync

func (t *Transceiver) TxRxMgmtAsync(txCb TxFn, req *nmp.NmpMsg, mtu int,
	timeout time.Duration, ch chan nmp.NmpRsp, errc chan error) error

type TxFn

type TxFn func(req []byte) error