|
|
b4ccde2228
|
resurrect broker event (#26)
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
|
2020-08-27 11:18:02 +03:00 |
|
|
|
0f4b1435d9
|
move implementations to external repos (#17)
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
|
2020-08-25 13:44:41 +03:00 |
|
|
|
06136312bb
|
regen files with never protoc (#6)
* regen files with never protoc
* rewrite import path
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
|
2020-08-19 17:47:17 +03:00 |
|
Asim Aslam
|
4413372a3f
|
Decruft the broker by removing Event interface (#1940)
|
2020-08-18 14:00:51 +01:00 |
|
Asim Aslam
|
563768b58a
|
v3 refactor (#1868)
* Move to v3
Co-authored-by: Ben Toogood <bentoogood@gmail.com>
|
2020-07-27 13:22:00 +01:00 |
|
Di Wu
|
f9bf562393
|
fix typo in comments (#1840)
* remove global error tracking
* rpc_server: fix invalid register err
* fix typo
Co-authored-by: Asim Aslam <asim@aslam.me>
|
2020-07-16 16:33:11 +01:00 |
|
|
|
9bb1904a38
|
broker: add publish context (#1590)
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
|
2020-04-28 19:29:00 +03:00 |
|
|
|
8ee5607254
|
[WIP]: broker ErrorHandler option (#1296)
* broker ErrorHandler option
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
* rewrite Event interface, add error
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
* implement new interface
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
* change ErrorHandler func to broker.Handler
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
* fix
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
|
2020-03-06 21:25:16 +00:00 |
|
|
|
f23638c036
|
fix import paths for v2 release
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
|
2020-01-30 14:44:40 +03:00 |
|
Lars Lehtonen
|
add78f2967
|
broker: drop unused registryKey variable
|
2020-01-23 12:51:57 -08:00 |
|
Asim Aslam
|
1d311ab457
|
Embedded NATS Broker (#1110)
* if the address is produced by a default route don't hash it
* embedded nats
* fix url parsing
* don't override help
* add ready flag
|
2020-01-14 13:23:16 +00:00 |
|
Asim Aslam
|
b4dc822ae3
|
Change context key to string
|
2019-05-29 10:58:41 +01:00 |
|
|
|
ac1afea7fc
|
add context to server.SubscriberOptions and broker.SubscribeOption
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
|
2019-01-24 15:36:01 +03:00 |
|
Asim Aslam
|
c086c33bb3
|
remove codecs
|
2019-01-10 09:42:02 +00:00 |
|
Asim Aslam
|
92082ac927
|
NewSubscribeOptions
|
2018-11-30 17:32:48 +00:00 |
|
Asim Aslam
|
c9b40cb33b
|
switch to stdlib context
|
2018-03-03 11:53:52 +00:00 |
|
Asim Aslam
|
25a6849609
|
move broker codec
|
2016-12-06 18:59:41 +00:00 |
|
Asim Aslam
|
bd3c798fd9
|
Add configurable codecs for broker/transport
|
2016-12-06 18:37:35 +00:00 |
|
Asim
|
aea81315d0
|
Change QueueName to Queue
|
2016-05-10 10:55:18 +01:00 |
|
Asim
|
64220dc0c5
|
Broker init
|
2016-03-15 22:12:28 +00:00 |
|
Asim
|
8724e68ae4
|
Initialise registry for broker
|
2016-01-20 15:22:44 +00:00 |
|
Asim
|
ae2ab911ed
|
Access tls config
|
2016-01-16 23:39:47 +00:00 |
|
Asim
|
36e709c9f7
|
Fix the broker and add secure option
|
2016-01-16 22:13:02 +00:00 |
|
Asim
|
8bf72a3325
|
Replace map[string]string with Context for extra options. map[string]string is essentially useless. Context can store anything
|
2016-01-06 16:25:12 +00:00 |
|
Asim
|
191e835aa9
|
Add extra options to be used by others that need them
|
2015-12-31 18:14:40 +00:00 |
|
Asim
|
64b45f7846
|
Update options to be public. This means people can implement the interfaces and actually use the options
|
2015-12-31 18:11:46 +00:00 |
|
Asim
|
5e1a618415
|
Screw num handlers, this adds complexity for concurrency which we dont need
|
2015-12-23 20:26:13 +00:00 |
|
Asim
|
6097c3296c
|
Shared queue distribution of messages
|
2015-12-23 20:05:47 +00:00 |
|
Asim
|
02aca819d7
|
Update the broker interface
|
2015-12-23 19:07:26 +00:00 |
|
