transport

Jun 7, 2017

Changes in this version

type CallHdr

+ Creds credentials.PerRPCCredentials

type ConnectOptions

+ InitialConnWindowSize int32

+ InitialWindowSize int32

type ServerConfig

+ InitialConnWindowSize int32

+ InitialWindowSize int32

Apr 28, 2017

Changes in this version

type ClientTransport

+ GetGoAwayReason func() GoAwayReason

+ type GoAwayReason uint8

+ const Invalid

+ const NoReason

+ const TooManyPings

type ServerConfig

+ KeepaliveParams keepalive.ServerParameters

+ KeepalivePolicy keepalive.EnforcementPolicy

type Stream

+ func (s *Stream) BytesReceived() bool

+ func (s *Stream) BytesSent() bool

+ func (s *Stream) Status() *status.Status

Apr 7, 2017

Changes in this version

type Stream

+ func (s *Stream) GoString() string

Mar 14, 2017

Changes in this version

type ConnectOptions

+ Authority string

+ KeepaliveParams keepalive.ClientParameters

+ StatsHandler stats.Handler

type ServerConfig

+ StatsHandler stats.Handler

Dec 2, 2016

Changes in this version

type ConnectOptions

+ FailOnNonTempDialError bool

+ type ServerConfig struct

+ AuthInfo credentials.AuthInfo

+ InTapHandle tap.ServerInHandle

+ MaxStreams uint32

Oct 17, 2016

Changes in this version

type Stream

+ func (s *Stream) SetHeader(md metadata.MD) error

+ type TargetInfo struct

+ Addr string

+ Metadata interface{}

Oct 3, 2016

Changes in this version

+ var ErrStreamDrain = streamErrorf(codes.Unavailable, "the server stops accepting new RPCs")

type ClientTransport

+ GoAway func() <-chan struct{}

type ConnectionError

+ func (e ConnectionError) Origin() error

+ func (e ConnectionError) Temporary() bool

type ServerTransport

+ Drain func()

type Stream

+ func (s *Stream) Done() <-chan struct{}

+ func (s *Stream) GoAway() <-chan struct{}

Jul 11, 2016

Changes in this version

+ var ErrConnClosing = ConnectionError

+ var ErrIllegalHeaderWrite = errors.New("transport: the stream is done or WriteHeader was already called")

+ var ErrIllegalTrailerSet = errors.New("transport: trailer has been set")

+ type CallHdr struct

+ Flush bool

+ Host string

+ Method string

+ RecvCompress string

+ SendCompress string

+ type ClientTransport interface

+ Close func() error

+ CloseStream func(stream *Stream, err error)

+ Error func() <-chan struct{}

+ GracefulClose func() error

+ NewStream func(ctx context.Context, callHdr *CallHdr) (*Stream, error)

+ Write func(s *Stream, data []byte, opts *Options) error

+ func NewClientTransport(target string, opts *ConnectOptions) (ClientTransport, error)

+ type ConnectOptions struct

+ Dialer func(string, time.Duration) (net.Conn, error)

+ PerRPCCredentials []credentials.PerRPCCredentials

+ Timeout time.Duration

+ TransportCredentials credentials.TransportCredentials

+ UserAgent string

+ type ConnectionError struct

+ Desc string

+ func ConnectionErrorf(format string, a ...interface{}) ConnectionError

+ func (e ConnectionError) Error() string

+ type Options struct

+ Delay bool

+ Last bool

+ type ServerTransport interface

+ Close func() error

+ HandleStreams func(func(*Stream))

+ RemoteAddr func() net.Addr

+ Write func(s *Stream, data []byte, opts *Options) error

+ WriteHeader func(s *Stream, md metadata.MD) error

+ WriteStatus func(s *Stream, statusCode codes.Code, statusDesc string) error

+ func NewServerHandlerTransport(w http.ResponseWriter, r *http.Request) (ServerTransport, error)

+ func NewServerTransport(protocol string, conn net.Conn, maxStreams uint32, ...) (ServerTransport, error)

+ type Stream struct

+ func StreamFromContext(ctx context.Context) (s *Stream, ok bool)

+ func (s *Stream) Context() context.Context

+ func (s *Stream) Header() (metadata.MD, error)

+ func (s *Stream) Method() string

+ func (s *Stream) Read(p []byte) (n int, err error)

+ func (s *Stream) RecvCompress() string

+ func (s *Stream) ServerTransport() ServerTransport

+ func (s *Stream) SetSendCompress(str string)

+ func (s *Stream) SetTrailer(md metadata.MD) error

+ func (s *Stream) StatusCode() codes.Code

+ func (s *Stream) StatusDesc() string

+ func (s *Stream) TraceContext(tr trace.Trace)

+ func (s *Stream) Trailer() metadata.MD

+ type StreamError struct

+ Code codes.Code

+ Desc string

+ func ContextErr(err error) StreamError

+ func StreamErrorf(c codes.Code, format string, a ...interface{}) StreamError

+ func (e StreamError) Error() string