type google.golang.org/grpc/encoding.Compressor
21 uses
google.golang.org/grpc/encoding (current package)
encoding.go#L41: type Compressor interface {
encoding.go#L65: var registeredCompressor = make(map[string]Compressor)
encoding.go#L76: func RegisterCompressor(c Compressor) {
encoding.go#L84: func GetCompressor(name string) Compressor {
google.golang.org/grpc
rpc_util.go#L610: func compress(in []byte, cp Compressor, compressor encoding.Compressor) ([]byte, error) {
rpc_util.go#L691: func recvAndDecompress(p *parser, s *transport.Stream, dc Decompressor, maxReceiveMessageSize int, payInfo *payloadInfo, compressor encoding.Compressor) ([]byte, error) {
rpc_util.go#L728: func decompress(compressor encoding.Compressor, d []byte, maxReceiveMessageSize int) ([]byte, int, error) {
rpc_util.go#L757: func recv(p *parser, c baseCodec, s *transport.Stream, dc Decompressor, m interface{}, maxReceiveMessageSize int, payInfo *payloadInfo, compressor encoding.Compressor) error {
rpc_util.go#L785: comp encoding.Compressor
rpc_util.go#L790: func newContextWithRPCInfo(ctx context.Context, failfast bool, codec baseCodec, cp Compressor, comp encoding.Compressor) context.Context {
server.go#L1106: func (s *Server) sendResponse(t transport.ServerTransport, stream *transport.Stream, msg interface{}, cp Compressor, opts *transport.Options, comp encoding.Compressor) error {
server.go#L1263: var comp, decomp encoding.Compressor
stream.go#L277: var comp encoding.Compressor
stream.go#L507: comp encoding.Compressor
stream.go#L560: decomp encoding.Compressor
stream.go#L1214: var comp encoding.Compressor
stream.go#L1285: comp encoding.Compressor
stream.go#L1288: decomp encoding.Compressor
stream.go#L1511: comp encoding.Compressor
stream.go#L1512: decomp encoding.Compressor
stream.go#L1724: func prepareMsg(m interface{}, codec baseCodec, cp Compressor, comp encoding.Compressor) (hdr, payload, data []byte, err error) {