MCPcopy Index your code
hub / github.com/VolantMQ/volantmq

github.com/VolantMQ/volantmq @v0.3.2

Chat with this repo
repository ↗ · DeepWiki ↗ · release v0.3.2 ↗ · + Follow
622 symbols 1,568 edges 54 files 205 documented · 33% updated 3y agov0.4.0-rc.8 · 2020-04-14★ 98820 open issues
What it actually does AI analysis from the code graph — generated when you open this
loading…
README

VolantMQ

Build Status BCH compliance Codacy Badge codecov.io License

VolantMQ image VolantMQ image by [Marina Troian ][rf], licensed under [Creative Commons 3.0 Attributions license][cc3-by].

VolantMQ is a high performance MQTT broker that aims to be fully compliant with MQTT specs

Features, Limitations, and Future

Features * MQTT v3.1 - V3.1.1 * MQTT V5.0 * WebSockets transport * SSL for both plain tcp and WebSockets transports * Independent auth providers for each transport * Persistence providers

Persistence providers * BBolt * In memory

Compatibility

Project has been tested with the following client libraries * Paho MQTT Conformance/Interoperability Testing Suite (in Python) * Pass with all of the test cases * Paho C Client library (in C) * Pass with all of the test cases

How to use

Best option is to run prebuilt docker image

docker run --rm -p 1883:1883 -p 8080:8080 -v $(pwd)/examples/config.yaml:/etc/volantmq/config.yaml --env VOLANTMQ_CONFIG=/etc/volantmq/config.yaml volantmq/volantmq
  • In example above port 1883 is mqtt listener with default user/password testuser/testpassword
  • Port 8080 exposes healthcheck endpoints as well as pprof at http://localhost:8080/debug/pprof

Contributing guidelines

Credits

Appreciate JetBrains for granted license

Extension points exported contracts — how you extend this code

PacketsMetric (Interface)
PacketsMetric packets metric [2 implementers]
systree/interfaces.go
TopicMessenger (Interface)
TopicMessenger interface for session or systree used to publish or retain messages [2 implementers]
types/types.go
SubscriberInterface (Interface)
SubscriberInterface used by subscriber to handle messages [2 implementers]
topics/types/types.go
SessionCallbacks (Interface)
SessionCallbacks ... [1 implementers]
connection/connection.go
DynamicValue (Interface)
DynamicValue interface describes states of the dynamic value [1 implementers]
systree/types.go
Pool (Interface)
Pool implements logic of goroutine reuse. [1 implementers]
types/pool.go
Handler (Interface)
Handler ... [1 implementers]
transport/conn.go
Server (Interface)
Server server API [1 implementers]
server/volantmq.go

Core symbols most depended-on inside this repo

Add
called by 30
types/queue.go
subscriptionInsert
called by 24
topics/mem/node.go
subscriptionSearch
called by 24
topics/mem/node.go
subscriptionSearch
called by 24
topics/memLockFree/node.go
Topic
called by 18
types/types.go
Subscribe
called by 16
topics/types/types.go
Do
called by 15
types/types.go
subscriptionInsert
called by 14
topics/memLockFree/node.go

Shape

Method 328
Function 149
Struct 101
Interface 28
TypeAlias 9
FuncType 7

Languages

Go100%

Modules by API surface

connection/connection.go51 symbols
clients/sessions.go32 symbols
connection/writer.go29 symbols
systree/interfaces.go28 symbols
topics/mem/trie_test.go26 symbols
cmd/volantmq/main.go23 symbols
topics/memLockFree/node.go22 symbols
topics/mem/node.go21 symbols
configuration/configTypes.go19 symbols
topics/types/types.go18 symbols
connection/options.go18 symbols
clients/session.go18 symbols

For agents

$ claude mcp add volantmq \
  -- python -m otcore.mcp_server <graph>

⬇ download graph artifact

Ask about this repo answers extend the page