1 // <auto-generated> 2 // Generated by the protocol buffer compiler. DO NOT EDIT! 3 // source: src/proto/grpc/testing/test.proto 4 // </auto-generated> 5 // Original file comments: 6 // Copyright 2015-2016 gRPC authors. 7 // 8 // Licensed under the Apache License, Version 2.0 (the "License"); 9 // you may not use this file except in compliance with the License. 10 // You may obtain a copy of the License at 11 // 12 // http://www.apache.org/licenses/LICENSE-2.0 13 // 14 // Unless required by applicable law or agreed to in writing, software 15 // distributed under the License is distributed on an "AS IS" BASIS, 16 // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 17 // See the License for the specific language governing permissions and 18 // limitations under the License. 19 // 20 // An integration test service that covers all the method signature permutations 21 // of unary/streaming requests/responses. 22 // 23 #pragma warning disable 0414, 1591 24 #region Designer generated code 25 26 using grpc = global::Grpc.Core; 27 28 namespace Grpc.Testing { 29 /// <summary> 30 /// A simple service to test the various types of RPCs and experiment with 31 /// performance with various types of payload. 32 /// </summary> 33 public static partial class TestService 34 { 35 static readonly string __ServiceName = "grpc.testing.TestService"; 36 37 static readonly grpc::Marshaller<global::Grpc.Testing.Empty> __Marshaller_grpc_testing_Empty = grpc::Marshallers.Create((arg) => global::Google.Protobuf.MessageExtensions.ToByteArray(arg), global::Grpc.Testing.Empty.Parser.ParseFrom); 38 static readonly grpc::Marshaller<global::Grpc.Testing.SimpleRequest> __Marshaller_grpc_testing_SimpleRequest = grpc::Marshallers.Create((arg) => global::Google.Protobuf.MessageExtensions.ToByteArray(arg), global::Grpc.Testing.SimpleRequest.Parser.ParseFrom); 39 static readonly grpc::Marshaller<global::Grpc.Testing.SimpleResponse> __Marshaller_grpc_testing_SimpleResponse = grpc::Marshallers.Create((arg) => global::Google.Protobuf.MessageExtensions.ToByteArray(arg), global::Grpc.Testing.SimpleResponse.Parser.ParseFrom); 40 static readonly grpc::Marshaller<global::Grpc.Testing.StreamingOutputCallRequest> __Marshaller_grpc_testing_StreamingOutputCallRequest = grpc::Marshallers.Create((arg) => global::Google.Protobuf.MessageExtensions.ToByteArray(arg), global::Grpc.Testing.StreamingOutputCallRequest.Parser.ParseFrom); 41 static readonly grpc::Marshaller<global::Grpc.Testing.StreamingOutputCallResponse> __Marshaller_grpc_testing_StreamingOutputCallResponse = grpc::Marshallers.Create((arg) => global::Google.Protobuf.MessageExtensions.ToByteArray(arg), global::Grpc.Testing.StreamingOutputCallResponse.Parser.ParseFrom); 42 static readonly grpc::Marshaller<global::Grpc.Testing.StreamingInputCallRequest> __Marshaller_grpc_testing_StreamingInputCallRequest = grpc::Marshallers.Create((arg) => global::Google.Protobuf.MessageExtensions.ToByteArray(arg), global::Grpc.Testing.StreamingInputCallRequest.Parser.ParseFrom); 43 static readonly grpc::Marshaller<global::Grpc.Testing.StreamingInputCallResponse> __Marshaller_grpc_testing_StreamingInputCallResponse = grpc::Marshallers.Create((arg) => global::Google.Protobuf.MessageExtensions.ToByteArray(arg), global::Grpc.Testing.StreamingInputCallResponse.Parser.ParseFrom); 44 45 static readonly grpc::Method<global::Grpc.Testing.Empty, global::Grpc.Testing.Empty> __Method_EmptyCall = new grpc::Method<global::Grpc.Testing.Empty, global::Grpc.Testing.Empty>( 46 grpc::MethodType.Unary, 47 __ServiceName, 48 "EmptyCall", 49 __Marshaller_grpc_testing_Empty, 50 __Marshaller_grpc_testing_Empty); 51 52 static readonly grpc::Method<global::Grpc.Testing.SimpleRequest, global::Grpc.Testing.SimpleResponse> __Method_UnaryCall = new grpc::Method<global::Grpc.Testing.SimpleRequest, global::Grpc.Testing.SimpleResponse>( 53 grpc::MethodType.Unary, 54 __ServiceName, 55 "UnaryCall", 56 __Marshaller_grpc_testing_SimpleRequest, 57 __Marshaller_grpc_testing_SimpleResponse); 58 59 static readonly grpc::Method<global::Grpc.Testing.SimpleRequest, global::Grpc.Testing.SimpleResponse> __Method_CacheableUnaryCall = new grpc::Method<global::Grpc.Testing.SimpleRequest, global::Grpc.Testing.SimpleResponse>( 60 grpc::MethodType.Unary, 61 __ServiceName, 62 "CacheableUnaryCall", 63 __Marshaller_grpc_testing_SimpleRequest, 64 __Marshaller_grpc_testing_SimpleResponse); 65 66 static readonly grpc::Method<global::Grpc.Testing.StreamingOutputCallRequest, global::Grpc.Testing.StreamingOutputCallResponse> __Method_StreamingOutputCall = new grpc::Method<global::Grpc.Testing.StreamingOutputCallRequest, global::Grpc.Testing.StreamingOutputCallResponse>( 67 grpc::MethodType.ServerStreaming, 68 __ServiceName, 69 "StreamingOutputCall", 70 __Marshaller_grpc_testing_StreamingOutputCallRequest, 71 __Marshaller_grpc_testing_StreamingOutputCallResponse); 72 73 static readonly grpc::Method<global::Grpc.Testing.StreamingInputCallRequest, global::Grpc.Testing.StreamingInputCallResponse> __Method_StreamingInputCall = new grpc::Method<global::Grpc.Testing.StreamingInputCallRequest, global::Grpc.Testing.StreamingInputCallResponse>( 74 grpc::MethodType.ClientStreaming, 75 __ServiceName, 76 "StreamingInputCall", 77 __Marshaller_grpc_testing_StreamingInputCallRequest, 78 __Marshaller_grpc_testing_StreamingInputCallResponse); 79 80 static readonly grpc::Method<global::Grpc.Testing.StreamingOutputCallRequest, global::Grpc.Testing.StreamingOutputCallResponse> __Method_FullDuplexCall = new grpc::Method<global::Grpc.Testing.StreamingOutputCallRequest, global::Grpc.Testing.StreamingOutputCallResponse>( 81 grpc::MethodType.DuplexStreaming, 82 __ServiceName, 83 "FullDuplexCall", 84 __Marshaller_grpc_testing_StreamingOutputCallRequest, 85 __Marshaller_grpc_testing_StreamingOutputCallResponse); 86 87 static readonly grpc::Method<global::Grpc.Testing.StreamingOutputCallRequest, global::Grpc.Testing.StreamingOutputCallResponse> __Method_HalfDuplexCall = new grpc::Method<global::Grpc.Testing.StreamingOutputCallRequest, global::Grpc.Testing.StreamingOutputCallResponse>( 88 grpc::MethodType.DuplexStreaming, 89 __ServiceName, 90 "HalfDuplexCall", 91 __Marshaller_grpc_testing_StreamingOutputCallRequest, 92 __Marshaller_grpc_testing_StreamingOutputCallResponse); 93 94 static readonly grpc::Method<global::Grpc.Testing.Empty, global::Grpc.Testing.Empty> __Method_UnimplementedCall = new grpc::Method<global::Grpc.Testing.Empty, global::Grpc.Testing.Empty>( 95 grpc::MethodType.Unary, 96 __ServiceName, 97 "UnimplementedCall", 98 __Marshaller_grpc_testing_Empty, 99 __Marshaller_grpc_testing_Empty); 100 101 /// <summary>Service descriptor</summary> 102 public static global::Google.Protobuf.Reflection.ServiceDescriptor Descriptor 103 { 104 get { return global::Grpc.Testing.TestReflection.Descriptor.Services[0]; } 105 } 106 107 /// <summary>Base class for server-side implementations of TestService</summary> 108 public abstract partial class TestServiceBase 109 { 110 /// <summary> 111 /// One empty request followed by one empty response. 112 /// </summary> 113 /// <param name="request">The request received from the client.</param> 114 /// <param name="context">The context of the server-side call handler being invoked.</param> 115 /// <returns>The response to send back to the client (wrapped by a task).</returns> EmptyCall(global::Grpc.Testing.Empty request, grpc::ServerCallContext context)116 public virtual global::System.Threading.Tasks.Task<global::Grpc.Testing.Empty> EmptyCall(global::Grpc.Testing.Empty request, grpc::ServerCallContext context) 117 { 118 throw new grpc::RpcException(new grpc::Status(grpc::StatusCode.Unimplemented, "")); 119 } 120 121 /// <summary> 122 /// One request followed by one response. 123 /// </summary> 124 /// <param name="request">The request received from the client.</param> 125 /// <param name="context">The context of the server-side call handler being invoked.</param> 126 /// <returns>The response to send back to the client (wrapped by a task).</returns> UnaryCall(global::Grpc.Testing.SimpleRequest request, grpc::ServerCallContext context)127 public virtual global::System.Threading.Tasks.Task<global::Grpc.Testing.SimpleResponse> UnaryCall(global::Grpc.Testing.SimpleRequest request, grpc::ServerCallContext context) 128 { 129 throw new grpc::RpcException(new grpc::Status(grpc::StatusCode.Unimplemented, "")); 130 } 131 132 /// <summary> 133 /// One request followed by one response. Response has cache control 134 /// headers set such that a caching HTTP proxy (such as GFE) can 135 /// satisfy subsequent requests. 136 /// </summary> 137 /// <param name="request">The request received from the client.</param> 138 /// <param name="context">The context of the server-side call handler being invoked.</param> 139 /// <returns>The response to send back to the client (wrapped by a task).</returns> CacheableUnaryCall(global::Grpc.Testing.SimpleRequest request, grpc::ServerCallContext context)140 public virtual global::System.Threading.Tasks.Task<global::Grpc.Testing.SimpleResponse> CacheableUnaryCall(global::Grpc.Testing.SimpleRequest request, grpc::ServerCallContext context) 141 { 142 throw new grpc::RpcException(new grpc::Status(grpc::StatusCode.Unimplemented, "")); 143 } 144 145 /// <summary> 146 /// One request followed by a sequence of responses (streamed download). 147 /// The server returns the payload with client desired type and sizes. 148 /// </summary> 149 /// <param name="request">The request received from the client.</param> 150 /// <param name="responseStream">Used for sending responses back to the client.</param> 151 /// <param name="context">The context of the server-side call handler being invoked.</param> 152 /// <returns>A task indicating completion of the handler.</returns> StreamingOutputCall(global::Grpc.Testing.StreamingOutputCallRequest request, grpc::IServerStreamWriter<global::Grpc.Testing.StreamingOutputCallResponse> responseStream, grpc::ServerCallContext context)153 public virtual global::System.Threading.Tasks.Task StreamingOutputCall(global::Grpc.Testing.StreamingOutputCallRequest request, grpc::IServerStreamWriter<global::Grpc.Testing.StreamingOutputCallResponse> responseStream, grpc::ServerCallContext context) 154 { 155 throw new grpc::RpcException(new grpc::Status(grpc::StatusCode.Unimplemented, "")); 156 } 157 158 /// <summary> 159 /// A sequence of requests followed by one response (streamed upload). 160 /// The server returns the aggregated size of client payload as the result. 161 /// </summary> 162 /// <param name="requestStream">Used for reading requests from the client.</param> 163 /// <param name="context">The context of the server-side call handler being invoked.</param> 164 /// <returns>The response to send back to the client (wrapped by a task).</returns> StreamingInputCall(grpc::IAsyncStreamReader<global::Grpc.Testing.StreamingInputCallRequest> requestStream, grpc::ServerCallContext context)165 public virtual global::System.Threading.Tasks.Task<global::Grpc.Testing.StreamingInputCallResponse> StreamingInputCall(grpc::IAsyncStreamReader<global::Grpc.Testing.StreamingInputCallRequest> requestStream, grpc::ServerCallContext context) 166 { 167 throw new grpc::RpcException(new grpc::Status(grpc::StatusCode.Unimplemented, "")); 168 } 169 170 /// <summary> 171 /// A sequence of requests with each request served by the server immediately. 172 /// As one request could lead to multiple responses, this interface 173 /// demonstrates the idea of full duplexing. 174 /// </summary> 175 /// <param name="requestStream">Used for reading requests from the client.</param> 176 /// <param name="responseStream">Used for sending responses back to the client.</param> 177 /// <param name="context">The context of the server-side call handler being invoked.</param> 178 /// <returns>A task indicating completion of the handler.</returns> FullDuplexCall(grpc::IAsyncStreamReader<global::Grpc.Testing.StreamingOutputCallRequest> requestStream, grpc::IServerStreamWriter<global::Grpc.Testing.StreamingOutputCallResponse> responseStream, grpc::ServerCallContext context)179 public virtual global::System.Threading.Tasks.Task FullDuplexCall(grpc::IAsyncStreamReader<global::Grpc.Testing.StreamingOutputCallRequest> requestStream, grpc::IServerStreamWriter<global::Grpc.Testing.StreamingOutputCallResponse> responseStream, grpc::ServerCallContext context) 180 { 181 throw new grpc::RpcException(new grpc::Status(grpc::StatusCode.Unimplemented, "")); 182 } 183 184 /// <summary> 185 /// A sequence of requests followed by a sequence of responses. 186 /// The server buffers all the client requests and then serves them in order. A 187 /// stream of responses are returned to the client when the server starts with 188 /// first request. 189 /// </summary> 190 /// <param name="requestStream">Used for reading requests from the client.</param> 191 /// <param name="responseStream">Used for sending responses back to the client.</param> 192 /// <param name="context">The context of the server-side call handler being invoked.</param> 193 /// <returns>A task indicating completion of the handler.</returns> HalfDuplexCall(grpc::IAsyncStreamReader<global::Grpc.Testing.StreamingOutputCallRequest> requestStream, grpc::IServerStreamWriter<global::Grpc.Testing.StreamingOutputCallResponse> responseStream, grpc::ServerCallContext context)194 public virtual global::System.Threading.Tasks.Task HalfDuplexCall(grpc::IAsyncStreamReader<global::Grpc.Testing.StreamingOutputCallRequest> requestStream, grpc::IServerStreamWriter<global::Grpc.Testing.StreamingOutputCallResponse> responseStream, grpc::ServerCallContext context) 195 { 196 throw new grpc::RpcException(new grpc::Status(grpc::StatusCode.Unimplemented, "")); 197 } 198 199 /// <summary> 200 /// The test server will not implement this method. It will be used 201 /// to test the behavior when clients call unimplemented methods. 202 /// </summary> 203 /// <param name="request">The request received from the client.</param> 204 /// <param name="context">The context of the server-side call handler being invoked.</param> 205 /// <returns>The response to send back to the client (wrapped by a task).</returns> UnimplementedCall(global::Grpc.Testing.Empty request, grpc::ServerCallContext context)206 public virtual global::System.Threading.Tasks.Task<global::Grpc.Testing.Empty> UnimplementedCall(global::Grpc.Testing.Empty request, grpc::ServerCallContext context) 207 { 208 throw new grpc::RpcException(new grpc::Status(grpc::StatusCode.Unimplemented, "")); 209 } 210 211 } 212 213 /// <summary>Client for TestService</summary> 214 public partial class TestServiceClient : grpc::ClientBase<TestServiceClient> 215 { 216 /// <summary>Creates a new client for TestService</summary> 217 /// <param name="channel">The channel to use to make remote calls.</param> TestServiceClient(grpc::Channel channel)218 public TestServiceClient(grpc::Channel channel) : base(channel) 219 { 220 } 221 /// <summary>Creates a new client for TestService that uses a custom <c>CallInvoker</c>.</summary> 222 /// <param name="callInvoker">The callInvoker to use to make remote calls.</param> TestServiceClient(grpc::CallInvoker callInvoker)223 public TestServiceClient(grpc::CallInvoker callInvoker) : base(callInvoker) 224 { 225 } 226 /// <summary>Protected parameterless constructor to allow creation of test doubles.</summary> TestServiceClient()227 protected TestServiceClient() : base() 228 { 229 } 230 /// <summary>Protected constructor to allow creation of configured clients.</summary> 231 /// <param name="configuration">The client configuration.</param> TestServiceClient(ClientBaseConfiguration configuration)232 protected TestServiceClient(ClientBaseConfiguration configuration) : base(configuration) 233 { 234 } 235 236 /// <summary> 237 /// One empty request followed by one empty response. 238 /// </summary> 239 /// <param name="request">The request to send to the server.</param> 240 /// <param name="headers">The initial metadata to send with the call. This parameter is optional.</param> 241 /// <param name="deadline">An optional deadline for the call. The call will be cancelled if deadline is hit.</param> 242 /// <param name="cancellationToken">An optional token for canceling the call.</param> 243 /// <returns>The response received from the server.</returns> EmptyCall(global::Grpc.Testing.Empty request, grpc::Metadata headers = null, global::System.DateTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threading.CancellationToken))244 public virtual global::Grpc.Testing.Empty EmptyCall(global::Grpc.Testing.Empty request, grpc::Metadata headers = null, global::System.DateTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threading.CancellationToken)) 245 { 246 return EmptyCall(request, new grpc::CallOptions(headers, deadline, cancellationToken)); 247 } 248 /// <summary> 249 /// One empty request followed by one empty response. 250 /// </summary> 251 /// <param name="request">The request to send to the server.</param> 252 /// <param name="options">The options for the call.</param> 253 /// <returns>The response received from the server.</returns> EmptyCall(global::Grpc.Testing.Empty request, grpc::CallOptions options)254 public virtual global::Grpc.Testing.Empty EmptyCall(global::Grpc.Testing.Empty request, grpc::CallOptions options) 255 { 256 return CallInvoker.BlockingUnaryCall(__Method_EmptyCall, null, options, request); 257 } 258 /// <summary> 259 /// One empty request followed by one empty response. 260 /// </summary> 261 /// <param name="request">The request to send to the server.</param> 262 /// <param name="headers">The initial metadata to send with the call. This parameter is optional.</param> 263 /// <param name="deadline">An optional deadline for the call. The call will be cancelled if deadline is hit.</param> 264 /// <param name="cancellationToken">An optional token for canceling the call.</param> 265 /// <returns>The call object.</returns> EmptyCallAsync(global::Grpc.Testing.Empty request, grpc::Metadata headers = null, global::System.DateTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threading.CancellationToken))266 public virtual grpc::AsyncUnaryCall<global::Grpc.Testing.Empty> EmptyCallAsync(global::Grpc.Testing.Empty request, grpc::Metadata headers = null, global::System.DateTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threading.CancellationToken)) 267 { 268 return EmptyCallAsync(request, new grpc::CallOptions(headers, deadline, cancellationToken)); 269 } 270 /// <summary> 271 /// One empty request followed by one empty response. 272 /// </summary> 273 /// <param name="request">The request to send to the server.</param> 274 /// <param name="options">The options for the call.</param> 275 /// <returns>The call object.</returns> EmptyCallAsync(global::Grpc.Testing.Empty request, grpc::CallOptions options)276 public virtual grpc::AsyncUnaryCall<global::Grpc.Testing.Empty> EmptyCallAsync(global::Grpc.Testing.Empty request, grpc::CallOptions options) 277 { 278 return CallInvoker.AsyncUnaryCall(__Method_EmptyCall, null, options, request); 279 } 280 /// <summary> 281 /// One request followed by one response. 282 /// </summary> 283 /// <param name="request">The request to send to the server.</param> 284 /// <param name="headers">The initial metadata to send with the call. This parameter is optional.</param> 285 /// <param name="deadline">An optional deadline for the call. The call will be cancelled if deadline is hit.</param> 286 /// <param name="cancellationToken">An optional token for canceling the call.</param> 287 /// <returns>The response received from the server.</returns> UnaryCall(global::Grpc.Testing.SimpleRequest request, grpc::Metadata headers = null, global::System.DateTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threading.CancellationToken))288 public virtual global::Grpc.Testing.SimpleResponse UnaryCall(global::Grpc.Testing.SimpleRequest request, grpc::Metadata headers = null, global::System.DateTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threading.CancellationToken)) 289 { 290 return UnaryCall(request, new grpc::CallOptions(headers, deadline, cancellationToken)); 291 } 292 /// <summary> 293 /// One request followed by one response. 294 /// </summary> 295 /// <param name="request">The request to send to the server.</param> 296 /// <param name="options">The options for the call.</param> 297 /// <returns>The response received from the server.</returns> UnaryCall(global::Grpc.Testing.SimpleRequest request, grpc::CallOptions options)298 public virtual global::Grpc.Testing.SimpleResponse UnaryCall(global::Grpc.Testing.SimpleRequest request, grpc::CallOptions options) 299 { 300 return CallInvoker.BlockingUnaryCall(__Method_UnaryCall, null, options, request); 301 } 302 /// <summary> 303 /// One request followed by one response. 304 /// </summary> 305 /// <param name="request">The request to send to the server.</param> 306 /// <param name="headers">The initial metadata to send with the call. This parameter is optional.</param> 307 /// <param name="deadline">An optional deadline for the call. The call will be cancelled if deadline is hit.</param> 308 /// <param name="cancellationToken">An optional token for canceling the call.</param> 309 /// <returns>The call object.</returns> UnaryCallAsync(global::Grpc.Testing.SimpleRequest request, grpc::Metadata headers = null, global::System.DateTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threading.CancellationToken))310 public virtual grpc::AsyncUnaryCall<global::Grpc.Testing.SimpleResponse> UnaryCallAsync(global::Grpc.Testing.SimpleRequest request, grpc::Metadata headers = null, global::System.DateTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threading.CancellationToken)) 311 { 312 return UnaryCallAsync(request, new grpc::CallOptions(headers, deadline, cancellationToken)); 313 } 314 /// <summary> 315 /// One request followed by one response. 316 /// </summary> 317 /// <param name="request">The request to send to the server.</param> 318 /// <param name="options">The options for the call.</param> 319 /// <returns>The call object.</returns> UnaryCallAsync(global::Grpc.Testing.SimpleRequest request, grpc::CallOptions options)320 public virtual grpc::AsyncUnaryCall<global::Grpc.Testing.SimpleResponse> UnaryCallAsync(global::Grpc.Testing.SimpleRequest request, grpc::CallOptions options) 321 { 322 return CallInvoker.AsyncUnaryCall(__Method_UnaryCall, null, options, request); 323 } 324 /// <summary> 325 /// One request followed by one response. Response has cache control 326 /// headers set such that a caching HTTP proxy (such as GFE) can 327 /// satisfy subsequent requests. 328 /// </summary> 329 /// <param name="request">The request to send to the server.</param> 330 /// <param name="headers">The initial metadata to send with the call. This parameter is optional.</param> 331 /// <param name="deadline">An optional deadline for the call. The call will be cancelled if deadline is hit.</param> 332 /// <param name="cancellationToken">An optional token for canceling the call.</param> 333 /// <returns>The response received from the server.</returns> CacheableUnaryCall(global::Grpc.Testing.SimpleRequest request, grpc::Metadata headers = null, global::System.DateTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threading.CancellationToken))334 public virtual global::Grpc.Testing.SimpleResponse CacheableUnaryCall(global::Grpc.Testing.SimpleRequest request, grpc::Metadata headers = null, global::System.DateTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threading.CancellationToken)) 335 { 336 return CacheableUnaryCall(request, new grpc::CallOptions(headers, deadline, cancellationToken)); 337 } 338 /// <summary> 339 /// One request followed by one response. Response has cache control 340 /// headers set such that a caching HTTP proxy (such as GFE) can 341 /// satisfy subsequent requests. 342 /// </summary> 343 /// <param name="request">The request to send to the server.</param> 344 /// <param name="options">The options for the call.</param> 345 /// <returns>The response received from the server.</returns> CacheableUnaryCall(global::Grpc.Testing.SimpleRequest request, grpc::CallOptions options)346 public virtual global::Grpc.Testing.SimpleResponse CacheableUnaryCall(global::Grpc.Testing.SimpleRequest request, grpc::CallOptions options) 347 { 348 return CallInvoker.BlockingUnaryCall(__Method_CacheableUnaryCall, null, options, request); 349 } 350 /// <summary> 351 /// One request followed by one response. Response has cache control 352 /// headers set such that a caching HTTP proxy (such as GFE) can 353 /// satisfy subsequent requests. 354 /// </summary> 355 /// <param name="request">The request to send to the server.</param> 356 /// <param name="headers">The initial metadata to send with the call. This parameter is optional.</param> 357 /// <param name="deadline">An optional deadline for the call. The call will be cancelled if deadline is hit.</param> 358 /// <param name="cancellationToken">An optional token for canceling the call.</param> 359 /// <returns>The call object.</returns> CacheableUnaryCallAsync(global::Grpc.Testing.SimpleRequest request, grpc::Metadata headers = null, global::System.DateTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threading.CancellationToken))360 public virtual grpc::AsyncUnaryCall<global::Grpc.Testing.SimpleResponse> CacheableUnaryCallAsync(global::Grpc.Testing.SimpleRequest request, grpc::Metadata headers = null, global::System.DateTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threading.CancellationToken)) 361 { 362 return CacheableUnaryCallAsync(request, new grpc::CallOptions(headers, deadline, cancellationToken)); 363 } 364 /// <summary> 365 /// One request followed by one response. Response has cache control 366 /// headers set such that a caching HTTP proxy (such as GFE) can 367 /// satisfy subsequent requests. 368 /// </summary> 369 /// <param name="request">The request to send to the server.</param> 370 /// <param name="options">The options for the call.</param> 371 /// <returns>The call object.</returns> CacheableUnaryCallAsync(global::Grpc.Testing.SimpleRequest request, grpc::CallOptions options)372 public virtual grpc::AsyncUnaryCall<global::Grpc.Testing.SimpleResponse> CacheableUnaryCallAsync(global::Grpc.Testing.SimpleRequest request, grpc::CallOptions options) 373 { 374 return CallInvoker.AsyncUnaryCall(__Method_CacheableUnaryCall, null, options, request); 375 } 376 /// <summary> 377 /// One request followed by a sequence of responses (streamed download). 378 /// The server returns the payload with client desired type and sizes. 379 /// </summary> 380 /// <param name="request">The request to send to the server.</param> 381 /// <param name="headers">The initial metadata to send with the call. This parameter is optional.</param> 382 /// <param name="deadline">An optional deadline for the call. The call will be cancelled if deadline is hit.</param> 383 /// <param name="cancellationToken">An optional token for canceling the call.</param> 384 /// <returns>The call object.</returns> StreamingOutputCall(global::Grpc.Testing.StreamingOutputCallRequest request, grpc::Metadata headers = null, global::System.DateTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threading.CancellationToken))385 public virtual grpc::AsyncServerStreamingCall<global::Grpc.Testing.StreamingOutputCallResponse> StreamingOutputCall(global::Grpc.Testing.StreamingOutputCallRequest request, grpc::Metadata headers = null, global::System.DateTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threading.CancellationToken)) 386 { 387 return StreamingOutputCall(request, new grpc::CallOptions(headers, deadline, cancellationToken)); 388 } 389 /// <summary> 390 /// One request followed by a sequence of responses (streamed download). 391 /// The server returns the payload with client desired type and sizes. 392 /// </summary> 393 /// <param name="request">The request to send to the server.</param> 394 /// <param name="options">The options for the call.</param> 395 /// <returns>The call object.</returns> StreamingOutputCall(global::Grpc.Testing.StreamingOutputCallRequest request, grpc::CallOptions options)396 public virtual grpc::AsyncServerStreamingCall<global::Grpc.Testing.StreamingOutputCallResponse> StreamingOutputCall(global::Grpc.Testing.StreamingOutputCallRequest request, grpc::CallOptions options) 397 { 398 return CallInvoker.AsyncServerStreamingCall(__Method_StreamingOutputCall, null, options, request); 399 } 400 /// <summary> 401 /// A sequence of requests followed by one response (streamed upload). 402 /// The server returns the aggregated size of client payload as the result. 403 /// </summary> 404 /// <param name="headers">The initial metadata to send with the call. This parameter is optional.</param> 405 /// <param name="deadline">An optional deadline for the call. The call will be cancelled if deadline is hit.</param> 406 /// <param name="cancellationToken">An optional token for canceling the call.</param> 407 /// <returns>The call object.</returns> StreamingInputCall(grpc::Metadata headers = null, global::System.DateTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threading.CancellationToken))408 public virtual grpc::AsyncClientStreamingCall<global::Grpc.Testing.StreamingInputCallRequest, global::Grpc.Testing.StreamingInputCallResponse> StreamingInputCall(grpc::Metadata headers = null, global::System.DateTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threading.CancellationToken)) 409 { 410 return StreamingInputCall(new grpc::CallOptions(headers, deadline, cancellationToken)); 411 } 412 /// <summary> 413 /// A sequence of requests followed by one response (streamed upload). 414 /// The server returns the aggregated size of client payload as the result. 415 /// </summary> 416 /// <param name="options">The options for the call.</param> 417 /// <returns>The call object.</returns> StreamingInputCall(grpc::CallOptions options)418 public virtual grpc::AsyncClientStreamingCall<global::Grpc.Testing.StreamingInputCallRequest, global::Grpc.Testing.StreamingInputCallResponse> StreamingInputCall(grpc::CallOptions options) 419 { 420 return CallInvoker.AsyncClientStreamingCall(__Method_StreamingInputCall, null, options); 421 } 422 /// <summary> 423 /// A sequence of requests with each request served by the server immediately. 424 /// As one request could lead to multiple responses, this interface 425 /// demonstrates the idea of full duplexing. 426 /// </summary> 427 /// <param name="headers">The initial metadata to send with the call. This parameter is optional.</param> 428 /// <param name="deadline">An optional deadline for the call. The call will be cancelled if deadline is hit.</param> 429 /// <param name="cancellationToken">An optional token for canceling the call.</param> 430 /// <returns>The call object.</returns> FullDuplexCall(grpc::Metadata headers = null, global::System.DateTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threading.CancellationToken))431 public virtual grpc::AsyncDuplexStreamingCall<global::Grpc.Testing.StreamingOutputCallRequest, global::Grpc.Testing.StreamingOutputCallResponse> FullDuplexCall(grpc::Metadata headers = null, global::System.DateTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threading.CancellationToken)) 432 { 433 return FullDuplexCall(new grpc::CallOptions(headers, deadline, cancellationToken)); 434 } 435 /// <summary> 436 /// A sequence of requests with each request served by the server immediately. 437 /// As one request could lead to multiple responses, this interface 438 /// demonstrates the idea of full duplexing. 439 /// </summary> 440 /// <param name="options">The options for the call.</param> 441 /// <returns>The call object.</returns> FullDuplexCall(grpc::CallOptions options)442 public virtual grpc::AsyncDuplexStreamingCall<global::Grpc.Testing.StreamingOutputCallRequest, global::Grpc.Testing.StreamingOutputCallResponse> FullDuplexCall(grpc::CallOptions options) 443 { 444 return CallInvoker.AsyncDuplexStreamingCall(__Method_FullDuplexCall, null, options); 445 } 446 /// <summary> 447 /// A sequence of requests followed by a sequence of responses. 448 /// The server buffers all the client requests and then serves them in order. A 449 /// stream of responses are returned to the client when the server starts with 450 /// first request. 451 /// </summary> 452 /// <param name="headers">The initial metadata to send with the call. This parameter is optional.</param> 453 /// <param name="deadline">An optional deadline for the call. The call will be cancelled if deadline is hit.</param> 454 /// <param name="cancellationToken">An optional token for canceling the call.</param> 455 /// <returns>The call object.</returns> HalfDuplexCall(grpc::Metadata headers = null, global::System.DateTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threading.CancellationToken))456 public virtual grpc::AsyncDuplexStreamingCall<global::Grpc.Testing.StreamingOutputCallRequest, global::Grpc.Testing.StreamingOutputCallResponse> HalfDuplexCall(grpc::Metadata headers = null, global::System.DateTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threading.CancellationToken)) 457 { 458 return HalfDuplexCall(new grpc::CallOptions(headers, deadline, cancellationToken)); 459 } 460 /// <summary> 461 /// A sequence of requests followed by a sequence of responses. 462 /// The server buffers all the client requests and then serves them in order. A 463 /// stream of responses are returned to the client when the server starts with 464 /// first request. 465 /// </summary> 466 /// <param name="options">The options for the call.</param> 467 /// <returns>The call object.</returns> HalfDuplexCall(grpc::CallOptions options)468 public virtual grpc::AsyncDuplexStreamingCall<global::Grpc.Testing.StreamingOutputCallRequest, global::Grpc.Testing.StreamingOutputCallResponse> HalfDuplexCall(grpc::CallOptions options) 469 { 470 return CallInvoker.AsyncDuplexStreamingCall(__Method_HalfDuplexCall, null, options); 471 } 472 /// <summary> 473 /// The test server will not implement this method. It will be used 474 /// to test the behavior when clients call unimplemented methods. 475 /// </summary> 476 /// <param name="request">The request to send to the server.</param> 477 /// <param name="headers">The initial metadata to send with the call. This parameter is optional.</param> 478 /// <param name="deadline">An optional deadline for the call. The call will be cancelled if deadline is hit.</param> 479 /// <param name="cancellationToken">An optional token for canceling the call.</param> 480 /// <returns>The response received from the server.</returns> UnimplementedCall(global::Grpc.Testing.Empty request, grpc::Metadata headers = null, global::System.DateTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threading.CancellationToken))481 public virtual global::Grpc.Testing.Empty UnimplementedCall(global::Grpc.Testing.Empty request, grpc::Metadata headers = null, global::System.DateTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threading.CancellationToken)) 482 { 483 return UnimplementedCall(request, new grpc::CallOptions(headers, deadline, cancellationToken)); 484 } 485 /// <summary> 486 /// The test server will not implement this method. It will be used 487 /// to test the behavior when clients call unimplemented methods. 488 /// </summary> 489 /// <param name="request">The request to send to the server.</param> 490 /// <param name="options">The options for the call.</param> 491 /// <returns>The response received from the server.</returns> UnimplementedCall(global::Grpc.Testing.Empty request, grpc::CallOptions options)492 public virtual global::Grpc.Testing.Empty UnimplementedCall(global::Grpc.Testing.Empty request, grpc::CallOptions options) 493 { 494 return CallInvoker.BlockingUnaryCall(__Method_UnimplementedCall, null, options, request); 495 } 496 /// <summary> 497 /// The test server will not implement this method. It will be used 498 /// to test the behavior when clients call unimplemented methods. 499 /// </summary> 500 /// <param name="request">The request to send to the server.</param> 501 /// <param name="headers">The initial metadata to send with the call. This parameter is optional.</param> 502 /// <param name="deadline">An optional deadline for the call. The call will be cancelled if deadline is hit.</param> 503 /// <param name="cancellationToken">An optional token for canceling the call.</param> 504 /// <returns>The call object.</returns> UnimplementedCallAsync(global::Grpc.Testing.Empty request, grpc::Metadata headers = null, global::System.DateTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threading.CancellationToken))505 public virtual grpc::AsyncUnaryCall<global::Grpc.Testing.Empty> UnimplementedCallAsync(global::Grpc.Testing.Empty request, grpc::Metadata headers = null, global::System.DateTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threading.CancellationToken)) 506 { 507 return UnimplementedCallAsync(request, new grpc::CallOptions(headers, deadline, cancellationToken)); 508 } 509 /// <summary> 510 /// The test server will not implement this method. It will be used 511 /// to test the behavior when clients call unimplemented methods. 512 /// </summary> 513 /// <param name="request">The request to send to the server.</param> 514 /// <param name="options">The options for the call.</param> 515 /// <returns>The call object.</returns> UnimplementedCallAsync(global::Grpc.Testing.Empty request, grpc::CallOptions options)516 public virtual grpc::AsyncUnaryCall<global::Grpc.Testing.Empty> UnimplementedCallAsync(global::Grpc.Testing.Empty request, grpc::CallOptions options) 517 { 518 return CallInvoker.AsyncUnaryCall(__Method_UnimplementedCall, null, options, request); 519 } 520 /// <summary>Creates a new instance of client from given <c>ClientBaseConfiguration</c>.</summary> NewInstance(ClientBaseConfiguration configuration)521 protected override TestServiceClient NewInstance(ClientBaseConfiguration configuration) 522 { 523 return new TestServiceClient(configuration); 524 } 525 } 526 527 /// <summary>Creates service definition that can be registered with a server</summary> 528 /// <param name="serviceImpl">An object implementing the server-side handling logic.</param> BindService(TestServiceBase serviceImpl)529 public static grpc::ServerServiceDefinition BindService(TestServiceBase serviceImpl) 530 { 531 return grpc::ServerServiceDefinition.CreateBuilder() 532 .AddMethod(__Method_EmptyCall, serviceImpl.EmptyCall) 533 .AddMethod(__Method_UnaryCall, serviceImpl.UnaryCall) 534 .AddMethod(__Method_CacheableUnaryCall, serviceImpl.CacheableUnaryCall) 535 .AddMethod(__Method_StreamingOutputCall, serviceImpl.StreamingOutputCall) 536 .AddMethod(__Method_StreamingInputCall, serviceImpl.StreamingInputCall) 537 .AddMethod(__Method_FullDuplexCall, serviceImpl.FullDuplexCall) 538 .AddMethod(__Method_HalfDuplexCall, serviceImpl.HalfDuplexCall) 539 .AddMethod(__Method_UnimplementedCall, serviceImpl.UnimplementedCall).Build(); 540 } 541 542 } 543 /// <summary> 544 /// A simple service NOT implemented at servers so clients can test for 545 /// that case. 546 /// </summary> 547 public static partial class UnimplementedService 548 { 549 static readonly string __ServiceName = "grpc.testing.UnimplementedService"; 550 551 static readonly grpc::Marshaller<global::Grpc.Testing.Empty> __Marshaller_grpc_testing_Empty = grpc::Marshallers.Create((arg) => global::Google.Protobuf.MessageExtensions.ToByteArray(arg), global::Grpc.Testing.Empty.Parser.ParseFrom); 552 553 static readonly grpc::Method<global::Grpc.Testing.Empty, global::Grpc.Testing.Empty> __Method_UnimplementedCall = new grpc::Method<global::Grpc.Testing.Empty, global::Grpc.Testing.Empty>( 554 grpc::MethodType.Unary, 555 __ServiceName, 556 "UnimplementedCall", 557 __Marshaller_grpc_testing_Empty, 558 __Marshaller_grpc_testing_Empty); 559 560 /// <summary>Service descriptor</summary> 561 public static global::Google.Protobuf.Reflection.ServiceDescriptor Descriptor 562 { 563 get { return global::Grpc.Testing.TestReflection.Descriptor.Services[1]; } 564 } 565 566 /// <summary>Base class for server-side implementations of UnimplementedService</summary> 567 public abstract partial class UnimplementedServiceBase 568 { 569 /// <summary> 570 /// A call that no server should implement 571 /// </summary> 572 /// <param name="request">The request received from the client.</param> 573 /// <param name="context">The context of the server-side call handler being invoked.</param> 574 /// <returns>The response to send back to the client (wrapped by a task).</returns> UnimplementedCall(global::Grpc.Testing.Empty request, grpc::ServerCallContext context)575 public virtual global::System.Threading.Tasks.Task<global::Grpc.Testing.Empty> UnimplementedCall(global::Grpc.Testing.Empty request, grpc::ServerCallContext context) 576 { 577 throw new grpc::RpcException(new grpc::Status(grpc::StatusCode.Unimplemented, "")); 578 } 579 580 } 581 582 /// <summary>Client for UnimplementedService</summary> 583 public partial class UnimplementedServiceClient : grpc::ClientBase<UnimplementedServiceClient> 584 { 585 /// <summary>Creates a new client for UnimplementedService</summary> 586 /// <param name="channel">The channel to use to make remote calls.</param> UnimplementedServiceClient(grpc::Channel channel)587 public UnimplementedServiceClient(grpc::Channel channel) : base(channel) 588 { 589 } 590 /// <summary>Creates a new client for UnimplementedService that uses a custom <c>CallInvoker</c>.</summary> 591 /// <param name="callInvoker">The callInvoker to use to make remote calls.</param> UnimplementedServiceClient(grpc::CallInvoker callInvoker)592 public UnimplementedServiceClient(grpc::CallInvoker callInvoker) : base(callInvoker) 593 { 594 } 595 /// <summary>Protected parameterless constructor to allow creation of test doubles.</summary> UnimplementedServiceClient()596 protected UnimplementedServiceClient() : base() 597 { 598 } 599 /// <summary>Protected constructor to allow creation of configured clients.</summary> 600 /// <param name="configuration">The client configuration.</param> UnimplementedServiceClient(ClientBaseConfiguration configuration)601 protected UnimplementedServiceClient(ClientBaseConfiguration configuration) : base(configuration) 602 { 603 } 604 605 /// <summary> 606 /// A call that no server should implement 607 /// </summary> 608 /// <param name="request">The request to send to the server.</param> 609 /// <param name="headers">The initial metadata to send with the call. This parameter is optional.</param> 610 /// <param name="deadline">An optional deadline for the call. The call will be cancelled if deadline is hit.</param> 611 /// <param name="cancellationToken">An optional token for canceling the call.</param> 612 /// <returns>The response received from the server.</returns> UnimplementedCall(global::Grpc.Testing.Empty request, grpc::Metadata headers = null, global::System.DateTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threading.CancellationToken))613 public virtual global::Grpc.Testing.Empty UnimplementedCall(global::Grpc.Testing.Empty request, grpc::Metadata headers = null, global::System.DateTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threading.CancellationToken)) 614 { 615 return UnimplementedCall(request, new grpc::CallOptions(headers, deadline, cancellationToken)); 616 } 617 /// <summary> 618 /// A call that no server should implement 619 /// </summary> 620 /// <param name="request">The request to send to the server.</param> 621 /// <param name="options">The options for the call.</param> 622 /// <returns>The response received from the server.</returns> UnimplementedCall(global::Grpc.Testing.Empty request, grpc::CallOptions options)623 public virtual global::Grpc.Testing.Empty UnimplementedCall(global::Grpc.Testing.Empty request, grpc::CallOptions options) 624 { 625 return CallInvoker.BlockingUnaryCall(__Method_UnimplementedCall, null, options, request); 626 } 627 /// <summary> 628 /// A call that no server should implement 629 /// </summary> 630 /// <param name="request">The request to send to the server.</param> 631 /// <param name="headers">The initial metadata to send with the call. This parameter is optional.</param> 632 /// <param name="deadline">An optional deadline for the call. The call will be cancelled if deadline is hit.</param> 633 /// <param name="cancellationToken">An optional token for canceling the call.</param> 634 /// <returns>The call object.</returns> UnimplementedCallAsync(global::Grpc.Testing.Empty request, grpc::Metadata headers = null, global::System.DateTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threading.CancellationToken))635 public virtual grpc::AsyncUnaryCall<global::Grpc.Testing.Empty> UnimplementedCallAsync(global::Grpc.Testing.Empty request, grpc::Metadata headers = null, global::System.DateTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threading.CancellationToken)) 636 { 637 return UnimplementedCallAsync(request, new grpc::CallOptions(headers, deadline, cancellationToken)); 638 } 639 /// <summary> 640 /// A call that no server should implement 641 /// </summary> 642 /// <param name="request">The request to send to the server.</param> 643 /// <param name="options">The options for the call.</param> 644 /// <returns>The call object.</returns> UnimplementedCallAsync(global::Grpc.Testing.Empty request, grpc::CallOptions options)645 public virtual grpc::AsyncUnaryCall<global::Grpc.Testing.Empty> UnimplementedCallAsync(global::Grpc.Testing.Empty request, grpc::CallOptions options) 646 { 647 return CallInvoker.AsyncUnaryCall(__Method_UnimplementedCall, null, options, request); 648 } 649 /// <summary>Creates a new instance of client from given <c>ClientBaseConfiguration</c>.</summary> NewInstance(ClientBaseConfiguration configuration)650 protected override UnimplementedServiceClient NewInstance(ClientBaseConfiguration configuration) 651 { 652 return new UnimplementedServiceClient(configuration); 653 } 654 } 655 656 /// <summary>Creates service definition that can be registered with a server</summary> 657 /// <param name="serviceImpl">An object implementing the server-side handling logic.</param> BindService(UnimplementedServiceBase serviceImpl)658 public static grpc::ServerServiceDefinition BindService(UnimplementedServiceBase serviceImpl) 659 { 660 return grpc::ServerServiceDefinition.CreateBuilder() 661 .AddMethod(__Method_UnimplementedCall, serviceImpl.UnimplementedCall).Build(); 662 } 663 664 } 665 /// <summary> 666 /// A service used to control reconnect server. 667 /// </summary> 668 public static partial class ReconnectService 669 { 670 static readonly string __ServiceName = "grpc.testing.ReconnectService"; 671 672 static readonly grpc::Marshaller<global::Grpc.Testing.ReconnectParams> __Marshaller_grpc_testing_ReconnectParams = grpc::Marshallers.Create((arg) => global::Google.Protobuf.MessageExtensions.ToByteArray(arg), global::Grpc.Testing.ReconnectParams.Parser.ParseFrom); 673 static readonly grpc::Marshaller<global::Grpc.Testing.Empty> __Marshaller_grpc_testing_Empty = grpc::Marshallers.Create((arg) => global::Google.Protobuf.MessageExtensions.ToByteArray(arg), global::Grpc.Testing.Empty.Parser.ParseFrom); 674 static readonly grpc::Marshaller<global::Grpc.Testing.ReconnectInfo> __Marshaller_grpc_testing_ReconnectInfo = grpc::Marshallers.Create((arg) => global::Google.Protobuf.MessageExtensions.ToByteArray(arg), global::Grpc.Testing.ReconnectInfo.Parser.ParseFrom); 675 676 static readonly grpc::Method<global::Grpc.Testing.ReconnectParams, global::Grpc.Testing.Empty> __Method_Start = new grpc::Method<global::Grpc.Testing.ReconnectParams, global::Grpc.Testing.Empty>( 677 grpc::MethodType.Unary, 678 __ServiceName, 679 "Start", 680 __Marshaller_grpc_testing_ReconnectParams, 681 __Marshaller_grpc_testing_Empty); 682 683 static readonly grpc::Method<global::Grpc.Testing.Empty, global::Grpc.Testing.ReconnectInfo> __Method_Stop = new grpc::Method<global::Grpc.Testing.Empty, global::Grpc.Testing.ReconnectInfo>( 684 grpc::MethodType.Unary, 685 __ServiceName, 686 "Stop", 687 __Marshaller_grpc_testing_Empty, 688 __Marshaller_grpc_testing_ReconnectInfo); 689 690 /// <summary>Service descriptor</summary> 691 public static global::Google.Protobuf.Reflection.ServiceDescriptor Descriptor 692 { 693 get { return global::Grpc.Testing.TestReflection.Descriptor.Services[2]; } 694 } 695 696 /// <summary>Base class for server-side implementations of ReconnectService</summary> 697 public abstract partial class ReconnectServiceBase 698 { Start(global::Grpc.Testing.ReconnectParams request, grpc::ServerCallContext context)699 public virtual global::System.Threading.Tasks.Task<global::Grpc.Testing.Empty> Start(global::Grpc.Testing.ReconnectParams request, grpc::ServerCallContext context) 700 { 701 throw new grpc::RpcException(new grpc::Status(grpc::StatusCode.Unimplemented, "")); 702 } 703 Stop(global::Grpc.Testing.Empty request, grpc::ServerCallContext context)704 public virtual global::System.Threading.Tasks.Task<global::Grpc.Testing.ReconnectInfo> Stop(global::Grpc.Testing.Empty request, grpc::ServerCallContext context) 705 { 706 throw new grpc::RpcException(new grpc::Status(grpc::StatusCode.Unimplemented, "")); 707 } 708 709 } 710 711 /// <summary>Client for ReconnectService</summary> 712 public partial class ReconnectServiceClient : grpc::ClientBase<ReconnectServiceClient> 713 { 714 /// <summary>Creates a new client for ReconnectService</summary> 715 /// <param name="channel">The channel to use to make remote calls.</param> ReconnectServiceClient(grpc::Channel channel)716 public ReconnectServiceClient(grpc::Channel channel) : base(channel) 717 { 718 } 719 /// <summary>Creates a new client for ReconnectService that uses a custom <c>CallInvoker</c>.</summary> 720 /// <param name="callInvoker">The callInvoker to use to make remote calls.</param> ReconnectServiceClient(grpc::CallInvoker callInvoker)721 public ReconnectServiceClient(grpc::CallInvoker callInvoker) : base(callInvoker) 722 { 723 } 724 /// <summary>Protected parameterless constructor to allow creation of test doubles.</summary> ReconnectServiceClient()725 protected ReconnectServiceClient() : base() 726 { 727 } 728 /// <summary>Protected constructor to allow creation of configured clients.</summary> 729 /// <param name="configuration">The client configuration.</param> ReconnectServiceClient(ClientBaseConfiguration configuration)730 protected ReconnectServiceClient(ClientBaseConfiguration configuration) : base(configuration) 731 { 732 } 733 Start(global::Grpc.Testing.ReconnectParams request, grpc::Metadata headers = null, global::System.DateTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threading.CancellationToken))734 public virtual global::Grpc.Testing.Empty Start(global::Grpc.Testing.ReconnectParams request, grpc::Metadata headers = null, global::System.DateTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threading.CancellationToken)) 735 { 736 return Start(request, new grpc::CallOptions(headers, deadline, cancellationToken)); 737 } Start(global::Grpc.Testing.ReconnectParams request, grpc::CallOptions options)738 public virtual global::Grpc.Testing.Empty Start(global::Grpc.Testing.ReconnectParams request, grpc::CallOptions options) 739 { 740 return CallInvoker.BlockingUnaryCall(__Method_Start, null, options, request); 741 } StartAsync(global::Grpc.Testing.ReconnectParams request, grpc::Metadata headers = null, global::System.DateTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threading.CancellationToken))742 public virtual grpc::AsyncUnaryCall<global::Grpc.Testing.Empty> StartAsync(global::Grpc.Testing.ReconnectParams request, grpc::Metadata headers = null, global::System.DateTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threading.CancellationToken)) 743 { 744 return StartAsync(request, new grpc::CallOptions(headers, deadline, cancellationToken)); 745 } StartAsync(global::Grpc.Testing.ReconnectParams request, grpc::CallOptions options)746 public virtual grpc::AsyncUnaryCall<global::Grpc.Testing.Empty> StartAsync(global::Grpc.Testing.ReconnectParams request, grpc::CallOptions options) 747 { 748 return CallInvoker.AsyncUnaryCall(__Method_Start, null, options, request); 749 } Stop(global::Grpc.Testing.Empty request, grpc::Metadata headers = null, global::System.DateTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threading.CancellationToken))750 public virtual global::Grpc.Testing.ReconnectInfo Stop(global::Grpc.Testing.Empty request, grpc::Metadata headers = null, global::System.DateTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threading.CancellationToken)) 751 { 752 return Stop(request, new grpc::CallOptions(headers, deadline, cancellationToken)); 753 } Stop(global::Grpc.Testing.Empty request, grpc::CallOptions options)754 public virtual global::Grpc.Testing.ReconnectInfo Stop(global::Grpc.Testing.Empty request, grpc::CallOptions options) 755 { 756 return CallInvoker.BlockingUnaryCall(__Method_Stop, null, options, request); 757 } StopAsync(global::Grpc.Testing.Empty request, grpc::Metadata headers = null, global::System.DateTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threading.CancellationToken))758 public virtual grpc::AsyncUnaryCall<global::Grpc.Testing.ReconnectInfo> StopAsync(global::Grpc.Testing.Empty request, grpc::Metadata headers = null, global::System.DateTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threading.CancellationToken)) 759 { 760 return StopAsync(request, new grpc::CallOptions(headers, deadline, cancellationToken)); 761 } StopAsync(global::Grpc.Testing.Empty request, grpc::CallOptions options)762 public virtual grpc::AsyncUnaryCall<global::Grpc.Testing.ReconnectInfo> StopAsync(global::Grpc.Testing.Empty request, grpc::CallOptions options) 763 { 764 return CallInvoker.AsyncUnaryCall(__Method_Stop, null, options, request); 765 } 766 /// <summary>Creates a new instance of client from given <c>ClientBaseConfiguration</c>.</summary> NewInstance(ClientBaseConfiguration configuration)767 protected override ReconnectServiceClient NewInstance(ClientBaseConfiguration configuration) 768 { 769 return new ReconnectServiceClient(configuration); 770 } 771 } 772 773 /// <summary>Creates service definition that can be registered with a server</summary> 774 /// <param name="serviceImpl">An object implementing the server-side handling logic.</param> BindService(ReconnectServiceBase serviceImpl)775 public static grpc::ServerServiceDefinition BindService(ReconnectServiceBase serviceImpl) 776 { 777 return grpc::ServerServiceDefinition.CreateBuilder() 778 .AddMethod(__Method_Start, serviceImpl.Start) 779 .AddMethod(__Method_Stop, serviceImpl.Stop).Build(); 780 } 781 782 } 783 } 784 #endregion 785