Updated Protobuf messages and services

This commit is contained in:
hondacrx
2021-10-01 12:49:34 -04:00
parent 475338bc4b
commit f671840984
36 changed files with 4662 additions and 3788 deletions
@@ -27,52 +27,55 @@ namespace Bgs.Protocol {
"CjdiZ3MvbG93L3BiL2NsaWVudC9nbG9iYWxfZXh0ZW5zaW9ucy9maWVsZF9v",
"cHRpb25zLnByb3RvEgxiZ3MucHJvdG9jb2waIGdvb2dsZS9wcm90b2J1Zi9k",
"ZXNjcmlwdG9yLnByb3RvGi9iZ3MvbG93L3BiL2NsaWVudC9nbG9iYWxfZXh0",
"ZW5zaW9ucy9yYW5nZS5wcm90byJmCg9CR1NGaWVsZE9wdGlvbnMSLAoDbG9n",
"GAEgASgOMhcuYmdzLnByb3RvY29sLkxvZ09wdGlvbjoGSElEREVOEhEKCXNo",
"YXJkX2tleRgCIAEoCBISCgpmYW5vdXRfa2V5GAMgASgIIqoDChBGaWVsZFJl",
"c3RyaWN0aW9uEjYKBnNpZ25lZBgBIAEoCzIkLmJncy5wcm90b2NvbC5TaWdu",
"ZWRGaWVsZFJlc3RyaWN0aW9uSAASOgoIdW5zaWduZWQYAiABKAsyJi5iZ3Mu",
"cHJvdG9jb2wuVW5zaWduZWRGaWVsZFJlc3RyaWN0aW9uSAASNAoFZmxvYXQY",
"AyABKAsyIy5iZ3MucHJvdG9jb2wuRmxvYXRGaWVsZFJlc3RyaWN0aW9uSAAS",
"NgoGc3RyaW5nGAQgASgLMiQuYmdzLnByb3RvY29sLlN0cmluZ0ZpZWxkUmVz",
"dHJpY3Rpb25IABI6CghyZXBlYXRlZBgFIAEoCzImLmJncy5wcm90b2NvbC5S",
"ZXBlYXRlZEZpZWxkUmVzdHJpY3Rpb25IABI4CgdtZXNzYWdlGAYgASgLMiUu",
"YmdzLnByb3RvY29sLk1lc3NhZ2VGaWVsZFJlc3RyaWN0aW9uSAASNgoJZW50",
"aXR5X2lkGAcgASgLMiEuYmdzLnByb3RvY29sLkVudGl0eUlkUmVzdHJpY3Rp",
"b25IAEIGCgR0eXBlIvoCChhSZXBlYXRlZEZpZWxkUmVzdHJpY3Rpb24SLAoE",
"c2l6ZRgBIAEoCzIeLmJncy5wcm90b2NvbC5VbnNpZ25lZEludFJhbmdlEg4K",
"BnVuaXF1ZRgCIAEoCBI2CgZzaWduZWQYAyABKAsyJC5iZ3MucHJvdG9jb2wu",
"U2lnbmVkRmllbGRSZXN0cmljdGlvbkgAEjoKCHVuc2lnbmVkGAQgASgLMiYu",
"YmdzLnByb3RvY29sLlVuc2lnbmVkRmllbGRSZXN0cmljdGlvbkgAEjQKBWZs",
"b2F0GAUgASgLMiMuYmdzLnByb3RvY29sLkZsb2F0RmllbGRSZXN0cmljdGlv",
"bkgAEjYKBnN0cmluZxgGIAEoCzIkLmJncy5wcm90b2NvbC5TdHJpbmdGaWVs",
"ZFJlc3RyaWN0aW9uSAASNgoJZW50aXR5X2lkGAcgASgLMiEuYmdzLnByb3Rv",
"Y29sLkVudGl0eUlkUmVzdHJpY3Rpb25IAEIGCgR0eXBlIlcKFlNpZ25lZEZp",
"ZWxkUmVzdHJpY3Rpb24SLAoGbGltaXRzGAEgASgLMhwuYmdzLnByb3RvY29s",
"LlNpZ25lZEludFJhbmdlEg8KB2V4Y2x1ZGUYAiADKBIiWwoYVW5zaWduZWRG",
"aWVsZFJlc3RyaWN0aW9uEi4KBmxpbWl0cxgBIAEoCzIeLmJncy5wcm90b2Nv",
"bC5VbnNpZ25lZEludFJhbmdlEg8KB2V4Y2x1ZGUYAiADKAQiUgoVRmxvYXRG",
"aWVsZFJlc3RyaWN0aW9uEigKBmxpbWl0cxgBIAEoCzIYLmJncy5wcm90b2Nv",
"bC5GbG9hdFJhbmdlEg8KB2V4Y2x1ZGUYAiADKAIiVwoWU3RyaW5nRmllbGRS",
"ZXN0cmljdGlvbhIsCgRzaXplGAEgASgLMh4uYmdzLnByb3RvY29sLlVuc2ln",
"bmVkSW50UmFuZ2USDwoHZXhjbHVkZRgCIAMoCSLHAQoTRW50aXR5SWRSZXN0",
"cmljdGlvbhIOCgZuZWVkZWQYASABKAgSOQoEa2luZBgCIAEoDjImLmJncy5w",
"cm90b2NvbC5FbnRpdHlJZFJlc3RyaWN0aW9uLktpbmQ6A0FOWSJlCgRLaW5k",
"EgcKA0FOWRAAEgsKB0FDQ09VTlQQARIQCgxHQU1FX0FDQ09VTlQQAhIbChdB",
"Q0NPVU5UX09SX0dBTUVfQUNDT1VOVBADEgsKB1NFUlZJQ0UQBBILCgdDSEFO",
"TkVMEAUiKQoXTWVzc2FnZUZpZWxkUmVzdHJpY3Rpb24SDgoGbmVlZGVkGAEg",
"ASgIKiAKCUxvZ09wdGlvbhIKCgZISURERU4QARIHCgNIRVgQAjpVCg1maWVs",
"ZF9vcHRpb25zEh0uZ29vZ2xlLnByb3RvYnVmLkZpZWxkT3B0aW9ucxiQvwUg",
"ASgLMh0uYmdzLnByb3RvY29sLkJHU0ZpZWxkT3B0aW9uczpOCgV2YWxpZBId",
"Lmdvb2dsZS5wcm90b2J1Zi5GaWVsZE9wdGlvbnMYkb8FIAEoCzIeLmJncy5w",
"cm90b2NvbC5GaWVsZFJlc3RyaWN0aW9uQiIKDWJuZXQucHJvdG9jb2xCEUZp",
"ZWxkT3B0aW9uc1Byb3Rv"));
"ZW5zaW9ucy9yYW5nZS5wcm90byKaAQoPQkdTRmllbGRPcHRpb25zEiwKA2xv",
"ZxgBIAEoDjIXLmJncy5wcm90b2NvbC5Mb2dPcHRpb246BkhJRERFThIRCglz",
"aGFyZF9rZXkYAiABKAgSEgoKZmFub3V0X2tleRgDIAEoCBIbChNjbGllbnRf",
"aW5zdGFuY2Vfa2V5GAQgASgIEhUKDXJlYWxpemVkX2VudW0YBSABKAki4QMK",
"EEZpZWxkUmVzdHJpY3Rpb24SNgoGc2lnbmVkGAEgASgLMiQuYmdzLnByb3Rv",
"Y29sLlNpZ25lZEZpZWxkUmVzdHJpY3Rpb25IABI6Cgh1bnNpZ25lZBgCIAEo",
"CzImLmJncy5wcm90b2NvbC5VbnNpZ25lZEZpZWxkUmVzdHJpY3Rpb25IABI0",
"CgVmbG9hdBgDIAEoCzIjLmJncy5wcm90b2NvbC5GbG9hdEZpZWxkUmVzdHJp",
"Y3Rpb25IABI2CgZzdHJpbmcYBCABKAsyJC5iZ3MucHJvdG9jb2wuU3RyaW5n",
"RmllbGRSZXN0cmljdGlvbkgAEjoKCHJlcGVhdGVkGAUgASgLMiYuYmdzLnBy",
"b3RvY29sLlJlcGVhdGVkRmllbGRSZXN0cmljdGlvbkgAEjgKB21lc3NhZ2UY",
"BiABKAsyJS5iZ3MucHJvdG9jb2wuTWVzc2FnZUZpZWxkUmVzdHJpY3Rpb25I",
"ABI2CgllbnRpdHlfaWQYByABKAsyIS5iZ3MucHJvdG9jb2wuRW50aXR5SWRS",
"ZXN0cmljdGlvbkgAEjUKBWJ5dGVzGAggASgLMiQuYmdzLnByb3RvY29sLlN0",
"cmluZ0ZpZWxkUmVzdHJpY3Rpb25IAEIGCgR0eXBlIrEDChhSZXBlYXRlZEZp",
"ZWxkUmVzdHJpY3Rpb24SLAoEc2l6ZRgBIAEoCzIeLmJncy5wcm90b2NvbC5V",
"bnNpZ25lZEludFJhbmdlEg4KBnVuaXF1ZRgCIAEoCBI2CgZzaWduZWQYAyAB",
"KAsyJC5iZ3MucHJvdG9jb2wuU2lnbmVkRmllbGRSZXN0cmljdGlvbkgAEjoK",
"CHVuc2lnbmVkGAQgASgLMiYuYmdzLnByb3RvY29sLlVuc2lnbmVkRmllbGRS",
"ZXN0cmljdGlvbkgAEjQKBWZsb2F0GAUgASgLMiMuYmdzLnByb3RvY29sLkZs",
"b2F0RmllbGRSZXN0cmljdGlvbkgAEjYKBnN0cmluZxgGIAEoCzIkLmJncy5w",
"cm90b2NvbC5TdHJpbmdGaWVsZFJlc3RyaWN0aW9uSAASNgoJZW50aXR5X2lk",
"GAcgASgLMiEuYmdzLnByb3RvY29sLkVudGl0eUlkUmVzdHJpY3Rpb25IABI1",
"CgVieXRlcxgIIAEoCzIkLmJncy5wcm90b2NvbC5TdHJpbmdGaWVsZFJlc3Ry",
"aWN0aW9uSABCBgoEdHlwZSJXChZTaWduZWRGaWVsZFJlc3RyaWN0aW9uEiwK",
"BmxpbWl0cxgBIAEoCzIcLmJncy5wcm90b2NvbC5TaWduZWRJbnRSYW5nZRIP",
"CgdleGNsdWRlGAIgAygSIlsKGFVuc2lnbmVkRmllbGRSZXN0cmljdGlvbhIu",
"CgZsaW1pdHMYASABKAsyHi5iZ3MucHJvdG9jb2wuVW5zaWduZWRJbnRSYW5n",
"ZRIPCgdleGNsdWRlGAIgAygEIlIKFUZsb2F0RmllbGRSZXN0cmljdGlvbhIo",
"CgZsaW1pdHMYASABKAsyGC5iZ3MucHJvdG9jb2wuRmxvYXRSYW5nZRIPCgdl",
"eGNsdWRlGAIgAygCIlcKFlN0cmluZ0ZpZWxkUmVzdHJpY3Rpb24SLAoEc2l6",
"ZRgBIAEoCzIeLmJncy5wcm90b2NvbC5VbnNpZ25lZEludFJhbmdlEg8KB2V4",
"Y2x1ZGUYAiADKAkixwEKE0VudGl0eUlkUmVzdHJpY3Rpb24SDgoGbmVlZGVk",
"GAEgASgIEjkKBGtpbmQYAiABKA4yJi5iZ3MucHJvdG9jb2wuRW50aXR5SWRS",
"ZXN0cmljdGlvbi5LaW5kOgNBTlkiZQoES2luZBIHCgNBTlkQABILCgdBQ0NP",
"VU5UEAESEAoMR0FNRV9BQ0NPVU5UEAISGwoXQUNDT1VOVF9PUl9HQU1FX0FD",
"Q09VTlQQAxILCgdTRVJWSUNFEAQSCwoHQ0hBTk5FTBAFIikKF01lc3NhZ2VG",
"aWVsZFJlc3RyaWN0aW9uEg4KBm5lZWRlZBgBIAEoCCogCglMb2dPcHRpb24S",
"CgoGSElEREVOEAESBwoDSEVYEAI6VQoNZmllbGRfb3B0aW9ucxIdLmdvb2ds",
"ZS5wcm90b2J1Zi5GaWVsZE9wdGlvbnMYkL8FIAEoCzIdLmJncy5wcm90b2Nv",
"bC5CR1NGaWVsZE9wdGlvbnM6TgoFdmFsaWQSHS5nb29nbGUucHJvdG9idWYu",
"RmllbGRPcHRpb25zGJG/BSABKAsyHi5iZ3MucHJvdG9jb2wuRmllbGRSZXN0",
"cmljdGlvbkIiCg1ibmV0LnByb3RvY29sQhFGaWVsZE9wdGlvbnNQcm90bw=="));
descriptor = pbr::FileDescriptor.FromGeneratedCode(descriptorData,
new pbr::FileDescriptor[] { global::Google.Protobuf.DescriptorReflection.Descriptor, global::Bgs.Protocol.RangeReflection.Descriptor, },
new pbr::GeneratedClrTypeInfo(new[] {typeof(global::Bgs.Protocol.LogOption), }, new pb::Extension[] { FieldOptionsExtensions.FieldOptions_, FieldOptionsExtensions.Valid }, new pbr::GeneratedClrTypeInfo[] {
new pbr::GeneratedClrTypeInfo(typeof(global::Bgs.Protocol.BGSFieldOptions), global::Bgs.Protocol.BGSFieldOptions.Parser, new[]{ "Log", "ShardKey", "FanoutKey" }, null, null, null, null),
new pbr::GeneratedClrTypeInfo(typeof(global::Bgs.Protocol.FieldRestriction), global::Bgs.Protocol.FieldRestriction.Parser, new[]{ "Signed", "Unsigned", "Float", "String", "Repeated", "Message", "EntityId" }, new[]{ "Type" }, null, null, null),
new pbr::GeneratedClrTypeInfo(typeof(global::Bgs.Protocol.RepeatedFieldRestriction), global::Bgs.Protocol.RepeatedFieldRestriction.Parser, new[]{ "Size", "Unique", "Signed", "Unsigned", "Float", "String", "EntityId" }, new[]{ "Type" }, null, null, null),
new pbr::GeneratedClrTypeInfo(typeof(global::Bgs.Protocol.BGSFieldOptions), global::Bgs.Protocol.BGSFieldOptions.Parser, new[]{ "Log", "ShardKey", "FanoutKey", "ClientInstanceKey", "RealizedEnum" }, null, null, null, null),
new pbr::GeneratedClrTypeInfo(typeof(global::Bgs.Protocol.FieldRestriction), global::Bgs.Protocol.FieldRestriction.Parser, new[]{ "Signed", "Unsigned", "Float", "String", "Repeated", "Message", "EntityId", "Bytes" }, new[]{ "Type" }, null, null, null),
new pbr::GeneratedClrTypeInfo(typeof(global::Bgs.Protocol.RepeatedFieldRestriction), global::Bgs.Protocol.RepeatedFieldRestriction.Parser, new[]{ "Size", "Unique", "Signed", "Unsigned", "Float", "String", "EntityId", "Bytes" }, new[]{ "Type" }, null, null, null),
new pbr::GeneratedClrTypeInfo(typeof(global::Bgs.Protocol.SignedFieldRestriction), global::Bgs.Protocol.SignedFieldRestriction.Parser, new[]{ "Limits", "Exclude" }, null, null, null, null),
new pbr::GeneratedClrTypeInfo(typeof(global::Bgs.Protocol.UnsignedFieldRestriction), global::Bgs.Protocol.UnsignedFieldRestriction.Parser, new[]{ "Limits", "Exclude" }, null, null, null, null),
new pbr::GeneratedClrTypeInfo(typeof(global::Bgs.Protocol.FloatFieldRestriction), global::Bgs.Protocol.FloatFieldRestriction.Parser, new[]{ "Limits", "Exclude" }, null, null, null, null),
@@ -131,6 +134,8 @@ namespace Bgs.Protocol {
log_ = other.log_;
shardKey_ = other.shardKey_;
fanoutKey_ = other.fanoutKey_;
clientInstanceKey_ = other.clientInstanceKey_;
realizedEnum_ = other.realizedEnum_;
_unknownFields = pb::UnknownFieldSet.Clone(other._unknownFields);
}
@@ -211,6 +216,53 @@ namespace Bgs.Protocol {
_hasBits0 &= ~4;
}
/// <summary>Field number for the "client_instance_key" field.</summary>
public const int ClientInstanceKeyFieldNumber = 4;
private readonly static bool ClientInstanceKeyDefaultValue = false;
private bool clientInstanceKey_;
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
public bool ClientInstanceKey {
get { if ((_hasBits0 & 8) != 0) { return clientInstanceKey_; } else { return ClientInstanceKeyDefaultValue; } }
set {
_hasBits0 |= 8;
clientInstanceKey_ = value;
}
}
/// <summary>Gets whether the "client_instance_key" field is set</summary>
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
public bool HasClientInstanceKey {
get { return (_hasBits0 & 8) != 0; }
}
/// <summary>Clears the value of the "client_instance_key" field</summary>
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
public void ClearClientInstanceKey() {
_hasBits0 &= ~8;
}
/// <summary>Field number for the "realized_enum" field.</summary>
public const int RealizedEnumFieldNumber = 5;
private readonly static string RealizedEnumDefaultValue = "";
private string realizedEnum_;
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
public string RealizedEnum {
get { return realizedEnum_ ?? RealizedEnumDefaultValue; }
set {
realizedEnum_ = pb::ProtoPreconditions.CheckNotNull(value, "value");
}
}
/// <summary>Gets whether the "realized_enum" field is set</summary>
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
public bool HasRealizedEnum {
get { return realizedEnum_ != null; }
}
/// <summary>Clears the value of the "realized_enum" field</summary>
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
public void ClearRealizedEnum() {
realizedEnum_ = null;
}
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
public override bool Equals(object other) {
return Equals(other as BGSFieldOptions);
@@ -227,6 +279,8 @@ namespace Bgs.Protocol {
if (Log != other.Log) return false;
if (ShardKey != other.ShardKey) return false;
if (FanoutKey != other.FanoutKey) return false;
if (ClientInstanceKey != other.ClientInstanceKey) return false;
if (RealizedEnum != other.RealizedEnum) return false;
return Equals(_unknownFields, other._unknownFields);
}
@@ -236,6 +290,8 @@ namespace Bgs.Protocol {
if (HasLog) hash ^= Log.GetHashCode();
if (HasShardKey) hash ^= ShardKey.GetHashCode();
if (HasFanoutKey) hash ^= FanoutKey.GetHashCode();
if (HasClientInstanceKey) hash ^= ClientInstanceKey.GetHashCode();
if (HasRealizedEnum) hash ^= RealizedEnum.GetHashCode();
if (_unknownFields != null) {
hash ^= _unknownFields.GetHashCode();
}
@@ -261,6 +317,14 @@ namespace Bgs.Protocol {
output.WriteRawTag(24);
output.WriteBool(FanoutKey);
}
if (HasClientInstanceKey) {
output.WriteRawTag(32);
output.WriteBool(ClientInstanceKey);
}
if (HasRealizedEnum) {
output.WriteRawTag(42);
output.WriteString(RealizedEnum);
}
if (_unknownFields != null) {
_unknownFields.WriteTo(output);
}
@@ -278,6 +342,12 @@ namespace Bgs.Protocol {
if (HasFanoutKey) {
size += 1 + 1;
}
if (HasClientInstanceKey) {
size += 1 + 1;
}
if (HasRealizedEnum) {
size += 1 + pb::CodedOutputStream.ComputeStringSize(RealizedEnum);
}
if (_unknownFields != null) {
size += _unknownFields.CalculateSize();
}
@@ -298,6 +368,12 @@ namespace Bgs.Protocol {
if (other.HasFanoutKey) {
FanoutKey = other.FanoutKey;
}
if (other.HasClientInstanceKey) {
ClientInstanceKey = other.ClientInstanceKey;
}
if (other.HasRealizedEnum) {
RealizedEnum = other.RealizedEnum;
}
_unknownFields = pb::UnknownFieldSet.MergeFrom(_unknownFields, other._unknownFields);
}
@@ -321,6 +397,14 @@ namespace Bgs.Protocol {
FanoutKey = input.ReadBool();
break;
}
case 32: {
ClientInstanceKey = input.ReadBool();
break;
}
case 42: {
RealizedEnum = input.ReadString();
break;
}
}
}
}
@@ -374,6 +458,9 @@ namespace Bgs.Protocol {
case TypeOneofCase.EntityId:
EntityId = other.EntityId.Clone();
break;
case TypeOneofCase.Bytes:
Bytes = other.Bytes.Clone();
break;
}
_unknownFields = pb::UnknownFieldSet.Clone(other._unknownFields);
@@ -545,6 +632,29 @@ namespace Bgs.Protocol {
}
}
/// <summary>Field number for the "bytes" field.</summary>
public const int BytesFieldNumber = 8;
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
public global::Bgs.Protocol.StringFieldRestriction Bytes {
get { return HasBytes ? (global::Bgs.Protocol.StringFieldRestriction) type_ : null; }
set {
type_ = value;
typeCase_ = value == null ? TypeOneofCase.None : TypeOneofCase.Bytes;
}
}
/// <summary>Gets whether the "bytes" field is set</summary>
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
public bool HasBytes {
get { return typeCase_ == TypeOneofCase.Bytes; }
}
/// <summary> Clears the value of the oneof if it's currently set to "bytes" </summary>
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
public void ClearBytes() {
if (HasBytes) {
ClearType();
}
}
private object type_;
/// <summary>Enum of possible cases for the "type" oneof.</summary>
public enum TypeOneofCase {
@@ -556,6 +666,7 @@ namespace Bgs.Protocol {
Repeated = 5,
Message = 6,
EntityId = 7,
Bytes = 8,
}
private TypeOneofCase typeCase_ = TypeOneofCase.None;
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
@@ -589,6 +700,7 @@ namespace Bgs.Protocol {
if (!object.Equals(Repeated, other.Repeated)) return false;
if (!object.Equals(Message, other.Message)) return false;
if (!object.Equals(EntityId, other.EntityId)) return false;
if (!object.Equals(Bytes, other.Bytes)) return false;
if (TypeCase != other.TypeCase) return false;
return Equals(_unknownFields, other._unknownFields);
}
@@ -603,6 +715,7 @@ namespace Bgs.Protocol {
if (HasRepeated) hash ^= Repeated.GetHashCode();
if (HasMessage) hash ^= Message.GetHashCode();
if (HasEntityId) hash ^= EntityId.GetHashCode();
if (HasBytes) hash ^= Bytes.GetHashCode();
hash ^= (int) typeCase_;
if (_unknownFields != null) {
hash ^= _unknownFields.GetHashCode();
@@ -645,6 +758,10 @@ namespace Bgs.Protocol {
output.WriteRawTag(58);
output.WriteMessage(EntityId);
}
if (HasBytes) {
output.WriteRawTag(66);
output.WriteMessage(Bytes);
}
if (_unknownFields != null) {
_unknownFields.WriteTo(output);
}
@@ -674,6 +791,9 @@ namespace Bgs.Protocol {
if (HasEntityId) {
size += 1 + pb::CodedOutputStream.ComputeMessageSize(EntityId);
}
if (HasBytes) {
size += 1 + pb::CodedOutputStream.ComputeMessageSize(Bytes);
}
if (_unknownFields != null) {
size += _unknownFields.CalculateSize();
}
@@ -728,6 +848,12 @@ namespace Bgs.Protocol {
}
EntityId.MergeFrom(other.EntityId);
break;
case TypeOneofCase.Bytes:
if (Bytes == null) {
Bytes = new global::Bgs.Protocol.StringFieldRestriction();
}
Bytes.MergeFrom(other.Bytes);
break;
}
_unknownFields = pb::UnknownFieldSet.MergeFrom(_unknownFields, other._unknownFields);
@@ -804,6 +930,15 @@ namespace Bgs.Protocol {
EntityId = subBuilder;
break;
}
case 66: {
global::Bgs.Protocol.StringFieldRestriction subBuilder = new global::Bgs.Protocol.StringFieldRestriction();
if (HasBytes) {
subBuilder.MergeFrom(Bytes);
}
input.ReadMessage(subBuilder);
Bytes = subBuilder;
break;
}
}
}
}
@@ -855,6 +990,9 @@ namespace Bgs.Protocol {
case TypeOneofCase.EntityId:
EntityId = other.EntityId.Clone();
break;
case TypeOneofCase.Bytes:
Bytes = other.Bytes.Clone();
break;
}
_unknownFields = pb::UnknownFieldSet.Clone(other._unknownFields);
@@ -1025,6 +1163,29 @@ namespace Bgs.Protocol {
}
}
/// <summary>Field number for the "bytes" field.</summary>
public const int BytesFieldNumber = 8;
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
public global::Bgs.Protocol.StringFieldRestriction Bytes {
get { return HasBytes ? (global::Bgs.Protocol.StringFieldRestriction) type_ : null; }
set {
type_ = value;
typeCase_ = value == null ? TypeOneofCase.None : TypeOneofCase.Bytes;
}
}
/// <summary>Gets whether the "bytes" field is set</summary>
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
public bool HasBytes {
get { return typeCase_ == TypeOneofCase.Bytes; }
}
/// <summary> Clears the value of the oneof if it's currently set to "bytes" </summary>
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
public void ClearBytes() {
if (HasBytes) {
ClearType();
}
}
private object type_;
/// <summary>Enum of possible cases for the "type" oneof.</summary>
public enum TypeOneofCase {
@@ -1034,6 +1195,7 @@ namespace Bgs.Protocol {
Float = 5,
String = 6,
EntityId = 7,
Bytes = 8,
}
private TypeOneofCase typeCase_ = TypeOneofCase.None;
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
@@ -1067,6 +1229,7 @@ namespace Bgs.Protocol {
if (!object.Equals(Float, other.Float)) return false;
if (!object.Equals(String, other.String)) return false;
if (!object.Equals(EntityId, other.EntityId)) return false;
if (!object.Equals(Bytes, other.Bytes)) return false;
if (TypeCase != other.TypeCase) return false;
return Equals(_unknownFields, other._unknownFields);
}
@@ -1081,6 +1244,7 @@ namespace Bgs.Protocol {
if (HasFloat) hash ^= Float.GetHashCode();
if (HasString) hash ^= String.GetHashCode();
if (HasEntityId) hash ^= EntityId.GetHashCode();
if (HasBytes) hash ^= Bytes.GetHashCode();
hash ^= (int) typeCase_;
if (_unknownFields != null) {
hash ^= _unknownFields.GetHashCode();
@@ -1123,6 +1287,10 @@ namespace Bgs.Protocol {
output.WriteRawTag(58);
output.WriteMessage(EntityId);
}
if (HasBytes) {
output.WriteRawTag(66);
output.WriteMessage(Bytes);
}
if (_unknownFields != null) {
_unknownFields.WriteTo(output);
}
@@ -1152,6 +1320,9 @@ namespace Bgs.Protocol {
if (HasEntityId) {
size += 1 + pb::CodedOutputStream.ComputeMessageSize(EntityId);
}
if (HasBytes) {
size += 1 + pb::CodedOutputStream.ComputeMessageSize(Bytes);
}
if (_unknownFields != null) {
size += _unknownFields.CalculateSize();
}
@@ -1203,6 +1374,12 @@ namespace Bgs.Protocol {
}
EntityId.MergeFrom(other.EntityId);
break;
case TypeOneofCase.Bytes:
if (Bytes == null) {
Bytes = new global::Bgs.Protocol.StringFieldRestriction();
}
Bytes.MergeFrom(other.Bytes);
break;
}
_unknownFields = pb::UnknownFieldSet.MergeFrom(_unknownFields, other._unknownFields);
@@ -1272,6 +1449,15 @@ namespace Bgs.Protocol {
EntityId = subBuilder;
break;
}
case 66: {
global::Bgs.Protocol.StringFieldRestriction subBuilder = new global::Bgs.Protocol.StringFieldRestriction();
if (HasBytes) {
subBuilder.MergeFrom(Bytes);
}
input.ReadMessage(subBuilder);
Bytes = subBuilder;
break;
}
}
}
}
@@ -26,16 +26,15 @@ namespace Bgs.Protocol {
string.Concat(
"CjliZ3MvbG93L3BiL2NsaWVudC9nbG9iYWxfZXh0ZW5zaW9ucy9tZXNzYWdl",
"X29wdGlvbnMucHJvdG8SDGJncy5wcm90b2NvbBogZ29vZ2xlL3Byb3RvYnVm",
"L2Rlc2NyaXB0b3IucHJvdG8iZAoRQkdTTWVzc2FnZU9wdGlvbnMSGwoTY3Vz",
"L2Rlc2NyaXB0b3IucHJvdG8iSgoRQkdTTWVzc2FnZU9wdGlvbnMSGwoTY3Vz",
"dG9tX3NlbGVjdF9zaGFyZBgBIAEoCBIYChBjdXN0b21fdmFsaWRhdG9yGAIg",
"ASgIEhgKEGNsaWVudF9pZF9mYW5vdXQYAyABKAg6WwoPbWVzc2FnZV9vcHRp",
"b25zEh8uZ29vZ2xlLnByb3RvYnVmLk1lc3NhZ2VPcHRpb25zGJC/BSABKAsy",
"Hy5iZ3MucHJvdG9jb2wuQkdTTWVzc2FnZU9wdGlvbnNCJAoNYm5ldC5wcm90",
"b2NvbEITTWVzc2FnZU9wdGlvbnNQcm90bw=="));
"ASgIOlsKD21lc3NhZ2Vfb3B0aW9ucxIfLmdvb2dsZS5wcm90b2J1Zi5NZXNz",
"YWdlT3B0aW9ucxiQvwUgASgLMh8uYmdzLnByb3RvY29sLkJHU01lc3NhZ2VP",
"cHRpb25zQiQKDWJuZXQucHJvdG9jb2xCE01lc3NhZ2VPcHRpb25zUHJvdG8="));
descriptor = pbr::FileDescriptor.FromGeneratedCode(descriptorData,
new pbr::FileDescriptor[] { global::Google.Protobuf.DescriptorReflection.Descriptor, },
new pbr::GeneratedClrTypeInfo(null, new pb::Extension[] { MessageOptionsExtensions.MessageOptions_ }, new pbr::GeneratedClrTypeInfo[] {
new pbr::GeneratedClrTypeInfo(typeof(global::Bgs.Protocol.BGSMessageOptions), global::Bgs.Protocol.BGSMessageOptions.Parser, new[]{ "CustomSelectShard", "CustomValidator", "ClientIdFanout" }, null, null, null, null)
new pbr::GeneratedClrTypeInfo(typeof(global::Bgs.Protocol.BGSMessageOptions), global::Bgs.Protocol.BGSMessageOptions.Parser, new[]{ "CustomSelectShard", "CustomValidator" }, null, null, null, null)
}));
}
#endregion
@@ -77,7 +76,6 @@ namespace Bgs.Protocol {
_hasBits0 = other._hasBits0;
customSelectShard_ = other.customSelectShard_;
customValidator_ = other.customValidator_;
clientIdFanout_ = other.clientIdFanout_;
_unknownFields = pb::UnknownFieldSet.Clone(other._unknownFields);
}
@@ -134,30 +132,6 @@ namespace Bgs.Protocol {
_hasBits0 &= ~2;
}
/// <summary>Field number for the "client_id_fanout" field.</summary>
public const int ClientIdFanoutFieldNumber = 3;
private readonly static bool ClientIdFanoutDefaultValue = false;
private bool clientIdFanout_;
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
public bool ClientIdFanout {
get { if ((_hasBits0 & 4) != 0) { return clientIdFanout_; } else { return ClientIdFanoutDefaultValue; } }
set {
_hasBits0 |= 4;
clientIdFanout_ = value;
}
}
/// <summary>Gets whether the "client_id_fanout" field is set</summary>
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
public bool HasClientIdFanout {
get { return (_hasBits0 & 4) != 0; }
}
/// <summary>Clears the value of the "client_id_fanout" field</summary>
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
public void ClearClientIdFanout() {
_hasBits0 &= ~4;
}
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
public override bool Equals(object other) {
return Equals(other as BGSMessageOptions);
@@ -173,7 +147,6 @@ namespace Bgs.Protocol {
}
if (CustomSelectShard != other.CustomSelectShard) return false;
if (CustomValidator != other.CustomValidator) return false;
if (ClientIdFanout != other.ClientIdFanout) return false;
return Equals(_unknownFields, other._unknownFields);
}
@@ -182,7 +155,6 @@ namespace Bgs.Protocol {
int hash = 1;
if (HasCustomSelectShard) hash ^= CustomSelectShard.GetHashCode();
if (HasCustomValidator) hash ^= CustomValidator.GetHashCode();
if (HasClientIdFanout) hash ^= ClientIdFanout.GetHashCode();
if (_unknownFields != null) {
hash ^= _unknownFields.GetHashCode();
}
@@ -204,10 +176,6 @@ namespace Bgs.Protocol {
output.WriteRawTag(16);
output.WriteBool(CustomValidator);
}
if (HasClientIdFanout) {
output.WriteRawTag(24);
output.WriteBool(ClientIdFanout);
}
if (_unknownFields != null) {
_unknownFields.WriteTo(output);
}
@@ -222,9 +190,6 @@ namespace Bgs.Protocol {
if (HasCustomValidator) {
size += 1 + 1;
}
if (HasClientIdFanout) {
size += 1 + 1;
}
if (_unknownFields != null) {
size += _unknownFields.CalculateSize();
}
@@ -242,9 +207,6 @@ namespace Bgs.Protocol {
if (other.HasCustomValidator) {
CustomValidator = other.CustomValidator;
}
if (other.HasClientIdFanout) {
ClientIdFanout = other.ClientIdFanout;
}
_unknownFields = pb::UnknownFieldSet.MergeFrom(_unknownFields, other._unknownFields);
}
@@ -264,10 +226,6 @@ namespace Bgs.Protocol {
CustomValidator = input.ReadBool();
break;
}
case 24: {
ClientIdFanout = input.ReadBool();
break;
}
}
}
}
@@ -26,14 +26,21 @@ namespace Bgs.Protocol {
string.Concat(
"CjhiZ3MvbG93L3BiL2NsaWVudC9nbG9iYWxfZXh0ZW5zaW9ucy9tZXRob2Rf",
"b3B0aW9ucy5wcm90bxIMYmdzLnByb3RvY29sGiBnb29nbGUvcHJvdG9idWYv",
"ZGVzY3JpcHRvci5wcm90byIeChBCR1NNZXRob2RPcHRpb25zEgoKAmlkGAEg",
"ASgNOlgKDm1ldGhvZF9vcHRpb25zEh4uZ29vZ2xlLnByb3RvYnVmLk1ldGhv",
"ZE9wdGlvbnMYkL8FIAEoCzIeLmJncy5wcm90b2NvbC5CR1NNZXRob2RPcHRp",
"b25zQiMKDWJuZXQucHJvdG9jb2xCEk1ldGhvZE9wdGlvbnNQcm90bw=="));
"ZGVzY3JpcHRvci5wcm90bxoxYmdzL2xvdy9wYi9jbGllbnQvZ2xvYmFsX2V4",
"dGVuc2lvbnMvcm91dGluZy5wcm90byKVAgoQQkdTTWV0aG9kT3B0aW9ucxIK",
"CgJpZBgBIAEoDRJqChdjbGllbnRfaWRlbnRpdHlfcm91dGluZxgCIAEoDjIn",
"LmJncy5wcm90b2NvbC5DbGllbnRJZGVudGl0eVJvdXRpbmdUeXBlOiBDTElF",
"TlRfSURFTlRJVFlfUk9VVElOR19ESVNBQkxFRBIVCg1lbmFibGVfZmFub3V0",
"GAMgASgIEiEKGWxlZ2FjeV9mYW5vdXRfcmVwbGFjZW1lbnQYBCABKAkSEwoL",
"Zm9yd2FyZF9rZXkYBSABKAkSEgoKaWRlbXBvdGVudBgGIAEoCBImCh5oYW5k",
"bGVfZGVzdGluYXRpb25fdW5yZWFjaGFibGUYByABKAg6WAoObWV0aG9kX29w",
"dGlvbnMSHi5nb29nbGUucHJvdG9idWYuTWV0aG9kT3B0aW9ucxiQvwUgASgL",
"Mh4uYmdzLnByb3RvY29sLkJHU01ldGhvZE9wdGlvbnNCIwoNYm5ldC5wcm90",
"b2NvbEISTWV0aG9kT3B0aW9uc1Byb3Rv"));
descriptor = pbr::FileDescriptor.FromGeneratedCode(descriptorData,
new pbr::FileDescriptor[] { global::Google.Protobuf.DescriptorReflection.Descriptor, },
new pbr::FileDescriptor[] { global::Google.Protobuf.DescriptorReflection.Descriptor, global::Bgs.Protocol.RoutingReflection.Descriptor, },
new pbr::GeneratedClrTypeInfo(null, new pb::Extension[] { MethodOptionsExtensions.MethodOptions_ }, new pbr::GeneratedClrTypeInfo[] {
new pbr::GeneratedClrTypeInfo(typeof(global::Bgs.Protocol.BGSMethodOptions), global::Bgs.Protocol.BGSMethodOptions.Parser, new[]{ "Id" }, null, null, null, null)
new pbr::GeneratedClrTypeInfo(typeof(global::Bgs.Protocol.BGSMethodOptions), global::Bgs.Protocol.BGSMethodOptions.Parser, new[]{ "Id", "ClientIdentityRouting", "EnableFanout", "LegacyFanoutReplacement", "ForwardKey", "Idempotent", "HandleDestinationUnreachable" }, null, null, null, null)
}));
}
#endregion
@@ -74,6 +81,12 @@ namespace Bgs.Protocol {
public BGSMethodOptions(BGSMethodOptions other) : this() {
_hasBits0 = other._hasBits0;
id_ = other.id_;
clientIdentityRouting_ = other.clientIdentityRouting_;
enableFanout_ = other.enableFanout_;
legacyFanoutReplacement_ = other.legacyFanoutReplacement_;
forwardKey_ = other.forwardKey_;
idempotent_ = other.idempotent_;
handleDestinationUnreachable_ = other.handleDestinationUnreachable_;
_unknownFields = pb::UnknownFieldSet.Clone(other._unknownFields);
}
@@ -106,6 +119,148 @@ namespace Bgs.Protocol {
_hasBits0 &= ~1;
}
/// <summary>Field number for the "client_identity_routing" field.</summary>
public const int ClientIdentityRoutingFieldNumber = 2;
private readonly static global::Bgs.Protocol.ClientIdentityRoutingType ClientIdentityRoutingDefaultValue = global::Bgs.Protocol.ClientIdentityRoutingType.ClientIdentityRoutingDisabled;
private global::Bgs.Protocol.ClientIdentityRoutingType clientIdentityRouting_;
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
public global::Bgs.Protocol.ClientIdentityRoutingType ClientIdentityRouting {
get { if ((_hasBits0 & 2) != 0) { return clientIdentityRouting_; } else { return ClientIdentityRoutingDefaultValue; } }
set {
_hasBits0 |= 2;
clientIdentityRouting_ = value;
}
}
/// <summary>Gets whether the "client_identity_routing" field is set</summary>
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
public bool HasClientIdentityRouting {
get { return (_hasBits0 & 2) != 0; }
}
/// <summary>Clears the value of the "client_identity_routing" field</summary>
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
public void ClearClientIdentityRouting() {
_hasBits0 &= ~2;
}
/// <summary>Field number for the "enable_fanout" field.</summary>
public const int EnableFanoutFieldNumber = 3;
private readonly static bool EnableFanoutDefaultValue = false;
private bool enableFanout_;
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
public bool EnableFanout {
get { if ((_hasBits0 & 4) != 0) { return enableFanout_; } else { return EnableFanoutDefaultValue; } }
set {
_hasBits0 |= 4;
enableFanout_ = value;
}
}
/// <summary>Gets whether the "enable_fanout" field is set</summary>
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
public bool HasEnableFanout {
get { return (_hasBits0 & 4) != 0; }
}
/// <summary>Clears the value of the "enable_fanout" field</summary>
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
public void ClearEnableFanout() {
_hasBits0 &= ~4;
}
/// <summary>Field number for the "legacy_fanout_replacement" field.</summary>
public const int LegacyFanoutReplacementFieldNumber = 4;
private readonly static string LegacyFanoutReplacementDefaultValue = "";
private string legacyFanoutReplacement_;
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
public string LegacyFanoutReplacement {
get { return legacyFanoutReplacement_ ?? LegacyFanoutReplacementDefaultValue; }
set {
legacyFanoutReplacement_ = pb::ProtoPreconditions.CheckNotNull(value, "value");
}
}
/// <summary>Gets whether the "legacy_fanout_replacement" field is set</summary>
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
public bool HasLegacyFanoutReplacement {
get { return legacyFanoutReplacement_ != null; }
}
/// <summary>Clears the value of the "legacy_fanout_replacement" field</summary>
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
public void ClearLegacyFanoutReplacement() {
legacyFanoutReplacement_ = null;
}
/// <summary>Field number for the "forward_key" field.</summary>
public const int ForwardKeyFieldNumber = 5;
private readonly static string ForwardKeyDefaultValue = "";
private string forwardKey_;
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
public string ForwardKey {
get { return forwardKey_ ?? ForwardKeyDefaultValue; }
set {
forwardKey_ = pb::ProtoPreconditions.CheckNotNull(value, "value");
}
}
/// <summary>Gets whether the "forward_key" field is set</summary>
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
public bool HasForwardKey {
get { return forwardKey_ != null; }
}
/// <summary>Clears the value of the "forward_key" field</summary>
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
public void ClearForwardKey() {
forwardKey_ = null;
}
/// <summary>Field number for the "idempotent" field.</summary>
public const int IdempotentFieldNumber = 6;
private readonly static bool IdempotentDefaultValue = false;
private bool idempotent_;
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
public bool Idempotent {
get { if ((_hasBits0 & 8) != 0) { return idempotent_; } else { return IdempotentDefaultValue; } }
set {
_hasBits0 |= 8;
idempotent_ = value;
}
}
/// <summary>Gets whether the "idempotent" field is set</summary>
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
public bool HasIdempotent {
get { return (_hasBits0 & 8) != 0; }
}
/// <summary>Clears the value of the "idempotent" field</summary>
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
public void ClearIdempotent() {
_hasBits0 &= ~8;
}
/// <summary>Field number for the "handle_destination_unreachable" field.</summary>
public const int HandleDestinationUnreachableFieldNumber = 7;
private readonly static bool HandleDestinationUnreachableDefaultValue = false;
private bool handleDestinationUnreachable_;
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
public bool HandleDestinationUnreachable {
get { if ((_hasBits0 & 16) != 0) { return handleDestinationUnreachable_; } else { return HandleDestinationUnreachableDefaultValue; } }
set {
_hasBits0 |= 16;
handleDestinationUnreachable_ = value;
}
}
/// <summary>Gets whether the "handle_destination_unreachable" field is set</summary>
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
public bool HasHandleDestinationUnreachable {
get { return (_hasBits0 & 16) != 0; }
}
/// <summary>Clears the value of the "handle_destination_unreachable" field</summary>
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
public void ClearHandleDestinationUnreachable() {
_hasBits0 &= ~16;
}
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
public override bool Equals(object other) {
return Equals(other as BGSMethodOptions);
@@ -120,6 +275,12 @@ namespace Bgs.Protocol {
return true;
}
if (Id != other.Id) return false;
if (ClientIdentityRouting != other.ClientIdentityRouting) return false;
if (EnableFanout != other.EnableFanout) return false;
if (LegacyFanoutReplacement != other.LegacyFanoutReplacement) return false;
if (ForwardKey != other.ForwardKey) return false;
if (Idempotent != other.Idempotent) return false;
if (HandleDestinationUnreachable != other.HandleDestinationUnreachable) return false;
return Equals(_unknownFields, other._unknownFields);
}
@@ -127,6 +288,12 @@ namespace Bgs.Protocol {
public override int GetHashCode() {
int hash = 1;
if (HasId) hash ^= Id.GetHashCode();
if (HasClientIdentityRouting) hash ^= ClientIdentityRouting.GetHashCode();
if (HasEnableFanout) hash ^= EnableFanout.GetHashCode();
if (HasLegacyFanoutReplacement) hash ^= LegacyFanoutReplacement.GetHashCode();
if (HasForwardKey) hash ^= ForwardKey.GetHashCode();
if (HasIdempotent) hash ^= Idempotent.GetHashCode();
if (HasHandleDestinationUnreachable) hash ^= HandleDestinationUnreachable.GetHashCode();
if (_unknownFields != null) {
hash ^= _unknownFields.GetHashCode();
}
@@ -144,6 +311,30 @@ namespace Bgs.Protocol {
output.WriteRawTag(8);
output.WriteUInt32(Id);
}
if (HasClientIdentityRouting) {
output.WriteRawTag(16);
output.WriteEnum((int) ClientIdentityRouting);
}
if (HasEnableFanout) {
output.WriteRawTag(24);
output.WriteBool(EnableFanout);
}
if (HasLegacyFanoutReplacement) {
output.WriteRawTag(34);
output.WriteString(LegacyFanoutReplacement);
}
if (HasForwardKey) {
output.WriteRawTag(42);
output.WriteString(ForwardKey);
}
if (HasIdempotent) {
output.WriteRawTag(48);
output.WriteBool(Idempotent);
}
if (HasHandleDestinationUnreachable) {
output.WriteRawTag(56);
output.WriteBool(HandleDestinationUnreachable);
}
if (_unknownFields != null) {
_unknownFields.WriteTo(output);
}
@@ -155,6 +346,24 @@ namespace Bgs.Protocol {
if (HasId) {
size += 1 + pb::CodedOutputStream.ComputeUInt32Size(Id);
}
if (HasClientIdentityRouting) {
size += 1 + pb::CodedOutputStream.ComputeEnumSize((int) ClientIdentityRouting);
}
if (HasEnableFanout) {
size += 1 + 1;
}
if (HasLegacyFanoutReplacement) {
size += 1 + pb::CodedOutputStream.ComputeStringSize(LegacyFanoutReplacement);
}
if (HasForwardKey) {
size += 1 + pb::CodedOutputStream.ComputeStringSize(ForwardKey);
}
if (HasIdempotent) {
size += 1 + 1;
}
if (HasHandleDestinationUnreachable) {
size += 1 + 1;
}
if (_unknownFields != null) {
size += _unknownFields.CalculateSize();
}
@@ -169,6 +378,24 @@ namespace Bgs.Protocol {
if (other.HasId) {
Id = other.Id;
}
if (other.HasClientIdentityRouting) {
ClientIdentityRouting = other.ClientIdentityRouting;
}
if (other.HasEnableFanout) {
EnableFanout = other.EnableFanout;
}
if (other.HasLegacyFanoutReplacement) {
LegacyFanoutReplacement = other.LegacyFanoutReplacement;
}
if (other.HasForwardKey) {
ForwardKey = other.ForwardKey;
}
if (other.HasIdempotent) {
Idempotent = other.Idempotent;
}
if (other.HasHandleDestinationUnreachable) {
HandleDestinationUnreachable = other.HandleDestinationUnreachable;
}
_unknownFields = pb::UnknownFieldSet.MergeFrom(_unknownFields, other._unknownFields);
}
@@ -184,6 +411,30 @@ namespace Bgs.Protocol {
Id = input.ReadUInt32();
break;
}
case 16: {
ClientIdentityRouting = (global::Bgs.Protocol.ClientIdentityRoutingType) input.ReadEnum();
break;
}
case 24: {
EnableFanout = input.ReadBool();
break;
}
case 34: {
LegacyFanoutReplacement = input.ReadString();
break;
}
case 42: {
ForwardKey = input.ReadString();
break;
}
case 48: {
Idempotent = input.ReadBool();
break;
}
case 56: {
HandleDestinationUnreachable = input.ReadBool();
break;
}
}
}
}
@@ -0,0 +1,52 @@
// <auto-generated>
// Generated by the protocol buffer compiler. DO NOT EDIT!
// source: bgs/low/pb/client/global_extensions/routing.proto
// </auto-generated>
#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 Bgs.Protocol {
/// <summary>Holder for reflection information generated from bgs/low/pb/client/global_extensions/routing.proto</summary>
public static partial class RoutingReflection {
#region Descriptor
/// <summary>File descriptor for bgs/low/pb/client/global_extensions/routing.proto</summary>
public static pbr::FileDescriptor Descriptor {
get { return descriptor; }
}
private static pbr::FileDescriptor descriptor;
static RoutingReflection() {
byte[] descriptorData = global::System.Convert.FromBase64String(
string.Concat(
"CjFiZ3MvbG93L3BiL2NsaWVudC9nbG9iYWxfZXh0ZW5zaW9ucy9yb3V0aW5n",
"LnByb3RvEgxiZ3MucHJvdG9jb2wqxAEKGUNsaWVudElkZW50aXR5Um91dGlu",
"Z1R5cGUSJAogQ0xJRU5UX0lERU5USVRZX1JPVVRJTkdfRElTQUJMRUQQABIu",
"CipDTElFTlRfSURFTlRJVFlfUk9VVElOR19CQVRUTEVfTkVUX0FDQ09VTlQQ",
"ARIoCiRDTElFTlRfSURFTlRJVFlfUk9VVElOR19HQU1FX0FDQ09VTlQQAhIn",
"CiNDTElFTlRfSURFTlRJVFlfUk9VVElOR19JTlNUQU5DRV9JRBAD"));
descriptor = pbr::FileDescriptor.FromGeneratedCode(descriptorData,
new pbr::FileDescriptor[] { },
new pbr::GeneratedClrTypeInfo(new[] {typeof(global::Bgs.Protocol.ClientIdentityRoutingType), }, null, null));
}
#endregion
}
#region Enums
public enum ClientIdentityRoutingType {
[pbr::OriginalName("CLIENT_IDENTITY_ROUTING_DISABLED")] ClientIdentityRoutingDisabled = 0,
[pbr::OriginalName("CLIENT_IDENTITY_ROUTING_BATTLE_NET_ACCOUNT")] ClientIdentityRoutingBattleNetAccount = 1,
[pbr::OriginalName("CLIENT_IDENTITY_ROUTING_GAME_ACCOUNT")] ClientIdentityRoutingGameAccount = 2,
[pbr::OriginalName("CLIENT_IDENTITY_ROUTING_INSTANCE_ID")] ClientIdentityRoutingInstanceId = 3,
}
#endregion
}
#endregion Designer generated code
@@ -26,20 +26,25 @@ namespace Bgs.Protocol {
string.Concat(
"CjliZ3MvbG93L3BiL2NsaWVudC9nbG9iYWxfZXh0ZW5zaW9ucy9zZXJ2aWNl",
"X29wdGlvbnMucHJvdG8SDGJncy5wcm90b2NvbBogZ29vZ2xlL3Byb3RvYnVm",
"L2Rlc2NyaXB0b3IucHJvdG8iUQoRQkdTU2VydmljZU9wdGlvbnMSFwoPZGVz",
"Y3JpcHRvcl9uYW1lGAEgASgJEg8KB3ZlcnNpb24YBCABKA0SEgoKc2hhcmRf",
"bmFtZRgFIAEoCSJNChFTREtTZXJ2aWNlT3B0aW9ucxIPCgdpbmJvdW5kGAEg",
"ASgIEhAKCG91dGJvdW5kGAIgASgIEhUKDXVzZV9jbGllbnRfaWQYAyABKAg6",
"WwoPc2VydmljZV9vcHRpb25zEh8uZ29vZ2xlLnByb3RvYnVmLlNlcnZpY2VP",
"cHRpb25zGJC/BSABKAsyHy5iZ3MucHJvdG9jb2wuQkdTU2VydmljZU9wdGlv",
"bnM6XwoTc2RrX3NlcnZpY2Vfb3B0aW9ucxIfLmdvb2dsZS5wcm90b2J1Zi5T",
"ZXJ2aWNlT3B0aW9ucxiRvwUgASgLMh8uYmdzLnByb3RvY29sLlNES1NlcnZp",
"Y2VPcHRpb25zQiQKDWJuZXQucHJvdG9jb2xCE1NlcnZpY2VPcHRpb25zUHJv",
"dG8="));
"L2Rlc2NyaXB0b3IucHJvdG8isAIKEUJHU1NlcnZpY2VPcHRpb25zEhcKD2Rl",
"c2NyaXB0b3JfbmFtZRgBIAEoCRIPCgd2ZXJzaW9uGAQgASgNEhIKCnNoYXJk",
"X25hbWUYBSABKAkSHwoXcmVzb2x2ZV9jbGllbnRfaW5zdGFuY2UYBiABKAgS",
"SwoEdHlwZRgHIAEoDjIrLmJncy5wcm90b2NvbC5CR1NTZXJ2aWNlT3B0aW9u",
"cy5TZXJ2aWNlVHlwZToQU0VSVklDRV9UWVBFX1JQQxIQCghhcGlfdHlwZRgI",
"IAEoCSJdCgtTZXJ2aWNlVHlwZRIUChBTRVJWSUNFX1RZUEVfUlBDEAASFgoS",
"U0VSVklDRV9UWVBFX0VWRU5UEAESIAocU0VSVklDRV9UWVBFX0VWRU5UX0JS",
"T0FEQ0FTVBACIk0KEVNES1NlcnZpY2VPcHRpb25zEg8KB2luYm91bmQYASAB",
"KAgSEAoIb3V0Ym91bmQYAiABKAgSFQoNdXNlX2NsaWVudF9pZBgDIAEoCDpb",
"Cg9zZXJ2aWNlX29wdGlvbnMSHy5nb29nbGUucHJvdG9idWYuU2VydmljZU9w",
"dGlvbnMYkL8FIAEoCzIfLmJncy5wcm90b2NvbC5CR1NTZXJ2aWNlT3B0aW9u",
"czpfChNzZGtfc2VydmljZV9vcHRpb25zEh8uZ29vZ2xlLnByb3RvYnVmLlNl",
"cnZpY2VPcHRpb25zGJG/BSABKAsyHy5iZ3MucHJvdG9jb2wuU0RLU2Vydmlj",
"ZU9wdGlvbnNCJAoNYm5ldC5wcm90b2NvbEITU2VydmljZU9wdGlvbnNQcm90",
"bw=="));
descriptor = pbr::FileDescriptor.FromGeneratedCode(descriptorData,
new pbr::FileDescriptor[] { global::Google.Protobuf.DescriptorReflection.Descriptor, },
new pbr::GeneratedClrTypeInfo(null, new pb::Extension[] { ServiceOptionsExtensions.ServiceOptions_, ServiceOptionsExtensions.SdkServiceOptions }, new pbr::GeneratedClrTypeInfo[] {
new pbr::GeneratedClrTypeInfo(typeof(global::Bgs.Protocol.BGSServiceOptions), global::Bgs.Protocol.BGSServiceOptions.Parser, new[]{ "DescriptorName", "Version", "ShardName" }, null, null, null, null),
new pbr::GeneratedClrTypeInfo(typeof(global::Bgs.Protocol.BGSServiceOptions), global::Bgs.Protocol.BGSServiceOptions.Parser, new[]{ "DescriptorName", "Version", "ShardName", "ResolveClientInstance", "Type", "ApiType" }, null, new[]{ typeof(global::Bgs.Protocol.BGSServiceOptions.Types.ServiceType) }, null, null),
new pbr::GeneratedClrTypeInfo(typeof(global::Bgs.Protocol.SDKServiceOptions), global::Bgs.Protocol.SDKServiceOptions.Parser, new[]{ "Inbound", "Outbound", "UseClientId" }, null, null, null, null)
}));
}
@@ -85,6 +90,9 @@ namespace Bgs.Protocol {
descriptorName_ = other.descriptorName_;
version_ = other.version_;
shardName_ = other.shardName_;
resolveClientInstance_ = other.resolveClientInstance_;
type_ = other.type_;
apiType_ = other.apiType_;
_unknownFields = pb::UnknownFieldSet.Clone(other._unknownFields);
}
@@ -163,6 +171,77 @@ namespace Bgs.Protocol {
shardName_ = null;
}
/// <summary>Field number for the "resolve_client_instance" field.</summary>
public const int ResolveClientInstanceFieldNumber = 6;
private readonly static bool ResolveClientInstanceDefaultValue = false;
private bool resolveClientInstance_;
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
public bool ResolveClientInstance {
get { if ((_hasBits0 & 2) != 0) { return resolveClientInstance_; } else { return ResolveClientInstanceDefaultValue; } }
set {
_hasBits0 |= 2;
resolveClientInstance_ = value;
}
}
/// <summary>Gets whether the "resolve_client_instance" field is set</summary>
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
public bool HasResolveClientInstance {
get { return (_hasBits0 & 2) != 0; }
}
/// <summary>Clears the value of the "resolve_client_instance" field</summary>
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
public void ClearResolveClientInstance() {
_hasBits0 &= ~2;
}
/// <summary>Field number for the "type" field.</summary>
public const int TypeFieldNumber = 7;
private readonly static global::Bgs.Protocol.BGSServiceOptions.Types.ServiceType TypeDefaultValue = global::Bgs.Protocol.BGSServiceOptions.Types.ServiceType.Rpc;
private global::Bgs.Protocol.BGSServiceOptions.Types.ServiceType type_;
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
public global::Bgs.Protocol.BGSServiceOptions.Types.ServiceType Type {
get { if ((_hasBits0 & 4) != 0) { return type_; } else { return TypeDefaultValue; } }
set {
_hasBits0 |= 4;
type_ = value;
}
}
/// <summary>Gets whether the "type" field is set</summary>
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
public bool HasType {
get { return (_hasBits0 & 4) != 0; }
}
/// <summary>Clears the value of the "type" field</summary>
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
public void ClearType() {
_hasBits0 &= ~4;
}
/// <summary>Field number for the "api_type" field.</summary>
public const int ApiTypeFieldNumber = 8;
private readonly static string ApiTypeDefaultValue = "";
private string apiType_;
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
public string ApiType {
get { return apiType_ ?? ApiTypeDefaultValue; }
set {
apiType_ = pb::ProtoPreconditions.CheckNotNull(value, "value");
}
}
/// <summary>Gets whether the "api_type" field is set</summary>
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
public bool HasApiType {
get { return apiType_ != null; }
}
/// <summary>Clears the value of the "api_type" field</summary>
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
public void ClearApiType() {
apiType_ = null;
}
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
public override bool Equals(object other) {
return Equals(other as BGSServiceOptions);
@@ -179,6 +258,9 @@ namespace Bgs.Protocol {
if (DescriptorName != other.DescriptorName) return false;
if (Version != other.Version) return false;
if (ShardName != other.ShardName) return false;
if (ResolveClientInstance != other.ResolveClientInstance) return false;
if (Type != other.Type) return false;
if (ApiType != other.ApiType) return false;
return Equals(_unknownFields, other._unknownFields);
}
@@ -188,6 +270,9 @@ namespace Bgs.Protocol {
if (HasDescriptorName) hash ^= DescriptorName.GetHashCode();
if (HasVersion) hash ^= Version.GetHashCode();
if (HasShardName) hash ^= ShardName.GetHashCode();
if (HasResolveClientInstance) hash ^= ResolveClientInstance.GetHashCode();
if (HasType) hash ^= Type.GetHashCode();
if (HasApiType) hash ^= ApiType.GetHashCode();
if (_unknownFields != null) {
hash ^= _unknownFields.GetHashCode();
}
@@ -213,6 +298,18 @@ namespace Bgs.Protocol {
output.WriteRawTag(42);
output.WriteString(ShardName);
}
if (HasResolveClientInstance) {
output.WriteRawTag(48);
output.WriteBool(ResolveClientInstance);
}
if (HasType) {
output.WriteRawTag(56);
output.WriteEnum((int) Type);
}
if (HasApiType) {
output.WriteRawTag(66);
output.WriteString(ApiType);
}
if (_unknownFields != null) {
_unknownFields.WriteTo(output);
}
@@ -230,6 +327,15 @@ namespace Bgs.Protocol {
if (HasShardName) {
size += 1 + pb::CodedOutputStream.ComputeStringSize(ShardName);
}
if (HasResolveClientInstance) {
size += 1 + 1;
}
if (HasType) {
size += 1 + pb::CodedOutputStream.ComputeEnumSize((int) Type);
}
if (HasApiType) {
size += 1 + pb::CodedOutputStream.ComputeStringSize(ApiType);
}
if (_unknownFields != null) {
size += _unknownFields.CalculateSize();
}
@@ -250,6 +356,15 @@ namespace Bgs.Protocol {
if (other.HasShardName) {
ShardName = other.ShardName;
}
if (other.HasResolveClientInstance) {
ResolveClientInstance = other.ResolveClientInstance;
}
if (other.HasType) {
Type = other.Type;
}
if (other.HasApiType) {
ApiType = other.ApiType;
}
_unknownFields = pb::UnknownFieldSet.MergeFrom(_unknownFields, other._unknownFields);
}
@@ -273,10 +388,35 @@ namespace Bgs.Protocol {
ShardName = input.ReadString();
break;
}
case 48: {
ResolveClientInstance = input.ReadBool();
break;
}
case 56: {
Type = (global::Bgs.Protocol.BGSServiceOptions.Types.ServiceType) input.ReadEnum();
break;
}
case 66: {
ApiType = input.ReadString();
break;
}
}
}
}
#region Nested types
/// <summary>Container for nested types declared in the BGSServiceOptions message type.</summary>
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
public static partial class Types {
public enum ServiceType {
[pbr::OriginalName("SERVICE_TYPE_RPC")] Rpc = 0,
[pbr::OriginalName("SERVICE_TYPE_EVENT")] Event = 1,
[pbr::OriginalName("SERVICE_TYPE_EVENT_BROADCAST")] EventBroadcast = 2,
}
}
#endregion
}
public sealed partial class SDKServiceOptions : pb::IMessage<SDKServiceOptions> {