type google.golang.org/grpc/mem.BufferSlice
54 uses
google.golang.org/grpc/mem (current package)
buffer_slice.go#L45: type BufferSlice []Buffer
buffer_slice.go#L53: func (s BufferSlice) Len() int {
buffer_slice.go#L62: func (s BufferSlice) Ref() {
buffer_slice.go#L69: func (s BufferSlice) Free() {
buffer_slice.go#L79: func (s BufferSlice) CopyTo(dst []byte) int {
buffer_slice.go#L89: func (s BufferSlice) Materialize() []byte {
buffer_slice.go#L105: func (s BufferSlice) MaterializeToBuffer(pool BufferPool) Buffer {
buffer_slice.go#L121: func (s BufferSlice) Reader() *Reader {
buffer_slice.go#L137: data BufferSlice
buffer_slice.go#L150: func (r *Reader) Reset(s BufferSlice) {
buffer_slice.go#L223: buffers *BufferSlice
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) {
buffer_slice.go#L250: var result BufferSlice
google.golang.org/grpc
codec.go#L32: Marshal(v any) (mem.BufferSlice, error)
codec.go#L33: Unmarshal(data mem.BufferSlice, v any) error
codec.go#L69: func (c codecV0Bridge) Marshal(v any) (mem.BufferSlice, error) {
codec.go#L74: return mem.BufferSlice{mem.SliceBuffer(data)}, nil
codec.go#L77: func (c codecV0Bridge) Unmarshal(data mem.BufferSlice, v any) (err error) {
preloader.go#L35: encodedData mem.BufferSlice
preloader.go#L37: payload mem.BufferSlice
preloader.go#L62: p.encodedData = mem.BufferSlice{mem.SliceBuffer(materializedData)}
preloader.go#L67: var compData mem.BufferSlice
preloader.go#L76: compData = mem.BufferSlice{mem.SliceBuffer(materializedCompData)}
rpc_util.go#L741: Read(n int) (mem.BufferSlice, error)
rpc_util.go#L785: func (p *parser) recvMsg(maxReceiveMessageSize int) (payloadFormat, mem.BufferSlice, error) {
rpc_util.go#L814: func encode(c baseCodec, msg any) (mem.BufferSlice, error) {
rpc_util.go#L834: func compress(in mem.BufferSlice, cp Compressor, compressor encoding.Compressor, pool mem.BufferPool) (mem.BufferSlice, payloadFormat, error) {
rpc_util.go#L838: var out mem.BufferSlice
rpc_util.go#L879: func msgHeader(data, compData mem.BufferSlice, pf payloadFormat) (hdr []byte, payload mem.BufferSlice) {
rpc_util.go#L929: uncompressedBytes mem.BufferSlice
rpc_util.go#L944: func recvAndDecompress(p *parser, s recvCompressor, dc Decompressor, maxReceiveMessageSize int, payInfo *payloadInfo, compressor encoding.Compressor, isServer bool) (out mem.BufferSlice, err error) {
rpc_util.go#L985: func decompress(compressor encoding.Compressor, d mem.BufferSlice, dc Decompressor, maxReceiveMessageSize int, pool mem.BufferPool) (mem.BufferSlice, error) {
rpc_util.go#L1010: return mem.BufferSlice{mem.SliceBuffer(uncompressed)}, nil
stream.go#L1123: func (a *csAttempt) sendMsg(m any, hdr []byte, payld mem.BufferSlice, dataLength, payloadLength int) error {
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/encoding
encoding_v2.go#L34: Marshal(v any) (out mem.BufferSlice, err error)
encoding_v2.go#L39: Unmarshal(data mem.BufferSlice, v any) error
google.golang.org/grpc/encoding/proto
proto.go#L43: func (c *codecV2) Marshal(v any) (data mem.BufferSlice, err error) {
proto.go#L85: func (c *codecV2) Unmarshal(data mem.BufferSlice, v any) (err error) {
google.golang.org/grpc/internal/transport
client_stream.go#L92: func (s *ClientStream) Read(n int) (mem.BufferSlice, error) {
client_stream.go#L114: func (s *ClientStream) Write(hdr []byte, data mem.BufferSlice, opts *WriteOptions) error {
controlbuf.go#L158: data mem.BufferSlice
handler_server.go#L336: func (ht *serverHandlerTransport) write(s *ServerStream, hdr []byte, data mem.BufferSlice, _ *WriteOptions) error {
http2_client.go#L1111: func (t *http2Client) write(s *ClientStream, hdr []byte, data mem.BufferSlice, opts *WriteOptions) error {
http2_server.go#L1150: func (t *http2Server) write(s *ServerStream, hdr []byte, data mem.BufferSlice, _ *WriteOptions) error {
server_stream.go#L56: func (s *ServerStream) Read(n int) (mem.BufferSlice, error) {
server_stream.go#L70: func (s *ServerStream) Write(hdr []byte, data mem.BufferSlice, opts *WriteOptions) error {
transport.go#L397: func (s *Stream) read(n int) (data mem.BufferSlice, err error) {
transport.go#L408: data = make(mem.BufferSlice, 0, allocCap)
transport.go#L673: write(s *ServerStream, hdr []byte, data mem.BufferSlice, opts *WriteOptions) error