type google.golang.org/grpc/encoding.Compressor

21 uses

	google.golang.org/grpc/encoding (current package)
		encoding.go#L36: type Compressor interface {
		encoding.go#L55: var registeredCompressor = make(map[string]Compressor)
		encoding.go#L66: func RegisterCompressor(c Compressor) {
		encoding.go#L71: func GetCompressor(name string) Compressor {

	google.golang.org/grpc
		rpc_util.go#L552: func compress(in []byte, cp Compressor, compressor encoding.Compressor) ([]byte, error) {
		rpc_util.go#L633: func recvAndDecompress(p *parser, s *transport.Stream, dc Decompressor, maxReceiveMessageSize int, payInfo *payloadInfo, compressor encoding.Compressor) ([]byte, error) {
		rpc_util.go#L672: func decompress(compressor encoding.Compressor, d []byte, maxReceiveMessageSize int) ([]byte, int, error) {
		rpc_util.go#L701: func recv(p *parser, c baseCodec, s *transport.Stream, dc Decompressor, m interface{}, maxReceiveMessageSize int, payInfo *payloadInfo, compressor encoding.Compressor) error {
		rpc_util.go#L729: 	comp  encoding.Compressor
		rpc_util.go#L734: func newContextWithRPCInfo(ctx context.Context, failfast bool, codec baseCodec, cp Compressor, comp encoding.Compressor) context.Context {
		server.go#L982: func (s *Server) sendResponse(t transport.ServerTransport, stream *transport.Stream, msg interface{}, cp Compressor, opts *transport.Options, comp encoding.Compressor) error {
		server.go#L1124: 	var comp, decomp encoding.Compressor
		stream.go#L217: 	var comp encoding.Compressor
		stream.go#L399: 	comp  encoding.Compressor
		stream.go#L451: 	decomp    encoding.Compressor
		stream.go#L1061: 	var comp encoding.Compressor
		stream.go#L1132: 	comp      encoding.Compressor
		stream.go#L1135: 	decomp    encoding.Compressor
		stream.go#L1353: 	comp   encoding.Compressor
		stream.go#L1354: 	decomp encoding.Compressor
		stream.go#L1535: func prepareMsg(m interface{}, codec baseCodec, cp Compressor, comp encoding.Compressor) (hdr, payload, data []byte, err error) {