forked from grpc/grpc
-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
1 parent
954177c
commit a60dd3b
Showing
4 changed files
with
327 additions
and
0 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,80 @@ | ||
|
||
// Copyright 2015, Google Inc. | ||
// All rights reserved. | ||
// | ||
// Redistribution and use in source and binary forms, with or without | ||
// modification, are permitted provided that the following conditions are | ||
// met: | ||
// | ||
// * Redistributions of source code must retain the above copyright | ||
// notice, this list of conditions and the following disclaimer. | ||
// * Redistributions in binary form must reproduce the above | ||
// copyright notice, this list of conditions and the following disclaimer | ||
// in the documentation and/or other materials provided with the | ||
// distribution. | ||
// * Neither the name of Google Inc. nor the names of its | ||
// contributors may be used to endorse or promote products derived from | ||
// this software without specific prior written permission. | ||
// | ||
// THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS | ||
// "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT | ||
// LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR | ||
// A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT | ||
// OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, | ||
// SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT | ||
// LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, | ||
// DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY | ||
// THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT | ||
// (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE | ||
// OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. | ||
|
||
syntax = "proto3"; | ||
|
||
package math; | ||
|
||
message DivArgs { | ||
optional int64 dividend = 1; | ||
optional int64 divisor = 2; | ||
} | ||
|
||
message DivReply { | ||
optional int64 quotient = 1; | ||
optional int64 remainder = 2; | ||
} | ||
|
||
message FibArgs { | ||
optional int64 limit = 1; | ||
} | ||
|
||
message Num { | ||
optional int64 num = 1; | ||
} | ||
|
||
message FibReply { | ||
optional int64 count = 1; | ||
} | ||
|
||
service Math { | ||
// Div divides args.dividend by args.divisor and returns the quotient and | ||
// remainder. | ||
rpc Div (DivArgs) returns (DivReply) { | ||
} | ||
|
||
// DivMany accepts an arbitrary number of division args from the client stream | ||
// and sends back the results in the reply stream. The stream continues until | ||
// the client closes its end; the server does the same after sending all the | ||
// replies. The stream ends immediately if either end aborts. | ||
rpc DivMany (stream DivArgs) returns (stream DivReply) { | ||
} | ||
|
||
// Fib generates numbers in the Fibonacci sequence. If args.limit > 0, Fib | ||
// generates up to limit numbers; otherwise it continues until the call is | ||
// canceled. Unlike Fib above, Fib has no final FibReply. | ||
rpc Fib (FibArgs) returns (stream Num) { | ||
} | ||
|
||
// Sum sums a stream of numbers, returning the final result once the stream | ||
// is closed. | ||
rpc Sum (stream Num) returns (Num) { | ||
} | ||
} |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,43 @@ | ||
|
||
// Copyright 2015, Google Inc. | ||
// All rights reserved. | ||
// | ||
// Redistribution and use in source and binary forms, with or without | ||
// modification, are permitted provided that the following conditions are | ||
// met: | ||
// | ||
// * Redistributions of source code must retain the above copyright | ||
// notice, this list of conditions and the following disclaimer. | ||
// * Redistributions in binary form must reproduce the above | ||
// copyright notice, this list of conditions and the following disclaimer | ||
// in the documentation and/or other materials provided with the | ||
// distribution. | ||
// * Neither the name of Google Inc. nor the names of its | ||
// contributors may be used to endorse or promote products derived from | ||
// this software without specific prior written permission. | ||
// | ||
// THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS | ||
// "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT | ||
// LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR | ||
// A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT | ||
// OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, | ||
// SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT | ||
// LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, | ||
// DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY | ||
// THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT | ||
// (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE | ||
// OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. | ||
|
||
syntax = "proto2"; | ||
|
||
package grpc.testing; | ||
|
||
// An empty message that you can re-use to avoid defining duplicated empty | ||
// messages in your project. A typical example is to use it as argument or the | ||
// return value of a service API. For instance: | ||
// | ||
// service Foo { | ||
// rpc Bar (grpc.testing.Empty) returns (grpc.testing.Empty) { }; | ||
// }; | ||
// | ||
message Empty {} |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,132 @@ | ||
|
||
// Copyright 2015, Google Inc. | ||
// All rights reserved. | ||
// | ||
// Redistribution and use in source and binary forms, with or without | ||
// modification, are permitted provided that the following conditions are | ||
// met: | ||
// | ||
// * Redistributions of source code must retain the above copyright | ||
// notice, this list of conditions and the following disclaimer. | ||
// * Redistributions in binary form must reproduce the above | ||
// copyright notice, this list of conditions and the following disclaimer | ||
// in the documentation and/or other materials provided with the | ||
// distribution. | ||
// * Neither the name of Google Inc. nor the names of its | ||
// contributors may be used to endorse or promote products derived from | ||
// this software without specific prior written permission. | ||
// | ||
// THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS | ||
// "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT | ||
// LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR | ||
// A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT | ||
// OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, | ||
// SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT | ||
// LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, | ||
// DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY | ||
// THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT | ||
// (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE | ||
// OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. | ||
|
||
// Message definitions to be used by integration test service definitions. | ||
|
||
syntax = "proto2"; | ||
|
||
package grpc.testing; | ||
|
||
// The type of payload that should be returned. | ||
enum PayloadType { | ||
// Compressable text format. | ||
COMPRESSABLE = 0; | ||
|
||
// Uncompressable binary format. | ||
UNCOMPRESSABLE = 1; | ||
|
||
// Randomly chosen from all other formats defined in this enum. | ||
RANDOM = 2; | ||
} | ||
|
||
// A block of data, to simply increase gRPC message size. | ||
message Payload { | ||
// The type of data in body. | ||
optional PayloadType type = 1 [default = COMPRESSABLE]; | ||
// Primary contents of payload. | ||
optional bytes body = 2; | ||
} | ||
|
||
// Unary request. | ||
message SimpleRequest { | ||
// Desired payload type in the response from the server. | ||
// If response_type is RANDOM, server randomly chooses one from other formats. | ||
optional PayloadType response_type = 1 [default = COMPRESSABLE]; | ||
|
||
// Desired payload size in the response from the server. | ||
// If response_type is COMPRESSABLE, this denotes the size before compression. | ||
optional int32 response_size = 2; | ||
|
||
// Optional input payload sent along with the request. | ||
optional Payload payload = 3; | ||
|
||
// Whether SimpleResponse should include username. | ||
optional bool fill_username = 4; | ||
|
||
// Whether SimpleResponse should include OAuth scope. | ||
optional bool fill_oauth_scope = 5; | ||
} | ||
|
||
// Unary response, as configured by the request. | ||
message SimpleResponse { | ||
// Payload to increase message size. | ||
optional Payload payload = 1; | ||
// The user the request came from, for verifying authentication was | ||
// successful when the client expected it. | ||
optional string username = 2; | ||
// OAuth scope. | ||
optional string oauth_scope = 3; | ||
} | ||
|
||
// Client-streaming request. | ||
message StreamingInputCallRequest { | ||
// Optional input payload sent along with the request. | ||
optional Payload payload = 1; | ||
|
||
// Not expecting any payload from the response. | ||
} | ||
|
||
// Client-streaming response. | ||
message StreamingInputCallResponse { | ||
// Aggregated size of payloads received from the client. | ||
optional int32 aggregated_payload_size = 1; | ||
} | ||
|
||
// Configuration for a particular response. | ||
message ResponseParameters { | ||
// Desired payload sizes in responses from the server. | ||
// If response_type is COMPRESSABLE, this denotes the size before compression. | ||
optional int32 size = 1; | ||
|
||
// Desired interval between consecutive responses in the response stream in | ||
// microseconds. | ||
optional int32 interval_us = 2; | ||
} | ||
|
||
// Server-streaming request. | ||
message StreamingOutputCallRequest { | ||
// Desired payload type in the response from the server. | ||
// If response_type is RANDOM, the payload from each response in the stream | ||
// might be of different types. This is to simulate a mixed type of payload | ||
// stream. | ||
optional PayloadType response_type = 1 [default = COMPRESSABLE]; | ||
|
||
// Configuration for each expected response message. | ||
repeated ResponseParameters response_parameters = 2; | ||
|
||
// Optional input payload sent along with the request. | ||
optional Payload payload = 3; | ||
} | ||
|
||
// Server-streaming response, as configured by the request and parameters. | ||
message StreamingOutputCallResponse { | ||
// Payload to increase response size. | ||
optional Payload payload = 1; | ||
} |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,72 @@ | ||
|
||
// Copyright 2015, Google Inc. | ||
// All rights reserved. | ||
// | ||
// Redistribution and use in source and binary forms, with or without | ||
// modification, are permitted provided that the following conditions are | ||
// met: | ||
// | ||
// * Redistributions of source code must retain the above copyright | ||
// notice, this list of conditions and the following disclaimer. | ||
// * Redistributions in binary form must reproduce the above | ||
// copyright notice, this list of conditions and the following disclaimer | ||
// in the documentation and/or other materials provided with the | ||
// distribution. | ||
// * Neither the name of Google Inc. nor the names of its | ||
// contributors may be used to endorse or promote products derived from | ||
// this software without specific prior written permission. | ||
// | ||
// THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS | ||
// "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT | ||
// LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR | ||
// A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT | ||
// OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, | ||
// SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT | ||
// LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, | ||
// DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY | ||
// THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT | ||
// (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE | ||
// OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. | ||
|
||
// An integration test service that covers all the method signature permutations | ||
// of unary/streaming requests/responses. | ||
syntax = "proto2"; | ||
|
||
import "empty.proto"; | ||
import "messages.proto"; | ||
|
||
package grpc.testing; | ||
|
||
// A simple service to test the various types of RPCs and experiment with | ||
// performance with various types of payload. | ||
service TestService { | ||
// One empty request followed by one empty response. | ||
rpc EmptyCall(grpc.testing.Empty) returns (grpc.testing.Empty); | ||
|
||
// One request followed by one response. | ||
// TODO(Issue 527): Describe required server behavior. | ||
rpc UnaryCall(SimpleRequest) returns (SimpleResponse); | ||
|
||
// One request followed by a sequence of responses (streamed download). | ||
// The server returns the payload with client desired type and sizes. | ||
rpc StreamingOutputCall(StreamingOutputCallRequest) | ||
returns (stream StreamingOutputCallResponse); | ||
|
||
// A sequence of requests followed by one response (streamed upload). | ||
// The server returns the aggregated size of client payload as the result. | ||
rpc StreamingInputCall(stream StreamingInputCallRequest) | ||
returns (StreamingInputCallResponse); | ||
|
||
// A sequence of requests with each request served by the server immediately. | ||
// As one request could lead to multiple responses, this interface | ||
// demonstrates the idea of full duplexing. | ||
rpc FullDuplexCall(stream StreamingOutputCallRequest) | ||
returns (stream StreamingOutputCallResponse); | ||
|
||
// A sequence of requests followed by a sequence of responses. | ||
// The server buffers all the client requests and then serves them in order. A | ||
// stream of responses are returned to the client when the server starts with | ||
// first request. | ||
rpc HalfDuplexCall(stream StreamingOutputCallRequest) | ||
returns (stream StreamingOutputCallResponse); | ||
} |