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 … // NewConnection creates a new spdy connection from an existing // network connection. func NewConnection(conn net.Conn, server bool) (*Connection, error) { … } // Ping sends a ping frame across the connection and // returns the response time func (s *Connection) Ping() (time.Duration, error) { … } // Serve handles frames sent from the server, including reply frames // which are needed to fully initiate connections. Both clients and servers // should call Serve in a separate goroutine before creating streams. 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) { … } // checkStreamFrame checks to see if a stream frame is allowed. // If the stream is invalid, then a reset frame with protocol error // will be returned. 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) { … } // CreateStream creates a new spdy stream using the parameters for // creating the stream frame. The stream frame will be sent upon // calling this function, however this function does not wait for // the reply frame. If waiting for the reply is desired, use // the stream Wait or WaitTimeout function on the stream returned // by this function. func (s *Connection) CreateStream(headers http.Header, parent *Stream, fin bool) (*Stream, error) { … } func (s *Connection) shutdown(closeTimeout time.Duration) { … } // Closes spdy connection by sending GoAway frame and initiating shutdown func (s *Connection) Close() error { … } // CloseWait closes the connection and waits for shutdown // to finish. Note the underlying network Connection // is not closed until the end of shutdown. func (s *Connection) CloseWait() error { … } // Wait waits for the connection to finish shutdown or for // the wait timeout duration to expire. This needs to be // called either after Close has been called or the GOAWAYFRAME // has been received. If the wait timeout is 0, this function // will block until shutdown finishes. If wait is never called // and a shutdown error occurs, that error will be logged as an // unhandled error. func (s *Connection) Wait(waitTimeout time.Duration) error { … } // NotifyClose registers a channel to be called when the remote // peer inidicates connection closure. The last stream to be // received by the remote will be sent on the channel. The notify // timeout will determine the duration between go away received // and the connection being closed. func (s *Connection) NotifyClose(c chan<- *Stream, timeout time.Duration) { … } // SetCloseTimeout sets the amount of time close will wait for // streams to finish before terminating the underlying network // connection. Setting the timeout to 0 will cause close to // wait forever, which is the default. func (s *Connection) SetCloseTimeout(timeout time.Duration) { … } // SetIdleTimeout sets the amount of time the connection may sit idle before // it is forcefully terminated. 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 { … } // getNextStreamId returns the next sequential id // every call should produce a unique value or an error func (s *Connection) getNextStreamId() spdy.StreamId { … } // PeekNextStreamId returns the next sequential id and keeps the next id untouched 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) { … } // FindStream looks up the given stream id and either waits for the // stream to be found or returns nil if the stream id is no longer // valid. func (s *Connection) FindStream(streamId uint32) *Stream { … } func (s *Connection) CloseChan() <-chan bool { … }
Codebase Browser
kubernetes