Core/Proto: Updated protobuf messages and services

This commit is contained in:
hondacrx
2023-05-23 07:37:39 -04:00
parent 8c4f2ab12d
commit e76aa05564
45 changed files with 5693 additions and 4305 deletions
@@ -69,7 +69,7 @@ namespace Bgs.Protocol {
"ZS5wcm90b2J1Zi5GaWVsZE9wdGlvbnMYkL8FIAEoCzIdLmJncy5wcm90b2Nv",
"bC5CR1NGaWVsZE9wdGlvbnM6TgoFdmFsaWQSHS5nb29nbGUucHJvdG9idWYu",
"RmllbGRPcHRpb25zGJG/BSABKAsyHi5iZ3MucHJvdG9jb2wuRmllbGRSZXN0",
"cmljdGlvbkIiCg1ibmV0LnByb3RvY29sQhFGaWVsZE9wdGlvbnNQcm90bw=="));
"cmljdGlvbkIhCgxiZ3MucHJvdG9jb2xCEUZpZWxkT3B0aW9uc1Byb3Rv"));
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[] {
@@ -30,7 +30,7 @@ namespace Bgs.Protocol {
"dG9tX3NlbGVjdF9zaGFyZBgBIAEoCBIYChBjdXN0b21fdmFsaWRhdG9yGAIg",
"ASgIOlsKD21lc3NhZ2Vfb3B0aW9ucxIfLmdvb2dsZS5wcm90b2J1Zi5NZXNz",
"YWdlT3B0aW9ucxiQvwUgASgLMh8uYmdzLnByb3RvY29sLkJHU01lc3NhZ2VP",
"cHRpb25zQiQKDWJuZXQucHJvdG9jb2xCE01lc3NhZ2VPcHRpb25zUHJvdG8="));
"cHRpb25zQiMKDGJncy5wcm90b2NvbEITTWVzc2FnZU9wdGlvbnNQcm90bw=="));
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[] {
@@ -27,20 +27,22 @@ namespace Bgs.Protocol {
"CjhiZ3MvbG93L3BiL2NsaWVudC9nbG9iYWxfZXh0ZW5zaW9ucy9tZXRob2Rf",
"b3B0aW9ucy5wcm90bxIMYmdzLnByb3RvY29sGiBnb29nbGUvcHJvdG9idWYv",
"ZGVzY3JpcHRvci5wcm90bxoxYmdzL2xvdy9wYi9jbGllbnQvZ2xvYmFsX2V4",
"dGVuc2lvbnMvcm91dGluZy5wcm90byKVAgoQQkdTTWV0aG9kT3B0aW9ucxIK",
"dGVuc2lvbnMvcm91dGluZy5wcm90byLoAgoQQkdTTWV0aG9kT3B0aW9ucxIK",
"CgJpZBgBIAEoDRJqChdjbGllbnRfaWRlbnRpdHlfcm91dGluZxgCIAEoDjIn",
"LmJncy5wcm90b2NvbC5DbGllbnRJZGVudGl0eVJvdXRpbmdUeXBlOiBDTElF",
"TlRfSURFTlRJVFlfUk9VVElOR19ESVNBQkxFRBIVCg1lbmFibGVfZmFub3V0",
"GAMgASgIEiEKGWxlZ2FjeV9mYW5vdXRfcmVwbGFjZW1lbnQYBCABKAkSEwoL",
"Zm9yd2FyZF9rZXkYBSABKAkSEgoKaWRlbXBvdGVudBgGIAEoCBImCh5oYW5k",
"bGVfZGVzdGluYXRpb25fdW5yZWFjaGFibGUYByABKAg6WAoObWV0aG9kX29w",
"dGlvbnMSHi5nb29nbGUucHJvdG9idWYuTWV0aG9kT3B0aW9ucxiQvwUgASgL",
"Mh4uYmdzLnByb3RvY29sLkJHU01ldGhvZE9wdGlvbnNCIwoNYm5ldC5wcm90",
"b2NvbEISTWV0aG9kT3B0aW9uc1Byb3Rv"));
"bGVfZGVzdGluYXRpb25fdW5yZWFjaGFibGUYByABKAgSHgoWY3VzdG9tX3Jl",
"Z2lvbl9yZXNvbHZlchgIIAEoCRIfChdleHBsaWNpdF9yZWdpb25fcm91dGlu",
"ZxgJIAEoCBIQCghvYnNvbGV0ZRgKIAEoCDpYCg5tZXRob2Rfb3B0aW9ucxIe",
"Lmdvb2dsZS5wcm90b2J1Zi5NZXRob2RPcHRpb25zGJC/BSABKAsyHi5iZ3Mu",
"cHJvdG9jb2wuQkdTTWV0aG9kT3B0aW9uc0IiCgxiZ3MucHJvdG9jb2xCEk1l",
"dGhvZE9wdGlvbnNQcm90bw=="));
descriptor = pbr::FileDescriptor.FromGeneratedCode(descriptorData,
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", "ClientIdentityRouting", "EnableFanout", "LegacyFanoutReplacement", "ForwardKey", "Idempotent", "HandleDestinationUnreachable" }, 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", "CustomRegionResolver", "ExplicitRegionRouting", "Obsolete" }, null, null, null, null)
}));
}
#endregion
@@ -87,6 +89,9 @@ namespace Bgs.Protocol {
forwardKey_ = other.forwardKey_;
idempotent_ = other.idempotent_;
handleDestinationUnreachable_ = other.handleDestinationUnreachable_;
customRegionResolver_ = other.customRegionResolver_;
explicitRegionRouting_ = other.explicitRegionRouting_;
obsolete_ = other.obsolete_;
_unknownFields = pb::UnknownFieldSet.Clone(other._unknownFields);
}
@@ -261,6 +266,77 @@ namespace Bgs.Protocol {
_hasBits0 &= ~16;
}
/// <summary>Field number for the "custom_region_resolver" field.</summary>
public const int CustomRegionResolverFieldNumber = 8;
private readonly static string CustomRegionResolverDefaultValue = "";
private string customRegionResolver_;
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
public string CustomRegionResolver {
get { return customRegionResolver_ ?? CustomRegionResolverDefaultValue; }
set {
customRegionResolver_ = pb::ProtoPreconditions.CheckNotNull(value, "value");
}
}
/// <summary>Gets whether the "custom_region_resolver" field is set</summary>
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
public bool HasCustomRegionResolver {
get { return customRegionResolver_ != null; }
}
/// <summary>Clears the value of the "custom_region_resolver" field</summary>
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
public void ClearCustomRegionResolver() {
customRegionResolver_ = null;
}
/// <summary>Field number for the "explicit_region_routing" field.</summary>
public const int ExplicitRegionRoutingFieldNumber = 9;
private readonly static bool ExplicitRegionRoutingDefaultValue = false;
private bool explicitRegionRouting_;
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
public bool ExplicitRegionRouting {
get { if ((_hasBits0 & 32) != 0) { return explicitRegionRouting_; } else { return ExplicitRegionRoutingDefaultValue; } }
set {
_hasBits0 |= 32;
explicitRegionRouting_ = value;
}
}
/// <summary>Gets whether the "explicit_region_routing" field is set</summary>
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
public bool HasExplicitRegionRouting {
get { return (_hasBits0 & 32) != 0; }
}
/// <summary>Clears the value of the "explicit_region_routing" field</summary>
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
public void ClearExplicitRegionRouting() {
_hasBits0 &= ~32;
}
/// <summary>Field number for the "obsolete" field.</summary>
public const int ObsoleteFieldNumber = 10;
private readonly static bool ObsoleteDefaultValue = false;
private bool obsolete_;
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
public bool Obsolete {
get { if ((_hasBits0 & 64) != 0) { return obsolete_; } else { return ObsoleteDefaultValue; } }
set {
_hasBits0 |= 64;
obsolete_ = value;
}
}
/// <summary>Gets whether the "obsolete" field is set</summary>
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
public bool HasObsolete {
get { return (_hasBits0 & 64) != 0; }
}
/// <summary>Clears the value of the "obsolete" field</summary>
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
public void ClearObsolete() {
_hasBits0 &= ~64;
}
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
public override bool Equals(object other) {
return Equals(other as BGSMethodOptions);
@@ -281,6 +357,9 @@ namespace Bgs.Protocol {
if (ForwardKey != other.ForwardKey) return false;
if (Idempotent != other.Idempotent) return false;
if (HandleDestinationUnreachable != other.HandleDestinationUnreachable) return false;
if (CustomRegionResolver != other.CustomRegionResolver) return false;
if (ExplicitRegionRouting != other.ExplicitRegionRouting) return false;
if (Obsolete != other.Obsolete) return false;
return Equals(_unknownFields, other._unknownFields);
}
@@ -294,6 +373,9 @@ namespace Bgs.Protocol {
if (HasForwardKey) hash ^= ForwardKey.GetHashCode();
if (HasIdempotent) hash ^= Idempotent.GetHashCode();
if (HasHandleDestinationUnreachable) hash ^= HandleDestinationUnreachable.GetHashCode();
if (HasCustomRegionResolver) hash ^= CustomRegionResolver.GetHashCode();
if (HasExplicitRegionRouting) hash ^= ExplicitRegionRouting.GetHashCode();
if (HasObsolete) hash ^= Obsolete.GetHashCode();
if (_unknownFields != null) {
hash ^= _unknownFields.GetHashCode();
}
@@ -335,6 +417,18 @@ namespace Bgs.Protocol {
output.WriteRawTag(56);
output.WriteBool(HandleDestinationUnreachable);
}
if (HasCustomRegionResolver) {
output.WriteRawTag(66);
output.WriteString(CustomRegionResolver);
}
if (HasExplicitRegionRouting) {
output.WriteRawTag(72);
output.WriteBool(ExplicitRegionRouting);
}
if (HasObsolete) {
output.WriteRawTag(80);
output.WriteBool(Obsolete);
}
if (_unknownFields != null) {
_unknownFields.WriteTo(output);
}
@@ -364,6 +458,15 @@ namespace Bgs.Protocol {
if (HasHandleDestinationUnreachable) {
size += 1 + 1;
}
if (HasCustomRegionResolver) {
size += 1 + pb::CodedOutputStream.ComputeStringSize(CustomRegionResolver);
}
if (HasExplicitRegionRouting) {
size += 1 + 1;
}
if (HasObsolete) {
size += 1 + 1;
}
if (_unknownFields != null) {
size += _unknownFields.CalculateSize();
}
@@ -396,6 +499,15 @@ namespace Bgs.Protocol {
if (other.HasHandleDestinationUnreachable) {
HandleDestinationUnreachable = other.HandleDestinationUnreachable;
}
if (other.HasCustomRegionResolver) {
CustomRegionResolver = other.CustomRegionResolver;
}
if (other.HasExplicitRegionRouting) {
ExplicitRegionRouting = other.ExplicitRegionRouting;
}
if (other.HasObsolete) {
Obsolete = other.Obsolete;
}
_unknownFields = pb::UnknownFieldSet.MergeFrom(_unknownFields, other._unknownFields);
}
@@ -435,6 +547,18 @@ namespace Bgs.Protocol {
HandleDestinationUnreachable = input.ReadBool();
break;
}
case 66: {
CustomRegionResolver = input.ReadString();
break;
}
case 72: {
ExplicitRegionRouting = input.ReadBool();
break;
}
case 80: {
Obsolete = input.ReadBool();
break;
}
}
}
}
@@ -26,25 +26,26 @@ namespace Bgs.Protocol {
string.Concat(
"CjliZ3MvbG93L3BiL2NsaWVudC9nbG9iYWxfZXh0ZW5zaW9ucy9zZXJ2aWNl",
"X29wdGlvbnMucHJvdG8SDGJncy5wcm90b2NvbBogZ29vZ2xlL3Byb3RvYnVm",
"L2Rlc2NyaXB0b3IucHJvdG8isAIKEUJHU1NlcnZpY2VPcHRpb25zEhcKD2Rl",
"L2Rlc2NyaXB0b3IucHJvdG8i4AIKEUJHU1NlcnZpY2VPcHRpb25zEhcKD2Rl",
"c2NyaXB0b3JfbmFtZRgBIAEoCRIPCgd2ZXJzaW9uGAQgASgNEhIKCnNoYXJk",
"X25hbWUYBSABKAkSHwoXcmVzb2x2ZV9jbGllbnRfaW5zdGFuY2UYBiABKAgS",
"SwoEdHlwZRgHIAEoDjIrLmJncy5wcm90b2NvbC5CR1NTZXJ2aWNlT3B0aW9u",
"cy5TZXJ2aWNlVHlwZToQU0VSVklDRV9UWVBFX1JQQxIQCghhcGlfdHlwZRgI",
"IAEoCSJdCgtTZXJ2aWNlVHlwZRIUChBTRVJWSUNFX1RZUEVfUlBDEAASFgoS",
"U0VSVklDRV9UWVBFX0VWRU5UEAESIAocU0VSVklDRV9UWVBFX0VWRU5UX0JS",
"T0FEQ0FTVBACIk0KEVNES1NlcnZpY2VPcHRpb25zEg8KB2luYm91bmQYASAB",
"KAgSEAoIb3V0Ym91bmQYAiABKAgSFQoNdXNlX2NsaWVudF9pZBgDIAEoCDpb",
"Cg9zZXJ2aWNlX29wdGlvbnMSHy5nb29nbGUucHJvdG9idWYuU2VydmljZU9w",
"dGlvbnMYkL8FIAEoCzIfLmJncy5wcm90b2NvbC5CR1NTZXJ2aWNlT3B0aW9u",
"czpfChNzZGtfc2VydmljZV9vcHRpb25zEh8uZ29vZ2xlLnByb3RvYnVmLlNl",
"cnZpY2VPcHRpb25zGJG/BSABKAsyHy5iZ3MucHJvdG9jb2wuU0RLU2Vydmlj",
"ZU9wdGlvbnNCJAoNYm5ldC5wcm90b2NvbEITU2VydmljZU9wdGlvbnNQcm90",
"bw=="));
"IAEoCRIRCglpc19nbG9iYWwYCSABKAgiegoLU2VydmljZVR5cGUSFAoQU0VS",
"VklDRV9UWVBFX1JQQxAAEhsKF1NFUlZJQ0VfVFlQRV9SUENfRElSRUNUEAES",
"FgoSU0VSVklDRV9UWVBFX0VWRU5UEAISIAocU0VSVklDRV9UWVBFX0VWRU5U",
"X0JST0FEQ0FTVBADIk0KEVNES1NlcnZpY2VPcHRpb25zEg8KB2luYm91bmQY",
"ASABKAgSEAoIb3V0Ym91bmQYAiABKAgSFQoNdXNlX2NsaWVudF9pZBgDIAEo",
"CDpbCg9zZXJ2aWNlX29wdGlvbnMSHy5nb29nbGUucHJvdG9idWYuU2Vydmlj",
"ZU9wdGlvbnMYkL8FIAEoCzIfLmJncy5wcm90b2NvbC5CR1NTZXJ2aWNlT3B0",
"aW9uczpfChNzZGtfc2VydmljZV9vcHRpb25zEh8uZ29vZ2xlLnByb3RvYnVm",
"LlNlcnZpY2VPcHRpb25zGJG/BSABKAsyHy5iZ3MucHJvdG9jb2wuU0RLU2Vy",
"dmljZU9wdGlvbnNCIwoMYmdzLnByb3RvY29sQhNTZXJ2aWNlT3B0aW9uc1By",
"b3Rv"));
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", "ResolveClientInstance", "Type", "ApiType" }, null, new[]{ typeof(global::Bgs.Protocol.BGSServiceOptions.Types.ServiceType) }, null, null),
new pbr::GeneratedClrTypeInfo(typeof(global::Bgs.Protocol.BGSServiceOptions), global::Bgs.Protocol.BGSServiceOptions.Parser, new[]{ "DescriptorName", "Version", "ShardName", "ResolveClientInstance", "Type", "ApiType", "IsGlobal" }, 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)
}));
}
@@ -93,6 +94,7 @@ namespace Bgs.Protocol {
resolveClientInstance_ = other.resolveClientInstance_;
type_ = other.type_;
apiType_ = other.apiType_;
isGlobal_ = other.isGlobal_;
_unknownFields = pb::UnknownFieldSet.Clone(other._unknownFields);
}
@@ -242,6 +244,30 @@ namespace Bgs.Protocol {
apiType_ = null;
}
/// <summary>Field number for the "is_global" field.</summary>
public const int IsGlobalFieldNumber = 9;
private readonly static bool IsGlobalDefaultValue = false;
private bool isGlobal_;
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
public bool IsGlobal {
get { if ((_hasBits0 & 8) != 0) { return isGlobal_; } else { return IsGlobalDefaultValue; } }
set {
_hasBits0 |= 8;
isGlobal_ = value;
}
}
/// <summary>Gets whether the "is_global" field is set</summary>
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
public bool HasIsGlobal {
get { return (_hasBits0 & 8) != 0; }
}
/// <summary>Clears the value of the "is_global" field</summary>
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
public void ClearIsGlobal() {
_hasBits0 &= ~8;
}
[global::System.Diagnostics.DebuggerNonUserCodeAttribute]
public override bool Equals(object other) {
return Equals(other as BGSServiceOptions);
@@ -261,6 +287,7 @@ namespace Bgs.Protocol {
if (ResolveClientInstance != other.ResolveClientInstance) return false;
if (Type != other.Type) return false;
if (ApiType != other.ApiType) return false;
if (IsGlobal != other.IsGlobal) return false;
return Equals(_unknownFields, other._unknownFields);
}
@@ -273,6 +300,7 @@ namespace Bgs.Protocol {
if (HasResolveClientInstance) hash ^= ResolveClientInstance.GetHashCode();
if (HasType) hash ^= Type.GetHashCode();
if (HasApiType) hash ^= ApiType.GetHashCode();
if (HasIsGlobal) hash ^= IsGlobal.GetHashCode();
if (_unknownFields != null) {
hash ^= _unknownFields.GetHashCode();
}
@@ -310,6 +338,10 @@ namespace Bgs.Protocol {
output.WriteRawTag(66);
output.WriteString(ApiType);
}
if (HasIsGlobal) {
output.WriteRawTag(72);
output.WriteBool(IsGlobal);
}
if (_unknownFields != null) {
_unknownFields.WriteTo(output);
}
@@ -336,6 +368,9 @@ namespace Bgs.Protocol {
if (HasApiType) {
size += 1 + pb::CodedOutputStream.ComputeStringSize(ApiType);
}
if (HasIsGlobal) {
size += 1 + 1;
}
if (_unknownFields != null) {
size += _unknownFields.CalculateSize();
}
@@ -365,6 +400,9 @@ namespace Bgs.Protocol {
if (other.HasApiType) {
ApiType = other.ApiType;
}
if (other.HasIsGlobal) {
IsGlobal = other.IsGlobal;
}
_unknownFields = pb::UnknownFieldSet.MergeFrom(_unknownFields, other._unknownFields);
}
@@ -400,6 +438,10 @@ namespace Bgs.Protocol {
ApiType = input.ReadString();
break;
}
case 72: {
IsGlobal = input.ReadBool();
break;
}
}
}
}
@@ -410,8 +452,9 @@ namespace Bgs.Protocol {
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,
[pbr::OriginalName("SERVICE_TYPE_RPC_DIRECT")] RpcDirect = 1,
[pbr::OriginalName("SERVICE_TYPE_EVENT")] Event = 2,
[pbr::OriginalName("SERVICE_TYPE_EVENT_BROADCAST")] EventBroadcast = 3,
}
}