Home
last modified time | relevance | path

Searched refs:payload (Results 1 – 7 of 7) sorted by relevance

/tonic/interop/proto/grpc/testing/
H A Dmessages.proto30 // The type of payload that should be returned.
41 // Primary contents of payload.
55 // Desired payload type in the response from the server.
62 // Optional input payload sent along with the request.
63 Payload payload = 3; field
87 Payload payload = 1; field
97 // Optional input payload sent along with the request.
98 Payload payload = 1; field
106 // Not expecting any payload from the response.
144 Payload payload = 3; field
[all …]
H A Dtest.proto26 // performance with various types of payload.
40 // The server returns the payload with client desired type and sizes.
45 // The server returns the aggregated size of client payload as the result.
/tonic/interop/src/
H A Dserver.rs47 payload: Some(Payload { in unary_call()
76 let payload = crate::server_payload(param.size as usize); in streaming_output_call() localVariable
77 yield StreamingOutputCallResponse { payload: Some(payload) }; in streaming_output_call()
94 aggregated_payload_size += msg.payload.unwrap().body.len() as i32; in streaming_input_call()
131 let payload = crate::server_payload(param.size as usize); in full_duplex_call() localVariable
132 yield StreamingOutputCallResponse { payload: Some(payload) }; in full_duplex_call()
H A Dlib.rs42 match &response.payload { in response_length()
43 Some(ref payload) => payload.body.len() as i32, in response_length()
H A Dclient.rs42 let payload = crate::client_payload(LARGE_REQ_SIZE); in large_unary() localVariable
46 payload: Some(payload), in large_unary()
60 let payload_len = body.payload.as_ref().map(|p| p.body.len()).unwrap_or(0); in large_unary()
86 payload: Some(crate::client_payload(*len as usize)), in client_streaming()
352 payload: Some(crate::client_payload(LARGE_REQ_SIZE)), in custom_metadata()
407 payload: Some(crate::client_payload(req_len as usize)), in make_ping_pong_request()
/tonic/tonic/src/codec/
H A Dbuffer.rs114 let mut payload = BytesMut::with_capacity(100); in decode_buf() localVariable
115 payload.put(&vec![0u8; 50][..]); in decode_buf()
116 let mut buf = DecodeBuf::new(&mut payload, 20); in decode_buf()
/tonic/tonic/benches/
H A Ddecode.rs20 let payload = make_payload($message_size, $message_count); localVariable
21 let body = MockBody::new(payload, $chunk_size);