Liu Song’s Projects


~/Projects/mqtt-go

git clone https://code.lsong.org/mqtt-go

History

ref
main
Hash Date Commit message Author
0d121537 2023-11-23 17:04:53 update Lsong
99e50ae7 2023-10-24 18:28:39 Revert "improve transport performance with bufio (#321)" (#323) JB
8e52e49b 2023-10-22 18:41:28 improve transport performance with bufio (#321) x20080406
4c0c862d 2023-10-21 13:10:02 Fix for unlimited maximum message expiry interval (#315) Marco Debus
2f2d8671 2023-10-16 18:03:54 Remove vendor folder (#319) JB
916d0220 2023-10-12 10:25:47 Bump golang.org/x/net from 0.7.0 to 0.17.0 (#316) dependabot[bot]
11e02569 2023-10-04 03:45:34 update README-CN.md (#312) werbenhu
858a28ea 2023-10-02 19:29:24 Update README.md JB
82f32cf5 2023-10-02 19:17:03 Indicate translators wanted JB
b4e2c61a 2023-10-01 21:49:30 Emit warning if client keepalive is less than recommended minimum (#305) JB
2b0732b8 2023-10-02 04:44:15 Add a Chinese version of README.md. (#307) werbenhu
450b8a28 2023-09-29 19:06:07 only build docker on tag for mochi-mqtt repo mochi-co
0d880fa9 2023-09-30 01:55:47 Add some error logging in Listener.Serve(). (#303) werbenhu
a5310bdf 2023-09-29 18:21:24 Update build.yml JB
96b96e82 2023-09-28 23:26:05 Update build.yml JB
a786a0a5 2023-09-28 23:21:02 Update build.yml JB
c6297ee9 2023-09-28 23:10:59 Update build.yml JB
2f947512 2023-09-28 23:05:55 Update build.yml JB
89a78683 2023-09-28 22:54:23 Update build.yml JB
8f93e35f 2023-09-28 22:41:49 Fix docker repo name JB
ba6b12a3 2023-09-28 22:39:57 Update build.yml JB
a3fe5d47 2023-09-28 22:29:32 Update build.yml JB
bb5fc40f 2023-09-28 22:26:53 Update build.yml JB
fbb1fb25 2023-09-22 19:47:33 Refactor Listener WG to track clients (#301) JB
fac733fd 2023-09-08 23:24:51 Update readme v2.4.0 mochi-co
add87fea 2023-09-08 23:06:14 Small fixes and cleanups (#295) JB
58f9fed3 2023-09-08 12:51:35 Disconnect or return ack if unauthorized publish (#292) thedevop
15744439 2023-09-09 03:45:08 Another code implementation for Inline Client Subscriptions. (#284) werbenhu
44bac0ad 2023-09-06 09:21:04 Migrate from zerolog to slog (#248) Derek Duncan
e784c755 2023-09-06 22:15:08 add aclcheck in publishToClient (#287) xyzj
eafc2d91 2023-08-12 03:00:52 Fix readme example (#276) Derek Duncan
0df69a4a 2023-08-01 17:25:17 Use JSONeq to compare JSON (#267) Wind
321a0514 2023-07-31 21:02:14 Update README.md JB
00387593 2023-07-31 20:56:51 Fix badges JB
af78d108 2023-07-31 20:55:06 Update README.md JB
30ca94e8 2023-07-31 13:27:06 Update README.md JB
ae3f72f6 2023-07-31 13:26:26 migrate imports, copyrights, etc (#270) JB
9838262e 2023-07-20 23:08:10 Update server version mochi-co
ac812154 2023-07-20 22:52:16 Allow Publish to return custom Ack error responses (#256) JB
02345891 2023-07-20 14:49:34 fix: fix data-race in badger hook (#266) Gabriel Sagula
ea970380 2023-07-21 05:41:49 method UnsubscribeClient's packet add fixedHeader (#264) KE
48233334 2023-07-16 20:41:28 Do not retain messages if retain is not available (#261) JB
33429451 2023-07-16 20:39:43 Preference Write, Read, Deny filters in ledger (#262) JB
050e2466 2023-07-16 20:36:45 Retain flag should be delivered as false in v3 (#257) JB
aec29e35 2023-07-16 15:36:15 Fix websocket reads for packets > 1 buffer size (#260) Ian Rose
cb99d6f4 2023-07-13 21:36:21 Update README.md JB
c77d1c03 2023-07-13 13:19:22 Ensure msg doesn't exceed subscription QoS (#253) thedevop
6f42c3fd 2023-07-14 01:12:11 WriterSize parameter is incorrectly set (#252) Wind
9c522927 2023-07-08 13:48:59 Small language clarification for non-english mochi-co
990f308f 2023-07-08 13:47:55 Update server version mochi-co
fe0c1d15 2023-07-08 07:09:58 Add OnSessionEstablish hook (#247) Derek Duncan
0648e395 2023-06-19 10:28:22 Update Readme mochi-co
233a82e4 2023-06-19 10:22:55 Add Healthcheck listener mochi-co
51a8d8cb 2023-06-19 10:15:37 Update README.md JB
23c32083 2023-06-19 10:14:07 Update SPDX annotations mochi-co
23e1092c 2023-06-19 10:13:43 Update Contribution Guidelines mochi-co
d4985769 2023-06-19 09:51:41 Update server version mochi-co
7e14ce99 2023-06-19 03:44:03 Add healthcheck listener (#244) Derek Duncan
4db49a4b 2023-06-19 01:42:16 Fix ScanSubscribersTopicInheritanceBug (#243) thedevop
e60b8ff0 2023-06-14 20:12:52 Update Hooks List mochi-co
b9d5dcb5 2023-06-14 20:12:31 Update Server Version mochi-co
6d394d1f 2023-06-14 20:05:02 Expose SendConnack, err return on OnConnect (#240) JB
1ee21587 2023-06-13 11:24:04 Add OnRetainPublished hook (#237) thedevop
af79b55b 2023-06-04 07:32:34 Update server version mochi-co
e1a9497c 2023-06-04 16:31:55 Add retainMessage to LWT to properly handle message retention (#234) Derek Duncan
62659e17 2023-05-18 20:29:56 Update server version mochi-co
7ad6dd8e 2023-05-18 15:14:50 Now when a "publish" command fails, then the publish method will throw an error (#229) Hector Oliveros
565e0774 2023-05-18 12:01:35 Minimize client lock duration (#223) thedevop
6acd775a 2023-05-18 11:14:29 Fix example usage of NewHTTPStats (#231) plourdedominic
493f6c8b 2023-05-15 20:01:12 Update README.md new benchmarks JB
d3785c27 2023-05-08 11:43:46 update server version mochi-co
52a34716 2023-05-08 03:30:44 Use context to exit WriteLoop (#222) thedevop
797d75cb 2023-05-06 14:32:42 update server version mochi-co
5225a357 2023-05-06 14:11:54 refactor server keepalive for hook access (#220) JB
a734a0dc 2023-05-06 11:55:40 Use context to signal client open state (#218) JB
6704cf72 2023-05-06 10:37:27 Add packet ID exhausted hook (#217) JB
9233e6fd 2023-05-06 02:12:33 Expire session if SessionExpiryInterval is 0 (#216) thedevop
1ca65d96 2023-05-06 10:02:25 Update codes.go (#215) ħþ
33229da8 2023-05-06 09:59:50 Update codes.go (#214) ħþ
c274d5fd 2023-05-05 00:04:27 Update server version mochi-co
10e82f41 2023-05-05 00:02:49 Lock on close outbound (#213) JB
e6c07b2b 2023-05-04 23:17:12 Add lock to client writes (#212) JB
eed3ef96 2023-05-04 22:51:40 Add OnPacketIDExhausted hook (#211) JB
1ec88084 2023-05-04 22:37:23 Correctly validate WillProperties (#210) JB
4b49652a 2023-05-05 01:09:58 Update build.yml (#203) werbenhu
d46e7b5b 2023-04-21 22:00:27 Protect close of nil outbound channel mochi-co
17fb7dad 2023-04-21 22:00:27 Protect close of nil outbound channel mochi-co
ed7fd836 2023-04-22 04:52:44 #78 storage hook should not execute the relevant code if the client has been reconnected (#198) werben
605bb93c 2023-04-21 21:49:49 Move msgToPacket to storage.Message.ToPacket mochi-co
c73ace2e 2023-04-22 04:29:03 Simplified code (#195) Wind
aac6d699 2023-04-21 13:20:46 Ensure to close client WriteLoop (#193) thedevop
7bd7bd50 2023-03-12 00:17:10 fix: common subscriptions issued by different clients at the same time may be lost (#186) Hubertus Hohl
655bf9fd 2023-03-11 23:15:51 Update readme mochi-co
b188055c 2023-03-11 23:14:06 Update server version mochi-co
aaf1d9d4 2023-03-11 23:13:28 Configurable client bufio reader/writer sizes (#190) JB
44ce8193 2023-02-28 20:57:59 Update server version mochi-co
e4c76cc6 2023-02-28 20:57:33 Bump golang.org/x/net from 0.0.0-20220927171203-f486391704dc to 0.7.0 (#182) dependabot[bot]
da79faa9 2023-02-28 12:53:26 Skip expire cleanup for isTakenOver session (#183) thedevop
46babc89 2023-02-25 01:37:54 Allow 0 byte usernames if correctly formed (#181) JB
9b7a9438 2023-02-25 01:24:17 Correctly identify and clean taken-over sessions (#180) JB
a909d309 2023-02-22 23:33:49 Small style fix mochi-co
0851b09e 2023-02-22 23:06:06 Update server version mochi-co
a302c9dd 2023-02-22 15:02:44 Use *packets.Packet for outbound chan (#176) thedevop
1e8f9221 2023-02-20 18:14:57 update server version mochi-co
4c16e559 2023-02-20 19:14:19 fix: correct decoding of packets including Properties exceeding 127 bytes in length (#172) Hubertus Hohl
49cada4f 2023-02-10 23:39:19 Update server version mochi-co
ef34510c 2023-02-10 23:38:20 Expose dropped publish messages count in sys info (#170) JB
e5716caa 2023-02-10 23:27:21 Fix potential NextPacketID endless loop, expand tests (#169) JB
4b039cb3 2023-02-10 06:44:01 Add PublishDropped metrics (#167) thedevop
aac24544 2023-02-09 23:57:24 No longer issue retained messages on session takeover (#166) JB
bb54cc68 2023-02-09 22:34:30 Client write buffers (#165) JB
7ba1352a 2023-02-09 11:07:17 Add Clone to system.Info (#163) thedevop
ca849131 2023-02-05 11:07:07 Update server version mochi-co
ba7e5341 2023-02-05 18:53:49 failed to delete inflight data (#162) Wind
db760c34 2023-02-04 10:57:27 Update server version mochi-co
ae3ee81b 2023-02-04 10:53:45 Rename Quota methods for clarity (#159) JB
c2ca02d1 2023-02-04 10:16:05 Move refreshDeadline to only trigger on successful transmission (#157) JB
77a64d9c 2023-02-04 11:10:10 Include a listener accepting an existing net.Listener (#155) Jeroen Rinzema
8dec9cc9 2023-02-04 18:06:26 invalid config type provided (#152) Wind
f90e5232 2023-01-16 20:08:43 Update server version mochi-co
50aae476 2023-01-16 19:50:01 Publish retained messages only after connack (#147) JB
0d79f2d6 2023-01-16 19:49:36 Use Atomic instead of RWMutex for Hooks concurrency (#148) JB
30015241 2023-01-13 23:38:49 Ignore retain as published v3 (#142) JB
0de1d731 2023-01-10 00:01:14 Update version number mochi-co
80746abc 2023-01-10 00:00:43 Use correct connack return codes for MQTTv3 (#140) JB
a73cf4ca 2023-01-09 23:08:49 Update server version mochi-co
bc549ee7 2023-01-09 22:52:24 Fix example imports mochi-co
c464b467 2023-01-09 22:49:40 export client.Net.Conn for external use mochi-co
05ce5600 2023-01-09 22:49:20 Small code improvements mochi-co
8254cb0c 2023-01-09 22:41:44 Make hooks safe for concurrency (#139) JB
4ae58b79 2023-01-07 20:13:48 Update server version mochi-co
b895d688 2023-01-07 12:02:05 Change inline check order (#133) thedevop
a600cd4e 2023-01-07 17:57:04 fix grammar on Closed method doc mochi-co
cdb44990 2023-01-07 17:30:58 Update version number mochi-co
2d9c1281 2023-01-07 17:30:30 Refactor stored subscription value assignments mochi-co
a0d5bdb3 2023-01-07 17:30:01 Fix Typos mochi-co
4ebcef3c 2023-01-08 01:24:23 Save subscription properties for mqttv5 (#131) Wind
fb8d4720 2023-01-07 09:14:51 Add Client Closed (#130) thedevop
4080c891 2022-12-21 21:00:53 Update README.md JB
1b67e6f3 2022-12-21 20:58:25 Update README.md JB
1adb02e0 2022-12-21 20:47:58 Update readme and server version mochi-co
4d4140aa 2022-12-21 20:37:08 Connect ReturnResponseInfo only applies to Connack values (#128) JB
e31840a3 2022-12-21 19:44:25 Optimize inflight expiry (#127) JB
7d2e16f2 2022-12-21 11:41:14 Merge pull request #123 from wind-c/master JB
92cd935a 2022-12-21 11:38:28 Merge branch 'master' into master JB
25ce27ce 2022-12-21 11:28:23 Merge pull request #124 from zgwit/master JB
527d084a 2022-12-20 23:02:59 Add unix socket listener jason
bb9f937b 2022-12-18 13:46:06 Variable existed in the method processSubscribe is unstable Wind
511fe886 2022-12-17 12:33:09 Merge branch 'mochi-co:master' into master Wind
75504ff2 2022-12-16 18:27:29 Update server version JB
a556feb3 2022-12-17 02:23:58 Add the OnUnsubscribed hook to the unsubscribeClient method (#122) Wind
d06f47f4 2022-12-17 00:40:06 Add the OnUnsubscribed hook to the unsubscribeClient method “Wind”
8d4cc091 2022-12-16 00:31:59 Update version number JB
d8f28cb8 2022-12-16 00:30:23 Enforce server max packet (#121) JB
88861c21 2022-12-15 18:21:53 Merge pull request #116 from tommyminds/bugfix/ws_malformed_package JB
7ba6cf28 2022-12-15 18:21:33 Merge branch 'master' into bugfix/ws_malformed_package JB
c174cfdc 2022-12-15 18:21:19 Merge pull request #119 from mochi-co/fix-on-published JB
4f198a99 2022-12-15 18:19:02 Fix mis-typed onpublished hook, update version, fanpool defaults mochi-co
2a9c9fcc 2022-12-14 21:41:33 Fix websocket malformed packet bug Tommy Maintz
835a85c8 2022-12-12 11:44:36 Update README.md JB
fe5d9ffa 2022-12-12 11:37:19 Simplify Client construction, add NewClient method to Server, add Publish convenience method mochi-co
aac186dc 2022-12-11 22:25:21 Add newline for godoc formatting mochi-co
42931f33 2022-12-11 21:44:44 Update badges to use v2 references JB
8a04648c 2022-12-11 21:38:01 Cleanup godoc formatting mochi-co
854c033f 2022-12-11 12:21:25 Update README.md JB
74ed8cd0 2022-12-11 11:50:36 Update go mod and imports to v2 mochi-co
be164fa7 2022-12-11 11:43:55 Update go.mod JB
42879551 2022-12-11 11:42:43 Update go.mod JB
bbf08ff4 2022-12-10 22:51:01 Update README.md JB
c38201ff 2022-12-10 22:32:53 Update README.md JB
f8b4ff5c 2022-12-10 22:29:11 Update README.md JB
661e23e0 2022-12-10 22:11:39 Update README.md JB
9c99db42 2022-12-10 21:58:03 Update build.yml JB
40b7273a 2022-12-10 21:52:06 update github workflow go version to 1.19 mochi-co
898c90d4 2022-12-10 21:48:37 Rewrite everything from scratch for mqtt v5 mochi-co
bc3d8b0e 2022-11-14 21:57:14 Update README.md JB
35bd9287 2022-11-14 21:56:29 Update README.md JB
20c2655d 2022-10-01 11:29:20 Update README.md JB
fec25f29 2022-10-01 00:23:07 Update README.md JB
1d7a3222 2022-10-01 00:22:08 Update README.md JB
d8b38a4a 2022-09-16 13:37:35 Update README.md JB
a83c0c4f 2022-09-16 13:37:07 Contributions paused pending v2.0.0 JB
66a1d19e 2022-09-16 13:32:53 Update README.md JB
0dbebbc0 2022-09-11 22:45:57 Revert "Merge pull request #97 from alexsporn/fix/writer-full" mochi-co
f22b8276 2022-09-10 18:20:09 Merge pull request #97 from alexsporn/fix/writer-full JB
d60c4389 2022-09-09 16:07:21 Merge branch 'mochi-co:master' into fix/writer-full Alexander Sporn
b2fc287a 2022-09-02 21:05:47 Merge pull request #99 from mochi-co/fix-inflight-race JB
3e3ba20b 2022-09-02 20:54:20 Return copies of client and inflight maps to avoid missed locks mochi-co
9ee462c7 2022-09-02 20:53:34 Increase inlinepub messages buffer mochi-co
3c89114b 2022-09-02 12:20:54 Instead of waiting for the writing buffer to have enough space, skip writing and return an error Alexander Sporn
ecbd07fa 2022-08-18 00:19:11 Check against the correct clean session var for abandoning old inflights mochi-co
ad8bf2a9 2022-08-18 00:58:43 Keep in sync server.System.Inflight (#92) zynzel
b8fb068b 2022-08-16 22:21:23 Update README.md JB
c1348a37 2022-08-16 22:20:50 Update README.md JB
84fc2f84 2022-08-16 21:41:39 Abandon inflights at the end of clean-session connections mochi-co
8703d6d0 2022-08-16 21:31:42 Merge pull request #90 from mochi-co/resend-inflights JB
666440fe 2022-08-16 21:19:42 Adds Inflight TTL and Period Resend mochi-co
1ae05093 2022-06-22 15:52:36 Merge pull request #84 from mochi-co/goreport-fixes JB
f4683d27 2022-06-22 15:45:13 remove ineffective assignments mochi
dff2b1db 2022-06-22 15:40:52 apply gofmt -s mochi
9de6b4e4 2022-06-22 15:32:23 Merge pull request #83 from mochi-co/tls-client-auth JB
78c19142 2022-06-22 15:31:31 Merge pull request #82 from mochi-co/expose-event-client-username JB
f71bf5c3 2022-06-22 15:26:51 use TLSConfig instead of deprecated TLS field mochi
53c4a6b0 2022-06-22 15:26:26 Add TLSConfig field to allow direct tls.Config setting mochi
a02c6bd8 2022-06-22 15:25:52 update TLS example to use TLSConfig field mochi
d8f6d63c 2022-06-22 12:33:09 Add CleanSession and Username to events.Client struct mochi
bef13eec 2022-05-04 12:58:23 Add OnSubscribe, OnUnsubscribe events examples mochi
27f3c484 2022-05-04 12:53:04 Extend onsusbcribe, onunsubscribe events mochi
9b5cdb0b 2022-05-04 12:33:12 Merge pull request #74 from muXxer/feat/topic-subscription-events JB
2b60a11d 2022-04-28 00:48:20 Add topic un-/subscribe events muXxer
b53774f8 2022-04-19 08:58:46 Merge pull request #72 from BoskyWSMFN/master JB
7dee729a 2022-04-19 00:26:44 fix-panic BoskyWSMFN
aed535b7 2022-04-13 10:46:13 fix comments mochi
4ff888ab 2022-04-13 10:37:24 Add auth controller example mochi
31252c08 2022-04-10 20:46:16 Add Docker info JB
3a15cc3a 2022-04-10 20:23:43 Merge pull request #69 from mochi-co/v1.2.0 JB
765f6e7c 2022-04-10 20:19:06 use NewServer instead of New mochi
e3bdfc1f 2022-04-10 20:18:18 update readme for new events mochi
60cd972b 2022-04-10 19:55:34 Merge pull request #68 from mochi-co/fix-store-retained JB
ee081d0a 2022-04-10 19:54:37 Merge branch 'v1.2.0' of https://github.com/mochi-co/mqtt into fix-store-retained mochi
d97b4bb8 2022-04-10 19:53:46 Merge pull request #67 from mochi-co/release-client-buffers JB
94aeacf0 2022-04-10 19:46:12 only check final outcome due to races mochi
5cb8a081 2022-04-10 19:43:59 accept any error for invalid protocol due to races mochi
fc00112e 2022-04-10 19:42:37 Check for protocol violation errors mochi
bbc22fae 2022-04-10 19:30:26 Add comments mochi
82cb7591 2022-04-10 19:28:22 Remove unused code mochi
45c4a64b 2022-04-10 19:07:40 Abandon client state if the existing client specified a cleansession mochi
bae25794 2022-04-10 19:07:08 Expose CleanSession value for checking mochi
1bc01271 2022-04-10 18:47:45 Store retained message based on corrected r value mochi
352a71f5 2022-04-10 18:46:46 Expect correct r values for RetainMessage mochi
6f9f62e3 2022-04-10 18:46:23 Correctly return R value of retainMessage mochi
0f67d9e8 2022-04-10 17:37:46 Update EstablishConnection tests to ensure buffers and pool are correctly released after use mochi
f2dd5b63 2022-04-10 17:37:25 Export R/W buffer values so they can be assessed in tests without causing races mochi
54e2d044 2022-04-10 17:36:46 Track number of pool blocks in use mochi
6298a872 2022-04-10 14:58:59 Use package errors instead of strings mochi
b6fd25bb 2022-04-10 01:46:18 test clarbuffers mochi
eef35925 2022-04-10 01:46:04 clear buffers after deferred stop mochi
5d343c12 2022-04-10 01:34:01 refactor clients for buffer releasing mochi
70f52c8a 2022-04-10 01:33:35 Refactor establishconnection to prevent same-id disconnects mochi
429b7226 2022-04-10 01:32:24 refactor connSetup for clarity mochi
f60d2dcf 2022-04-10 01:32:04 Clarify error messages mochi
6674cd64 2022-04-10 01:31:36 clarify error checking mochi
f218cde6 2022-04-09 20:53:28 Use defer to release buffers and decrease stats on any client closure mochi
9ea687eb 2022-04-09 20:29:23 Merge pull request #61 from mochi-co/server-options JB
949e4e2e 2022-04-09 20:29:03 Merge pull request #63 from mochi-co/add-drop-packet-error JB
515e0269 2022-04-06 11:23:51 Merge pull request #62 from mochi-co/fix-inflight-key JB
ae6073c7 2022-03-31 18:23:12 track logged error mochi
b072a08f 2022-03-31 18:04:41 Update test to check for packet rejection mochi
01d8a450 2022-03-31 17:56:08 Ensure OnError is set before using it mochi
da2fd41f 2022-03-31 17:53:34 Update OnProcessMessage documentation mochi
56e80390 2022-03-31 17:53:13 Optionally drop a packet if the ErrRejectPacket error is returned from OnProcessMessage mochi
7b9bc844 2022-03-31 17:52:40 Add ErrRejectPacket error to abandon packet processing from OnMessageProcess mochi
8acb1828 2022-03-31 17:41:22 Merge pull request #53 from stffabi/feature/onprocessmessage-event JB
57268800 2022-03-31 17:36:03 fix inflight key reference mochi
ee459e1b 2022-03-31 17:32:17 Fix code block formatting mochi
6aec3a8b 2022-03-31 17:21:42 Update readme with server options mochi
74699f0a 2022-03-31 17:21:35 Add example implementation mochi
70def39f 2022-03-31 17:00:00 add tests for new NewServer function mochi
8e7098a3 2022-03-31 16:59:49 remove deprecated log message mochi
e4f02919 2022-03-31 16:49:27 Update code to use new NewServer function instead of deprecated New mochi
99c96c84 2022-03-31 16:49:02 Update example code to use new NewServer function instead of deprecated New mochi
18629aea 2022-03-31 16:48:42 Use internal default values instead of relying on passed value mochi
a0060429 2022-03-31 16:48:29 Add Server Options mochi
d946a9ae 2022-03-31 16:39:28 Update go mod to ensure bolt is using 1.3.5 mochi
51a2eb5f 2022-03-30 09:37:53 Merge pull request #57 from hybridgroup/v1.2.0-docker JB
0d4b0a89 2022-03-30 09:30:11 Merge pull request #58 from soyoo/patch-1 JB
0e7ccfe3 2022-03-25 16:55:57 typo soyoo
5d723063 2022-03-18 19:32:59 docker: add initial simple Dockerfile Ron Evans
6a3cbd60 2022-03-22 16:19:24 Merge pull request #51 from jmacd/jmacd/noracefix JB
7b4e7970 2022-03-21 10:11:29 Events: Add OnProcessMessage event stffabi
c6643592 2022-03-17 13:40:46 Combines two fixes Joshua MacDonald
5de12d04 2022-03-17 12:53:59 Merge branch 'master' of https://github.com/mochi-co/mqtt into v1.1.2 mochi
0a7205e1 2022-03-17 12:50:01 Update README.md JB
8133dd82 2022-03-17 12:48:37 Update README.md JB
fdbfff57 2022-03-17 09:41:48 Merge pull request #46 from stffabi/bugfix/acls-retain JB
f5fc5e8c 2022-03-17 09:13:03 Subscribe: Only send retained messages if ACLs has allowed subscription to the topic stffabi
9f44712b 2022-03-16 18:16:48 Fix incorrect test mochi
1f86168d 2022-03-16 19:12:07 Publish: Set the retain flag in the fixedheader (#42) stffabi
ab25083e 2022-03-16 18:09:00 Merge branch 'master' of https://github.com/mochi-co/mqtt into v1.1.2 mochi
9b0aa4d5 2022-03-15 20:04:04 Update README.md JB
03814944 2022-03-15 19:58:58 Update README.md JB
3286d5a4 2022-03-15 19:56:42 Replace Travis with Github Actions (#41) JB
7e970d3c 2022-03-15 19:13:24 Fix typo mochi
d6a92cc5 2022-03-15 18:44:49 Add Keyed fields to events.Client for readability and go vet mochi
325d44d4 2022-03-15 18:44:21 Add missing method comments mochi
0a5f6d3a 2022-03-15 10:59:52 Add an OnError handler; report the reason for disconnects. (#38) Joshua MacDonald
17253ad8 2022-03-15 10:34:49 Wrap packet errors with cause information (#39) Joshua MacDonald
9f1c3870 2022-03-15 10:33:31 Move two WaitGroup.Add calls (#36) Joshua MacDonald
9c6f6026 2022-02-27 08:36:40 Merge pull request #29 from jmacd/jmacd/payload_not_utf8 JB
b0dcaabd 2022-02-26 22:53:51 Support non-UTF8 payloads per MQTT specification Joshua MacDonald
460f0ef6 2022-02-24 21:19:46 revert redis update JB
6e16765f 2022-02-24 21:19:22 revert server version JB
2b361df1 2022-02-24 21:15:08 Merge pull request #27 from mochi-co/revert-26-master JB
c8c0a5a0 2022-02-24 21:10:39 Revert "added redis persistence mode" JB
4a833dd0 2022-02-24 21:07:54 Update server version JB
81198d98 2022-02-24 21:07:24 Update README.md JB
6c12d8a7 2022-02-24 21:05:35 Merge pull request #26 from wind-c/master JB
19b598b6 2022-02-23 16:00:32 redis and trie narwal
b6529f05 2022-02-22 18:57:31 add redis persistence mode and example narwal
7f76445c 2022-01-30 10:39:49 update server version mochi
b1c01792 2022-01-30 10:38:28 Merge pull request #24 from mochi-co/feature/optimise-struct-fields JB
eda03d43 2022-01-30 10:30:34 optimise Server struct mochi
18070f1f 2022-01-30 10:30:19 pass byte pool by address mochi
7f10c28a 2022-01-30 10:30:01 remove println mochi
122531bb 2022-01-28 21:07:10 Pass inflight by address to avoid lock copying mochi
e6dbcae4 2022-01-28 21:06:57 Correct function signature mochi
98875de5 2022-01-28 21:06:43 Update test to match new FixedHeader struct mochi
c9fd9451 2022-01-28 21:06:24 Prevent locks from being copied mochi
6550b8d6 2022-01-28 21:05:50 8bit align struct fields mochi
a60c96c8 2022-01-28 21:04:15 Update comment for clarity mochi
86e0a582 2022-01-26 20:49:53 Update version to 1.1.0 mochi
06c399b6 2022-01-26 20:49:42 indicate ARM32 compatibility mochi
ed117f67 2022-01-26 20:36:13 Merge pull request #22 from mochi-co/feature/32bit-compatibility JB
880a3299 2022-01-26 08:02:57 Merge pull request #19 from rkennedy/bugfix/32-bit-atomic-alignment JB
1c408d05 2022-01-25 00:03:50 Fix encodeLength for 32-bit platforms Rob Kennedy
fce495f8 2022-01-25 00:00:43 Avoid race condition when closing listeners Rob Kennedy
471ca00a 2022-01-24 22:03:42 Make atomics work on 32-bit systems Rob Kennedy
a2c07496 2022-01-24 18:46:34 Update server version to 1.0.5 mochi
37293aee 2022-01-24 18:44:39 Merge pull request #18 from mochi-co/feature/connect-disconnect-hooks JB
7a2d4db6 2022-01-24 18:42:09 Update for OnConnect and OnDisconnect hooks mochi
03d2a8bc 2022-01-24 18:29:18 Add tests for OnConnect, OnDisconnect mochi
4b51e5c7 2022-01-24 17:42:33 Add OnConnect and OnDisconnect hooks to example mochi
d15ad682 2022-01-24 17:42:19 Call OnDisconnect Event if applicable mochi
130ffcbb 2022-01-24 17:42:04 Add OnDisconnect Event Hook mochi
33cf2f99 2022-01-24 17:41:46 Add testbolt file to ignore list mochi
a360ea6a 2022-01-24 17:37:11 Call OnConnect Event if applicable mochi
ae3aa0d3 2022-01-24 17:36:50 Add OnConnect event hook mochi
811ae0e1 2022-01-24 17:36:14 Prevent locks being copied by passing non-pointer to FromClient mochi
51d68254 2022-01-17 10:08:20 Merge pull request #15 from ClarkQAQ/master JB
514288c5 2022-01-16 20:06:49 update tcp.go maybe this will be better clark
957fc0a0 2022-01-16 18:23:45 fix local variable black hole clark
03f94f94 2022-01-16 18:22:37 update mock.go plase use range clark
1bc752a2 2022-01-16 18:21:33 fix [ST1005] strings should not be capitalized clark
b9db59ba 2022-01-16 18:20:06 update websocket.go fix check origin clark
c0ef58c3 2022-01-14 17:48:21 Update README.md JB
994adea3 2022-01-14 17:38:29 Merge pull request #14 from mochi-co/feature/allow-clients-value JB
fc61cc9b 2022-01-14 17:04:55 Add example for AllowClients field mochi
22d73388 2022-01-14 17:04:39 Add test for AllowClients field mochi
3f285157 2022-01-14 17:04:21 Remove unnecessary type declarations mochi
7d73ce9c 2022-01-14 17:04:01 Add setupServerClients to inherit existing server instance mochi
0758bc96 2022-01-14 17:02:31 Add AllowClients check in publishToSubscribers mochi
8472b9ae 2022-01-14 17:01:42 use .systemInfo instead of .system for clarity mochi
530a018e 2022-01-14 17:01:31 use .systemInfo instead of .system for clarity mochi
0b594afb 2022-01-14 16:59:17 Add AllowClients field to packets mochi
9d0ea957 2022-01-14 16:58:48 Increment server version mochi
8067785a 2022-01-14 16:58:33 Add tests for InSliceString mochi
6ffc8a83 2022-01-14 16:58:21 Add InSliceString function mochi
fb136483 2022-01-10 23:50:40 Revert server version mochi
b209cd95 2022-01-10 23:48:33 increment server version mochi
3a7e58ec 2022-01-10 23:47:33 Remove unnecessary fmt import mochi
a674632c 2022-01-10 23:41:46 Increment server version mochi
09ddc412 2022-01-10 23:38:33 Merge pull request #12 from jphastings/remove-erroneous-print JB
6fbd8a5e 2022-01-10 23:36:33 Remove unnecessary println JP Hastings-Spital
d4ae73a9 2022-01-05 21:43:47 fix indentation in code blocks JB
3ff853a9 2022-01-05 21:41:45 Update README.md JB
4302eed8 2022-01-05 21:28:00 Update vendor mochi
a1fee6ff 2022-01-05 21:27:52 Update go mod to 1.17 mochi
7fbc0b01 2022-01-05 21:26:11 fix code indents mochi
8bbca347 2022-01-05 21:21:35 Update go to 1.17 mochi
b2776008 2022-01-05 21:14:11 Increment server version to 1.0.1 mochi
685c050f 2022-01-05 21:13:01 Merge pull request #11 from mochi-co/feature/event-hooks-publish JB
0abbaf50 2022-01-05 21:09:12 fix onmessage test mochi
1ab1928c 2022-01-05 21:05:31 change scheduled message for clarity mochi
8890bb9d 2022-01-05 21:05:20 remove redundant code mochi
f9348aaf 2022-01-05 20:59:25 Update Readme to add Event Hooks section mochi
c2a42a16 2022-01-05 20:59:14 Merge OnMessage and OnMessageModify mochi
d14d944d 2022-01-05 20:38:32 Update events example with publish hooks mochi
480e60b3 2022-01-05 20:38:10 Adds tests for publishing event hooks mochi
d4cbf1ab 2022-01-05 20:38:00 Add Event Hooks mochi
8a1c5343 2022-01-05 20:37:15 Add Events mochi
7c7b8d58 2022-01-05 18:10:24 Return packets to internal mochi
ce773b39 2022-01-05 17:06:36 Merge pull request #10 from mochi-co/expose-packets JB
f3e74694 2022-01-05 17:02:14 Merge pull request #8 from mochi-co/feature/inline-publish JB
b5685ca0 2022-01-05 17:01:15 update packets library import reference mochi
66edb056 2022-01-05 17:00:51 expose packets library mochi
1d9fa419 2022-01-05 17:00:17 Add .DS_Store to ignore list mochi
dec88023 2022-01-05 13:49:41 Update with direct publishing mochi
21d4e54e 2022-01-05 13:48:17 Add inline publishing example mochi
aeb41907 2022-01-05 13:32:28 Add tests for new inline publishing method mochi
484e4abd 2022-01-05 13:32:12 Directly publish messages from embedding system mochi
d51bad30 2022-01-05 13:14:50 Update comments and rename input parameter for clarity mochi
060fbffa 2022-01-05 13:14:15 Update comments for clarity mochi
7c686149 2022-01-05 13:13:54 Add .gitignore mochi
124be96c 2021-11-01 21:54:40 Remove Codacy badge JB
b08a57eb 2020-02-12 22:56:49 Update Readme Mochi
e8e29e95 2020-02-12 22:49:11 Update Readme Mochi
8e468852 2020-02-12 22:48:50 Update Chart Labels Mochi
7c23925e 2020-02-12 21:59:56 Update Readme Mochi
aa90dd80 2020-02-12 21:47:49 Update Badges Mochi
a98e1679 2020-02-12 21:47:21 Update Badges Mochi
bec94012 2020-02-12 21:15:15 Fix test races Mochi
7103f043 2020-02-12 20:43:11 Update travis Mochi
b605c94e 2020-02-12 20:39:30 Fix examples Mochi
31a026b1 2020-02-12 20:35:53 Add TravisCI Mochi
4fdf2ae2 2020-02-12 20:30:17 Add badges Mochi
3961e87c 2020-02-12 20:20:32 Update Readme Mochi
74ebdaf1 2020-02-12 20:15:26 Update Readme Mochi
c17d6a92 2020-02-12 20:12:09 Resort Charts Mochi
bcd6ef30 2020-02-12 20:11:30 Resort Charts Mochi
0d6a6653 2020-02-12 20:10:42 Charts Mochi
91dc8876 2020-02-12 20:02:25 Image test Mochi
e7eeba7d 2020-02-12 20:01:41 Image test Mochi
da3deb58 2020-02-12 19:59:14 Update README Mochi
073d8256 2020-02-09 14:03:43 Update README, better command main Mochi
e96ef017 2020-02-08 13:24:31 Code and Comments cleanup, vendor deps Mochi
d1daa843 2020-02-04 21:18:29 Persistence V1 Mochi
85f269af 2020-02-02 14:38:39 Adds delete from persistence Mochi
4a10b0b6 2020-02-01 18:35:46 Adds more persistence tests Mochi
216b0401 2020-01-25 13:21:24 Load persistence into server Mochi
908aa95b 2020-01-24 16:42:26 Persistence and tests Mochi
b1476ca6 2020-01-23 23:20:16 Inflght and retained messages persistence Mochi
79d1ee39 2020-01-15 21:32:40 Progress on persistence Mochi
50732468 2020-01-04 22:02:39 Adds TLS/SSL Mochi
6a2d5bed 2020-01-04 20:06:37 Websocket Listener Mochi
0eaa1113 2020-01-03 15:49:52 Don't receive $SYS retained on # Mochi
4d3b1d7d 2019-12-31 23:49:17 Publish $SYS Stats to topics Mochi
19f74cb6 2019-12-31 19:02:55 Basic $SYS stats Mochi
e111c442 2019-12-31 16:34:00 Merge branch 'restructure-paths' Mochi
be4240b3 2019-12-31 16:33:50 Http Sys Stats listener Mochi
b6184987 2019-12-31 15:02:16 Restructures code Mochi
901df4ad 2019-12-30 14:11:31 Fix tests Mochi
5d78b1b0 2019-12-29 19:10:00 Pass Paho Tests Mochi
7babede0 2019-12-29 17:30:12 Dont inflight secondary qos flow messages Mochi
80f76c93 2019-12-28 18:50:32 Satisfy Keepalive, fix Keepalive 0 Mochi
aa40d28e 2019-12-28 17:25:33 Small fix Mochi
61af05fd 2019-12-28 16:04:52 Satisfy 4.7.2 - restrict $ topics Mochi
663224e0 2019-12-27 11:57:52 Periodic Resend of Inflight messages Mochi
ebf7fe58 2019-12-08 11:40:51 Cleanup TCP Listener Mochi
cccbc017 2019-12-07 16:14:10 Merge remote-tracking branch 'origin/master' Mochi
a5aba5c9 2019-12-07 16:13:27 Merge pull request #1 from mochi-co/iobuffers Jonathan B
b81a6dc4 2019-12-07 16:10:59 Merge branch 'iobuffers' Mochi
818d2cec 2019-12-07 15:53:45 Fix close sequence, update test coverage Mochi
e7970d9a 2019-12-03 20:44:01 LWT and Validate packet Mochi
7fa7fffc 2019-12-01 21:44:05 bytes buffer to pool Mochi
7331d93a 2019-12-01 15:36:45 refactor pointers Mochi
43833744 2019-12-01 12:38:20 Publish Mochi
544bbf61 2019-11-30 21:33:49 Process packets Mochi
f65500c9 2019-11-29 21:33:22 Establish Tests Mochi
a33add6b 2019-11-24 22:17:34 start establish Mochi
4ddfa37e 2019-11-24 21:35:20 client write packet Mochi
8f61bdf5 2019-11-23 20:15:50 update tests Mochi
fec72b03 2019-11-23 20:01:40 Rebuilding Mochi
ad6ae7e8 2019-11-17 19:55:54 New Packets Mochi
84484364 2019-11-15 19:54:53 Fix CheckEmpty Mochi
f1ede684 2019-11-09 17:59:38 Rebuild Mochi
e48a0e3a 2019-11-08 20:06:53 Rebuild Mochi
d291081b 2019-11-08 15:54:09 Rebuild Mochi
6a9e021c 2019-11-07 22:40:10 Rebuild Mochi
1f44457a 2019-11-07 22:37:42 Rebuild Mochi
3bfa5ee4 2019-11-03 21:36:51 working but bottlenecks Mochi
52981b77 2019-11-03 09:38:41 pre-refactor Mochi
240187ff 2019-11-02 22:04:15 More tests, connecting MQTT Mochi
5d0aa0f1 2019-11-02 16:46:21 More Tests Mochi
21fe6d6b 2019-10-29 21:45:33 Fixes sync.cond deadlock Mochi
d8bba41d 2019-10-27 11:00:50 Debug func, better closers Mochi
f3310b05 2019-10-25 19:57:52 Tests and buffer sizes Mochi
ef49b7b8 2019-10-25 17:57:48 Write Bytes Mochi
bd8fb95f 2019-10-24 21:47:57 Processor Read and Tests Mochi
7913e93f 2019-10-23 21:05:37 Refactor, fixes to Circ Peek, start processor/parser Mochi
e0a00feb 2019-10-13 13:25:22 WriteTo / Tests Mochi
705eb84d 2019-10-13 12:15:11 Read+Read Test Mochi
a520a9e7 2019-10-13 00:31:13 cleanup Mochi
96fe3aa2 2019-10-13 00:10:40 AwaitFilled Mochi
e02f81bd 2019-10-12 15:25:55 Cleanup, start reader/writer model Mochi
aa68753b 2019-10-12 13:53:18 Small fixes Mochi
4c016c98 2019-10-12 13:48:54 WriteTo / Tests Mochi
748cd5e0 2019-10-12 00:53:11 Start on Peek Mochi
dd97f476 2019-10-11 00:14:25 ReadFrom IO Mochi
f89ff283 2019-10-10 20:39:30 AwaitCapacity tests Mochi
5da1d498 2019-10-10 19:24:07 Working wait logic Mochi
c3af69f7 2019-10-09 08:30:57 Move Parser, cleanup to basic Mochi
d5e2312a 2019-10-08 22:40:55 Cleanup Mochi
2fadf082 2019-10-08 20:42:26 All working Mochi
2a00e70b 2019-10-08 19:31:20 Adds Retained Delete Mochi
e9c6915e 2019-10-08 10:55:08 Cleanup, Tests fix, Client closers Mochi
02295662 2019-10-08 08:55:01 Fix packet buffer mutation Mochi
956633a6 2019-10-08 01:14:14 midway various pointer bytes fixes Mochi
4f1859a4 2019-10-07 23:34:49 server cmd Mochi
659daabf 2019-10-07 23:34:30 Cleanup Mochi
8e3cf9f3 2019-10-07 23:34:16 Fix unsafe.pointer, unsub cascade bugs Mochi
3917be82 2019-10-07 22:00:33 Testing example Mochi
c04e02a0 2019-10-07 20:37:38 Cleanup Mochi
174559e4 2019-10-07 20:14:04 Fix Error nil/contains checks Mochi
1056e7b0 2019-10-07 20:02:52 Send LWT+tests Mochi
5d6eaf8d 2019-10-07 19:14:40 Resend unsent inFlight Mochi
e3680539 2019-10-07 17:55:33 Performance changes Mochi
49d528dc 2019-10-07 17:13:54 Cleanup tests and benchmarks Mochi
a48fb260 2019-10-07 13:57:25 Handle CleanSession Mochi
f03de833 2019-10-07 12:22:52 Pub/sub ACL and acks Mochi
aaa8c754 2019-10-07 11:37:12 Write Client coverage Mochi
9b37eece 2019-10-07 10:19:20 Client Tests Mochi
e7f1576c 2019-10-07 10:19:11 Tests Cleanup Mochi
2a154012 2019-10-06 23:02:34 Refactor Tests Mochi
9a2a4c51 2019-10-06 22:17:15 Subscribe Retain Mochi
6ff9912f 2019-10-06 21:45:01 Subscribe basic + Unsubscribe Mochi
a18e8820 2019-10-06 21:06:50 Pubcomp Mochi
9d0d6d59 2019-10-06 20:21:35 Pubrel + Pubrec Mochi
375d2259 2019-10-06 17:26:05 Fix Establish tests Mochi
7e1c6cad 2019-10-06 16:45:06 Fix Establish test Mochi
80a163ec 2019-10-06 11:37:45 Process Publish+Recv Mochi