type google.golang.org/grpc.Compressor
18 uses
google.golang.org/grpc (current package)
dialoptions.go#L76: compressorV0 Compressor
dialoptions.go#L294: func WithCompressor(cp Compressor) DialOption {
rpc_util.go#L53: type Compressor interface {
rpc_util.go#L67: func NewGZIPCompressor() Compressor {
rpc_util.go#L78: func NewGZIPCompressorWithLevel(level int) (Compressor, 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#L1083: cp Compressor
rpc_util.go#L1089: func newContextWithRPCInfo(ctx context.Context, failfast bool, codec baseCodec, cp Compressor, comp encoding.Compressor) context.Context {
server.go#L159: cp Compressor
server.go#L422: func RPCCompressor(cp Compressor) ServerOption {
server.go#L1188: func (s *Server) sendResponse(ctx context.Context, stream *transport.ServerStream, msg any, cp Compressor, opts *transport.WriteOptions, comp encoding.Compressor) error {
server.go#L1355: var cp Compressor
stream.go#L336: var compressorV0 Compressor
stream.go#L582: compressorV0 Compressor
stream.go#L1324: var cp Compressor
stream.go#L1403: sendCompressorV0 Compressor
stream.go#L1639: compressorV0 Compressor
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) {