type google.golang.org/grpc/mem.BufferPool
37 uses
google.golang.org/grpc/mem (current package)
buffer_pool.go#L30: type BufferPool interface {
buffer_pool.go#L49: defaultBufferPool BufferPool
buffer_pool.go#L59: internal.SetDefaultBufferPool = func(pool BufferPool) {
buffer_pool.go#L71: func DefaultBufferPool() BufferPool {
buffer_pool.go#L77: func NewTieredBufferPool(poolSizes ...int) BufferPool {
buffer_pool.go#L87: func NewBinaryTieredBufferPool(powerOfTwoExponents ...uint8) (BufferPool, error) {
buffer_pool.go#L96: var _ BufferPool = NopBufferPool{}
buffer_slice.go#L105: func (s BufferSlice) MaterializeToBuffer(pool BufferPool) Buffer {
buffer_slice.go#L224: pool BufferPool
buffer_slice.go#L237: func NewWriter(buffers *BufferSlice, pool BufferPool) io.Writer {
buffer_slice.go#L249: func ReadAll(r io.Reader, pool BufferPool) (BufferSlice, error) {
buffers.go#L92: pool BufferPool
buffers.go#L107: func NewBuffer(data *[]byte, pool BufferPool) Buffer {
buffers.go#L130: func Copy(data []byte, pool BufferPool) Buffer {
google.golang.org/grpc
dialoptions.go#L808: func withBufferPool(bufferPool mem.BufferPool) DialOption {
rpc_util.go#L768: bufferPool mem.BufferPool
rpc_util.go#L834: func compress(in mem.BufferSlice, cp Compressor, compressor encoding.Compressor, pool mem.BufferPool) (mem.BufferSlice, payloadFormat, error) {
rpc_util.go#L985: func decompress(compressor encoding.Compressor, d mem.BufferSlice, dc Decompressor, maxReceiveMessageSize int, pool mem.BufferPool) (mem.BufferSlice, error) {
server.go#L183: bufferPool mem.BufferPool
server.go#L660: func bufferPool(bufferPool mem.BufferPool) ServerOption {
stream.go#L1887: func prepareMsg(m any, codec baseCodec, cp Compressor, comp encoding.Compressor, pool mem.BufferPool) (hdr []byte, data, payload mem.BufferSlice, pf payloadFormat, err error) {
google.golang.org/grpc/internal/transport
controlbuf.go#L534: bufferPool mem.BufferPool
controlbuf.go#L542: func newLoopyWriter(s side, fr *framer, cbuf *controlBuffer, bdpEst *bdpEstimator, conn net.Conn, logger *grpclog.PrefixLogger, goAwayHandler func(*goAway) (bool, error), bufferPool mem.BufferPool) *loopyWriter {
handler_server.go#L53: func NewServerHandlerTransport(w http.ResponseWriter, r *http.Request, stats stats.Handler, bufferPool mem.BufferPool) (ServerTransport, error) {
handler_server.go#L176: bufferPool mem.BufferPool
http2_client.go#L155: bufferPool mem.BufferPool
http2_server.go#L128: bufferPool mem.BufferPool
http_util.go#L409: pool mem.BufferPool
http_util.go#L429: func newFramer(conn io.ReadWriter, writeBufferSize, readBufferSize int, sharedWriteBuffer bool, maxHeaderListSize uint32, memPool mem.BufferPool) *framer {
transport.go#L514: BufferPool mem.BufferPool
transport.go#L553: BufferPool mem.BufferPool
google.golang.org/grpc/internal/transport/readyreader
ready_reader.go#L43: ReadOnReady(bufSize int, pool mem.BufferPool) (b *[]byte, n int, err error)
ready_reader.go#L58: pool mem.BufferPool
ready_reader.go#L109: func (c *nonBlockingReader) ReadOnReady(bufSize int, pool mem.BufferPool) (*[]byte, int, error) {
ready_reader.go#L144: func (c *blockingReader) ReadOnReady(bufSize int, pool mem.BufferPool) (*[]byte, int, error) {
ready_reader.go#L168: pool mem.BufferPool
ready_reader.go#L178: func NewBuffered(rd Reader, size int, pool mem.BufferPool) io.Reader {