type google.golang.org/grpc/mem.BufferSlice
56 uses
google.golang.org/grpc/mem (current package)
buffer_slice.go#L44: type BufferSlice []Buffer
buffer_slice.go#L52: func (s BufferSlice) Len() int {
buffer_slice.go#L61: func (s BufferSlice) Ref() {
buffer_slice.go#L68: func (s BufferSlice) Free() {
buffer_slice.go#L78: func (s BufferSlice) CopyTo(dst []byte) int {
buffer_slice.go#L88: func (s BufferSlice) Materialize() []byte {
buffer_slice.go#L104: func (s BufferSlice) MaterializeToBuffer(pool BufferPool) Buffer {
buffer_slice.go#L120: func (s BufferSlice) Reader() Reader {
buffer_slice.go#L142: Reset(s BufferSlice)
buffer_slice.go#L146: data BufferSlice
buffer_slice.go#L156: func (r *sliceReader) Reset(s BufferSlice) {
buffer_slice.go#L226: buffers *BufferSlice
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) {
buffer_slice.go#L253: 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#L65: p.encodedData = mem.BufferSlice{mem.SliceBuffer(materializedData)}
preloader.go#L70: var compData mem.BufferSlice
preloader.go#L79: compData = mem.BufferSlice{mem.SliceBuffer(materializedCompData)}
rpc_util.go#L657: Read(n int) (mem.BufferSlice, error)
rpc_util.go#L689: func (p *parser) recvMsg(maxReceiveMessageSize int) (payloadFormat, mem.BufferSlice, error) {
rpc_util.go#L718: func encode(c baseCodec, msg any) (mem.BufferSlice, error) {
rpc_util.go#L738: func compress(in mem.BufferSlice, cp Compressor, compressor encoding.Compressor, pool mem.BufferPool) (mem.BufferSlice, payloadFormat, error) {
rpc_util.go#L742: var out mem.BufferSlice
rpc_util.go#L783: func msgHeader(data, compData mem.BufferSlice, pf payloadFormat) (hdr []byte, payload mem.BufferSlice) {
rpc_util.go#L833: uncompressedBytes mem.BufferSlice
rpc_util.go#L849: ) (out mem.BufferSlice, err error) {
rpc_util.go#L887: func decompress(compressor encoding.Compressor, d mem.BufferSlice, dc Decompressor, maxReceiveMessageSize int, pool mem.BufferPool) (mem.BufferSlice, error) {
rpc_util.go#L896: return mem.BufferSlice{mem.SliceBuffer(uncompressed)}, nil
stream.go#L1093: func (a *csAttempt) sendMsg(m any, hdr []byte, payld mem.BufferSlice, dataLength, payloadLength int) error {
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/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#L69: func (c *codecV2) Unmarshal(data mem.BufferSlice, v any) (err error) {
google.golang.org/grpc/internal/transport
client_stream.go#L54: func (s *ClientStream) Read(n int) (mem.BufferSlice, error) {
client_stream.go#L76: func (s *ClientStream) Write(hdr []byte, data mem.BufferSlice, opts *WriteOptions) error {
controlbuf.go#L163: data mem.BufferSlice
controlbuf.go#L672: reader: mem.BufferSlice{}.Reader(),
controlbuf.go#L708: reader: mem.BufferSlice{}.Reader(),
handler_server.go#L336: func (ht *serverHandlerTransport) write(s *ServerStream, hdr []byte, data mem.BufferSlice, _ *WriteOptions) error {
http2_client.go#L1090: func (t *http2Client) write(s *ClientStream, hdr []byte, data mem.BufferSlice, opts *WriteOptions) error {
http2_server.go#L1149: func (t *http2Server) write(s *ServerStream, hdr []byte, data mem.BufferSlice, _ *WriteOptions) error {
server_stream.go#L55: func (s *ServerStream) Read(n int) (mem.BufferSlice, error) {
server_stream.go#L69: func (s *ServerStream) Write(hdr []byte, data mem.BufferSlice, opts *WriteOptions) error {
transport.go#L376: func (s *Stream) read(n int) (data mem.BufferSlice, err error) {
transport.go#L615: write(s *ServerStream, hdr []byte, data mem.BufferSlice, opts *WriteOptions) error