var ErrInvalidStreamId …
var ErrTimeout …
var ErrReset …
var ErrWriteClosedStream …
const FRAME_WORKERS …
const QUEUE_SIZE …
type StreamHandler …
type AuthHandler …
type idleAwareFramer …
func newIdleAwareFramer(framer *spdy.Framer) *idleAwareFramer { … }
func (i *idleAwareFramer) monitor() { … }
func (i *idleAwareFramer) WriteFrame(frame spdy.Frame) error { … }
func (i *idleAwareFramer) ReadFrame() (spdy.Frame, error) { … }
func (i *idleAwareFramer) setIdleTimeout(timeout time.Duration) { … }
type Connection …
func NewConnection(conn net.Conn, server bool) (*Connection, error) { … }
func (s *Connection) Ping() (time.Duration, error) { … }
func (s *Connection) Serve(newHandler StreamHandler) { … }
func (s *Connection) frameHandler(frameQueue *PriorityFrameQueue, newHandler StreamHandler) { … }
func (s *Connection) getStreamPriority(streamId spdy.StreamId) uint8 { … }
func (s *Connection) addStreamFrame(frame *spdy.SynStreamFrame) { … }
func (s *Connection) checkStreamFrame(frame *spdy.SynStreamFrame) bool { … }
func (s *Connection) handleStreamFrame(frame *spdy.SynStreamFrame, newHandler StreamHandler) error { … }
func (s *Connection) handleReplyFrame(frame *spdy.SynReplyFrame) error { … }
func (s *Connection) handleResetFrame(frame *spdy.RstStreamFrame) error { … }
func (s *Connection) handleHeaderFrame(frame *spdy.HeadersFrame) error { … }
func (s *Connection) handleDataFrame(frame *spdy.DataFrame) error { … }
func (s *Connection) handlePingFrame(frame *spdy.PingFrame) error { … }
func (s *Connection) handleGoAwayFrame(frame *spdy.GoAwayFrame) error { … }
func (s *Connection) remoteStreamFinish(stream *Stream) { … }
func (s *Connection) CreateStream(headers http.Header, parent *Stream, fin bool) (*Stream, error) { … }
func (s *Connection) shutdown(closeTimeout time.Duration) { … }
func (s *Connection) Close() error { … }
func (s *Connection) CloseWait() error { … }
func (s *Connection) Wait(waitTimeout time.Duration) error { … }
func (s *Connection) NotifyClose(c chan<- *Stream, timeout time.Duration) { … }
func (s *Connection) SetCloseTimeout(timeout time.Duration) { … }
func (s *Connection) SetIdleTimeout(timeout time.Duration) { … }
func (s *Connection) sendHeaders(headers http.Header, stream *Stream, fin bool) error { … }
func (s *Connection) sendReply(headers http.Header, stream *Stream, fin bool) error { … }
func (s *Connection) sendResetFrame(status spdy.RstStreamStatus, streamId spdy.StreamId) error { … }
func (s *Connection) sendReset(status spdy.RstStreamStatus, stream *Stream) error { … }
func (s *Connection) sendStream(stream *Stream, fin bool) error { … }
func (s *Connection) getNextStreamId() spdy.StreamId { … }
func (s *Connection) PeekNextStreamId() spdy.StreamId { … }
func (s *Connection) validateStreamId(rid spdy.StreamId) error { … }
func (s *Connection) addStream(stream *Stream) { … }
func (s *Connection) removeStream(stream *Stream) { … }
func (s *Connection) getStream(streamId spdy.StreamId) (stream *Stream, ok bool) { … }
func (s *Connection) FindStream(streamId uint32) *Stream { … }
func (s *Connection) CloseChan() <-chan bool { … }