type google.golang.org/grpc.Compressor
18 uses
google.golang.org/grpc (current package)
dialoptions.go#L76: compressorV0 Compressor
dialoptions.go#L280: func WithCompressor(cp Compressor) DialOption {
rpc_util.go#L47: type Compressor interface {
rpc_util.go#L61: func NewGZIPCompressor() Compressor {
rpc_util.go#L72: func NewGZIPCompressorWithLevel(level int) (Compressor, 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#L962: cp Compressor
rpc_util.go#L968: func newContextWithRPCInfo(ctx context.Context, failfast bool, codec baseCodec, cp Compressor, comp encoding.Compressor) context.Context {
server.go#L156: cp Compressor
server.go#L404: func RPCCompressor(cp Compressor) ServerOption {
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#L1343: var cp Compressor
stream.go#L307: var compressorV0 Compressor
stream.go#L545: compressorV0 Compressor
stream.go#L1288: var cp Compressor
stream.go#L1364: sendCompressorV0 Compressor
stream.go#L1591: compressorV0 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) {