Asim Aslam
|
b3b4bc6059
|
remove Plus
|
2018-12-31 20:51:22 +00:00 |
|
Asim Aslam
|
45c05c4e2b
|
Add timeout error
|
2018-11-25 09:41:28 +00:00 |
|
fireyang
|
ef8b5e28b0
|
fix rpc client call WARNING: DATA RACE
|
2018-09-20 10:08:00 +08:00 |
|
fireyang
|
446d3fc72e
|
fix bug: loop variable i captured by func literal
|
2018-09-19 21:58:20 +08:00 |
|
Asim Aslam
|
88505388c1
|
Add verbosity to errors
|
2018-07-26 09:33:50 +01:00 |
|
Asim Aslam
|
ac2106ced7
|
strip deadline from stream
|
2018-07-17 16:39:07 -07:00 |
|
Asim Aslam
|
1b4f7d8a68
|
a stream should not timeout
|
2018-07-17 16:32:35 -07:00 |
|
Asim Aslam
|
ba8582a47a
|
change retries to actually mean retries
|
2018-05-28 16:01:04 +01:00 |
|
bogle
|
541e894507
|
just update the pool configuration if the options changed, because recreating the pool,existed idleconnection, if any, will be dropped without closing
|
2018-05-26 15:38:41 +08:00 |
|
Asim Aslam
|
c3c0543733
|
add message options
|
2018-05-10 17:33:54 +01:00 |
|
Asim Aslam
|
65068e8b82
|
rename Streamer to Stream
|
2018-04-14 18:15:09 +01:00 |
|
Asim Aslam
|
c2cfe5310c
|
Rework client interface
|
2018-04-14 18:06:52 +01:00 |
|
Asim Aslam
|
07068379c6
|
remove remote func methods
|
2018-04-14 16:16:58 +01:00 |
|
leon.peng
|
9b99d50396
|
fix bug #239
|
2018-03-21 03:17:38 +00:00 |
|
Asim Aslam
|
c9b40cb33b
|
switch to stdlib context
|
2018-03-03 11:53:52 +00:00 |
|
Asim Aslam
|
32b7ebcfbc
|
use updated error formatting
|
2017-06-11 13:02:08 +01:00 |
|
Asim Aslam
|
a7312f5c7e
|
log panics
|
2017-05-16 19:14:00 +01:00 |
|
Asim Aslam
|
095793ee96
|
handle codec and transport errors
|
2016-12-06 19:40:44 +00:00 |
|
Asim
|
b05b42eccd
|
Differentiate between request and call timeouts
|
2016-11-22 10:44:32 +01:00 |
|
Asim
|
99a3ba7358
|
wrap before the call, we don't want to rewrap on retry
|
2016-11-09 18:02:41 +00:00 |
|
Asim
|
f3b591d722
|
Strip stream func and rename call wrappers...
|
2016-11-07 17:58:34 +00:00 |
|
Asim
|
5ee585e77d
|
Rename to CallFuncWrappers
|
2016-11-07 17:52:19 +00:00 |
|
Asim
|
c6b5237cce
|
Add call func wrapper
|
2016-11-07 17:49:35 +00:00 |
|
Scott Finlay
|
1ab59094eb
|
Fixing return value and gofmt
|
2016-11-07 17:46:12 +01:00 |
|
Scott Finlay
|
a6812ba332
|
Adjusting the logic around the returned error from the retry function
|
2016-11-07 17:41:51 +01:00 |
|
Scott Finlay
|
a66bce0e4b
|
Adjusting arguments and return value of retry function and adding new retry logic to stream
|
2016-11-07 17:10:40 +01:00 |
|
Scott Finlay
|
092d17a74e
|
Adjusting names
|
2016-11-07 09:40:11 +01:00 |
|
Scott Finlay
|
d7e4062a0e
|
Adding the ability to specify a function to check if micro should retry a failed rpc call
|
2016-11-03 10:51:47 +01:00 |
|
Asim
|
b8241f3026
|
specify the Accept header along with Content-Type
|
2016-08-25 13:34:47 +01:00 |
|
Asim
|
02481c4446
|
request panic catch all
|
2016-06-30 16:19:02 +01:00 |
|
Asim
|
89401cbb95
|
Make pool configurable
|
2016-06-07 00:46:14 +01:00 |
|
Asim
|
2e9f4271a8
|
Pool first attempt
|
2016-05-13 15:58:53 +01:00 |
|
Asim
|
b6f5e15362
|
Fix the error returns from done and bail early if we dont have time
|
2016-05-12 23:56:25 +01:00 |
|
Asim
|
00a26677b8
|
Continue to return our error types
|
2016-05-12 23:52:29 +01:00 |
|
Asim
|
8c8573426c
|
Add cascading timeouts
|
2016-05-12 23:32:58 +01:00 |
|
Asim
|
2254578760
|
We don't need sync.Once, we can just select
|
2016-05-11 00:01:32 +01:00 |
|
Asim
|
7167f998ce
|
First crack at backoff function
|
2016-04-05 20:04:37 +01:00 |
|
Asim
|
56c6993eb8
|
Set CallOptions as struct in Options. Can then be overridden easily during Call/Stream
|
2016-04-05 18:07:07 +01:00 |
|
Asim
|
9ae0956cea
|
Move context to metadata
|
2016-01-28 17:55:28 +00:00 |
|
Asim
|
ad4637d89b
|
Lets strip out the rpcplus code
|
2016-01-05 21:13:20 +00:00 |
|
Asim
|
d43d3e8efa
|
Add transport dial timeout
|
2016-01-03 21:25:03 +00:00 |
|
Asim
|
332a229169
|
Add request timeout
|
2016-01-03 21:14:33 +00:00 |
|
Asim
|
1037663acf
|
Add retries
|
2016-01-02 23:16:15 +00:00 |
|
Asim
|
3b56a62589
|
Update the way flags are used
|
2016-01-02 19:12:17 +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
|
bffd55f500
|
Channel rather than mutex to check is closed
|
2015-12-28 19:11:10 +00:00 |
|
Asim
|
be43d827c7
|
Add String method to all interfaces
|
2015-12-19 21:56:14 +00:00 |
|
Asim
|
a5be9ca585
|
switchup init
|
2015-12-18 01:21:56 +00:00 |
|
Asim
|
6ae48c9f29
|
checkpoint
|
2015-12-17 20:37:35 +00:00 |
|
Asim
|
271b827aa9
|
add changes for mercury
|
2015-12-16 01:18:05 +00:00 |
|
Asim
|
eefb9c53d4
|
Move to a selector package
|
2015-12-09 19:23:16 +00:00 |
|
Asim
|
29ee9e2753
|
Add error checking
|
2015-12-09 12:44:28 +00:00 |
|
Asim
|
9072a944e2
|
Add selector code
|
2015-12-09 00:02:45 +00:00 |
|
Asim
|
02985c35d5
|
Add call and publish options
|
2015-12-08 19:25:42 +00:00 |
|
Asim
|
3d279ffcfd
|
Select is a better method
|
2015-12-08 00:11:51 +00:00 |
|
Asim
|
140febb081
|
Switch up the selector so it actually allows you to inform it how the node performed
|
2015-12-07 23:56:17 +00:00 |
|
Asim
|
4e6b9347d9
|
Add the notion of a node selector for routing
|
2015-12-07 21:09:10 +00:00 |
|
Asim
|
0c9f8411bb
|
Pull rpcplus in local for the time being. We need to modify it for server side middleware
|
2015-12-01 23:32:23 +00:00 |
|
Asim
|
654728027b
|
Updated codec interface and code. Painful stuff
|
2015-11-28 11:22:29 +00:00 |
|
Asim
|
f49922f6b3
|
experimental codec branch
|
2015-11-27 00:17:36 +00:00 |
|
Asim
|
fb172df0ce
|
Add wrapper implementation
|
2015-11-26 20:36:42 +00:00 |
|
Asim
|
bcff71167c
|
Remove unused roundtripper code
|
2015-11-26 16:51:39 +00:00 |
|
Asim
|
12a1e1eeda
|
Add pluggable codec support
|
2015-11-25 19:50:05 +00:00 |
|
Asim
|
5d88115f2a
|
update links from myodc to micro
|
2015-11-20 16:17:33 +00:00 |
|
Asim
|
0320fc1b55
|
Update registry so version is surfaced
|
2015-11-08 01:48:48 +00:00 |
|
Asim
|
5e598d8ef0
|
Fix leaking go routine issue
|
2015-10-22 15:14:56 +01:00 |
|
Asim
|
b1b316df77
|
Fix connection leak
|
2015-10-22 10:33:33 +01:00 |
|
Asim
|
b91af916f9
|
Add pub/sub to client/server and make broker more low level
|
2015-06-12 19:52:27 +01:00 |
|
Asim
|
09c784d294
|
add support for streaming requests. cleanup watcher initilisation
|
2015-06-01 18:55:27 +01:00 |
|
Asim
|
36b5ca46fe
|
Change initialisation and add metadata
|
2015-05-26 22:39:48 +01:00 |
|
Asim
|
7aa2c82ced
|
Service and node should be structs rather than interface
|
2015-05-25 22:14:28 +01:00 |
|
Asim
|
e192f335da
|
Dont expose rpc client/server
|
2015-05-23 17:40:53 +01:00 |
|
Asim
|
3db51216b2
|
Rework use of context
|
2015-05-23 11:53:40 +01:00 |
|
Asim
|
c9df1cf7d2
|
use send/recv semantics
|
2015-05-21 21:08:19 +01:00 |
|
Asim
|
4f909d0be4
|
Declare option not options
|
2015-05-21 19:28:57 +01:00 |
|
Asim
|
9d514f0e60
|
further transport rework
|
2015-05-21 19:24:57 +01:00 |
|
Asim
|
50e44726f5
|
transport cruft
|
2015-05-20 22:57:19 +01:00 |
|
Asim
|
c77be7c571
|
Add grpc client and example
|
2015-05-16 00:33:43 +01:00 |
|
Asim
|
45a619c2c6
|
Fixup import paths
|
2015-05-05 19:05:06 +01:00 |
|
Asim
|
8e55cde513
|
First
|
2015-01-13 23:31:27 +00:00 |
|