type google.golang.org/grpc/internal/transport.http2Client

38 uses

	google.golang.org/grpc/internal/transport (current package)
		http2_client.go#L56: type http2Client struct {
		http2_client.go#L166: func newHTTP2Client(connectCtx, ctx context.Context, addr resolver.Address, opts ConnectOptions, onPrefaceReceipt func(), onGoAway func(GoAwayReason), onClose func()) (_ *http2Client, err error) {
		http2_client.go#L246: 	t := &http2Client{
		http2_client.go#L372: func (t *http2Client) newStream(ctx context.Context, callHdr *CallHdr) *Stream {
		http2_client.go#L408: func (t *http2Client) getPeer() *peer.Peer {
		http2_client.go#L415: func (t *http2Client) createHeaderFields(ctx context.Context, callHdr *CallHdr) ([]hpack.HeaderField, error) {
		http2_client.go#L508: func (t *http2Client) createAudience(callHdr *CallHdr) string {
		http2_client.go#L523: func (t *http2Client) getTrAuthData(ctx context.Context, audience string) (map[string]string, error) {
		http2_client.go#L546: func (t *http2Client) getCallAuthData(ctx context.Context, audience string, callHdr *CallHdr) (map[string]string, error) {
		http2_client.go#L582: func (t *http2Client) NewStream(ctx context.Context, callHdr *CallHdr) (_ *Stream, err error) {
		http2_client.go#L731: func (t *http2Client) CloseStream(s *Stream, err error) {
		http2_client.go#L743: func (t *http2Client) closeStream(s *Stream, err error, rst bool, rstCode http2.ErrCode, st *status.Status, mdata map[string][]string, eosReceived bool) {
		http2_client.go#L808: func (t *http2Client) Close() error {
		http2_client.go#L851: func (t *http2Client) GracefulClose() {
		http2_client.go#L870: func (t *http2Client) Write(s *Stream, hdr []byte, data []byte, opts *Options) error {
		http2_client.go#L893: func (t *http2Client) getStream(f http2.Frame) *Stream {
		http2_client.go#L903: func (t *http2Client) adjustWindow(s *Stream, n uint32) {
		http2_client.go#L912: func (t *http2Client) updateWindow(s *Stream, n uint32) {
		http2_client.go#L921: func (t *http2Client) updateFlowControl(n uint32) {
		http2_client.go#L942: func (t *http2Client) handleData(f *http2.DataFrame) {
		http2_client.go#L1008: func (t *http2Client) handleRSTStream(f *http2.RSTStreamFrame) {
		http2_client.go#L1034: func (t *http2Client) handleSettings(f *http2.SettingsFrame, isFirst bool) {
		http2_client.go#L1083: func (t *http2Client) handlePing(f *http2.PingFrame) {
		http2_client.go#L1096: func (t *http2Client) handleGoAway(f *http2.GoAwayFrame) {
		http2_client.go#L1166: func (t *http2Client) setGoAwayReason(f *http2.GoAwayFrame) {
		http2_client.go#L1176: func (t *http2Client) GetGoAwayReason() GoAwayReason {
		http2_client.go#L1182: func (t *http2Client) handleWindowUpdate(f *http2.WindowUpdateFrame) {
		http2_client.go#L1190: func (t *http2Client) operateHeaders(frame *http2.MetaHeadersFrame) {
		http2_client.go#L1271: func (t *http2Client) reader() {
		http2_client.go#L1350: func (t *http2Client) keepalive() {
		http2_client.go#L1428: func (t *http2Client) Error() <-chan struct{} {
		http2_client.go#L1432: func (t *http2Client) GoAway() <-chan struct{} {
		http2_client.go#L1436: func (t *http2Client) ChannelzMetric() *channelz.SocketInternalMetric {
		http2_client.go#L1460: func (t *http2Client) RemoteAddr() net.Addr { return t.remoteAddr }
		http2_client.go#L1462: func (t *http2Client) IncrMsgSent() {
		http2_client.go#L1467: func (t *http2Client) IncrMsgRecv() {
		http2_client.go#L1472: func (t *http2Client) getOutFlowWindow() int64 {
		transport.go#L240: 	ct           *http2Client       // nil for server side Stream