文件历史

提交图

146 次代码提交

作者 SHA1 备注 提交日期
Asim Aslam ca5acba0c6 Move selector to client/selector 2019-06-21 15:13:54 +01:00
Asim Aslam ed4bce3285 check in this cruft 2019-06-08 19:40:44 +01:00
Asim Aslam 9e23855c37 Fixup the proxy, strip down go.mod. Win bigly 2019-06-07 13:42:39 +01:00
lpxxn a86c26d485 fix bug need pass the variable as a parameter to the anonymous function 2019-05-31 14:24:37 +08:00
Asim Aslam f824ba0779 non-blocking call chan when retries are 0 2019-04-18 09:05:22 +00:00
Asim Aslam b8f20924cc proxy publish 2019-02-23 17:06:17 +00:00
Asim Aslam 58adaef339 Add Exchange option 2019-02-23 10:50:53 +00:00
Asim Aslam b1a31134bd Support micro proxy 2019-01-30 18:42:11 +00:00
Asim Aslam 8090f9968d Update headers to remove X- prefix 2019-01-24 10:11:02 +00:00
Asim Aslam 6468733d98 Use protocol from node metadata 2019-01-18 12:30:39 +00:00
Asim Aslam c1d0237370 Add client response 2019-01-14 21:30:43 +00:00
Asim Aslam 9adebfcf1e rename method to endpoint 2019-01-10 21:25:31 +00:00
Asim Aslam 40ff5b749b Set topic header 2019-01-10 20:35:10 +00:00
Asim Aslam 648da5494f Change a few things 2019-01-10 11:39:39 +00:00
Asim Aslam 4cb41721f1 further codec changes 2019-01-08 15:38:25 +00:00
Asim Aslam d179c971af Switch default codec and add default codec for server 2019-01-07 13:48:38 +00:00
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