Functions — github.com/jeffallen/mqtt

CodeHub MCPcopy Create free account

hub / github.com/jeffallen/mqtt / functions

Functions65 in github.com/jeffallen/mqtt

⨍ Functions 65 ◇ Types & classes 14

↓ 23 callersMethodString

↓ 13 callersMethodsubmit

Queue a message; no notification of sending is done.

↓ 6 callersMethodConnect

Connect sends the CONNECT message to the server. If the ClientId is not already set, use a default (a 63-bit decimal random number). The "clean sessio

↓ 6 callersMethodDisconnect

Disconnect sends a DISCONNECT message to the server. This function blocks until the disconnect message is actually sent, and the connection is closed.

↓ 6 callersMethodPublish

Publish publishes the given message to the MQTT server. The QosLevel of the message must be QosAtLeastOnce for now.

↓ 6 callersMethodSubscribe

Subscribe subscribes this connection to a list of topics. Messages will be delivered on the Incoming channel.

↓ 5 callersFunctionstatsMessage

(topic string, stat int64)

↓ 4 callersFunctionisWildcard

↓ 3 callersMethodWritePayload

↓ 3 callersMethodadd

Add this connection to the map, or find out that an existing connection already exists for the same client-id.

↓ 3 callersFunctionconnect

pingtest/main.go:198

↓ 3 callersMethodsync

sync sends a message and blocks until it was actually sent.

↓ 2 callersMethodStart

Start makes the Server start accepting and handling connections.

↓ 2 callersFunctionconnect

loadtest/main.go:117

↓ 2 callersFunctionheader

header is used to initialize a proto.Header when the zero value is not correct. The zero value of proto.Header is the equivalent of header(dupFalse, p

↓ 2 callersMethodmatches

(parts []string)

↓ 2 callersFunctionnewWild

(topic string, c *incomingConn)

↓ 2 callersMethodnextid

↓ 2 callersMethodvalid

↓ 1 callersMethodSize

↓ 1 callersMethodadd

(sample time.Duration)

pingtest/main.go:34

↓ 1 callersMethodcalculate

pingtest/main.go:41

↓ 1 callersFunctionclient

many/main.go:57

↓ 1 callersMethodclientConnect

↓ 1 callersMethodclientDisconnect

↓ 1 callersMethoddel

Delete a connection; the connection must be closed by the caller first.

↓ 1 callersMethodmessageRecv

↓ 1 callersMethodmessageSend

↓ 1 callersMethodnewIncomingConn

newIncomingConn creates a new incomingConn associated with this server. The connection becomes the property of the incomingConn and should not be touc

↓ 1 callersFunctionnewIntPayload

↓ 1 callersFunctionnewSubscriptions

↓ 1 callersFunctionping

pingtest/main.go:111

↓ 1 callersFunctionpub

loadtest/main.go:86

↓ 1 callersMethodpublish

(sub *subscriptions, interval time.Duration)

↓ 1 callersFunctionreadCert

See http://mosquitto.org/man/mosquitto-tls-7.html for how to make the server.{crt,key} files. Then use mosquitto like this to talk to it: mosquitto_s

smqttsrv/main.go:17

↓ 1 callersMethodreader

↓ 1 callersMethodreader

↓ 1 callersMethodrun

The subscription processing worker.

↓ 1 callersMethodsendRetain

(topic string, c *incomingConn)

↓ 1 callersMethodstart

Start reading and writing on this connection.

↓ 1 callersFunctionsub

(i int, wg *sync.WaitGroup)

loadtest/main.go:143

↓ 1 callersMethodsubmitSync

Queue a message, returns a channel that will be readable when the message is sent.

↓ 1 callersMethodsubscribers

Find all connections that are subscribed to this topic.

↓ 1 callersMethodunsub

Remove the subscription to topic for a given connection.

↓ 1 callersMethodunsubAll

Remove all subscriptions that refer to a connection.

↓ 1 callersMethodwait

Wait for the receipt to indicate that the job is done.

↓ 1 callersMethodwriter

↓ 1 callersMethodwriter

↓ 1 callersFunctionwsub

pingtest/main.go:221

FunctionNewClientConn

NewClientConn allocates a new ClientConn.

FunctionNewServer

NewServer creates a new MQTT server, which accepts connections from the given listener. When the server is stopped (for instance by another goroutine

MethodReadPayload

FunctionTestWild

(topic string, c *incomingConn)

loadtest/main.go:110

pingtest/main.go:55

loadtest/main.go:25

mqttsrv/main.go:13

many/main.go:26

ticktock/main.go:22

smqttsrv/main.go:25

(c *incomingConn, m *proto.Publish)