kubernetes/vendor/google.golang.org/grpc/internal/transport/http_util.go

const http2MaxFrameLen …

const http2InitHeaderTableSize …

var clientPreface …

var http2ErrConvTab …

var HTTPStatusConvTab …

var grpcStatusDetailsBinHeader …

// isReservedHeader checks whether hdr belongs to HTTP2 headers
// reserved by gRPC protocol. Any other headers are classified as the
// user-specified metadata.
func isReservedHeader(hdr string) bool { … }

// isWhitelistedHeader checks whether hdr should be propagated into metadata
// visible to users, even though it is classified as "reserved", above.
func isWhitelistedHeader(hdr string) bool { … }

const binHdrSuffix …

func encodeBinHeader(v []byte) string { … }

func decodeBinHeader(v string) ([]byte, error) { … }

func encodeMetadataHeader(k, v string) string { … }

func decodeMetadataHeader(k, v string) (string, error) { … }

type timeoutUnit …

const hour …

const minute …

const second …

const millisecond …

const microsecond …

const nanosecond …

func timeoutUnitToDuration(u timeoutUnit) (d time.Duration, ok bool) { … }

func decodeTimeout(s string) (time.Duration, error) { … }

const spaceByte …

const tildeByte …

const percentByte …

// encodeGrpcMessage is used to encode status code in header field
// "grpc-message". It does percent encoding and also replaces invalid utf-8
// characters with Unicode replacement character.
//
// It checks to see if each individual byte in msg is an allowable byte, and
// then either percent encoding or passing it through. When percent encoding,
// the byte is converted into hexadecimal notation with a '%' prepended.
func encodeGrpcMessage(msg string) string { … }

func encodeGrpcMessageUnchecked(msg string) string { … }

// decodeGrpcMessage decodes the msg encoded by encodeGrpcMessage.
func decodeGrpcMessage(msg string) string { … }

func decodeGrpcMessageUnchecked(msg string) string { … }

type bufWriter …

func newBufWriter(conn net.Conn, batchSize int, pool *sync.Pool) *bufWriter { … }

func (w *bufWriter) Write(b []byte) (n int, err error) { … }

func (w *bufWriter) Flush() error { … }

func (w *bufWriter) flushKeepBuffer() error { … }

type ioError …

func (i ioError) Unwrap() error { … }

func isIOError(err error) bool { … }

func toIOError(err error) error { … }

type framer …

var writeBufferPoolMap …

var writeBufferMutex …

func newFramer(conn net.Conn, writeBufferSize, readBufferSize int, sharedWriteBuffer bool, maxHeaderListSize uint32) *framer { … }

func getWriteBufferPool(size int) *sync.Pool { … }

// parseDialTarget returns the network and address to pass to dialer.
func parseDialTarget(target string) (string, string) { … }