mtp

package
v0.0.0-...-1242a22 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 30, 2023 License: Apache-2.0 Imports: 22 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CoAPServerThread

func CoAPServerThread(c *CoAP)

func MqttInit

func MqttInit() (mqtt.Client, error)

func MqttStart

func MqttStart(mc mqtt.Client) error

func SetRxChannel

func SetRxChannel(rxChannel chan RxChannelData)

func StompReceiveThread

func StompReceiveThread(s *Stomp, rxChannel chan RxChannelData)

Types

type AgentCoap

type AgentCoap struct {
	Port        string
	Path        string
	IsEncrypted string
	// contains filtered or unexported fields
}

func (AgentCoap) GetMsgCnt

func (c AgentCoap) GetMsgCnt() uint64

func (AgentCoap) IncMsgCnt

func (c AgentCoap) IncMsgCnt()

func (AgentCoap) SendMsg

func (c AgentCoap) SendMsg(msg []byte) error

type AgentStomp

type AgentStomp struct {
	Conn      *stompngo.Connection
	DestQueue string
	MsgCnt    uint64
}

func (AgentStomp) GetMsgCnt

func (s AgentStomp) GetMsgCnt() uint64

func (AgentStomp) IncMsgCnt

func (s AgentStomp) IncMsgCnt()

func (AgentStomp) SendMsg

func (s AgentStomp) SendMsg(msg []byte) error

type CoAP

type CoAP struct {
	Router *mux.Router
}

func CoAPServerInit

func CoAPServerInit() (*CoAP, error)

type Mqtt

type Mqtt struct {
	Client mqtt.Client
}

type RxChannelData

type RxChannelData struct {
	Rec     []byte
	MtpType string
}

type Stomp

type Stomp struct {
	Conn      *stompngo.Connection
	RxChannel <-chan stompngo.MessageData
}

func StompInit

func StompInit() (*Stomp, error)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL