Menghan Li
277e90a432
Client load report for grpclb. ( #1200 )
2017-04-27 10:43:38 -07:00
MakMukhi
2d949be2fe
Make sure all in-flight streams close when ClientConn.Close() is called. ( #1136 )
...
* Make sure all in-flight streams close when ClientConn.Close() is called.
* added test
2017-04-21 15:03:04 -07:00
Menghan Li
cd8432ec07
Move handling stats.End to clientStream.finish() ( #1182 )
...
* move handling stats.End to clientStream.finish()
* add stats test for streaming RPC not calling last recv()
2017-04-12 11:55:54 -07:00
dfawley
1d27587e10
Change status package to deal with concrete types instead of interfaces ( #1171 )
2017-04-06 11:41:07 -07:00
dfawley
b507112439
Add status package for reporting gRPC status and errors ( #1156 )
...
When an error implemented by the status package is returned from a service
handler, the server will transmit a rich status message in the
"grpc-status-details-bin" trailing metadata field if any detailed data is
attached to the error. Client-side, we will decode them if present in the
server's response and return them to the user code performing the RPC.
This is backward compatible with the existing errors supported by the grpc
package. However, the grpc.Errorf, grpc.Code and grpc.ErrorDesc functions for
managing errors are now deprecated; status.Errorf and status.Status type
asserions should be used instead.
2017-04-05 10:35:40 -07:00
Mahak Mukhi
a94b0948a3
Client should have a check on maximum size of received message size.
2017-03-09 16:58:23 -08:00
Menghan Li
cb653e4b61
Change stats APIs ( #1030 )
...
Change stats API from one static handler to one handler per server or client.
2017-01-09 17:11:32 -08:00
Qi Zhao
09aecb094e
Add the initial service config support ( #1009 )
...
* Add the initial service config support
* start scWatcher later
* remove timeoutCh
* address the comments
* deal with dial timeout
* defer cancel for the newly created context for correct lifetime management
* fix the defer order
* added other 2 missing cancels
2016-12-19 16:31:00 -08:00
Menghan Li
deb01f422a
add stats tagger APIs and connection stats. ( #992 )
...
* add stats.tagger APIs and connection stats.
* fix comments
use ac.ctx in http2client
change name and comments
small fixes stats_tests
* add a TODO to ConnTagInfo
* rename handle to handleRPC
* modify stats comments
2016-11-30 16:25:46 -08:00
Menghan Li
ff0b1db33e
fix comments
2016-11-08 10:31:02 -08:00
Menghan Li
3de821b781
remote end stats in header() and SendMsg()
2016-11-07 18:30:22 -08:00
Menghan Li
badd5540a4
fix comments
2016-11-07 17:55:44 -08:00
Menghan Li
5938492b60
fix comments
2016-11-07 15:16:52 -08:00
Menghan Li
a4edc462a2
renaming
2016-11-07 15:16:52 -08:00
Menghan Li
aa5b5c7e2a
client side, use user context, and change sent time
2016-11-07 15:16:52 -08:00
Menghan Li
1d2a929ae5
add stats.Begin and stats.End
2016-11-07 15:16:52 -08:00
Menghan Li
c0087b3c91
add failfast option to stats
2016-11-07 15:16:52 -08:00
Menghan Li
c698588285
Renaming types and variables
2016-11-07 15:16:52 -08:00
Menghan Li
e42a66c81b
add client stats
2016-11-07 15:16:52 -08:00
Menghan Li
7984a9c679
change CallBack to handler, and move ctx out of Stats.
2016-11-07 15:16:52 -08:00
Menghan Li
17ee5a3637
Add package stats, and export stats on server side.
2016-11-07 15:16:52 -08:00
Menghan Li
e790079956
Add grpc.SetHeader and ServerStream.SetHeader
2016-10-11 13:58:16 -07:00
Menghan Li
1247834778
Allow multiple calls to setTrailer
2016-09-29 14:38:20 -07:00
Menghan Li
52f6504dc2
Merge pull request #867 from iamqizhao/master
...
Support client side interceptor
2016-09-02 15:12:15 -07:00
Menghan Li
5e734ab23e
Avoid creating transport stream error outside of transport
2016-09-02 11:57:42 -07:00
iamqizhao
1e47e17230
Support client side interceptor
2016-08-26 13:50:38 -07:00
Menghan Li
c72b08a774
Change errors returned by ac.wait()
2016-08-16 16:56:16 -07:00
Menghan Li
d2b50c7ca5
Allocate clientstream after getTransport
2016-08-09 13:22:02 -07:00
Menghan Li
43cdc3c81c
Finish clientstream when newclientsteram returns error
2016-08-08 16:27:22 -07:00
iamqizhao
a4c08780d5
Merge branch 'master' of https://github.com/grpc/grpc-go
2016-07-29 10:10:58 -07:00
iamqizhao
80572b2739
fix the streaming rpc case
2016-07-28 16:45:48 -07:00
iamqizhao
8c908a8c1d
Reject over-sized requests on server
2016-07-26 16:44:49 -07:00
iamqizhao
9ad4c58355
Make it work for streaming
2016-07-21 16:19:34 -07:00
iamqizhao
873cc272c2
support goaway
2016-07-20 18:48:49 -07:00
iamqizhao
0e86f69ef3
Merge branch 'master' of https://github.com/grpc/grpc-go
2016-07-19 16:29:15 -07:00
iamqizhao
d2e79470cc
client goaway support
2016-07-19 16:29:13 -07:00
Menghan Li
d017580d29
Merge pull request #769 from iamqizhao/master
...
Fix an issue in #766
2016-07-19 16:19:02 -07:00
Michael McGreevy
36bd01e409
Clarify doc comment for ClientStream.Trailer by simplifying it.
...
Change-Id: I1ce494d753b6e48d23c4aa23b396d182f44d9c39
2016-07-19 14:20:15 +10:00
iamqizhao
8635e25ebb
Specialize the io.EOF processing of server streaming
2016-07-18 14:57:52 -07:00
iamqizhao
0bfa80150a
add a TODO
2016-07-15 15:43:42 -07:00
iamqizhao
df0a2ae779
finish trace with the right status
2016-07-15 15:06:00 -07:00
iamqizhao
c9f0b89a96
clean up underlying footprint when Stream.Done() is read
2016-07-15 14:53:49 -07:00
iamqizhao
ec7eacfcc4
some fix
2016-07-15 11:02:03 -07:00
iamqizhao
0f1aeede97
do not cancel stream in http2_client.go, use done chanel instead
2016-07-14 18:38:43 -07:00
iamqizhao
7b7cb1ae8c
fix bugs and flaky tests
2016-07-14 17:12:11 -07:00
Menghan Li
ffdfb592e8
Fix type assertion error after rebase
2016-07-08 10:35:38 -07:00
iamqizhao
be59d023f2
refactor error handling a bit
2016-06-29 15:21:44 -07:00
iamqizhao
213a20c4fe
bug fix, typo fix and slight error refactoring
2016-06-28 16:08:19 -07:00
iamqizhao
3e71fb360d
Support fail-fast mode and make it the default
2016-06-27 14:36:59 -07:00
joe2far
487ada6517
Fixed typos in docstrings
2016-06-07 12:01:07 +01:00