hub / github.com/256dpi/gomqtt
github.com/256dpi/gomqtt @v0.14.4
Chat with this repo
973 symbols
5,905 edges
105 files
444 documented · 46%
2 cross-repo links
What it actually does AI analysis from the code graph — generated when you open this
loading…
README
gomqtt
Go Packages for working with the MQTT 3.1.1 protocol.
Installation
$ go get github.com/256dpi/gomqtt
Extension points exported contracts — how you extend this code
Generic (Interface)Generic is an MQTT control packet that can be encoded to a buffer or decoded from a buffer. [14 implementers]
packet/packet.go
Server (Interface)
A Server is a local port on which incoming connections can be accepted. [2 implementers]
transport/server.go
Dialer (Interface)
Dialer defines the dialer used by a client. [1 implementers]
client/config.go
GenericFuture (Interface)
A GenericFuture is returned by publish and unsubscribe methods. [1 implementers]
client/futures.go
Session (Interface)
A Session is used to persist incoming and outgoing packets. [1 implementers]
client/client.go
Carrier (Interface)
A Carrier is a generalized stream that can be used with BaseConn. [1 implementers]
transport/base_conn.go
Session (Interface)
A Session is used to get packet ids and persist incoming/outgoing packets. [1 implementers]
broker/client.go
Conn (Interface)
A Conn is a connection between a client and a broker. It abstracts an existing underlying stream connection.
transport/conn.go
Core symbols most depended-on inside this repo
Waitcalled by 208
client/futures.go
Receive
called by 202
transport/flow/flow.go
Error
called by 168
packet/error.go
Send
called by 160
transport/flow/flow.go
New
called by 89
client/client.go
Close
called by 89
transport/server.go
Connect
called by 88
client/client.go
NewConfig
called by 87
client/config.go
Shape
Languages
Go100%
Modules by API surface
topic/tree_test.go44 symbols
broker/client.go42 symbols
packet/identified.go38 symbols
packet/connect_test.go37 symbols
topic/tree.go35 symbols
client/client.go31 symbols
client/client_test.go28 symbols
packet/naked.go24 symbols
transport/flow/flow.go23 symbols
transport/websocket_conn_test.go22 symbols
transport/net_conn_test.go21 symbols
packet/publish_test.go19 symbols
Used by 2 indexed graphs manifest dependencies, hub-wide
For agents
$ claude mcp add gomqtt \
-- python -m otcore.mcp_server <graph>