You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
56 lines
2.1 KiB
56 lines
2.1 KiB
// Copyright 2016 gRPC authors. |
|
// |
|
// Licensed under the Apache License, Version 2.0 (the "License"); |
|
// you may not use this file except in compliance with the License. |
|
// You may obtain a copy of the License at |
|
// |
|
// http://www.apache.org/licenses/LICENSE-2.0 |
|
// |
|
// Unless required by applicable law or agreed to in writing, software |
|
// distributed under the License is distributed on an "AS IS" BASIS, |
|
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
|
// See the License for the specific language governing permissions and |
|
// limitations under the License. |
|
|
|
// An integration test service that covers all the method signature permutations |
|
// of unary/streaming requests/responses. |
|
syntax = "proto3"; |
|
|
|
import "messages.proto"; |
|
import "control.proto"; |
|
|
|
package grpc.testing; |
|
|
|
service BenchmarkService { |
|
// One request followed by one response. |
|
// The server returns the client payload as-is. |
|
rpc UnaryCall(SimpleRequest) returns (SimpleResponse); |
|
|
|
// One request followed by one response. |
|
// The server returns the client payload as-is. |
|
rpc StreamingCall(stream SimpleRequest) returns (stream SimpleResponse); |
|
} |
|
|
|
service WorkerService { |
|
// Start server with specified workload. |
|
// First request sent specifies the ServerConfig followed by ServerStatus |
|
// response. After that, a "Mark" can be sent anytime to request the latest |
|
// stats. Closing the stream will initiate shutdown of the test server |
|
// and once the shutdown has finished, the OK status is sent to terminate |
|
// this RPC. |
|
rpc RunServer(stream ServerArgs) returns (stream ServerStatus); |
|
|
|
// Start client with specified workload. |
|
// First request sent specifies the ClientConfig followed by ClientStatus |
|
// response. After that, a "Mark" can be sent anytime to request the latest |
|
// stats. Closing the stream will initiate shutdown of the test client |
|
// and once the shutdown has finished, the OK status is sent to terminate |
|
// this RPC. |
|
rpc RunClient(stream ClientArgs) returns (stream ClientStatus); |
|
|
|
// Just return the core count - unary call |
|
rpc CoreCount(CoreRequest) returns (CoreResponse); |
|
|
|
// Quit this worker |
|
rpc QuitWorker(Void) returns (Void); |
|
}
|
|
|