文件历史

提交图

20 次代码提交

作者 SHA1 备注 提交日期
Vasiliy Tolstov 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
Asim Aslam 11b104677a Shift embedded nats to the default 2020-01-19 00:55:01 +00:00
Asim Aslam c5dd737568 Add back in broker address 2019-07-10 19:58:30 +01:00
Asim Aslam 4b4ad68eb9 Change Publication to Event 2019-07-07 12:44:09 +01:00
Asim Aslam 79b03a6825 add broker args 2019-07-07 12:36:14 +01:00
Asim Aslam c1097a4509 strip broker address 2019-07-07 12:33:47 +01:00
Asim Aslam bd46e60c13 optimise http broker with rcache 2017-10-26 20:48:11 +01:00
Asim Aslam 71d717a06d strip doc.go files 2016-12-14 15:41:48 +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 64220dc0c5 Broker init 2016-03-15 22:12:28 +00:00
Asim a53979dfed Add broker comment 2016-01-30 21:18:57 +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 02aca819d7 Update the broker interface 2015-12-23 19:07:26 +00:00
Asim be43d827c7 Add String method to all interfaces 2015-12-19 21:56:14 +00:00
Asim b91af916f9 Add pub/sub to client/server and make broker more low level 2015-06-12 19:52:27 +01:00
Asim 32928bfb67 Publish/Subscribe with context 2015-05-23 23:16:26 +01:00
Asim 74fd1fc989 Restructure go-micro layout and plugins 2015-05-23 20:04:16 +01:00
Asim 0e7bd77f4c Allow configurable addresses for everything 2015-05-16 00:34:02 +01:00
Asim d99180ea37 Add broker package for message queue support. Include http and nats 2015-04-26 19:33:35 +01:00