type google.golang.org/grpc/mem.BufferPool
30 uses
google.golang.org/grpc/mem (current package)
buffer_pool.go#L30: type BufferPool interface {
buffer_pool.go#L46: var defaultBufferPool BufferPool
buffer_pool.go#L51: internal.SetDefaultBufferPoolForTesting = func(pool BufferPool) {
buffer_pool.go#L63: func DefaultBufferPool() BufferPool {
buffer_pool.go#L69: func NewTieredBufferPool(poolSizes ...int) BufferPool {
buffer_pool.go#L95: func (p *tieredBufferPool) getPool(size int) BufferPool {
buffer_pool.go#L150: var _ BufferPool = (*simpleBufferPool)(nil)
buffer_pool.go#L181: var _ BufferPool = NopBufferPool{}
buffer_slice.go#L104: func (s BufferSlice) MaterializeToBuffer(pool BufferPool) Buffer {
buffer_slice.go#L227: pool BufferPool
buffer_slice.go#L240: func NewWriter(buffers *BufferSlice, pool BufferPool) io.Writer {
buffer_slice.go#L252: func ReadAll(r io.Reader, pool BufferPool) (BufferSlice, error) {
buffers.go#L79: pool BufferPool
buffers.go#L94: func NewBuffer(data *[]byte, pool BufferPool) Buffer {
buffers.go#L117: func Copy(data []byte, pool BufferPool) Buffer {
google.golang.org/grpc
dialoptions.go#L793: func withBufferPool(bufferPool mem.BufferPool) DialOption {
rpc_util.go#L672: bufferPool mem.BufferPool
rpc_util.go#L738: func compress(in mem.BufferSlice, cp Compressor, compressor encoding.Compressor, pool mem.BufferPool) (mem.BufferSlice, payloadFormat, error) {
rpc_util.go#L887: func decompress(compressor encoding.Compressor, d mem.BufferSlice, dc Decompressor, maxReceiveMessageSize int, pool mem.BufferPool) (mem.BufferSlice, error) {
server.go#L180: bufferPool mem.BufferPool
server.go#L642: func bufferPool(bufferPool mem.BufferPool) ServerOption {
stream.go#L1843: 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#L529: bufferPool mem.BufferPool
controlbuf.go#L535: 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#L151: bufferPool mem.BufferPool
http2_server.go#L125: bufferPool mem.BufferPool
transport.go#L468: BufferPool mem.BufferPool
transport.go#L507: BufferPool mem.BufferPool