type writeFramer … type writeContext … // writeEndsStream reports whether w writes a frame that will transition // the stream to a half-closed local state. This returns false for RST_STREAM, // which closes the entire stream (not just the local half). func writeEndsStream(w writeFramer) bool { … } type flushFrameWriter … func (flushFrameWriter) writeFrame(ctx writeContext) error { … } func (flushFrameWriter) staysWithinBuffer(max int) bool { … } type writeSettings … func (s writeSettings) staysWithinBuffer(max int) bool { … } func (s writeSettings) writeFrame(ctx writeContext) error { … } type writeGoAway … func (p *writeGoAway) writeFrame(ctx writeContext) error { … } func (*writeGoAway) staysWithinBuffer(max int) bool { … } type writeData … func (w *writeData) String() string { … } func (w *writeData) writeFrame(ctx writeContext) error { … } func (w *writeData) staysWithinBuffer(max int) bool { … } type handlerPanicRST … func (hp handlerPanicRST) writeFrame(ctx writeContext) error { … } func (hp handlerPanicRST) staysWithinBuffer(max int) bool { … } func (se StreamError) writeFrame(ctx writeContext) error { … } func (se StreamError) staysWithinBuffer(max int) bool { … } type writePing … func (w writePing) writeFrame(ctx writeContext) error { … } func (w writePing) staysWithinBuffer(max int) bool { … } type writePingAck … func (w writePingAck) writeFrame(ctx writeContext) error { … } func (w writePingAck) staysWithinBuffer(max int) bool { … } type writeSettingsAck … func (writeSettingsAck) writeFrame(ctx writeContext) error { … } func (writeSettingsAck) staysWithinBuffer(max int) bool { … } // splitHeaderBlock splits headerBlock into fragments so that each fragment fits // in a single frame, then calls fn for each fragment. firstFrag/lastFrag are true // for the first/last fragment, respectively. func splitHeaderBlock(ctx writeContext, headerBlock []byte, fn func(ctx writeContext, frag []byte, firstFrag, lastFrag bool) error) error { … } type writeResHeaders … func encKV(enc *hpack.Encoder, k, v string) { … } func (w *writeResHeaders) staysWithinBuffer(max int) bool { … } func (w *writeResHeaders) writeFrame(ctx writeContext) error { … } func (w *writeResHeaders) writeHeaderBlock(ctx writeContext, frag []byte, firstFrag, lastFrag bool) error { … } type writePushPromise … func (w *writePushPromise) staysWithinBuffer(max int) bool { … } func (w *writePushPromise) writeFrame(ctx writeContext) error { … } func (w *writePushPromise) writeHeaderBlock(ctx writeContext, frag []byte, firstFrag, lastFrag bool) error { … } type write100ContinueHeadersFrame … func (w write100ContinueHeadersFrame) writeFrame(ctx writeContext) error { … } func (w write100ContinueHeadersFrame) staysWithinBuffer(max int) bool { … } type writeWindowUpdate … func (wu writeWindowUpdate) staysWithinBuffer(max int) bool { … } func (wu writeWindowUpdate) writeFrame(ctx writeContext) error { … } // encodeHeaders encodes an http.Header. If keys is not nil, then (k, h[k]) // is encoded only if k is in keys. func encodeHeaders(enc *hpack.Encoder, h http.Header, keys []string) { … }
Codebase Browser
kubernetes