parent
ecaba8a8d3
commit
b335d58cb7
4 changed files with 438 additions and 11 deletions
@ -0,0 +1,286 @@ |
|||||||
|
// Generated by the protocol buffer compiler. DO NOT EDIT! |
||||||
|
// source: helloworld.proto |
||||||
|
#pragma warning disable 1591, 0612, 3021 |
||||||
|
#region Designer generated code |
||||||
|
|
||||||
|
using pb = global::Google.Protobuf; |
||||||
|
using pbc = global::Google.Protobuf.Collections; |
||||||
|
using pbr = global::Google.Protobuf.Reflection; |
||||||
|
using scg = global::System.Collections.Generic; |
||||||
|
namespace Helloworld { |
||||||
|
|
||||||
|
/// <summary>Holder for reflection information generated from helloworld.proto</summary> |
||||||
|
public static partial class HelloworldReflection { |
||||||
|
|
||||||
|
#region Descriptor |
||||||
|
/// <summary>File descriptor for helloworld.proto</summary> |
||||||
|
public static pbr::FileDescriptor Descriptor { |
||||||
|
get { return descriptor; } |
||||||
|
} |
||||||
|
private static pbr::FileDescriptor descriptor; |
||||||
|
|
||||||
|
static HelloworldReflection() { |
||||||
|
byte[] descriptorData = global::System.Convert.FromBase64String( |
||||||
|
string.Concat( |
||||||
|
"ChBoZWxsb3dvcmxkLnByb3RvEgpoZWxsb3dvcmxkIhwKDEhlbGxvUmVxdWVz", |
||||||
|
"dBIMCgRuYW1lGAEgASgJIh0KCkhlbGxvUmVwbHkSDwoHbWVzc2FnZRgBIAEo", |
||||||
|
"CTJJCgdHcmVldGVyEj4KCFNheUhlbGxvEhguaGVsbG93b3JsZC5IZWxsb1Jl", |
||||||
|
"cXVlc3QaFi5oZWxsb3dvcmxkLkhlbGxvUmVwbHkiAEI2Chtpby5ncnBjLmV4", |
||||||
|
"YW1wbGVzLmhlbGxvd29ybGRCD0hlbGxvV29ybGRQcm90b1ABogIDSExXYgZw", |
||||||
|
"cm90bzM=")); |
||||||
|
descriptor = pbr::FileDescriptor.FromGeneratedCode(descriptorData, |
||||||
|
new pbr::FileDescriptor[] { }, |
||||||
|
new pbr::GeneratedClrTypeInfo(null, new pbr::GeneratedClrTypeInfo[] { |
||||||
|
new pbr::GeneratedClrTypeInfo(typeof(global::Helloworld.HelloRequest), global::Helloworld.HelloRequest.Parser, new[]{ "Name" }, null, null, null), |
||||||
|
new pbr::GeneratedClrTypeInfo(typeof(global::Helloworld.HelloReply), global::Helloworld.HelloReply.Parser, new[]{ "Message" }, null, null, null) |
||||||
|
})); |
||||||
|
} |
||||||
|
#endregion |
||||||
|
|
||||||
|
} |
||||||
|
#region Messages |
||||||
|
/// <summary> |
||||||
|
/// The request message containing the user's name. |
||||||
|
/// </summary> |
||||||
|
public sealed partial class HelloRequest : pb::IMessage<HelloRequest> { |
||||||
|
private static readonly pb::MessageParser<HelloRequest> _parser = new pb::MessageParser<HelloRequest>(() => new HelloRequest()); |
||||||
|
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
||||||
|
public static pb::MessageParser<HelloRequest> Parser { get { return _parser; } } |
||||||
|
|
||||||
|
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
||||||
|
public static pbr::MessageDescriptor Descriptor { |
||||||
|
get { return global::Helloworld.HelloworldReflection.Descriptor.MessageTypes[0]; } |
||||||
|
} |
||||||
|
|
||||||
|
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
||||||
|
pbr::MessageDescriptor pb::IMessage.Descriptor { |
||||||
|
get { return Descriptor; } |
||||||
|
} |
||||||
|
|
||||||
|
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
||||||
|
public HelloRequest() { |
||||||
|
OnConstruction(); |
||||||
|
} |
||||||
|
|
||||||
|
partial void OnConstruction(); |
||||||
|
|
||||||
|
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
||||||
|
public HelloRequest(HelloRequest other) : this() { |
||||||
|
name_ = other.name_; |
||||||
|
} |
||||||
|
|
||||||
|
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
||||||
|
public HelloRequest Clone() { |
||||||
|
return new HelloRequest(this); |
||||||
|
} |
||||||
|
|
||||||
|
/// <summary>Field number for the "name" field.</summary> |
||||||
|
public const int NameFieldNumber = 1; |
||||||
|
private string name_ = ""; |
||||||
|
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
||||||
|
public string Name { |
||||||
|
get { return name_; } |
||||||
|
set { |
||||||
|
name_ = pb::ProtoPreconditions.CheckNotNull(value, "value"); |
||||||
|
} |
||||||
|
} |
||||||
|
|
||||||
|
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
||||||
|
public override bool Equals(object other) { |
||||||
|
return Equals(other as HelloRequest); |
||||||
|
} |
||||||
|
|
||||||
|
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
||||||
|
public bool Equals(HelloRequest other) { |
||||||
|
if (ReferenceEquals(other, null)) { |
||||||
|
return false; |
||||||
|
} |
||||||
|
if (ReferenceEquals(other, this)) { |
||||||
|
return true; |
||||||
|
} |
||||||
|
if (Name != other.Name) return false; |
||||||
|
return true; |
||||||
|
} |
||||||
|
|
||||||
|
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
||||||
|
public override int GetHashCode() { |
||||||
|
int hash = 1; |
||||||
|
if (Name.Length != 0) hash ^= Name.GetHashCode(); |
||||||
|
return hash; |
||||||
|
} |
||||||
|
|
||||||
|
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
||||||
|
public override string ToString() { |
||||||
|
return pb::JsonFormatter.ToDiagnosticString(this); |
||||||
|
} |
||||||
|
|
||||||
|
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
||||||
|
public void WriteTo(pb::CodedOutputStream output) { |
||||||
|
if (Name.Length != 0) { |
||||||
|
output.WriteRawTag(10); |
||||||
|
output.WriteString(Name); |
||||||
|
} |
||||||
|
} |
||||||
|
|
||||||
|
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
||||||
|
public int CalculateSize() { |
||||||
|
int size = 0; |
||||||
|
if (Name.Length != 0) { |
||||||
|
size += 1 + pb::CodedOutputStream.ComputeStringSize(Name); |
||||||
|
} |
||||||
|
return size; |
||||||
|
} |
||||||
|
|
||||||
|
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
||||||
|
public void MergeFrom(HelloRequest other) { |
||||||
|
if (other == null) { |
||||||
|
return; |
||||||
|
} |
||||||
|
if (other.Name.Length != 0) { |
||||||
|
Name = other.Name; |
||||||
|
} |
||||||
|
} |
||||||
|
|
||||||
|
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
||||||
|
public void MergeFrom(pb::CodedInputStream input) { |
||||||
|
uint tag; |
||||||
|
while ((tag = input.ReadTag()) != 0) { |
||||||
|
switch(tag) { |
||||||
|
default: |
||||||
|
input.SkipLastField(); |
||||||
|
break; |
||||||
|
case 10: { |
||||||
|
Name = input.ReadString(); |
||||||
|
break; |
||||||
|
} |
||||||
|
} |
||||||
|
} |
||||||
|
} |
||||||
|
|
||||||
|
} |
||||||
|
|
||||||
|
/// <summary> |
||||||
|
/// The response message containing the greetings |
||||||
|
/// </summary> |
||||||
|
public sealed partial class HelloReply : pb::IMessage<HelloReply> { |
||||||
|
private static readonly pb::MessageParser<HelloReply> _parser = new pb::MessageParser<HelloReply>(() => new HelloReply()); |
||||||
|
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
||||||
|
public static pb::MessageParser<HelloReply> Parser { get { return _parser; } } |
||||||
|
|
||||||
|
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
||||||
|
public static pbr::MessageDescriptor Descriptor { |
||||||
|
get { return global::Helloworld.HelloworldReflection.Descriptor.MessageTypes[1]; } |
||||||
|
} |
||||||
|
|
||||||
|
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
||||||
|
pbr::MessageDescriptor pb::IMessage.Descriptor { |
||||||
|
get { return Descriptor; } |
||||||
|
} |
||||||
|
|
||||||
|
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
||||||
|
public HelloReply() { |
||||||
|
OnConstruction(); |
||||||
|
} |
||||||
|
|
||||||
|
partial void OnConstruction(); |
||||||
|
|
||||||
|
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
||||||
|
public HelloReply(HelloReply other) : this() { |
||||||
|
message_ = other.message_; |
||||||
|
} |
||||||
|
|
||||||
|
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
||||||
|
public HelloReply Clone() { |
||||||
|
return new HelloReply(this); |
||||||
|
} |
||||||
|
|
||||||
|
/// <summary>Field number for the "message" field.</summary> |
||||||
|
public const int MessageFieldNumber = 1; |
||||||
|
private string message_ = ""; |
||||||
|
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
||||||
|
public string Message { |
||||||
|
get { return message_; } |
||||||
|
set { |
||||||
|
message_ = pb::ProtoPreconditions.CheckNotNull(value, "value"); |
||||||
|
} |
||||||
|
} |
||||||
|
|
||||||
|
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
||||||
|
public override bool Equals(object other) { |
||||||
|
return Equals(other as HelloReply); |
||||||
|
} |
||||||
|
|
||||||
|
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
||||||
|
public bool Equals(HelloReply other) { |
||||||
|
if (ReferenceEquals(other, null)) { |
||||||
|
return false; |
||||||
|
} |
||||||
|
if (ReferenceEquals(other, this)) { |
||||||
|
return true; |
||||||
|
} |
||||||
|
if (Message != other.Message) return false; |
||||||
|
return true; |
||||||
|
} |
||||||
|
|
||||||
|
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
||||||
|
public override int GetHashCode() { |
||||||
|
int hash = 1; |
||||||
|
if (Message.Length != 0) hash ^= Message.GetHashCode(); |
||||||
|
return hash; |
||||||
|
} |
||||||
|
|
||||||
|
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
||||||
|
public override string ToString() { |
||||||
|
return pb::JsonFormatter.ToDiagnosticString(this); |
||||||
|
} |
||||||
|
|
||||||
|
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
||||||
|
public void WriteTo(pb::CodedOutputStream output) { |
||||||
|
if (Message.Length != 0) { |
||||||
|
output.WriteRawTag(10); |
||||||
|
output.WriteString(Message); |
||||||
|
} |
||||||
|
} |
||||||
|
|
||||||
|
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
||||||
|
public int CalculateSize() { |
||||||
|
int size = 0; |
||||||
|
if (Message.Length != 0) { |
||||||
|
size += 1 + pb::CodedOutputStream.ComputeStringSize(Message); |
||||||
|
} |
||||||
|
return size; |
||||||
|
} |
||||||
|
|
||||||
|
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
||||||
|
public void MergeFrom(HelloReply other) { |
||||||
|
if (other == null) { |
||||||
|
return; |
||||||
|
} |
||||||
|
if (other.Message.Length != 0) { |
||||||
|
Message = other.Message; |
||||||
|
} |
||||||
|
} |
||||||
|
|
||||||
|
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
||||||
|
public void MergeFrom(pb::CodedInputStream input) { |
||||||
|
uint tag; |
||||||
|
while ((tag = input.ReadTag()) != 0) { |
||||||
|
switch(tag) { |
||||||
|
default: |
||||||
|
input.SkipLastField(); |
||||||
|
break; |
||||||
|
case 10: { |
||||||
|
Message = input.ReadString(); |
||||||
|
break; |
||||||
|
} |
||||||
|
} |
||||||
|
} |
||||||
|
} |
||||||
|
|
||||||
|
} |
||||||
|
|
||||||
|
#endregion |
||||||
|
|
||||||
|
} |
||||||
|
|
||||||
|
#endregion Designer generated code |
@ -0,0 +1,150 @@ |
|||||||
|
// Generated by the protocol buffer compiler. DO NOT EDIT! |
||||||
|
// source: helloworld.proto |
||||||
|
// Original file comments: |
||||||
|
// Copyright 2015 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. |
||||||
|
// |
||||||
|
#pragma warning disable 1591 |
||||||
|
#region Designer generated code |
||||||
|
|
||||||
|
using System; |
||||||
|
using System.Threading; |
||||||
|
using System.Threading.Tasks; |
||||||
|
using grpc = global::Grpc.Core; |
||||||
|
|
||||||
|
namespace Helloworld { |
||||||
|
/// <summary> |
||||||
|
/// The greeting service definition. |
||||||
|
/// </summary> |
||||||
|
public static partial class Greeter |
||||||
|
{ |
||||||
|
static readonly string __ServiceName = "helloworld.Greeter"; |
||||||
|
|
||||||
|
static readonly grpc::Marshaller<global::Helloworld.HelloRequest> __Marshaller_HelloRequest = grpc::Marshallers.Create((arg) => global::Google.Protobuf.MessageExtensions.ToByteArray(arg), global::Helloworld.HelloRequest.Parser.ParseFrom); |
||||||
|
static readonly grpc::Marshaller<global::Helloworld.HelloReply> __Marshaller_HelloReply = grpc::Marshallers.Create((arg) => global::Google.Protobuf.MessageExtensions.ToByteArray(arg), global::Helloworld.HelloReply.Parser.ParseFrom); |
||||||
|
|
||||||
|
static readonly grpc::Method<global::Helloworld.HelloRequest, global::Helloworld.HelloReply> __Method_SayHello = new grpc::Method<global::Helloworld.HelloRequest, global::Helloworld.HelloReply>( |
||||||
|
grpc::MethodType.Unary, |
||||||
|
__ServiceName, |
||||||
|
"SayHello", |
||||||
|
__Marshaller_HelloRequest, |
||||||
|
__Marshaller_HelloReply); |
||||||
|
|
||||||
|
/// <summary>Service descriptor</summary> |
||||||
|
public static global::Google.Protobuf.Reflection.ServiceDescriptor Descriptor |
||||||
|
{ |
||||||
|
get { return global::Helloworld.HelloworldReflection.Descriptor.Services[0]; } |
||||||
|
} |
||||||
|
|
||||||
|
/// <summary>Base class for server-side implementations of Greeter</summary> |
||||||
|
public abstract partial class GreeterBase |
||||||
|
{ |
||||||
|
/// <summary> |
||||||
|
/// Sends a greeting |
||||||
|
/// </summary> |
||||||
|
/// <param name="request">The request received from the client.</param> |
||||||
|
/// <param name="context">The context of the server-side call handler being invoked.</param> |
||||||
|
/// <returns>The response to send back to the client (wrapped by a task).</returns> |
||||||
|
public virtual global::System.Threading.Tasks.Task<global::Helloworld.HelloReply> SayHello(global::Helloworld.HelloRequest request, grpc::ServerCallContext context) |
||||||
|
{ |
||||||
|
throw new grpc::RpcException(new grpc::Status(grpc::StatusCode.Unimplemented, "")); |
||||||
|
} |
||||||
|
|
||||||
|
} |
||||||
|
|
||||||
|
/// <summary>Client for Greeter</summary> |
||||||
|
public partial class GreeterClient : grpc::ClientBase<GreeterClient> |
||||||
|
{ |
||||||
|
/// <summary>Creates a new client for Greeter</summary> |
||||||
|
/// <param name="channel">The channel to use to make remote calls.</param> |
||||||
|
public GreeterClient(grpc::Channel channel) : base(channel) |
||||||
|
{ |
||||||
|
} |
||||||
|
/// <summary>Creates a new client for Greeter that uses a custom <c>CallInvoker</c>.</summary> |
||||||
|
/// <param name="callInvoker">The callInvoker to use to make remote calls.</param> |
||||||
|
public GreeterClient(grpc::CallInvoker callInvoker) : base(callInvoker) |
||||||
|
{ |
||||||
|
} |
||||||
|
/// <summary>Protected parameterless constructor to allow creation of test doubles.</summary> |
||||||
|
protected GreeterClient() : base() |
||||||
|
{ |
||||||
|
} |
||||||
|
/// <summary>Protected constructor to allow creation of configured clients.</summary> |
||||||
|
/// <param name="configuration">The client configuration.</param> |
||||||
|
protected GreeterClient(ClientBaseConfiguration configuration) : base(configuration) |
||||||
|
{ |
||||||
|
} |
||||||
|
|
||||||
|
/// <summary> |
||||||
|
/// Sends a greeting |
||||||
|
/// </summary> |
||||||
|
/// <param name="request">The request to send to the server.</param> |
||||||
|
/// <param name="headers">The initial metadata to send with the call. This parameter is optional.</param> |
||||||
|
/// <param name="deadline">An optional deadline for the call. The call will be cancelled if deadline is hit.</param> |
||||||
|
/// <param name="cancellationToken">An optional token for canceling the call.</param> |
||||||
|
/// <returns>The response received from the server.</returns> |
||||||
|
public virtual global::Helloworld.HelloReply SayHello(global::Helloworld.HelloRequest request, grpc::Metadata headers = null, DateTime? deadline = null, CancellationToken cancellationToken = default(CancellationToken)) |
||||||
|
{ |
||||||
|
return SayHello(request, new grpc::CallOptions(headers, deadline, cancellationToken)); |
||||||
|
} |
||||||
|
/// <summary> |
||||||
|
/// Sends a greeting |
||||||
|
/// </summary> |
||||||
|
/// <param name="request">The request to send to the server.</param> |
||||||
|
/// <param name="options">The options for the call.</param> |
||||||
|
/// <returns>The response received from the server.</returns> |
||||||
|
public virtual global::Helloworld.HelloReply SayHello(global::Helloworld.HelloRequest request, grpc::CallOptions options) |
||||||
|
{ |
||||||
|
return CallInvoker.BlockingUnaryCall(__Method_SayHello, null, options, request); |
||||||
|
} |
||||||
|
/// <summary> |
||||||
|
/// Sends a greeting |
||||||
|
/// </summary> |
||||||
|
/// <param name="request">The request to send to the server.</param> |
||||||
|
/// <param name="headers">The initial metadata to send with the call. This parameter is optional.</param> |
||||||
|
/// <param name="deadline">An optional deadline for the call. The call will be cancelled if deadline is hit.</param> |
||||||
|
/// <param name="cancellationToken">An optional token for canceling the call.</param> |
||||||
|
/// <returns>The call object.</returns> |
||||||
|
public virtual grpc::AsyncUnaryCall<global::Helloworld.HelloReply> SayHelloAsync(global::Helloworld.HelloRequest request, grpc::Metadata headers = null, DateTime? deadline = null, CancellationToken cancellationToken = default(CancellationToken)) |
||||||
|
{ |
||||||
|
return SayHelloAsync(request, new grpc::CallOptions(headers, deadline, cancellationToken)); |
||||||
|
} |
||||||
|
/// <summary> |
||||||
|
/// Sends a greeting |
||||||
|
/// </summary> |
||||||
|
/// <param name="request">The request to send to the server.</param> |
||||||
|
/// <param name="options">The options for the call.</param> |
||||||
|
/// <returns>The call object.</returns> |
||||||
|
public virtual grpc::AsyncUnaryCall<global::Helloworld.HelloReply> SayHelloAsync(global::Helloworld.HelloRequest request, grpc::CallOptions options) |
||||||
|
{ |
||||||
|
return CallInvoker.AsyncUnaryCall(__Method_SayHello, null, options, request); |
||||||
|
} |
||||||
|
/// <summary>Creates a new instance of client from given <c>ClientBaseConfiguration</c>.</summary> |
||||||
|
protected override GreeterClient NewInstance(ClientBaseConfiguration configuration) |
||||||
|
{ |
||||||
|
return new GreeterClient(configuration); |
||||||
|
} |
||||||
|
} |
||||||
|
|
||||||
|
/// <summary>Creates service definition that can be registered with a server</summary> |
||||||
|
/// <param name="serviceImpl">An object implementing the server-side handling logic.</param> |
||||||
|
public static grpc::ServerServiceDefinition BindService(GreeterBase serviceImpl) |
||||||
|
{ |
||||||
|
return grpc::ServerServiceDefinition.CreateBuilder() |
||||||
|
.AddMethod(__Method_SayHello, serviceImpl.SayHello).Build(); |
||||||
|
} |
||||||
|
|
||||||
|
} |
||||||
|
} |
||||||
|
#endregion |
Loading…
Reference in new issue