Versions in this module Expand all Collapse all v1 v1.0.2 Oct 3, 2023 v1.0.1 Oct 3, 2023 Changes in this version + func CompareMsgCriteria(mc1 MsgCriteria, mc2 MsgCriteria) int + func CreateMsg(isTcp bool, mp MsgParams) (coap.Message, error) + func Encode(m coap.Message) ([]byte, error) + func MatchMsgCriteria(listenc MsgCriteria, msgc MsgCriteria) bool + func NextMessageId() uint16 + func ParseOp(op string) (coap.COAPCode, error) + func SortListeners(listeners []*Listener) + type Dispatcher struct + func NewDispatcher(isTcp bool, logDepth int) *Dispatcher + func (d *Dispatcher) AddListener(mc MsgCriteria) (*Listener, error) + func (d *Dispatcher) Dispatch(data []byte) bool + func (d *Dispatcher) ErrorAll(err error) + func (d *Dispatcher) ErrorOne(mc MsgCriteria, err error) error + func (d *Dispatcher) ProcessCoapReq(data []byte) (coap.Message, error) + func (d *Dispatcher) RemoveListener(mc MsgCriteria) *Listener + type Listener struct + Criteria MsgCriteria + ErrChan chan error + RspChan chan coap.Message + func NewListener(mc MsgCriteria) *Listener + func (ol *Listener) AfterTimeout(tmo time.Duration) <-chan time.Time + func (ol *Listener) Close() + type MsgCriteria struct + Path string + Token []byte + func CriteriaFromMsg(msg coap.Message) MsgCriteria + func (mc *MsgCriteria) String() string + type MsgParams struct + Code coap.COAPCode + Observe ObserveCode + Payload []byte + Token []byte + Uri string + type ObserveCode int + const OBSERVE_NONE + const OBSERVE_START + const OBSERVE_STOP + func (o ObserveCode) Spec() int + type Reassembler struct + func NewReassembler() *Reassembler + func (r *Reassembler) RxFrag(frag []byte) *coap.TcpMessage + type Receiver struct + func NewReceiver(isTcp bool) Receiver + func (r *Receiver) Rx(data []byte) coap.Message + type RxFilterFunc func(msg coap.Message) (coap.Message, error) + func (f RxFilterFunc) Filter(msg coap.Message) (coap.Message, error) + type RxMsgFilter interface + Filter func(msg coap.Message) (coap.Message, error) + type TxMsgFilter interface + Filter func(msg coap.Message) (coap.Message, error) + Freeze func() + Unfreeze func()