Asim Aslam
|
31b6cad47b
|
make copy before writing
|
2019-02-04 10:29:10 +00:00 |
|
Asim Aslam
|
e22fa01935
|
fix ticker
|
2019-01-24 16:08:04 +00:00 |
|
Asim Aslam
|
a5015692e3
|
Merge pull request #400 from micro/interval
Move RegisterInterval into the server
|
2019-01-24 13:55:05 +00:00 |
|
Asim Aslam
|
539b8c1a3b
|
Move RegisterInterval into the server
|
2019-01-24 13:22:17 +00:00 |
|
Asim Aslam
|
67a738b504
|
Merge pull request #399 from unistack-org/master
add context to SubscriberOptions
|
2019-01-24 13:11:33 +00: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
|
8090f9968d
|
Update headers to remove X- prefix
|
2019-01-24 10:11:02 +00:00 |
|
Asim Aslam
|
8a0d5f0489
|
log if we can't even respond
|
2019-01-22 13:55:04 +00:00 |
|
Asim Aslam
|
d8ba18deff
|
change logging
|
2019-01-22 12:18:33 +00:00 |
|
Asim Aslam
|
6468733d98
|
Use protocol from node metadata
|
2019-01-18 12:30:39 +00:00 |
|
Asim Aslam
|
2cd2258731
|
For the legacy
|
2019-01-18 10:12:57 +00:00 |
|
Asim Aslam
|
00661f8a99
|
Clarify log message
|
2019-01-15 15:17:30 +00:00 |
|
Asim Aslam
|
e362466e8a
|
use default router
|
2019-01-14 21:45:43 +00:00 |
|
Asim Aslam
|
c17d0fcc0f
|
grpc request
|
2019-01-13 19:54:07 +00:00 |
|
Asim Aslam
|
e1bc240a14
|
Respond with error type
|
2019-01-13 12:15:35 +00:00 |
|
Asim Aslam
|
bfd341a269
|
Execute wrappers before router
|
2019-01-11 15:49:54 +00:00 |
|
Asim Aslam
|
9adebfcf1e
|
rename method to endpoint
|
2019-01-10 21:25:31 +00:00 |
|
Asim Aslam
|
6e0e4a684c
|
Further crufting
|
2019-01-09 19:28:13 +00:00 |
|
Asim Aslam
|
873fc6d663
|
rewriting a lot
|
2019-01-09 19:11:47 +00:00 |
|
Asim Aslam
|
d004c9624b
|
Add router modifications
|
2019-01-09 16:20:57 +00:00 |
|
Asim Aslam
|
f46828be33
|
Add Router interface
|
2019-01-08 20:32:47 +00:00 |
|
Asim Aslam
|
c9963cb870
|
rename
|
2019-01-07 18:20:47 +00:00 |
|
Asim Aslam
|
9544058af3
|
Merge pull request #372 from micro/codec
Switch default codec and add default codec for server
|
2019-01-07 17:54:28 +00:00 |
|
Asim Aslam
|
c717af21ac
|
Some router changes
|
2019-01-07 17:17:06 +00:00 |
|
Asim Aslam
|
46ece968d4
|
rename service to router
|
2019-01-07 14:44:40 +00:00 |
|
Asim Aslam
|
d179c971af
|
Switch default codec and add default codec for server
|
2019-01-07 13:48:38 +00:00 |
|
Asim Aslam
|
34ed5235a3
|
rename rpc codec
|
2018-11-23 20:05:31 +00:00 |
|
Asim Aslam
|
e69413b763
|
add continue
|
2018-11-15 21:13:33 +00:00 |
|
Asim Aslam
|
45f18042b7
|
make accept loop
|
2018-11-15 19:55:13 +00:00 |
|
Asim Aslam
|
0672b051cc
|
Add Local/Remote ip to metadata
|
2018-11-14 20:27:58 +00:00 |
|
Asim Aslam
|
a56e97b47d
|
Change waitgroup processing
|
2018-05-26 09:41:41 +01:00 |
|
Asim Aslam
|
c666558f8c
|
make the broker/transport listen on new addr when stop/started with addr :0
|
2018-05-25 15:19:25 +01:00 |
|
Asim Aslam
|
e55437698b
|
misc moved to util
|
2018-04-08 12:37:45 +01:00 |
|
Asim Aslam
|
c9b40cb33b
|
switch to stdlib context
|
2018-03-03 11:53:52 +00:00 |
|
Tobias Wellnitz, DH1TW
|
0dcea05fb8
|
fix possible deadlock since code can return without unlocking the Mutex
|
2018-01-01 19:57:13 +01:00 |
|
Shannon Wynter
|
0e696f4907
|
Fix hashing of the service definition
Maps are sorted randomly, order the keys as a slice
|
2017-08-24 18:25:05 +10:00 |
|
Asim Aslam
|
3812cbbcb6
|
defer wg.Done so it's called even if there's a panic
|
2017-06-12 14:18:59 +01:00 |
|
Asim Aslam
|
2ee22f5336
|
strip init of wg
|
2017-05-31 19:35:16 +01:00 |
|
Asim Aslam
|
726793b6fa
|
Wait for requests to finish before closing transport
|
2017-05-31 19:21:41 +01:00 |
|
Asim Aslam
|
a7312f5c7e
|
log panics
|
2017-05-16 19:14:00 +01:00 |
|
Asim Aslam
|
bab586b71e
|
make use of micro/go-log
|
2017-05-11 20:43:42 +01:00 |
|
Asim Aslam
|
a9889730d6
|
move addr extractor to misc
|
2017-01-12 13:20:34 +00:00 |
|
Asim
|
2e9f4271a8
|
Pool first attempt
|
2016-05-13 15:58:53 +01:00 |
|
Asim
|
8c8573426c
|
Add cascading timeouts
|
2016-05-12 23:32:58 +01:00 |
|
Asim
|
aea81315d0
|
Change QueueName to Queue
|
2016-05-10 10:55:18 +01:00 |
|
Asim
|
d1eae8fabe
|
remove use of glog
|
2016-03-14 11:01:10 +00:00 |
|
Asim
|
1adcb237d9
|
Only log registering if not registered
|
2016-02-27 22:14:25 +00:00 |
|
Asim
|
8e61057bc9
|
Allow init of wrappers and name. Set server.name for rpc request
|
2016-02-18 18:08:43 +00:00 |
|
Asim
|
8cd906e75e
|
Set TTL on first registration of http broker. Also dont resubscribe
|
2016-02-15 22:20:54 +00:00 |
|
Asim
|
9ae0956cea
|
Move context to metadata
|
2016-01-28 17:55:28 +00:00 |
|
