type google.golang.org/grpc/encoding.Compressor
21 uses
google.golang.org/grpc/encoding (current package)
encoding.go#L45: type Compressor interface {
encoding.go#L60: var registeredCompressor = make(map[string]Compressor)
encoding.go#L71: func RegisterCompressor(c Compressor) {
encoding.go#L79: func GetCompressor(name string) Compressor {
google.golang.org/grpc
rpc_util.go#L738: func compress(in mem.BufferSlice, cp Compressor, compressor encoding.Compressor, pool mem.BufferPool) (mem.BufferSlice, payloadFormat, error) {
rpc_util.go#L848: func recvAndDecompress(p *parser, s recvCompressor, dc Decompressor, maxReceiveMessageSize int, payInfo *payloadInfo, compressor encoding.Compressor, isServer bool,
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#L932: func recv(p *parser, c baseCodec, s recvCompressor, dc Decompressor, m any, maxReceiveMessageSize int, payInfo *payloadInfo, compressor encoding.Compressor, isServer bool) error {
rpc_util.go#L963: comp encoding.Compressor
rpc_util.go#L968: func newContextWithRPCInfo(ctx context.Context, failfast bool, codec baseCodec, cp Compressor, comp encoding.Compressor) context.Context {
server.go#L1171: func (s *Server) sendResponse(ctx context.Context, stream *transport.ServerStream, msg any, cp Compressor, opts *transport.WriteOptions, comp encoding.Compressor) error {
server.go#L1342: var comp, decomp encoding.Compressor
stream.go#L308: var compressorV1 encoding.Compressor
stream.go#L546: compressorV1 encoding.Compressor
stream.go#L607: decompressorV1 encoding.Compressor
stream.go#L1289: var comp encoding.Compressor
stream.go#L1365: sendCompressorV1 encoding.Compressor
stream.go#L1368: decompressorV1 encoding.Compressor
stream.go#L1592: compressorV1 encoding.Compressor
stream.go#L1594: decompressorV1 encoding.Compressor
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) {