1# Generated by the protocol buffer compiler.  DO NOT EDIT!
2# Source: src/proto/grpc/testing/worker_service.proto for package 'grpc.testing'
3# Original file comments:
4# Copyright 2015 gRPC authors.
5#
6# Licensed under the Apache License, Version 2.0 (the "License");
7# you may not use this file except in compliance with the License.
8# You may obtain a copy of the License at
9#
10#     http://www.apache.org/licenses/LICENSE-2.0
11#
12# Unless required by applicable law or agreed to in writing, software
13# distributed under the License is distributed on an "AS IS" BASIS,
14# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
15# See the License for the specific language governing permissions and
16# limitations under the License.
17#
18# An integration test service that covers all the method signature permutations
19# of unary/streaming requests/responses.
20
21require 'grpc'
22require 'src/proto/grpc/testing/worker_service_pb'
23
24module Grpc
25  module Testing
26    module WorkerService
27      class Service
28
29        include GRPC::GenericService
30
31        self.marshal_class_method = :encode
32        self.unmarshal_class_method = :decode
33        self.service_name = 'grpc.testing.WorkerService'
34
35        # Start server with specified workload.
36        # First request sent specifies the ServerConfig followed by ServerStatus
37        # response. After that, a "Mark" can be sent anytime to request the latest
38        # stats. Closing the stream will initiate shutdown of the test server
39        # and once the shutdown has finished, the OK status is sent to terminate
40        # this RPC.
41        rpc :RunServer, stream(ServerArgs), stream(ServerStatus)
42        # Start client with specified workload.
43        # First request sent specifies the ClientConfig followed by ClientStatus
44        # response. After that, a "Mark" can be sent anytime to request the latest
45        # stats. Closing the stream will initiate shutdown of the test client
46        # and once the shutdown has finished, the OK status is sent to terminate
47        # this RPC.
48        rpc :RunClient, stream(ClientArgs), stream(ClientStatus)
49        # Just return the core count - unary call
50        rpc :CoreCount, CoreRequest, CoreResponse
51        # Quit this worker
52        rpc :QuitWorker, Void, Void
53      end
54
55      Stub = Service.rpc_stub_class
56    end
57  end
58end
59