Commit Graph

642 Commits

Author SHA1 Message Date
Arnaud Cogoluègnes d2a29c5aef Support client properties 2020-06-09 17:48:23 +02:00
Arnaud Cogoluègnes 121f0e3575 Improve readme 2020-06-09 13:53:49 +02:00
Arnaud Cogoluègnes 6ef10c8573 Use MPL 2.0 2020-06-08 09:54:33 +02:00
Arnaud Cogoluègnes a56cf4013c Support first/last/next/offset/timestamp offset spec 2020-06-02 16:35:00 +02:00
Arnaud Cogoluègnes 9536d74f9d Update link to osiris for data format 2020-06-02 11:13:19 +02:00
Arnaud Cogoluègnes ecf47a8a42 Fix typo 2020-06-02 10:47:46 +02:00
Arnaud Cogoluègnes 2ab7e864dc Consume from a local member 2020-05-28 11:59:13 +02:00
Arnaud Cogoluègnes efc6fbc089 Add advertised host/port settings
This allows to communicate whatever it's appropriate to clients when
they issue the metadata command.
2020-05-28 10:47:30 +02:00
Arnaud Cogoluègnes 2f8559ae41 Polish documentation 2020-05-25 17:56:02 +02:00
Arnaud Cogoluègnes 838ef21b0d Document authentication sequence 2020-05-25 17:53:34 +02:00
Arnaud Cogoluègnes 4faa853b00 Fix link in documentation 2020-05-25 17:04:00 +02:00
Arnaud Cogoluègnes 0f86e54b61 Cover all commands in protocol documentation 2020-05-25 17:02:43 +02:00
Arnaud Cogoluègnes b7f70c6598 Fix links in documentation 2020-05-25 15:57:16 +02:00
Arnaud Cogoluègnes 848c95a181 Start documenting protocol 2020-05-25 15:55:51 +02:00
Arnaud Cogoluègnes b54026aa32 Add arguments for stream creation
To handle retention settings.
2020-05-19 18:18:30 +02:00
Arnaud Cogoluègnes 55adca1b44 Make sure queue is stream queue 2020-05-07 11:00:45 +02:00
Arnaud Cogoluègnes c2e35eb55f Use stream coordinator to manage streams 2020-05-06 17:35:41 +02:00
Arnaud Cogoluègnes 2d19e85925 Use stream instead of target 2020-05-06 09:15:16 +02:00
Arnaud Cogoluègnes b61a79b9ff Credit value is signed 2020-04-03 11:00:35 +02:00
Arnaud Cogoluègnes 204f61399b Handle client heartbeat 2020-04-01 10:08:32 +02:00
Arnaud Cogoluègnes 8c97d442ce Add heartbeat 2020-03-31 14:43:06 +02:00
Arnaud Cogoluègnes ece2a4770f Refactoring before introducing heartbeat
Introduce a level of supervisors to have a parent PID for the heartbeat
process.
2020-03-31 10:12:35 +02:00
Arnaud Cogoluègnes b693f71c5d Add todo task 2020-03-30 17:46:27 +02:00
Arnaud Cogoluègnes 47d46d145b Send close when client sends frame too large 2020-03-30 15:18:57 +02:00
Arnaud Cogoluègnes e899bdfb3e Refactor tune
Use int32 for both max frame size and bump max frame size to 1 MB.
2020-03-27 15:55:57 +01:00
Arnaud Cogoluègnes 670f5f639b Add test for close 2020-03-27 09:26:02 +01:00
Arnaud Cogoluègnes 9667525cd7 Update test for opening sequence 2020-03-26 17:52:54 +01:00
Arnaud Cogoluègnes 4e035dfbdb Add support to send close 2020-03-26 16:56:53 +01:00
Arnaud Cogoluègnes a26962cfcb Handle close command from client 2020-03-26 14:52:19 +01:00
Arnaud Cogoluègnes 7c33112f25 Check virtual host access in open 2020-03-26 09:53:28 +01:00
Arnaud Cogoluègnes 728a017f9e Add skeleton for tune and open 2020-03-25 17:06:04 +01:00
Arnaud Cogoluègnes 1fd5270d01 Use constants in tests 2020-03-25 10:22:16 +01:00
Arnaud Cogoluègnes b84de96d0b Add test for authentication 2020-03-25 10:08:10 +01:00
Arnaud Cogoluègnes 55a836b488 Refactor to pre/post authentication frame handling 2020-03-24 17:42:10 +01:00
Arnaud Cogoluègnes 6ae44768f3 Handle null binary in SASL authenticate 2020-03-24 16:40:05 +01:00
Arnaud Cogoluègnes 22dc72c9d9 Handle SASL authenticate 2020-03-24 11:47:50 +01:00
Arnaud Cogoluègnes e2f11fdafc Handle SASL handshake 2020-03-23 14:54:59 +01:00
Arnaud Cogoluègnes 1f42faeab8 Refactor after some Osiris changes 2020-03-23 10:48:46 +01:00
Arnaud Cogoluègnes 9f64d3d490 Add instructions to build and run 2020-03-17 11:37:04 +01:00
Arnaud Cogoluègnes 4e8a801e8d Add license information 2020-03-17 10:59:37 +01:00
Arnaud Cogoluègnes ab98aecd17 Initial import 2020-03-16 16:40:02 +01:00
Arnaud Cogoluègnes b9de5bc80b Initial commit 2020-03-16 16:21:18 +01:00