type google.golang.org/grpc.Compressor
18 uses
google.golang.org/grpc (current package)
dialoptions.go#L59: cp Compressor
dialoptions.go#L204: 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#L610: func compress(in []byte, cp Compressor, compressor encoding.Compressor) ([]byte, error) {
rpc_util.go#L784: cp Compressor
rpc_util.go#L790: func newContextWithRPCInfo(ctx context.Context, failfast bool, codec baseCodec, cp Compressor, comp encoding.Compressor) context.Context {
server.go#L154: cp Compressor
server.go#L345: func RPCCompressor(cp Compressor) ServerOption {
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#L1264: var cp Compressor
stream.go#L276: var cp Compressor
stream.go#L506: cp Compressor
stream.go#L1213: var cp Compressor
stream.go#L1284: cp Compressor
stream.go#L1509: cp Compressor
stream.go#L1724: func prepareMsg(m interface{}, codec baseCodec, cp Compressor, comp encoding.Compressor) (hdr, payload, data []byte, err error) {