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 + const MAX_PACKET_SIZE_IN + const MAX_PACKET_SIZE_OUT + const UDP_RX_PORT + const UDP_TX_PORT + var LoraDataRateMapUS = map[string]int + func DenormalizeAddr(addr string) string + func NormalizeAddr(addr string) (string, error) + type Listener struct + ConnChan chan *LoraSesn + Crc uint16 + Data *bytes.Buffer + MsgChan chan []byte + MtuChan chan int + NextFrag uint8 + RefCnt int + func NewListener() *Listener + func (ll *Listener) Close() + type ListenerKey struct + Target string + Type string + func TgtKey(tgt string, msgType string) ListenerKey + func TgtPortKey(tgt string, port uint8, msgType string) ListenerKey + func TypeKey(msgType string) ListenerKey + type ListenerMap struct + func NewListenerMap() *ListenerMap + func (lm *ListenerMap) AddListener(key ListenerKey, listener *Listener) error + func (lm *ListenerMap) Dump() + func (lm *ListenerMap) FindListener(tgt string, port uint8, msgType string) (ListenerKey, *Listener) + func (lm *ListenerMap) RemoveKey(key ListenerKey) *Listener + func (lm *ListenerMap) RemoveListener(listener *Listener) *ListenerKey + type ListenerSlice struct + func NewListenerSlice() *ListenerSlice + func (lm *ListenerSlice) AddListener(key ListenerKey, listener *Listener) error + func (lm *ListenerSlice) FindListener(tgt string, msgType string) (ListenerKey, []*Listener) + func (lm *ListenerSlice) RemoveListener(listener *Listener) *ListenerKey + func (ls *ListenerSlice) Dump() + type LoraConfig struct + Addr string + ConfirmedTx bool + Port uint8 + SegSz int + type LoraData struct + Data string + Port uint8 + type LoraJoinedCb func(dev LoraConfig) + type LoraPacketSent struct + DataRate string + type LoraSesn struct + func NewLoraSesn(cfg sesn.SesnCfg, lx *LoraXport) (*LoraSesn, error) + func (s *LoraSesn) AbortRx(seq uint8) error + func (s *LoraSesn) Close() error + func (s *LoraSesn) CoapIsTcp() bool + func (s *LoraSesn) Filters() (nmcoap.TxMsgFilter, nmcoap.RxMsgFilter) + func (s *LoraSesn) IsOpen() bool + func (s *LoraSesn) ListenCoap(mc nmcoap.MsgCriteria) (*nmcoap.Listener, error) + func (s *LoraSesn) MgmtProto() sesn.MgmtProto + func (s *LoraSesn) Mtu() int + func (s *LoraSesn) MtuIn() int + func (s *LoraSesn) MtuOut() int + func (s *LoraSesn) Open() error + func (s *LoraSesn) RxAccept() (sesn.Sesn, *sesn.SesnCfg, error) + func (s *LoraSesn) RxCoap(opt sesn.TxOptions) (coap.Message, error) + func (s *LoraSesn) SetFilters(txFilter nmcoap.TxMsgFilter, rxFilter nmcoap.RxMsgFilter) + func (s *LoraSesn) StopListenCoap(mc nmcoap.MsgCriteria) + func (s *LoraSesn) TxCoap(m coap.Message) error + func (s *LoraSesn) TxRxMgmt(m *nmp.NmpMsg, timeout time.Duration) (nmp.NmpRsp, error) + func (s *LoraSesn) TxRxMgmtAsync(m *nmp.NmpMsg, timeout time.Duration, ch chan nmp.NmpRsp, errc chan error) error + type LoraXport struct + func NewLoraXport(cfg *LoraXportCfg) *LoraXport + func (lx *LoraXport) BuildSesn(cfg sesn.SesnCfg) (sesn.Sesn, error) + func (lx *LoraXport) DumpListeners() + func (lx *LoraXport) SetJoinCb(joinCb LoraJoinedCb) + func (lx *LoraXport) Start() error + func (lx *LoraXport) Stop() error + func (lx *LoraXport) Tx(bytes []byte) error + type LoraXportCfg struct + AppPortDown int + AppPortUp int + func NewXportCfg() *LoraXportCfg