Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

transport

package

Go to main page

Versions in this module

v1

v1.0.3

Oct 17, 2016

Changes in this version

type Stream

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

+ type TargetInfo struct

+ Addr string

+ Metadata interface{}

v1.0.2

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{}

v1.0.1-GA

Aug 19, 2016

v1.0.0

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