5eb0e56373
move all imports to own domain
...
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2021-10-02 19:55:07 +03:00
5c9b3dae33
broker: improve option naming, move BatchBroker to Broker interface
...
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2021-07-24 16:16:18 +03:00
e64269b2a8
broker: add BatchBroker interface to avoid breaking older brokers
...
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2021-07-23 12:55:36 +03:00
675e121049
metadata: add default headers
...
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2021-07-23 12:03:18 +03:00
d357fb1e0d
WIP: broker batch processing
...
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2021-07-22 22:53:44 +03:00
f28b107372
broker: fix RawMessage marshal
...
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2021-07-01 23:23:01 +03:00
eb107020c7
broker: replace Message.Body []byte slice to RawMessage
...
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2021-07-01 15:11:17 +03:00
86626c5922
fieldalignment of all structs to save memory
...
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2021-04-27 08:32:47 +03:00
827d467077
micro: rewrite options to support multiple building blocks
...
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2021-01-29 13:17:32 +03:00
b7b28f6b9a
lint
...
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2020-12-08 00:38:37 +03:00
daffa9e548
use metadata.Metadata ( #8 )
...
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2020-11-18 16:50:41 +03:00
40b0870cf8
fix linting ( #4 )
...
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2020-11-03 01:08:23 +03:00
e6ab6d50eb
remove unneeded Error field from broker.Message
...
close github.com/unistack-org/micro-roadmap/issues/26 (#3 )
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2020-11-02 23:45:41 +03:00
14c97d59c1
many improvements with options and noop stuff
...
* add many options helpers
* fix noop client to allow publish messages to topic in broker
* fix noop server to allow registering in registry
* fix noop server to allow subscribe to topic in broker
* fix new service initialization
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2020-10-16 09:38:57 +03:00
c062aab1a9
add noop broker and noop store ( #30 )
...
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2020-09-03 15:11:05 +03:00
7cf42589b3
cleanup deps
...
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2020-08-28 11:52:51 +03:00
b4ccde2228
resurrect broker event ( #26 )
...
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2020-08-27 11:18:02 +03:00
8076e410a9
fix repocard issues ( #20 )
...
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2020-08-25 14:33:36 +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
Asim Aslam
dd2dc7a2b9
Update broker.go
2020-08-18 14:05:25 +01: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
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