Updating the autogenerated code from the Pulsar API proto file.
diff --git a/src/DotPulsar/Internal/ConsumerChannel.cs b/src/DotPulsar/Internal/ConsumerChannel.cs
index 2dd2325..3a632e9 100644
--- a/src/DotPulsar/Internal/ConsumerChannel.cs
+++ b/src/DotPulsar/Internal/ConsumerChannel.cs
@@ -173,7 +173,7 @@
private async Task RejectPackage(MessagePackage messagePackage, CancellationToken cancellationToken)
{
- var ack = new CommandAck { Type = CommandAck.AckType.Individual, validation_error = CommandAck.ValidationError.ChecksumMismatch };
+ var ack = new CommandAck { Type = CommandAck.AckType.Individual, ValidationError = CommandAck.ValidationErrorType.ChecksumMismatch };
ack.MessageIds.Add(messagePackage.MessageId);
diff --git a/src/DotPulsar/Internal/ConsumerChannelFactory.cs b/src/DotPulsar/Internal/ConsumerChannelFactory.cs
index f98d9fd..5268264 100644
--- a/src/DotPulsar/Internal/ConsumerChannelFactory.cs
+++ b/src/DotPulsar/Internal/ConsumerChannelFactory.cs
@@ -46,7 +46,7 @@
_subscribe = new CommandSubscribe
{
ConsumerName = options.ConsumerName,
- initialPosition = (CommandSubscribe.InitialPosition) options.InitialPosition,
+ InitialPosition = (CommandSubscribe.InitialPositionType) options.InitialPosition,
PriorityLevel = options.PriorityLevel,
ReadCompacted = options.ReadCompacted,
Subscription = options.SubscriptionName,
diff --git a/src/DotPulsar/Internal/PulsarApi/GeneratedCode.cs b/src/DotPulsar/Internal/PulsarApi/GeneratedCode.cs
index 2e33017..e5ca9aa 100644
--- a/src/DotPulsar/Internal/PulsarApi/GeneratedCode.cs
+++ b/src/DotPulsar/Internal/PulsarApi/GeneratedCode.cs
@@ -13,13 +13,16 @@
*/
#nullable disable
+#region Designer generated code
+#pragma warning disable CS0612, CS0618, CS1591, CS3021, IDE0079, IDE1006, RCS1036, RCS1057, RCS1085, RCS1192
+
namespace DotPulsar.Internal.PulsarApi
{
- // This file was generated by a tool; you should avoid making direct changes.
- // Consider using 'partial classes' to extend these types
- // Input: PulsarApi.proto (Last edit: ba24d73)
-
-#pragma warning disable CS1591, CS0612, CS3021, IDE1006
+ // <auto-generated>
+ // This file was generated by a tool; you should avoid making direct changes.
+ // Consider using 'partial classes' to extend these types
+ // Input: PulsarApi.proto (281163b)
+ // </auto-generated>
[global::ProtoBuf.ProtoContract()]
public partial class Schema : global::ProtoBuf.IExtensible
@@ -59,7 +62,13 @@
Time = 13,
Timestamp = 14,
KeyValue = 15,
+ Instant = 16,
+ LocalDate = 17,
+ LocalTime = 18,
+ LocalDateTime = 19,
+ ProtobufNative = 20,
}
+
}
[global::ProtoBuf.ProtoContract()]
@@ -79,8 +88,8 @@
[global::System.ComponentModel.DefaultValue(-1)]
public int Partition
{
- get { return __pbn__Partition ?? -1; }
- set { __pbn__Partition = value; }
+ get => __pbn__Partition ?? -1;
+ set => __pbn__Partition = value;
}
public bool ShouldSerializePartition() => __pbn__Partition != null;
public void ResetPartition() => __pbn__Partition = null;
@@ -90,12 +99,26 @@
[global::System.ComponentModel.DefaultValue(-1)]
public int BatchIndex
{
- get { return __pbn__BatchIndex ?? -1; }
- set { __pbn__BatchIndex = value; }
+ get => __pbn__BatchIndex ?? -1;
+ set => __pbn__BatchIndex = value;
}
public bool ShouldSerializeBatchIndex() => __pbn__BatchIndex != null;
public void ResetBatchIndex() => __pbn__BatchIndex = null;
private int? __pbn__BatchIndex;
+
+ [global::ProtoBuf.ProtoMember(5, Name = @"ack_set")]
+ public long[] AckSets { get; set; }
+
+ [global::ProtoBuf.ProtoMember(6, Name = @"batch_size")]
+ public int BatchSize
+ {
+ get => __pbn__BatchSize.GetValueOrDefault();
+ set => __pbn__BatchSize = value;
+ }
+ public bool ShouldSerializeBatchSize() => __pbn__BatchSize != null;
+ public void ResetBatchSize() => __pbn__BatchSize = null;
+ private int? __pbn__BatchSize;
+
}
[global::ProtoBuf.ProtoContract()]
@@ -110,6 +133,7 @@
[global::ProtoBuf.ProtoMember(2, Name = @"value", IsRequired = true)]
public string Value { get; set; }
+
}
[global::ProtoBuf.ProtoContract()]
@@ -124,6 +148,22 @@
[global::ProtoBuf.ProtoMember(2, Name = @"value", IsRequired = true)]
public ulong Value { get; set; }
+
+ }
+
+ [global::ProtoBuf.ProtoContract()]
+ public partial class IntRange : global::ProtoBuf.IExtensible
+ {
+ private global::ProtoBuf.IExtension __pbn__extensionData;
+ global::ProtoBuf.IExtension global::ProtoBuf.IExtensible.GetExtensionObject(bool createIfMissing)
+ => global::ProtoBuf.Extensible.GetExtensionObject(ref __pbn__extensionData, createIfMissing);
+
+ [global::ProtoBuf.ProtoMember(1, Name = @"start", IsRequired = true)]
+ public int Start { get; set; }
+
+ [global::ProtoBuf.ProtoMember(2, Name = @"end", IsRequired = true)]
+ public int End { get; set; }
+
}
[global::ProtoBuf.ProtoContract()]
@@ -141,6 +181,7 @@
[global::ProtoBuf.ProtoMember(3, Name = @"metadata")]
public global::System.Collections.Generic.List<KeyValue> Metadatas { get; } = new global::System.Collections.Generic.List<KeyValue>();
+
}
[global::ProtoBuf.ProtoContract()]
@@ -166,8 +207,8 @@
[global::System.ComponentModel.DefaultValue("")]
public string ReplicatedFrom
{
- get { return __pbn__ReplicatedFrom ?? ""; }
- set { __pbn__ReplicatedFrom = value; }
+ get => __pbn__ReplicatedFrom ?? "";
+ set => __pbn__ReplicatedFrom = value;
}
public bool ShouldSerializeReplicatedFrom() => __pbn__ReplicatedFrom != null;
public void ResetReplicatedFrom() => __pbn__ReplicatedFrom = null;
@@ -177,8 +218,8 @@
[global::System.ComponentModel.DefaultValue("")]
public string PartitionKey
{
- get { return __pbn__PartitionKey ?? ""; }
- set { __pbn__PartitionKey = value; }
+ get => __pbn__PartitionKey ?? "";
+ set => __pbn__PartitionKey = value;
}
public bool ShouldSerializePartitionKey() => __pbn__PartitionKey != null;
public void ResetPartitionKey() => __pbn__PartitionKey = null;
@@ -191,8 +232,8 @@
[global::System.ComponentModel.DefaultValue(CompressionType.None)]
public CompressionType Compression
{
- get { return __pbn__Compression ?? CompressionType.None; }
- set { __pbn__Compression = value; }
+ get => __pbn__Compression ?? CompressionType.None;
+ set => __pbn__Compression = value;
}
public bool ShouldSerializeCompression() => __pbn__Compression != null;
public void ResetCompression() => __pbn__Compression = null;
@@ -202,8 +243,8 @@
[global::System.ComponentModel.DefaultValue(0)]
public uint UncompressedSize
{
- get { return __pbn__UncompressedSize ?? 0; }
- set { __pbn__UncompressedSize = value; }
+ get => __pbn__UncompressedSize ?? 0;
+ set => __pbn__UncompressedSize = value;
}
public bool ShouldSerializeUncompressedSize() => __pbn__UncompressedSize != null;
public void ResetUncompressedSize() => __pbn__UncompressedSize = null;
@@ -213,19 +254,19 @@
[global::System.ComponentModel.DefaultValue(1)]
public int NumMessagesInBatch
{
- get { return __pbn__NumMessagesInBatch ?? 1; }
- set { __pbn__NumMessagesInBatch = value; }
+ get => __pbn__NumMessagesInBatch ?? 1;
+ set => __pbn__NumMessagesInBatch = value;
}
public bool ShouldSerializeNumMessagesInBatch() => __pbn__NumMessagesInBatch != null;
public void ResetNumMessagesInBatch() => __pbn__NumMessagesInBatch = null;
private int? __pbn__NumMessagesInBatch;
[global::ProtoBuf.ProtoMember(12, Name = @"event_time")]
- [global::System.ComponentModel.DefaultValue(0)]
+ [global::System.ComponentModel.DefaultValue(typeof(ulong), "0")]
public ulong EventTime
{
- get { return __pbn__EventTime ?? 0; }
- set { __pbn__EventTime = value; }
+ get => __pbn__EventTime ?? 0;
+ set => __pbn__EventTime = value;
}
public bool ShouldSerializeEventTime() => __pbn__EventTime != null;
public void ResetEventTime() => __pbn__EventTime = null;
@@ -238,8 +279,8 @@
[global::System.ComponentModel.DefaultValue("")]
public string EncryptionAlgo
{
- get { return __pbn__EncryptionAlgo ?? ""; }
- set { __pbn__EncryptionAlgo = value; }
+ get => __pbn__EncryptionAlgo ?? "";
+ set => __pbn__EncryptionAlgo = value;
}
public bool ShouldSerializeEncryptionAlgo() => __pbn__EncryptionAlgo != null;
public void ResetEncryptionAlgo() => __pbn__EncryptionAlgo = null;
@@ -248,8 +289,8 @@
[global::ProtoBuf.ProtoMember(15, Name = @"encryption_param")]
public byte[] EncryptionParam
{
- get { return __pbn__EncryptionParam; }
- set { __pbn__EncryptionParam = value; }
+ get => __pbn__EncryptionParam;
+ set => __pbn__EncryptionParam = value;
}
public bool ShouldSerializeEncryptionParam() => __pbn__EncryptionParam != null;
public void ResetEncryptionParam() => __pbn__EncryptionParam = null;
@@ -258,8 +299,8 @@
[global::ProtoBuf.ProtoMember(16, Name = @"schema_version")]
public byte[] SchemaVersion
{
- get { return __pbn__SchemaVersion; }
- set { __pbn__SchemaVersion = value; }
+ get => __pbn__SchemaVersion;
+ set => __pbn__SchemaVersion = value;
}
public bool ShouldSerializeSchemaVersion() => __pbn__SchemaVersion != null;
public void ResetSchemaVersion() => __pbn__SchemaVersion = null;
@@ -269,8 +310,8 @@
[global::System.ComponentModel.DefaultValue(false)]
public bool PartitionKeyB64Encoded
{
- get { return __pbn__PartitionKeyB64Encoded ?? false; }
- set { __pbn__PartitionKeyB64Encoded = value; }
+ get => __pbn__PartitionKeyB64Encoded ?? false;
+ set => __pbn__PartitionKeyB64Encoded = value;
}
public bool ShouldSerializePartitionKeyB64Encoded() => __pbn__PartitionKeyB64Encoded != null;
public void ResetPartitionKeyB64Encoded() => __pbn__PartitionKeyB64Encoded = null;
@@ -279,8 +320,8 @@
[global::ProtoBuf.ProtoMember(18, Name = @"ordering_key")]
public byte[] OrderingKey
{
- get { return __pbn__OrderingKey; }
- set { __pbn__OrderingKey = value; }
+ get => __pbn__OrderingKey;
+ set => __pbn__OrderingKey = value;
}
public bool ShouldSerializeOrderingKey() => __pbn__OrderingKey != null;
public void ResetOrderingKey() => __pbn__OrderingKey = null;
@@ -289,8 +330,8 @@
[global::ProtoBuf.ProtoMember(19, Name = @"deliver_at_time")]
public long DeliverAtTime
{
- get { return __pbn__DeliverAtTime.GetValueOrDefault(); }
- set { __pbn__DeliverAtTime = value; }
+ get => __pbn__DeliverAtTime.GetValueOrDefault();
+ set => __pbn__DeliverAtTime = value;
}
public bool ShouldSerializeDeliverAtTime() => __pbn__DeliverAtTime != null;
public void ResetDeliverAtTime() => __pbn__DeliverAtTime = null;
@@ -299,12 +340,107 @@
[global::ProtoBuf.ProtoMember(20, Name = @"marker_type")]
public int MarkerType
{
- get { return __pbn__MarkerType.GetValueOrDefault(); }
- set { __pbn__MarkerType = value; }
+ get => __pbn__MarkerType.GetValueOrDefault();
+ set => __pbn__MarkerType = value;
}
public bool ShouldSerializeMarkerType() => __pbn__MarkerType != null;
public void ResetMarkerType() => __pbn__MarkerType = null;
private int? __pbn__MarkerType;
+
+ [global::ProtoBuf.ProtoMember(22, Name = @"txnid_least_bits")]
+ public ulong TxnidLeastBits
+ {
+ get => __pbn__TxnidLeastBits.GetValueOrDefault();
+ set => __pbn__TxnidLeastBits = value;
+ }
+ public bool ShouldSerializeTxnidLeastBits() => __pbn__TxnidLeastBits != null;
+ public void ResetTxnidLeastBits() => __pbn__TxnidLeastBits = null;
+ private ulong? __pbn__TxnidLeastBits;
+
+ [global::ProtoBuf.ProtoMember(23, Name = @"txnid_most_bits")]
+ public ulong TxnidMostBits
+ {
+ get => __pbn__TxnidMostBits.GetValueOrDefault();
+ set => __pbn__TxnidMostBits = value;
+ }
+ public bool ShouldSerializeTxnidMostBits() => __pbn__TxnidMostBits != null;
+ public void ResetTxnidMostBits() => __pbn__TxnidMostBits = null;
+ private ulong? __pbn__TxnidMostBits;
+
+ [global::ProtoBuf.ProtoMember(24, Name = @"highest_sequence_id")]
+ [global::System.ComponentModel.DefaultValue(typeof(ulong), "0")]
+ public ulong HighestSequenceId
+ {
+ get => __pbn__HighestSequenceId ?? 0;
+ set => __pbn__HighestSequenceId = value;
+ }
+ public bool ShouldSerializeHighestSequenceId() => __pbn__HighestSequenceId != null;
+ public void ResetHighestSequenceId() => __pbn__HighestSequenceId = null;
+ private ulong? __pbn__HighestSequenceId;
+
+ [global::ProtoBuf.ProtoMember(25, Name = @"null_value")]
+ [global::System.ComponentModel.DefaultValue(false)]
+ public bool NullValue
+ {
+ get => __pbn__NullValue ?? false;
+ set => __pbn__NullValue = value;
+ }
+ public bool ShouldSerializeNullValue() => __pbn__NullValue != null;
+ public void ResetNullValue() => __pbn__NullValue = null;
+ private bool? __pbn__NullValue;
+
+ [global::ProtoBuf.ProtoMember(26, Name = @"uuid")]
+ [global::System.ComponentModel.DefaultValue("")]
+ public string Uuid
+ {
+ get => __pbn__Uuid ?? "";
+ set => __pbn__Uuid = value;
+ }
+ public bool ShouldSerializeUuid() => __pbn__Uuid != null;
+ public void ResetUuid() => __pbn__Uuid = null;
+ private string __pbn__Uuid;
+
+ [global::ProtoBuf.ProtoMember(27, Name = @"num_chunks_from_msg")]
+ public int NumChunksFromMsg
+ {
+ get => __pbn__NumChunksFromMsg.GetValueOrDefault();
+ set => __pbn__NumChunksFromMsg = value;
+ }
+ public bool ShouldSerializeNumChunksFromMsg() => __pbn__NumChunksFromMsg != null;
+ public void ResetNumChunksFromMsg() => __pbn__NumChunksFromMsg = null;
+ private int? __pbn__NumChunksFromMsg;
+
+ [global::ProtoBuf.ProtoMember(28, Name = @"total_chunk_msg_size")]
+ public int TotalChunkMsgSize
+ {
+ get => __pbn__TotalChunkMsgSize.GetValueOrDefault();
+ set => __pbn__TotalChunkMsgSize = value;
+ }
+ public bool ShouldSerializeTotalChunkMsgSize() => __pbn__TotalChunkMsgSize != null;
+ public void ResetTotalChunkMsgSize() => __pbn__TotalChunkMsgSize = null;
+ private int? __pbn__TotalChunkMsgSize;
+
+ [global::ProtoBuf.ProtoMember(29, Name = @"chunk_id")]
+ public int ChunkId
+ {
+ get => __pbn__ChunkId.GetValueOrDefault();
+ set => __pbn__ChunkId = value;
+ }
+ public bool ShouldSerializeChunkId() => __pbn__ChunkId != null;
+ public void ResetChunkId() => __pbn__ChunkId = null;
+ private int? __pbn__ChunkId;
+
+ [global::ProtoBuf.ProtoMember(30, Name = @"null_partition_key")]
+ [global::System.ComponentModel.DefaultValue(false)]
+ public bool NullPartitionKey
+ {
+ get => __pbn__NullPartitionKey ?? false;
+ set => __pbn__NullPartitionKey = value;
+ }
+ public bool ShouldSerializeNullPartitionKey() => __pbn__NullPartitionKey != null;
+ public void ResetNullPartitionKey() => __pbn__NullPartitionKey = null;
+ private bool? __pbn__NullPartitionKey;
+
}
[global::ProtoBuf.ProtoContract()]
@@ -321,8 +457,8 @@
[global::System.ComponentModel.DefaultValue("")]
public string PartitionKey
{
- get { return __pbn__PartitionKey ?? ""; }
- set { __pbn__PartitionKey = value; }
+ get => __pbn__PartitionKey ?? "";
+ set => __pbn__PartitionKey = value;
}
public bool ShouldSerializePartitionKey() => __pbn__PartitionKey != null;
public void ResetPartitionKey() => __pbn__PartitionKey = null;
@@ -335,19 +471,19 @@
[global::System.ComponentModel.DefaultValue(false)]
public bool CompactedOut
{
- get { return __pbn__CompactedOut ?? false; }
- set { __pbn__CompactedOut = value; }
+ get => __pbn__CompactedOut ?? false;
+ set => __pbn__CompactedOut = value;
}
public bool ShouldSerializeCompactedOut() => __pbn__CompactedOut != null;
public void ResetCompactedOut() => __pbn__CompactedOut = null;
private bool? __pbn__CompactedOut;
[global::ProtoBuf.ProtoMember(5, Name = @"event_time")]
- [global::System.ComponentModel.DefaultValue(0)]
+ [global::System.ComponentModel.DefaultValue(typeof(ulong), "0")]
public ulong EventTime
{
- get { return __pbn__EventTime ?? 0; }
- set { __pbn__EventTime = value; }
+ get => __pbn__EventTime ?? 0;
+ set => __pbn__EventTime = value;
}
public bool ShouldSerializeEventTime() => __pbn__EventTime != null;
public void ResetEventTime() => __pbn__EventTime = null;
@@ -357,8 +493,8 @@
[global::System.ComponentModel.DefaultValue(false)]
public bool PartitionKeyB64Encoded
{
- get { return __pbn__PartitionKeyB64Encoded ?? false; }
- set { __pbn__PartitionKeyB64Encoded = value; }
+ get => __pbn__PartitionKeyB64Encoded ?? false;
+ set => __pbn__PartitionKeyB64Encoded = value;
}
public bool ShouldSerializePartitionKeyB64Encoded() => __pbn__PartitionKeyB64Encoded != null;
public void ResetPartitionKeyB64Encoded() => __pbn__PartitionKeyB64Encoded = null;
@@ -367,8 +503,8 @@
[global::ProtoBuf.ProtoMember(7, Name = @"ordering_key")]
public byte[] OrderingKey
{
- get { return __pbn__OrderingKey; }
- set { __pbn__OrderingKey = value; }
+ get => __pbn__OrderingKey;
+ set => __pbn__OrderingKey = value;
}
public bool ShouldSerializeOrderingKey() => __pbn__OrderingKey != null;
public void ResetOrderingKey() => __pbn__OrderingKey = null;
@@ -377,12 +513,35 @@
[global::ProtoBuf.ProtoMember(8, Name = @"sequence_id")]
public ulong SequenceId
{
- get { return __pbn__SequenceId.GetValueOrDefault(); }
- set { __pbn__SequenceId = value; }
+ get => __pbn__SequenceId.GetValueOrDefault();
+ set => __pbn__SequenceId = value;
}
public bool ShouldSerializeSequenceId() => __pbn__SequenceId != null;
public void ResetSequenceId() => __pbn__SequenceId = null;
private ulong? __pbn__SequenceId;
+
+ [global::ProtoBuf.ProtoMember(9, Name = @"null_value")]
+ [global::System.ComponentModel.DefaultValue(false)]
+ public bool NullValue
+ {
+ get => __pbn__NullValue ?? false;
+ set => __pbn__NullValue = value;
+ }
+ public bool ShouldSerializeNullValue() => __pbn__NullValue != null;
+ public void ResetNullValue() => __pbn__NullValue = null;
+ private bool? __pbn__NullValue;
+
+ [global::ProtoBuf.ProtoMember(10, Name = @"null_partition_key")]
+ [global::System.ComponentModel.DefaultValue(false)]
+ public bool NullPartitionKey
+ {
+ get => __pbn__NullPartitionKey ?? false;
+ set => __pbn__NullPartitionKey = value;
+ }
+ public bool ShouldSerializeNullPartitionKey() => __pbn__NullPartitionKey != null;
+ public void ResetNullPartitionKey() => __pbn__NullPartitionKey = null;
+ private bool? __pbn__NullPartitionKey;
+
}
[global::ProtoBuf.ProtoContract()]
@@ -399,8 +558,8 @@
[global::System.ComponentModel.DefaultValue(AuthMethod.AuthMethodNone)]
public AuthMethod AuthMethod
{
- get { return __pbn__AuthMethod ?? AuthMethod.AuthMethodNone; }
- set { __pbn__AuthMethod = value; }
+ get => __pbn__AuthMethod ?? AuthMethod.AuthMethodNone;
+ set => __pbn__AuthMethod = value;
}
public bool ShouldSerializeAuthMethod() => __pbn__AuthMethod != null;
public void ResetAuthMethod() => __pbn__AuthMethod = null;
@@ -410,8 +569,8 @@
[global::System.ComponentModel.DefaultValue("")]
public string AuthMethodName
{
- get { return __pbn__AuthMethodName ?? ""; }
- set { __pbn__AuthMethodName = value; }
+ get => __pbn__AuthMethodName ?? "";
+ set => __pbn__AuthMethodName = value;
}
public bool ShouldSerializeAuthMethodName() => __pbn__AuthMethodName != null;
public void ResetAuthMethodName() => __pbn__AuthMethodName = null;
@@ -420,8 +579,8 @@
[global::ProtoBuf.ProtoMember(3, Name = @"auth_data")]
public byte[] AuthData
{
- get { return __pbn__AuthData; }
- set { __pbn__AuthData = value; }
+ get => __pbn__AuthData;
+ set => __pbn__AuthData = value;
}
public bool ShouldSerializeAuthData() => __pbn__AuthData != null;
public void ResetAuthData() => __pbn__AuthData = null;
@@ -431,8 +590,8 @@
[global::System.ComponentModel.DefaultValue(0)]
public int ProtocolVersion
{
- get { return __pbn__ProtocolVersion ?? 0; }
- set { __pbn__ProtocolVersion = value; }
+ get => __pbn__ProtocolVersion ?? 0;
+ set => __pbn__ProtocolVersion = value;
}
public bool ShouldSerializeProtocolVersion() => __pbn__ProtocolVersion != null;
public void ResetProtocolVersion() => __pbn__ProtocolVersion = null;
@@ -442,8 +601,8 @@
[global::System.ComponentModel.DefaultValue("")]
public string ProxyToBrokerUrl
{
- get { return __pbn__ProxyToBrokerUrl ?? ""; }
- set { __pbn__ProxyToBrokerUrl = value; }
+ get => __pbn__ProxyToBrokerUrl ?? "";
+ set => __pbn__ProxyToBrokerUrl = value;
}
public bool ShouldSerializeProxyToBrokerUrl() => __pbn__ProxyToBrokerUrl != null;
public void ResetProxyToBrokerUrl() => __pbn__ProxyToBrokerUrl = null;
@@ -453,8 +612,8 @@
[global::System.ComponentModel.DefaultValue("")]
public string OriginalPrincipal
{
- get { return __pbn__OriginalPrincipal ?? ""; }
- set { __pbn__OriginalPrincipal = value; }
+ get => __pbn__OriginalPrincipal ?? "";
+ set => __pbn__OriginalPrincipal = value;
}
public bool ShouldSerializeOriginalPrincipal() => __pbn__OriginalPrincipal != null;
public void ResetOriginalPrincipal() => __pbn__OriginalPrincipal = null;
@@ -464,8 +623,8 @@
[global::System.ComponentModel.DefaultValue("")]
public string OriginalAuthData
{
- get { return __pbn__OriginalAuthData ?? ""; }
- set { __pbn__OriginalAuthData = value; }
+ get => __pbn__OriginalAuthData ?? "";
+ set => __pbn__OriginalAuthData = value;
}
public bool ShouldSerializeOriginalAuthData() => __pbn__OriginalAuthData != null;
public void ResetOriginalAuthData() => __pbn__OriginalAuthData = null;
@@ -475,12 +634,36 @@
[global::System.ComponentModel.DefaultValue("")]
public string OriginalAuthMethod
{
- get { return __pbn__OriginalAuthMethod ?? ""; }
- set { __pbn__OriginalAuthMethod = value; }
+ get => __pbn__OriginalAuthMethod ?? "";
+ set => __pbn__OriginalAuthMethod = value;
}
public bool ShouldSerializeOriginalAuthMethod() => __pbn__OriginalAuthMethod != null;
public void ResetOriginalAuthMethod() => __pbn__OriginalAuthMethod = null;
private string __pbn__OriginalAuthMethod;
+
+ [global::ProtoBuf.ProtoMember(10, Name = @"feature_flags")]
+ public FeatureFlags FeatureFlags { get; set; }
+
+ }
+
+ [global::ProtoBuf.ProtoContract()]
+ public partial class FeatureFlags : global::ProtoBuf.IExtensible
+ {
+ private global::ProtoBuf.IExtension __pbn__extensionData;
+ global::ProtoBuf.IExtension global::ProtoBuf.IExtensible.GetExtensionObject(bool createIfMissing)
+ => global::ProtoBuf.Extensible.GetExtensionObject(ref __pbn__extensionData, createIfMissing);
+
+ [global::ProtoBuf.ProtoMember(1, Name = @"supports_auth_refresh")]
+ [global::System.ComponentModel.DefaultValue(false)]
+ public bool SupportsAuthRefresh
+ {
+ get => __pbn__SupportsAuthRefresh ?? false;
+ set => __pbn__SupportsAuthRefresh = value;
+ }
+ public bool ShouldSerializeSupportsAuthRefresh() => __pbn__SupportsAuthRefresh != null;
+ public void ResetSupportsAuthRefresh() => __pbn__SupportsAuthRefresh = null;
+ private bool? __pbn__SupportsAuthRefresh;
+
}
[global::ProtoBuf.ProtoContract()]
@@ -497,8 +680,8 @@
[global::System.ComponentModel.DefaultValue(0)]
public int ProtocolVersion
{
- get { return __pbn__ProtocolVersion ?? 0; }
- set { __pbn__ProtocolVersion = value; }
+ get => __pbn__ProtocolVersion ?? 0;
+ set => __pbn__ProtocolVersion = value;
}
public bool ShouldSerializeProtocolVersion() => __pbn__ProtocolVersion != null;
public void ResetProtocolVersion() => __pbn__ProtocolVersion = null;
@@ -507,12 +690,13 @@
[global::ProtoBuf.ProtoMember(3, Name = @"max_message_size")]
public int MaxMessageSize
{
- get { return __pbn__MaxMessageSize.GetValueOrDefault(); }
- set { __pbn__MaxMessageSize = value; }
+ get => __pbn__MaxMessageSize.GetValueOrDefault();
+ set => __pbn__MaxMessageSize = value;
}
public bool ShouldSerializeMaxMessageSize() => __pbn__MaxMessageSize != null;
public void ResetMaxMessageSize() => __pbn__MaxMessageSize = null;
private int? __pbn__MaxMessageSize;
+
}
[global::ProtoBuf.ProtoContract()]
@@ -526,8 +710,8 @@
[global::System.ComponentModel.DefaultValue("")]
public string ClientVersion
{
- get { return __pbn__ClientVersion ?? ""; }
- set { __pbn__ClientVersion = value; }
+ get => __pbn__ClientVersion ?? "";
+ set => __pbn__ClientVersion = value;
}
public bool ShouldSerializeClientVersion() => __pbn__ClientVersion != null;
public void ResetClientVersion() => __pbn__ClientVersion = null;
@@ -540,12 +724,13 @@
[global::System.ComponentModel.DefaultValue(0)]
public int ProtocolVersion
{
- get { return __pbn__ProtocolVersion ?? 0; }
- set { __pbn__ProtocolVersion = value; }
+ get => __pbn__ProtocolVersion ?? 0;
+ set => __pbn__ProtocolVersion = value;
}
public bool ShouldSerializeProtocolVersion() => __pbn__ProtocolVersion != null;
public void ResetProtocolVersion() => __pbn__ProtocolVersion = null;
private int? __pbn__ProtocolVersion;
+
}
[global::ProtoBuf.ProtoContract()]
@@ -559,8 +744,8 @@
[global::System.ComponentModel.DefaultValue("")]
public string ServerVersion
{
- get { return __pbn__ServerVersion ?? ""; }
- set { __pbn__ServerVersion = value; }
+ get => __pbn__ServerVersion ?? "";
+ set => __pbn__ServerVersion = value;
}
public bool ShouldSerializeServerVersion() => __pbn__ServerVersion != null;
public void ResetServerVersion() => __pbn__ServerVersion = null;
@@ -573,12 +758,13 @@
[global::System.ComponentModel.DefaultValue(0)]
public int ProtocolVersion
{
- get { return __pbn__ProtocolVersion ?? 0; }
- set { __pbn__ProtocolVersion = value; }
+ get => __pbn__ProtocolVersion ?? 0;
+ set => __pbn__ProtocolVersion = value;
}
public bool ShouldSerializeProtocolVersion() => __pbn__ProtocolVersion != null;
public void ResetProtocolVersion() => __pbn__ProtocolVersion = null;
private int? __pbn__ProtocolVersion;
+
}
[global::ProtoBuf.ProtoContract()]
@@ -592,22 +778,49 @@
[global::System.ComponentModel.DefaultValue("")]
public string AuthMethodName
{
- get { return __pbn__AuthMethodName ?? ""; }
- set { __pbn__AuthMethodName = value; }
+ get => __pbn__AuthMethodName ?? "";
+ set => __pbn__AuthMethodName = value;
}
public bool ShouldSerializeAuthMethodName() => __pbn__AuthMethodName != null;
public void ResetAuthMethodName() => __pbn__AuthMethodName = null;
private string __pbn__AuthMethodName;
[global::ProtoBuf.ProtoMember(2)]
- public byte[] auth_data
+ public byte[] Data
{
- get { return __pbn__auth_data; }
- set { __pbn__auth_data = value; }
+ get => __pbn__auth_data;
+ set => __pbn__auth_data = value;
}
public bool ShouldSerializeauth_data() => __pbn__auth_data != null;
public void Resetauth_data() => __pbn__auth_data = null;
private byte[] __pbn__auth_data;
+
+ }
+
+ [global::ProtoBuf.ProtoContract()]
+ public partial class KeySharedMeta : global::ProtoBuf.IExtensible
+ {
+ private global::ProtoBuf.IExtension __pbn__extensionData;
+ global::ProtoBuf.IExtension global::ProtoBuf.IExtensible.GetExtensionObject(bool createIfMissing)
+ => global::ProtoBuf.Extensible.GetExtensionObject(ref __pbn__extensionData, createIfMissing);
+
+ [global::ProtoBuf.ProtoMember(1, IsRequired = true)]
+ public KeySharedMode KeySharedMode { get; set; }
+
+ [global::ProtoBuf.ProtoMember(3)]
+ public global::System.Collections.Generic.List<IntRange> hashRanges { get; } = new global::System.Collections.Generic.List<IntRange>();
+
+ [global::ProtoBuf.ProtoMember(4)]
+ [global::System.ComponentModel.DefaultValue(false)]
+ public bool allowOutOfOrderDelivery
+ {
+ get => __pbn__allowOutOfOrderDelivery ?? false;
+ set => __pbn__allowOutOfOrderDelivery = value;
+ }
+ public bool ShouldSerializeallowOutOfOrderDelivery() => __pbn__allowOutOfOrderDelivery != null;
+ public void ResetallowOutOfOrderDelivery() => __pbn__allowOutOfOrderDelivery = null;
+ private bool? __pbn__allowOutOfOrderDelivery;
+
}
[global::ProtoBuf.ProtoContract()]
@@ -636,8 +849,8 @@
[global::System.ComponentModel.DefaultValue("")]
public string ConsumerName
{
- get { return __pbn__ConsumerName ?? ""; }
- set { __pbn__ConsumerName = value; }
+ get => __pbn__ConsumerName ?? "";
+ set => __pbn__ConsumerName = value;
}
public bool ShouldSerializeConsumerName() => __pbn__ConsumerName != null;
public void ResetConsumerName() => __pbn__ConsumerName = null;
@@ -646,8 +859,8 @@
[global::ProtoBuf.ProtoMember(7, Name = @"priority_level")]
public int PriorityLevel
{
- get { return __pbn__PriorityLevel.GetValueOrDefault(); }
- set { __pbn__PriorityLevel = value; }
+ get => __pbn__PriorityLevel.GetValueOrDefault();
+ set => __pbn__PriorityLevel = value;
}
public bool ShouldSerializePriorityLevel() => __pbn__PriorityLevel != null;
public void ResetPriorityLevel() => __pbn__PriorityLevel = null;
@@ -657,8 +870,8 @@
[global::System.ComponentModel.DefaultValue(true)]
public bool Durable
{
- get { return __pbn__Durable ?? true; }
- set { __pbn__Durable = value; }
+ get => __pbn__Durable ?? true;
+ set => __pbn__Durable = value;
}
public bool ShouldSerializeDurable() => __pbn__Durable != null;
public void ResetDurable() => __pbn__Durable = null;
@@ -673,8 +886,8 @@
[global::ProtoBuf.ProtoMember(11, Name = @"read_compacted")]
public bool ReadCompacted
{
- get { return __pbn__ReadCompacted.GetValueOrDefault(); }
- set { __pbn__ReadCompacted = value; }
+ get => __pbn__ReadCompacted.GetValueOrDefault();
+ set => __pbn__ReadCompacted = value;
}
public bool ShouldSerializeReadCompacted() => __pbn__ReadCompacted != null;
public void ResetReadCompacted() => __pbn__ReadCompacted = null;
@@ -684,26 +897,51 @@
public Schema Schema { get; set; }
[global::ProtoBuf.ProtoMember(13)]
- [global::System.ComponentModel.DefaultValue(InitialPosition.Latest)]
- public InitialPosition initialPosition
+ [global::System.ComponentModel.DefaultValue(InitialPositionType.Latest)]
+ public InitialPositionType InitialPosition
{
- get { return __pbn__initialPosition ?? InitialPosition.Latest; }
- set { __pbn__initialPosition = value; }
+ get => __pbn__initialPosition ?? InitialPositionType.Latest;
+ set => __pbn__initialPosition = value;
}
public bool ShouldSerializeinitialPosition() => __pbn__initialPosition != null;
public void ResetinitialPosition() => __pbn__initialPosition = null;
- private InitialPosition? __pbn__initialPosition;
+ private InitialPositionType? __pbn__initialPosition;
[global::ProtoBuf.ProtoMember(14, Name = @"replicate_subscription_state")]
public bool ReplicateSubscriptionState
{
- get { return __pbn__ReplicateSubscriptionState.GetValueOrDefault(); }
- set { __pbn__ReplicateSubscriptionState = value; }
+ get => __pbn__ReplicateSubscriptionState.GetValueOrDefault();
+ set => __pbn__ReplicateSubscriptionState = value;
}
public bool ShouldSerializeReplicateSubscriptionState() => __pbn__ReplicateSubscriptionState != null;
public void ResetReplicateSubscriptionState() => __pbn__ReplicateSubscriptionState = null;
private bool? __pbn__ReplicateSubscriptionState;
+ [global::ProtoBuf.ProtoMember(15, Name = @"force_topic_creation")]
+ [global::System.ComponentModel.DefaultValue(true)]
+ public bool ForceTopicCreation
+ {
+ get => __pbn__ForceTopicCreation ?? true;
+ set => __pbn__ForceTopicCreation = value;
+ }
+ public bool ShouldSerializeForceTopicCreation() => __pbn__ForceTopicCreation != null;
+ public void ResetForceTopicCreation() => __pbn__ForceTopicCreation = null;
+ private bool? __pbn__ForceTopicCreation;
+
+ [global::ProtoBuf.ProtoMember(16, Name = @"start_message_rollback_duration_sec")]
+ [global::System.ComponentModel.DefaultValue(typeof(ulong), "0")]
+ public ulong StartMessageRollbackDurationSec
+ {
+ get => __pbn__StartMessageRollbackDurationSec ?? 0;
+ set => __pbn__StartMessageRollbackDurationSec = value;
+ }
+ public bool ShouldSerializeStartMessageRollbackDurationSec() => __pbn__StartMessageRollbackDurationSec != null;
+ public void ResetStartMessageRollbackDurationSec() => __pbn__StartMessageRollbackDurationSec = null;
+ private ulong? __pbn__StartMessageRollbackDurationSec;
+
+ [global::ProtoBuf.ProtoMember(17)]
+ public KeySharedMeta KeySharedMeta { get; set; }
+
[global::ProtoBuf.ProtoContract()]
public enum SubType
{
@@ -715,11 +953,12 @@
}
[global::ProtoBuf.ProtoContract()]
- public enum InitialPosition
+ public enum InitialPositionType
{
Latest = 0,
Earliest = 1,
}
+
}
[global::ProtoBuf.ProtoContract()]
@@ -739,8 +978,8 @@
[global::System.ComponentModel.DefaultValue("")]
public string OriginalPrincipal
{
- get { return __pbn__OriginalPrincipal ?? ""; }
- set { __pbn__OriginalPrincipal = value; }
+ get => __pbn__OriginalPrincipal ?? "";
+ set => __pbn__OriginalPrincipal = value;
}
public bool ShouldSerializeOriginalPrincipal() => __pbn__OriginalPrincipal != null;
public void ResetOriginalPrincipal() => __pbn__OriginalPrincipal = null;
@@ -750,8 +989,8 @@
[global::System.ComponentModel.DefaultValue("")]
public string OriginalAuthData
{
- get { return __pbn__OriginalAuthData ?? ""; }
- set { __pbn__OriginalAuthData = value; }
+ get => __pbn__OriginalAuthData ?? "";
+ set => __pbn__OriginalAuthData = value;
}
public bool ShouldSerializeOriginalAuthData() => __pbn__OriginalAuthData != null;
public void ResetOriginalAuthData() => __pbn__OriginalAuthData = null;
@@ -761,12 +1000,13 @@
[global::System.ComponentModel.DefaultValue("")]
public string OriginalAuthMethod
{
- get { return __pbn__OriginalAuthMethod ?? ""; }
- set { __pbn__OriginalAuthMethod = value; }
+ get => __pbn__OriginalAuthMethod ?? "";
+ set => __pbn__OriginalAuthMethod = value;
}
public bool ShouldSerializeOriginalAuthMethod() => __pbn__OriginalAuthMethod != null;
public void ResetOriginalAuthMethod() => __pbn__OriginalAuthMethod = null;
private string __pbn__OriginalAuthMethod;
+
}
[global::ProtoBuf.ProtoContract()]
@@ -779,8 +1019,8 @@
[global::ProtoBuf.ProtoMember(1, Name = @"partitions")]
public uint Partitions
{
- get { return __pbn__Partitions.GetValueOrDefault(); }
- set { __pbn__Partitions = value; }
+ get => __pbn__Partitions.GetValueOrDefault();
+ set => __pbn__Partitions = value;
}
public bool ShouldSerializePartitions() => __pbn__Partitions != null;
public void ResetPartitions() => __pbn__Partitions = null;
@@ -793,8 +1033,8 @@
[global::System.ComponentModel.DefaultValue(LookupType.Success)]
public LookupType Response
{
- get { return __pbn__Response ?? LookupType.Success; }
- set { __pbn__Response = value; }
+ get => __pbn__Response ?? LookupType.Success;
+ set => __pbn__Response = value;
}
public bool ShouldSerializeResponse() => __pbn__Response != null;
public void ResetResponse() => __pbn__Response = null;
@@ -804,8 +1044,8 @@
[global::System.ComponentModel.DefaultValue(ServerError.UnknownError)]
public ServerError Error
{
- get { return __pbn__Error ?? ServerError.UnknownError; }
- set { __pbn__Error = value; }
+ get => __pbn__Error ?? ServerError.UnknownError;
+ set => __pbn__Error = value;
}
public bool ShouldSerializeError() => __pbn__Error != null;
public void ResetError() => __pbn__Error = null;
@@ -815,8 +1055,8 @@
[global::System.ComponentModel.DefaultValue("")]
public string Message
{
- get { return __pbn__Message ?? ""; }
- set { __pbn__Message = value; }
+ get => __pbn__Message ?? "";
+ set => __pbn__Message = value;
}
public bool ShouldSerializeMessage() => __pbn__Message != null;
public void ResetMessage() => __pbn__Message = null;
@@ -828,6 +1068,7 @@
Success = 0,
Failed = 1,
}
+
}
[global::ProtoBuf.ProtoContract()]
@@ -847,8 +1088,8 @@
[global::System.ComponentModel.DefaultValue(false)]
public bool Authoritative
{
- get { return __pbn__Authoritative ?? false; }
- set { __pbn__Authoritative = value; }
+ get => __pbn__Authoritative ?? false;
+ set => __pbn__Authoritative = value;
}
public bool ShouldSerializeAuthoritative() => __pbn__Authoritative != null;
public void ResetAuthoritative() => __pbn__Authoritative = null;
@@ -858,8 +1099,8 @@
[global::System.ComponentModel.DefaultValue("")]
public string OriginalPrincipal
{
- get { return __pbn__OriginalPrincipal ?? ""; }
- set { __pbn__OriginalPrincipal = value; }
+ get => __pbn__OriginalPrincipal ?? "";
+ set => __pbn__OriginalPrincipal = value;
}
public bool ShouldSerializeOriginalPrincipal() => __pbn__OriginalPrincipal != null;
public void ResetOriginalPrincipal() => __pbn__OriginalPrincipal = null;
@@ -869,8 +1110,8 @@
[global::System.ComponentModel.DefaultValue("")]
public string OriginalAuthData
{
- get { return __pbn__OriginalAuthData ?? ""; }
- set { __pbn__OriginalAuthData = value; }
+ get => __pbn__OriginalAuthData ?? "";
+ set => __pbn__OriginalAuthData = value;
}
public bool ShouldSerializeOriginalAuthData() => __pbn__OriginalAuthData != null;
public void ResetOriginalAuthData() => __pbn__OriginalAuthData = null;
@@ -880,12 +1121,24 @@
[global::System.ComponentModel.DefaultValue("")]
public string OriginalAuthMethod
{
- get { return __pbn__OriginalAuthMethod ?? ""; }
- set { __pbn__OriginalAuthMethod = value; }
+ get => __pbn__OriginalAuthMethod ?? "";
+ set => __pbn__OriginalAuthMethod = value;
}
public bool ShouldSerializeOriginalAuthMethod() => __pbn__OriginalAuthMethod != null;
public void ResetOriginalAuthMethod() => __pbn__OriginalAuthMethod = null;
private string __pbn__OriginalAuthMethod;
+
+ [global::ProtoBuf.ProtoMember(7, Name = @"advertised_listener_name")]
+ [global::System.ComponentModel.DefaultValue("")]
+ public string AdvertisedListenerName
+ {
+ get => __pbn__AdvertisedListenerName ?? "";
+ set => __pbn__AdvertisedListenerName = value;
+ }
+ public bool ShouldSerializeAdvertisedListenerName() => __pbn__AdvertisedListenerName != null;
+ public void ResetAdvertisedListenerName() => __pbn__AdvertisedListenerName = null;
+ private string __pbn__AdvertisedListenerName;
+
}
[global::ProtoBuf.ProtoContract()]
@@ -899,8 +1152,8 @@
[global::System.ComponentModel.DefaultValue("")]
public string BrokerServiceUrl
{
- get { return __pbn__brokerServiceUrl ?? ""; }
- set { __pbn__brokerServiceUrl = value; }
+ get => __pbn__brokerServiceUrl ?? "";
+ set => __pbn__brokerServiceUrl = value;
}
public bool ShouldSerializebrokerServiceUrl() => __pbn__brokerServiceUrl != null;
public void ResetbrokerServiceUrl() => __pbn__brokerServiceUrl = null;
@@ -910,8 +1163,8 @@
[global::System.ComponentModel.DefaultValue("")]
public string BrokerServiceUrlTls
{
- get { return __pbn__brokerServiceUrlTls ?? ""; }
- set { __pbn__brokerServiceUrlTls = value; }
+ get => __pbn__brokerServiceUrlTls ?? "";
+ set => __pbn__brokerServiceUrlTls = value;
}
public bool ShouldSerializebrokerServiceUrlTls() => __pbn__brokerServiceUrlTls != null;
public void ResetbrokerServiceUrlTls() => __pbn__brokerServiceUrlTls = null;
@@ -921,8 +1174,8 @@
[global::System.ComponentModel.DefaultValue(LookupType.Redirect)]
public LookupType Response
{
- get { return __pbn__Response ?? LookupType.Redirect; }
- set { __pbn__Response = value; }
+ get => __pbn__Response ?? LookupType.Redirect;
+ set => __pbn__Response = value;
}
public bool ShouldSerializeResponse() => __pbn__Response != null;
public void ResetResponse() => __pbn__Response = null;
@@ -935,8 +1188,8 @@
[global::System.ComponentModel.DefaultValue(false)]
public bool Authoritative
{
- get { return __pbn__Authoritative ?? false; }
- set { __pbn__Authoritative = value; }
+ get => __pbn__Authoritative ?? false;
+ set => __pbn__Authoritative = value;
}
public bool ShouldSerializeAuthoritative() => __pbn__Authoritative != null;
public void ResetAuthoritative() => __pbn__Authoritative = null;
@@ -946,8 +1199,8 @@
[global::System.ComponentModel.DefaultValue(ServerError.UnknownError)]
public ServerError Error
{
- get { return __pbn__Error ?? ServerError.UnknownError; }
- set { __pbn__Error = value; }
+ get => __pbn__Error ?? ServerError.UnknownError;
+ set => __pbn__Error = value;
}
public bool ShouldSerializeError() => __pbn__Error != null;
public void ResetError() => __pbn__Error = null;
@@ -957,8 +1210,8 @@
[global::System.ComponentModel.DefaultValue("")]
public string Message
{
- get { return __pbn__Message ?? ""; }
- set { __pbn__Message = value; }
+ get => __pbn__Message ?? "";
+ set => __pbn__Message = value;
}
public bool ShouldSerializeMessage() => __pbn__Message != null;
public void ResetMessage() => __pbn__Message = null;
@@ -968,8 +1221,8 @@
[global::System.ComponentModel.DefaultValue(false)]
public bool ProxyThroughServiceUrl
{
- get { return __pbn__ProxyThroughServiceUrl ?? false; }
- set { __pbn__ProxyThroughServiceUrl = value; }
+ get => __pbn__ProxyThroughServiceUrl ?? false;
+ set => __pbn__ProxyThroughServiceUrl = value;
}
public bool ShouldSerializeProxyThroughServiceUrl() => __pbn__ProxyThroughServiceUrl != null;
public void ResetProxyThroughServiceUrl() => __pbn__ProxyThroughServiceUrl = null;
@@ -982,6 +1235,7 @@
Connect = 1,
Failed = 2,
}
+
}
[global::ProtoBuf.ProtoContract()]
@@ -1004,8 +1258,8 @@
[global::System.ComponentModel.DefaultValue("")]
public string ProducerName
{
- get { return __pbn__ProducerName ?? ""; }
- set { __pbn__ProducerName = value; }
+ get => __pbn__ProducerName ?? "";
+ set => __pbn__ProducerName = value;
}
public bool ShouldSerializeProducerName() => __pbn__ProducerName != null;
public void ResetProducerName() => __pbn__ProducerName = null;
@@ -1015,8 +1269,8 @@
[global::System.ComponentModel.DefaultValue(false)]
public bool Encrypted
{
- get { return __pbn__Encrypted ?? false; }
- set { __pbn__Encrypted = value; }
+ get => __pbn__Encrypted ?? false;
+ set => __pbn__Encrypted = value;
}
public bool ShouldSerializeEncrypted() => __pbn__Encrypted != null;
public void ResetEncrypted() => __pbn__Encrypted = null;
@@ -1027,6 +1281,29 @@
[global::ProtoBuf.ProtoMember(7, Name = @"schema")]
public Schema Schema { get; set; }
+
+ [global::ProtoBuf.ProtoMember(8, Name = @"epoch")]
+ [global::System.ComponentModel.DefaultValue(typeof(ulong), "0")]
+ public ulong Epoch
+ {
+ get => __pbn__Epoch ?? 0;
+ set => __pbn__Epoch = value;
+ }
+ public bool ShouldSerializeEpoch() => __pbn__Epoch != null;
+ public void ResetEpoch() => __pbn__Epoch = null;
+ private ulong? __pbn__Epoch;
+
+ [global::ProtoBuf.ProtoMember(9, Name = @"user_provided_producer_name")]
+ [global::System.ComponentModel.DefaultValue(true)]
+ public bool UserProvidedProducerName
+ {
+ get => __pbn__UserProvidedProducerName ?? true;
+ set => __pbn__UserProvidedProducerName = value;
+ }
+ public bool ShouldSerializeUserProvidedProducerName() => __pbn__UserProvidedProducerName != null;
+ public void ResetUserProvidedProducerName() => __pbn__UserProvidedProducerName = null;
+ private bool? __pbn__UserProvidedProducerName;
+
}
[global::ProtoBuf.ProtoContract()]
@@ -1046,12 +1323,57 @@
[global::System.ComponentModel.DefaultValue(1)]
public int NumMessages
{
- get { return __pbn__NumMessages ?? 1; }
- set { __pbn__NumMessages = value; }
+ get => __pbn__NumMessages ?? 1;
+ set => __pbn__NumMessages = value;
}
public bool ShouldSerializeNumMessages() => __pbn__NumMessages != null;
public void ResetNumMessages() => __pbn__NumMessages = null;
private int? __pbn__NumMessages;
+
+ [global::ProtoBuf.ProtoMember(4, Name = @"txnid_least_bits")]
+ [global::System.ComponentModel.DefaultValue(typeof(ulong), "0")]
+ public ulong TxnidLeastBits
+ {
+ get => __pbn__TxnidLeastBits ?? 0;
+ set => __pbn__TxnidLeastBits = value;
+ }
+ public bool ShouldSerializeTxnidLeastBits() => __pbn__TxnidLeastBits != null;
+ public void ResetTxnidLeastBits() => __pbn__TxnidLeastBits = null;
+ private ulong? __pbn__TxnidLeastBits;
+
+ [global::ProtoBuf.ProtoMember(5, Name = @"txnid_most_bits")]
+ [global::System.ComponentModel.DefaultValue(typeof(ulong), "0")]
+ public ulong TxnidMostBits
+ {
+ get => __pbn__TxnidMostBits ?? 0;
+ set => __pbn__TxnidMostBits = value;
+ }
+ public bool ShouldSerializeTxnidMostBits() => __pbn__TxnidMostBits != null;
+ public void ResetTxnidMostBits() => __pbn__TxnidMostBits = null;
+ private ulong? __pbn__TxnidMostBits;
+
+ [global::ProtoBuf.ProtoMember(6, Name = @"highest_sequence_id")]
+ [global::System.ComponentModel.DefaultValue(typeof(ulong), "0")]
+ public ulong HighestSequenceId
+ {
+ get => __pbn__HighestSequenceId ?? 0;
+ set => __pbn__HighestSequenceId = value;
+ }
+ public bool ShouldSerializeHighestSequenceId() => __pbn__HighestSequenceId != null;
+ public void ResetHighestSequenceId() => __pbn__HighestSequenceId = null;
+ private ulong? __pbn__HighestSequenceId;
+
+ [global::ProtoBuf.ProtoMember(7, Name = @"is_chunk")]
+ [global::System.ComponentModel.DefaultValue(false)]
+ public bool IsChunk
+ {
+ get => __pbn__IsChunk ?? false;
+ set => __pbn__IsChunk = value;
+ }
+ public bool ShouldSerializeIsChunk() => __pbn__IsChunk != null;
+ public void ResetIsChunk() => __pbn__IsChunk = null;
+ private bool? __pbn__IsChunk;
+
}
[global::ProtoBuf.ProtoContract()]
@@ -1069,6 +1391,18 @@
[global::ProtoBuf.ProtoMember(3, Name = @"message_id")]
public MessageIdData MessageId { get; set; }
+
+ [global::ProtoBuf.ProtoMember(4, Name = @"highest_sequence_id")]
+ [global::System.ComponentModel.DefaultValue(typeof(ulong), "0")]
+ public ulong HighestSequenceId
+ {
+ get => __pbn__HighestSequenceId ?? 0;
+ set => __pbn__HighestSequenceId = value;
+ }
+ public bool ShouldSerializeHighestSequenceId() => __pbn__HighestSequenceId != null;
+ public void ResetHighestSequenceId() => __pbn__HighestSequenceId = null;
+ private ulong? __pbn__HighestSequenceId;
+
}
[global::ProtoBuf.ProtoContract()]
@@ -1089,6 +1423,7 @@
[global::ProtoBuf.ProtoMember(4, Name = @"message", IsRequired = true)]
public string Message { get; set; }
+
}
[global::ProtoBuf.ProtoContract()]
@@ -1108,12 +1443,16 @@
[global::System.ComponentModel.DefaultValue(0)]
public uint RedeliveryCount
{
- get { return __pbn__RedeliveryCount ?? 0; }
- set { __pbn__RedeliveryCount = value; }
+ get => __pbn__RedeliveryCount ?? 0;
+ set => __pbn__RedeliveryCount = value;
}
public bool ShouldSerializeRedeliveryCount() => __pbn__RedeliveryCount != null;
public void ResetRedeliveryCount() => __pbn__RedeliveryCount = null;
private uint? __pbn__RedeliveryCount;
+
+ [global::ProtoBuf.ProtoMember(4, Name = @"ack_set")]
+ public long[] AckSets { get; set; }
+
}
[global::ProtoBuf.ProtoContract()]
@@ -1130,22 +1469,54 @@
public AckType Type { get; set; }
[global::ProtoBuf.ProtoMember(3, Name = @"message_id")]
- public global::System.Collections.Generic.List<MessageIdData> MessageIds { get; } = new global::System.Collections.Generic.List<MessageIdData>(1);
+ public global::System.Collections.Generic.List<MessageIdData> MessageIds { get; } = new global::System.Collections.Generic.List<MessageIdData>();
[global::ProtoBuf.ProtoMember(4)]
- [global::System.ComponentModel.DefaultValue(ValidationError.UncompressedSizeCorruption)]
- public ValidationError validation_error
+ [global::System.ComponentModel.DefaultValue(ValidationErrorType.UncompressedSizeCorruption)]
+ public ValidationErrorType ValidationError
{
- get { return __pbn__validation_error ?? ValidationError.UncompressedSizeCorruption; }
- set { __pbn__validation_error = value; }
+ get => __pbn__validation_error ?? ValidationErrorType.UncompressedSizeCorruption;
+ set => __pbn__validation_error = value;
}
public bool ShouldSerializevalidation_error() => __pbn__validation_error != null;
public void Resetvalidation_error() => __pbn__validation_error = null;
- private ValidationError? __pbn__validation_error;
+ private ValidationErrorType? __pbn__validation_error;
[global::ProtoBuf.ProtoMember(5, Name = @"properties")]
public global::System.Collections.Generic.List<KeyLongValue> Properties { get; } = new global::System.Collections.Generic.List<KeyLongValue>();
+ [global::ProtoBuf.ProtoMember(6, Name = @"txnid_least_bits")]
+ [global::System.ComponentModel.DefaultValue(typeof(ulong), "0")]
+ public ulong TxnidLeastBits
+ {
+ get => __pbn__TxnidLeastBits ?? 0;
+ set => __pbn__TxnidLeastBits = value;
+ }
+ public bool ShouldSerializeTxnidLeastBits() => __pbn__TxnidLeastBits != null;
+ public void ResetTxnidLeastBits() => __pbn__TxnidLeastBits = null;
+ private ulong? __pbn__TxnidLeastBits;
+
+ [global::ProtoBuf.ProtoMember(7, Name = @"txnid_most_bits")]
+ [global::System.ComponentModel.DefaultValue(typeof(ulong), "0")]
+ public ulong TxnidMostBits
+ {
+ get => __pbn__TxnidMostBits ?? 0;
+ set => __pbn__TxnidMostBits = value;
+ }
+ public bool ShouldSerializeTxnidMostBits() => __pbn__TxnidMostBits != null;
+ public void ResetTxnidMostBits() => __pbn__TxnidMostBits = null;
+ private ulong? __pbn__TxnidMostBits;
+
+ [global::ProtoBuf.ProtoMember(8, Name = @"request_id")]
+ public ulong RequestId
+ {
+ get => __pbn__RequestId.GetValueOrDefault();
+ set => __pbn__RequestId = value;
+ }
+ public bool ShouldSerializeRequestId() => __pbn__RequestId != null;
+ public void ResetRequestId() => __pbn__RequestId = null;
+ private ulong? __pbn__RequestId;
+
[global::ProtoBuf.ProtoContract()]
public enum AckType
{
@@ -1154,7 +1525,7 @@
}
[global::ProtoBuf.ProtoContract()]
- public enum ValidationError
+ public enum ValidationErrorType
{
UncompressedSizeCorruption = 0,
DecompressionError = 1,
@@ -1162,6 +1533,73 @@
BatchDeSerializeError = 3,
DecryptionError = 4,
}
+
+ }
+
+ [global::ProtoBuf.ProtoContract()]
+ public partial class CommandAckResponse : global::ProtoBuf.IExtensible
+ {
+ private global::ProtoBuf.IExtension __pbn__extensionData;
+ global::ProtoBuf.IExtension global::ProtoBuf.IExtensible.GetExtensionObject(bool createIfMissing)
+ => global::ProtoBuf.Extensible.GetExtensionObject(ref __pbn__extensionData, createIfMissing);
+
+ [global::ProtoBuf.ProtoMember(1, Name = @"consumer_id", IsRequired = true)]
+ public ulong ConsumerId { get; set; }
+
+ [global::ProtoBuf.ProtoMember(2, Name = @"txnid_least_bits")]
+ [global::System.ComponentModel.DefaultValue(typeof(ulong), "0")]
+ public ulong TxnidLeastBits
+ {
+ get => __pbn__TxnidLeastBits ?? 0;
+ set => __pbn__TxnidLeastBits = value;
+ }
+ public bool ShouldSerializeTxnidLeastBits() => __pbn__TxnidLeastBits != null;
+ public void ResetTxnidLeastBits() => __pbn__TxnidLeastBits = null;
+ private ulong? __pbn__TxnidLeastBits;
+
+ [global::ProtoBuf.ProtoMember(3, Name = @"txnid_most_bits")]
+ [global::System.ComponentModel.DefaultValue(typeof(ulong), "0")]
+ public ulong TxnidMostBits
+ {
+ get => __pbn__TxnidMostBits ?? 0;
+ set => __pbn__TxnidMostBits = value;
+ }
+ public bool ShouldSerializeTxnidMostBits() => __pbn__TxnidMostBits != null;
+ public void ResetTxnidMostBits() => __pbn__TxnidMostBits = null;
+ private ulong? __pbn__TxnidMostBits;
+
+ [global::ProtoBuf.ProtoMember(4, Name = @"error")]
+ [global::System.ComponentModel.DefaultValue(ServerError.UnknownError)]
+ public ServerError Error
+ {
+ get => __pbn__Error ?? ServerError.UnknownError;
+ set => __pbn__Error = value;
+ }
+ public bool ShouldSerializeError() => __pbn__Error != null;
+ public void ResetError() => __pbn__Error = null;
+ private ServerError? __pbn__Error;
+
+ [global::ProtoBuf.ProtoMember(5, Name = @"message")]
+ [global::System.ComponentModel.DefaultValue("")]
+ public string Message
+ {
+ get => __pbn__Message ?? "";
+ set => __pbn__Message = value;
+ }
+ public bool ShouldSerializeMessage() => __pbn__Message != null;
+ public void ResetMessage() => __pbn__Message = null;
+ private string __pbn__Message;
+
+ [global::ProtoBuf.ProtoMember(6, Name = @"request_id")]
+ public ulong RequestId
+ {
+ get => __pbn__RequestId.GetValueOrDefault();
+ set => __pbn__RequestId = value;
+ }
+ public bool ShouldSerializeRequestId() => __pbn__RequestId != null;
+ public void ResetRequestId() => __pbn__RequestId = null;
+ private ulong? __pbn__RequestId;
+
}
[global::ProtoBuf.ProtoContract()]
@@ -1178,12 +1616,13 @@
[global::System.ComponentModel.DefaultValue(false)]
public bool IsActive
{
- get { return __pbn__IsActive ?? false; }
- set { __pbn__IsActive = value; }
+ get => __pbn__IsActive ?? false;
+ set => __pbn__IsActive = value;
}
public bool ShouldSerializeIsActive() => __pbn__IsActive != null;
public void ResetIsActive() => __pbn__IsActive = null;
private bool? __pbn__IsActive;
+
}
[global::ProtoBuf.ProtoContract()]
@@ -1198,6 +1637,7 @@
[global::ProtoBuf.ProtoMember(2, IsRequired = true)]
public uint MessagePermits { get; set; }
+
}
[global::ProtoBuf.ProtoContract()]
@@ -1212,6 +1652,7 @@
[global::ProtoBuf.ProtoMember(2, Name = @"request_id", IsRequired = true)]
public ulong RequestId { get; set; }
+
}
[global::ProtoBuf.ProtoContract()]
@@ -1233,12 +1674,13 @@
[global::ProtoBuf.ProtoMember(4, Name = @"message_publish_time")]
public ulong MessagePublishTime
{
- get { return __pbn__MessagePublishTime.GetValueOrDefault(); }
- set { __pbn__MessagePublishTime = value; }
+ get => __pbn__MessagePublishTime.GetValueOrDefault();
+ set => __pbn__MessagePublishTime = value;
}
public bool ShouldSerializeMessagePublishTime() => __pbn__MessagePublishTime != null;
public void ResetMessagePublishTime() => __pbn__MessagePublishTime = null;
private ulong? __pbn__MessagePublishTime;
+
}
[global::ProtoBuf.ProtoContract()]
@@ -1250,6 +1692,7 @@
[global::ProtoBuf.ProtoMember(1, Name = @"consumer_id", IsRequired = true)]
public ulong ConsumerId { get; set; }
+
}
[global::ProtoBuf.ProtoContract()]
@@ -1264,6 +1707,7 @@
[global::ProtoBuf.ProtoMember(2, Name = @"request_id", IsRequired = true)]
public ulong RequestId { get; set; }
+
}
[global::ProtoBuf.ProtoContract()]
@@ -1278,6 +1722,7 @@
[global::ProtoBuf.ProtoMember(2, Name = @"request_id", IsRequired = true)]
public ulong RequestId { get; set; }
+
}
[global::ProtoBuf.ProtoContract()]
@@ -1292,6 +1737,7 @@
[global::ProtoBuf.ProtoMember(2, Name = @"message_ids")]
public global::System.Collections.Generic.List<MessageIdData> MessageIds { get; } = new global::System.Collections.Generic.List<MessageIdData>();
+
}
[global::ProtoBuf.ProtoContract()]
@@ -1306,6 +1752,7 @@
[global::ProtoBuf.ProtoMember(2, Name = @"schema")]
public Schema Schema { get; set; }
+
}
[global::ProtoBuf.ProtoContract()]
@@ -1325,8 +1772,8 @@
[global::System.ComponentModel.DefaultValue(-1)]
public long LastSequenceId
{
- get { return __pbn__LastSequenceId ?? -1; }
- set { __pbn__LastSequenceId = value; }
+ get => __pbn__LastSequenceId ?? -1;
+ set => __pbn__LastSequenceId = value;
}
public bool ShouldSerializeLastSequenceId() => __pbn__LastSequenceId != null;
public void ResetLastSequenceId() => __pbn__LastSequenceId = null;
@@ -1335,12 +1782,13 @@
[global::ProtoBuf.ProtoMember(4, Name = @"schema_version")]
public byte[] SchemaVersion
{
- get { return __pbn__SchemaVersion; }
- set { __pbn__SchemaVersion = value; }
+ get => __pbn__SchemaVersion;
+ set => __pbn__SchemaVersion = value;
}
public bool ShouldSerializeSchemaVersion() => __pbn__SchemaVersion != null;
public void ResetSchemaVersion() => __pbn__SchemaVersion = null;
private byte[] __pbn__SchemaVersion;
+
}
[global::ProtoBuf.ProtoContract()]
@@ -1358,6 +1806,7 @@
[global::ProtoBuf.ProtoMember(3, Name = @"message", IsRequired = true)]
public string Message { get; set; }
+
}
[global::ProtoBuf.ProtoContract()]
@@ -1366,6 +1815,7 @@
private global::ProtoBuf.IExtension __pbn__extensionData;
global::ProtoBuf.IExtension global::ProtoBuf.IExtensible.GetExtensionObject(bool createIfMissing)
=> global::ProtoBuf.Extensible.GetExtensionObject(ref __pbn__extensionData, createIfMissing);
+
}
[global::ProtoBuf.ProtoContract()]
@@ -1374,6 +1824,7 @@
private global::ProtoBuf.IExtension __pbn__extensionData;
global::ProtoBuf.IExtension global::ProtoBuf.IExtensible.GetExtensionObject(bool createIfMissing)
=> global::ProtoBuf.Extensible.GetExtensionObject(ref __pbn__extensionData, createIfMissing);
+
}
[global::ProtoBuf.ProtoContract()]
@@ -1388,6 +1839,7 @@
[global::ProtoBuf.ProtoMember(4, Name = @"consumer_id", IsRequired = true)]
public ulong ConsumerId { get; set; }
+
}
[global::ProtoBuf.ProtoContract()]
@@ -1404,8 +1856,8 @@
[global::System.ComponentModel.DefaultValue(ServerError.UnknownError)]
public ServerError ErrorCode
{
- get { return __pbn__ErrorCode ?? ServerError.UnknownError; }
- set { __pbn__ErrorCode = value; }
+ get => __pbn__ErrorCode ?? ServerError.UnknownError;
+ set => __pbn__ErrorCode = value;
}
public bool ShouldSerializeErrorCode() => __pbn__ErrorCode != null;
public void ResetErrorCode() => __pbn__ErrorCode = null;
@@ -1415,8 +1867,8 @@
[global::System.ComponentModel.DefaultValue("")]
public string ErrorMessage
{
- get { return __pbn__ErrorMessage ?? ""; }
- set { __pbn__ErrorMessage = value; }
+ get => __pbn__ErrorMessage ?? "";
+ set => __pbn__ErrorMessage = value;
}
public bool ShouldSerializeErrorMessage() => __pbn__ErrorMessage != null;
public void ResetErrorMessage() => __pbn__ErrorMessage = null;
@@ -1425,8 +1877,8 @@
[global::ProtoBuf.ProtoMember(4)]
public double MsgRateOut
{
- get { return __pbn__msgRateOut.GetValueOrDefault(); }
- set { __pbn__msgRateOut = value; }
+ get => __pbn__msgRateOut.GetValueOrDefault();
+ set => __pbn__msgRateOut = value;
}
public bool ShouldSerializemsgRateOut() => __pbn__msgRateOut != null;
public void ResetmsgRateOut() => __pbn__msgRateOut = null;
@@ -1435,8 +1887,8 @@
[global::ProtoBuf.ProtoMember(5)]
public double MsgThroughputOut
{
- get { return __pbn__msgThroughputOut.GetValueOrDefault(); }
- set { __pbn__msgThroughputOut = value; }
+ get => __pbn__msgThroughputOut.GetValueOrDefault();
+ set => __pbn__msgThroughputOut = value;
}
public bool ShouldSerializemsgThroughputOut() => __pbn__msgThroughputOut != null;
public void ResetmsgThroughputOut() => __pbn__msgThroughputOut = null;
@@ -1445,8 +1897,8 @@
[global::ProtoBuf.ProtoMember(6)]
public double MsgRateRedeliver
{
- get { return __pbn__msgRateRedeliver.GetValueOrDefault(); }
- set { __pbn__msgRateRedeliver = value; }
+ get => __pbn__msgRateRedeliver.GetValueOrDefault();
+ set => __pbn__msgRateRedeliver = value;
}
public bool ShouldSerializemsgRateRedeliver() => __pbn__msgRateRedeliver != null;
public void ResetmsgRateRedeliver() => __pbn__msgRateRedeliver = null;
@@ -1456,8 +1908,8 @@
[global::System.ComponentModel.DefaultValue("")]
public string ConsumerName
{
- get { return __pbn__consumerName ?? ""; }
- set { __pbn__consumerName = value; }
+ get => __pbn__consumerName ?? "";
+ set => __pbn__consumerName = value;
}
public bool ShouldSerializeconsumerName() => __pbn__consumerName != null;
public void ResetconsumerName() => __pbn__consumerName = null;
@@ -1466,8 +1918,8 @@
[global::ProtoBuf.ProtoMember(8)]
public ulong AvailablePermits
{
- get { return __pbn__availablePermits.GetValueOrDefault(); }
- set { __pbn__availablePermits = value; }
+ get => __pbn__availablePermits.GetValueOrDefault();
+ set => __pbn__availablePermits = value;
}
public bool ShouldSerializeavailablePermits() => __pbn__availablePermits != null;
public void ResetavailablePermits() => __pbn__availablePermits = null;
@@ -1476,8 +1928,8 @@
[global::ProtoBuf.ProtoMember(9)]
public ulong UnackedMessages
{
- get { return __pbn__unackedMessages.GetValueOrDefault(); }
- set { __pbn__unackedMessages = value; }
+ get => __pbn__unackedMessages.GetValueOrDefault();
+ set => __pbn__unackedMessages = value;
}
public bool ShouldSerializeunackedMessages() => __pbn__unackedMessages != null;
public void ResetunackedMessages() => __pbn__unackedMessages = null;
@@ -1486,8 +1938,8 @@
[global::ProtoBuf.ProtoMember(10)]
public bool BlockedConsumerOnUnackedMsgs
{
- get { return __pbn__blockedConsumerOnUnackedMsgs.GetValueOrDefault(); }
- set { __pbn__blockedConsumerOnUnackedMsgs = value; }
+ get => __pbn__blockedConsumerOnUnackedMsgs.GetValueOrDefault();
+ set => __pbn__blockedConsumerOnUnackedMsgs = value;
}
public bool ShouldSerializeblockedConsumerOnUnackedMsgs() => __pbn__blockedConsumerOnUnackedMsgs != null;
public void ResetblockedConsumerOnUnackedMsgs() => __pbn__blockedConsumerOnUnackedMsgs = null;
@@ -1497,8 +1949,8 @@
[global::System.ComponentModel.DefaultValue("")]
public string Address
{
- get { return __pbn__Address ?? ""; }
- set { __pbn__Address = value; }
+ get => __pbn__Address ?? "";
+ set => __pbn__Address = value;
}
public bool ShouldSerializeAddress() => __pbn__Address != null;
public void ResetAddress() => __pbn__Address = null;
@@ -1508,8 +1960,8 @@
[global::System.ComponentModel.DefaultValue("")]
public string ConnectedSince
{
- get { return __pbn__connectedSince ?? ""; }
- set { __pbn__connectedSince = value; }
+ get => __pbn__connectedSince ?? "";
+ set => __pbn__connectedSince = value;
}
public bool ShouldSerializeconnectedSince() => __pbn__connectedSince != null;
public void ResetconnectedSince() => __pbn__connectedSince = null;
@@ -1519,8 +1971,8 @@
[global::System.ComponentModel.DefaultValue("")]
public string Type
{
- get { return __pbn__Type ?? ""; }
- set { __pbn__Type = value; }
+ get => __pbn__Type ?? "";
+ set => __pbn__Type = value;
}
public bool ShouldSerializeType() => __pbn__Type != null;
public void ResetType() => __pbn__Type = null;
@@ -1529,8 +1981,8 @@
[global::ProtoBuf.ProtoMember(14)]
public double MsgRateExpired
{
- get { return __pbn__msgRateExpired.GetValueOrDefault(); }
- set { __pbn__msgRateExpired = value; }
+ get => __pbn__msgRateExpired.GetValueOrDefault();
+ set => __pbn__msgRateExpired = value;
}
public bool ShouldSerializemsgRateExpired() => __pbn__msgRateExpired != null;
public void ResetmsgRateExpired() => __pbn__msgRateExpired = null;
@@ -1539,12 +1991,13 @@
[global::ProtoBuf.ProtoMember(15)]
public ulong MsgBacklog
{
- get { return __pbn__msgBacklog.GetValueOrDefault(); }
- set { __pbn__msgBacklog = value; }
+ get => __pbn__msgBacklog.GetValueOrDefault();
+ set => __pbn__msgBacklog = value;
}
public bool ShouldSerializemsgBacklog() => __pbn__msgBacklog != null;
public void ResetmsgBacklog() => __pbn__msgBacklog = null;
private ulong? __pbn__msgBacklog;
+
}
[global::ProtoBuf.ProtoContract()]
@@ -1559,6 +2012,7 @@
[global::ProtoBuf.ProtoMember(2, Name = @"request_id", IsRequired = true)]
public ulong RequestId { get; set; }
+
}
[global::ProtoBuf.ProtoContract()]
@@ -1573,6 +2027,7 @@
[global::ProtoBuf.ProtoMember(2, Name = @"request_id", IsRequired = true)]
public ulong RequestId { get; set; }
+
}
[global::ProtoBuf.ProtoContract()]
@@ -1589,18 +2044,18 @@
public string Namespace { get; set; }
[global::ProtoBuf.ProtoMember(3)]
- [global::System.ComponentModel.DefaultValue(Mode.Persistent)]
- public Mode mode
+ [global::System.ComponentModel.DefaultValue(ModeType.Persistent)]
+ public ModeType Mode
{
- get { return __pbn__mode ?? Mode.Persistent; }
- set { __pbn__mode = value; }
+ get => __pbn__mode ?? ModeType.Persistent;
+ set => __pbn__mode = value;
}
public bool ShouldSerializemode() => __pbn__mode != null;
public void Resetmode() => __pbn__mode = null;
- private Mode? __pbn__mode;
+ private ModeType? __pbn__mode;
[global::ProtoBuf.ProtoContract()]
- public enum Mode
+ public enum ModeType
{
[global::ProtoBuf.ProtoEnum(Name = @"PERSISTENT")]
Persistent = 0,
@@ -1609,6 +2064,7 @@
[global::ProtoBuf.ProtoEnum(Name = @"ALL")]
All = 2,
}
+
}
[global::ProtoBuf.ProtoContract()]
@@ -1623,6 +2079,7 @@
[global::ProtoBuf.ProtoMember(2, Name = @"topics")]
public global::System.Collections.Generic.List<string> Topics { get; } = new global::System.Collections.Generic.List<string>();
+
}
[global::ProtoBuf.ProtoContract()]
@@ -1641,12 +2098,13 @@
[global::ProtoBuf.ProtoMember(3, Name = @"schema_version")]
public byte[] SchemaVersion
{
- get { return __pbn__SchemaVersion; }
- set { __pbn__SchemaVersion = value; }
+ get => __pbn__SchemaVersion;
+ set => __pbn__SchemaVersion = value;
}
public bool ShouldSerializeSchemaVersion() => __pbn__SchemaVersion != null;
public void ResetSchemaVersion() => __pbn__SchemaVersion = null;
private byte[] __pbn__SchemaVersion;
+
}
[global::ProtoBuf.ProtoContract()]
@@ -1663,8 +2121,8 @@
[global::System.ComponentModel.DefaultValue(ServerError.UnknownError)]
public ServerError ErrorCode
{
- get { return __pbn__ErrorCode ?? ServerError.UnknownError; }
- set { __pbn__ErrorCode = value; }
+ get => __pbn__ErrorCode ?? ServerError.UnknownError;
+ set => __pbn__ErrorCode = value;
}
public bool ShouldSerializeErrorCode() => __pbn__ErrorCode != null;
public void ResetErrorCode() => __pbn__ErrorCode = null;
@@ -1674,8 +2132,8 @@
[global::System.ComponentModel.DefaultValue("")]
public string ErrorMessage
{
- get { return __pbn__ErrorMessage ?? ""; }
- set { __pbn__ErrorMessage = value; }
+ get => __pbn__ErrorMessage ?? "";
+ set => __pbn__ErrorMessage = value;
}
public bool ShouldSerializeErrorMessage() => __pbn__ErrorMessage != null;
public void ResetErrorMessage() => __pbn__ErrorMessage = null;
@@ -1687,12 +2145,689 @@
[global::ProtoBuf.ProtoMember(5, Name = @"schema_version")]
public byte[] SchemaVersion
{
- get { return __pbn__SchemaVersion; }
- set { __pbn__SchemaVersion = value; }
+ get => __pbn__SchemaVersion;
+ set => __pbn__SchemaVersion = value;
}
public bool ShouldSerializeSchemaVersion() => __pbn__SchemaVersion != null;
public void ResetSchemaVersion() => __pbn__SchemaVersion = null;
private byte[] __pbn__SchemaVersion;
+
+ }
+
+ [global::ProtoBuf.ProtoContract()]
+ public partial class CommandGetOrCreateSchema : global::ProtoBuf.IExtensible
+ {
+ private global::ProtoBuf.IExtension __pbn__extensionData;
+ global::ProtoBuf.IExtension global::ProtoBuf.IExtensible.GetExtensionObject(bool createIfMissing)
+ => global::ProtoBuf.Extensible.GetExtensionObject(ref __pbn__extensionData, createIfMissing);
+
+ [global::ProtoBuf.ProtoMember(1, Name = @"request_id", IsRequired = true)]
+ public ulong RequestId { get; set; }
+
+ [global::ProtoBuf.ProtoMember(2, Name = @"topic", IsRequired = true)]
+ public string Topic { get; set; }
+
+ [global::ProtoBuf.ProtoMember(3, Name = @"schema", IsRequired = true)]
+ public Schema Schema { get; set; }
+
+ }
+
+ [global::ProtoBuf.ProtoContract()]
+ public partial class CommandGetOrCreateSchemaResponse : global::ProtoBuf.IExtensible
+ {
+ private global::ProtoBuf.IExtension __pbn__extensionData;
+ global::ProtoBuf.IExtension global::ProtoBuf.IExtensible.GetExtensionObject(bool createIfMissing)
+ => global::ProtoBuf.Extensible.GetExtensionObject(ref __pbn__extensionData, createIfMissing);
+
+ [global::ProtoBuf.ProtoMember(1, Name = @"request_id", IsRequired = true)]
+ public ulong RequestId { get; set; }
+
+ [global::ProtoBuf.ProtoMember(2, Name = @"error_code")]
+ [global::System.ComponentModel.DefaultValue(ServerError.UnknownError)]
+ public ServerError ErrorCode
+ {
+ get => __pbn__ErrorCode ?? ServerError.UnknownError;
+ set => __pbn__ErrorCode = value;
+ }
+ public bool ShouldSerializeErrorCode() => __pbn__ErrorCode != null;
+ public void ResetErrorCode() => __pbn__ErrorCode = null;
+ private ServerError? __pbn__ErrorCode;
+
+ [global::ProtoBuf.ProtoMember(3, Name = @"error_message")]
+ [global::System.ComponentModel.DefaultValue("")]
+ public string ErrorMessage
+ {
+ get => __pbn__ErrorMessage ?? "";
+ set => __pbn__ErrorMessage = value;
+ }
+ public bool ShouldSerializeErrorMessage() => __pbn__ErrorMessage != null;
+ public void ResetErrorMessage() => __pbn__ErrorMessage = null;
+ private string __pbn__ErrorMessage;
+
+ [global::ProtoBuf.ProtoMember(4, Name = @"schema_version")]
+ public byte[] SchemaVersion
+ {
+ get => __pbn__SchemaVersion;
+ set => __pbn__SchemaVersion = value;
+ }
+ public bool ShouldSerializeSchemaVersion() => __pbn__SchemaVersion != null;
+ public void ResetSchemaVersion() => __pbn__SchemaVersion = null;
+ private byte[] __pbn__SchemaVersion;
+
+ }
+
+ [global::ProtoBuf.ProtoContract()]
+ public partial class CommandNewTxn : global::ProtoBuf.IExtensible
+ {
+ private global::ProtoBuf.IExtension __pbn__extensionData;
+ global::ProtoBuf.IExtension global::ProtoBuf.IExtensible.GetExtensionObject(bool createIfMissing)
+ => global::ProtoBuf.Extensible.GetExtensionObject(ref __pbn__extensionData, createIfMissing);
+
+ [global::ProtoBuf.ProtoMember(1, Name = @"request_id", IsRequired = true)]
+ public ulong RequestId { get; set; }
+
+ [global::ProtoBuf.ProtoMember(2, Name = @"txn_ttl_seconds")]
+ [global::System.ComponentModel.DefaultValue(typeof(ulong), "0")]
+ public ulong TxnTtlSeconds
+ {
+ get => __pbn__TxnTtlSeconds ?? 0;
+ set => __pbn__TxnTtlSeconds = value;
+ }
+ public bool ShouldSerializeTxnTtlSeconds() => __pbn__TxnTtlSeconds != null;
+ public void ResetTxnTtlSeconds() => __pbn__TxnTtlSeconds = null;
+ private ulong? __pbn__TxnTtlSeconds;
+
+ [global::ProtoBuf.ProtoMember(3, Name = @"tc_id")]
+ [global::System.ComponentModel.DefaultValue(typeof(ulong), "0")]
+ public ulong TcId
+ {
+ get => __pbn__TcId ?? 0;
+ set => __pbn__TcId = value;
+ }
+ public bool ShouldSerializeTcId() => __pbn__TcId != null;
+ public void ResetTcId() => __pbn__TcId = null;
+ private ulong? __pbn__TcId;
+
+ }
+
+ [global::ProtoBuf.ProtoContract()]
+ public partial class CommandNewTxnResponse : global::ProtoBuf.IExtensible
+ {
+ private global::ProtoBuf.IExtension __pbn__extensionData;
+ global::ProtoBuf.IExtension global::ProtoBuf.IExtensible.GetExtensionObject(bool createIfMissing)
+ => global::ProtoBuf.Extensible.GetExtensionObject(ref __pbn__extensionData, createIfMissing);
+
+ [global::ProtoBuf.ProtoMember(1, Name = @"request_id", IsRequired = true)]
+ public ulong RequestId { get; set; }
+
+ [global::ProtoBuf.ProtoMember(2, Name = @"txnid_least_bits")]
+ [global::System.ComponentModel.DefaultValue(typeof(ulong), "0")]
+ public ulong TxnidLeastBits
+ {
+ get => __pbn__TxnidLeastBits ?? 0;
+ set => __pbn__TxnidLeastBits = value;
+ }
+ public bool ShouldSerializeTxnidLeastBits() => __pbn__TxnidLeastBits != null;
+ public void ResetTxnidLeastBits() => __pbn__TxnidLeastBits = null;
+ private ulong? __pbn__TxnidLeastBits;
+
+ [global::ProtoBuf.ProtoMember(3, Name = @"txnid_most_bits")]
+ [global::System.ComponentModel.DefaultValue(typeof(ulong), "0")]
+ public ulong TxnidMostBits
+ {
+ get => __pbn__TxnidMostBits ?? 0;
+ set => __pbn__TxnidMostBits = value;
+ }
+ public bool ShouldSerializeTxnidMostBits() => __pbn__TxnidMostBits != null;
+ public void ResetTxnidMostBits() => __pbn__TxnidMostBits = null;
+ private ulong? __pbn__TxnidMostBits;
+
+ [global::ProtoBuf.ProtoMember(4, Name = @"error")]
+ [global::System.ComponentModel.DefaultValue(ServerError.UnknownError)]
+ public ServerError Error
+ {
+ get => __pbn__Error ?? ServerError.UnknownError;
+ set => __pbn__Error = value;
+ }
+ public bool ShouldSerializeError() => __pbn__Error != null;
+ public void ResetError() => __pbn__Error = null;
+ private ServerError? __pbn__Error;
+
+ [global::ProtoBuf.ProtoMember(5, Name = @"message")]
+ [global::System.ComponentModel.DefaultValue("")]
+ public string Message
+ {
+ get => __pbn__Message ?? "";
+ set => __pbn__Message = value;
+ }
+ public bool ShouldSerializeMessage() => __pbn__Message != null;
+ public void ResetMessage() => __pbn__Message = null;
+ private string __pbn__Message;
+
+ }
+
+ [global::ProtoBuf.ProtoContract()]
+ public partial class CommandAddPartitionToTxn : global::ProtoBuf.IExtensible
+ {
+ private global::ProtoBuf.IExtension __pbn__extensionData;
+ global::ProtoBuf.IExtension global::ProtoBuf.IExtensible.GetExtensionObject(bool createIfMissing)
+ => global::ProtoBuf.Extensible.GetExtensionObject(ref __pbn__extensionData, createIfMissing);
+
+ [global::ProtoBuf.ProtoMember(1, Name = @"request_id", IsRequired = true)]
+ public ulong RequestId { get; set; }
+
+ [global::ProtoBuf.ProtoMember(2, Name = @"txnid_least_bits")]
+ [global::System.ComponentModel.DefaultValue(typeof(ulong), "0")]
+ public ulong TxnidLeastBits
+ {
+ get => __pbn__TxnidLeastBits ?? 0;
+ set => __pbn__TxnidLeastBits = value;
+ }
+ public bool ShouldSerializeTxnidLeastBits() => __pbn__TxnidLeastBits != null;
+ public void ResetTxnidLeastBits() => __pbn__TxnidLeastBits = null;
+ private ulong? __pbn__TxnidLeastBits;
+
+ [global::ProtoBuf.ProtoMember(3, Name = @"txnid_most_bits")]
+ [global::System.ComponentModel.DefaultValue(typeof(ulong), "0")]
+ public ulong TxnidMostBits
+ {
+ get => __pbn__TxnidMostBits ?? 0;
+ set => __pbn__TxnidMostBits = value;
+ }
+ public bool ShouldSerializeTxnidMostBits() => __pbn__TxnidMostBits != null;
+ public void ResetTxnidMostBits() => __pbn__TxnidMostBits = null;
+ private ulong? __pbn__TxnidMostBits;
+
+ [global::ProtoBuf.ProtoMember(4, Name = @"partitions")]
+ public global::System.Collections.Generic.List<string> Partitions { get; } = new global::System.Collections.Generic.List<string>();
+
+ }
+
+ [global::ProtoBuf.ProtoContract()]
+ public partial class CommandAddPartitionToTxnResponse : global::ProtoBuf.IExtensible
+ {
+ private global::ProtoBuf.IExtension __pbn__extensionData;
+ global::ProtoBuf.IExtension global::ProtoBuf.IExtensible.GetExtensionObject(bool createIfMissing)
+ => global::ProtoBuf.Extensible.GetExtensionObject(ref __pbn__extensionData, createIfMissing);
+
+ [global::ProtoBuf.ProtoMember(1, Name = @"request_id", IsRequired = true)]
+ public ulong RequestId { get; set; }
+
+ [global::ProtoBuf.ProtoMember(2, Name = @"txnid_least_bits")]
+ [global::System.ComponentModel.DefaultValue(typeof(ulong), "0")]
+ public ulong TxnidLeastBits
+ {
+ get => __pbn__TxnidLeastBits ?? 0;
+ set => __pbn__TxnidLeastBits = value;
+ }
+ public bool ShouldSerializeTxnidLeastBits() => __pbn__TxnidLeastBits != null;
+ public void ResetTxnidLeastBits() => __pbn__TxnidLeastBits = null;
+ private ulong? __pbn__TxnidLeastBits;
+
+ [global::ProtoBuf.ProtoMember(3, Name = @"txnid_most_bits")]
+ [global::System.ComponentModel.DefaultValue(typeof(ulong), "0")]
+ public ulong TxnidMostBits
+ {
+ get => __pbn__TxnidMostBits ?? 0;
+ set => __pbn__TxnidMostBits = value;
+ }
+ public bool ShouldSerializeTxnidMostBits() => __pbn__TxnidMostBits != null;
+ public void ResetTxnidMostBits() => __pbn__TxnidMostBits = null;
+ private ulong? __pbn__TxnidMostBits;
+
+ [global::ProtoBuf.ProtoMember(4, Name = @"error")]
+ [global::System.ComponentModel.DefaultValue(ServerError.UnknownError)]
+ public ServerError Error
+ {
+ get => __pbn__Error ?? ServerError.UnknownError;
+ set => __pbn__Error = value;
+ }
+ public bool ShouldSerializeError() => __pbn__Error != null;
+ public void ResetError() => __pbn__Error = null;
+ private ServerError? __pbn__Error;
+
+ [global::ProtoBuf.ProtoMember(5, Name = @"message")]
+ [global::System.ComponentModel.DefaultValue("")]
+ public string Message
+ {
+ get => __pbn__Message ?? "";
+ set => __pbn__Message = value;
+ }
+ public bool ShouldSerializeMessage() => __pbn__Message != null;
+ public void ResetMessage() => __pbn__Message = null;
+ private string __pbn__Message;
+
+ }
+
+ [global::ProtoBuf.ProtoContract()]
+ public partial class Subscription : global::ProtoBuf.IExtensible
+ {
+ private global::ProtoBuf.IExtension __pbn__extensionData;
+ global::ProtoBuf.IExtension global::ProtoBuf.IExtensible.GetExtensionObject(bool createIfMissing)
+ => global::ProtoBuf.Extensible.GetExtensionObject(ref __pbn__extensionData, createIfMissing);
+
+ [global::ProtoBuf.ProtoMember(1, Name = @"topic", IsRequired = true)]
+ public string Topic { get; set; }
+
+ [global::ProtoBuf.ProtoMember(2, IsRequired = true)]
+ public string SubscriptionName { get; set; }
+
+ }
+
+ [global::ProtoBuf.ProtoContract()]
+ public partial class CommandAddSubscriptionToTxn : global::ProtoBuf.IExtensible
+ {
+ private global::ProtoBuf.IExtension __pbn__extensionData;
+ global::ProtoBuf.IExtension global::ProtoBuf.IExtensible.GetExtensionObject(bool createIfMissing)
+ => global::ProtoBuf.Extensible.GetExtensionObject(ref __pbn__extensionData, createIfMissing);
+
+ [global::ProtoBuf.ProtoMember(1, Name = @"request_id", IsRequired = true)]
+ public ulong RequestId { get; set; }
+
+ [global::ProtoBuf.ProtoMember(2, Name = @"txnid_least_bits")]
+ [global::System.ComponentModel.DefaultValue(typeof(ulong), "0")]
+ public ulong TxnidLeastBits
+ {
+ get => __pbn__TxnidLeastBits ?? 0;
+ set => __pbn__TxnidLeastBits = value;
+ }
+ public bool ShouldSerializeTxnidLeastBits() => __pbn__TxnidLeastBits != null;
+ public void ResetTxnidLeastBits() => __pbn__TxnidLeastBits = null;
+ private ulong? __pbn__TxnidLeastBits;
+
+ [global::ProtoBuf.ProtoMember(3, Name = @"txnid_most_bits")]
+ [global::System.ComponentModel.DefaultValue(typeof(ulong), "0")]
+ public ulong TxnidMostBits
+ {
+ get => __pbn__TxnidMostBits ?? 0;
+ set => __pbn__TxnidMostBits = value;
+ }
+ public bool ShouldSerializeTxnidMostBits() => __pbn__TxnidMostBits != null;
+ public void ResetTxnidMostBits() => __pbn__TxnidMostBits = null;
+ private ulong? __pbn__TxnidMostBits;
+
+ [global::ProtoBuf.ProtoMember(4, Name = @"subscription")]
+ public global::System.Collections.Generic.List<Subscription> Subscriptions { get; } = new global::System.Collections.Generic.List<Subscription>();
+
+ }
+
+ [global::ProtoBuf.ProtoContract()]
+ public partial class CommandAddSubscriptionToTxnResponse : global::ProtoBuf.IExtensible
+ {
+ private global::ProtoBuf.IExtension __pbn__extensionData;
+ global::ProtoBuf.IExtension global::ProtoBuf.IExtensible.GetExtensionObject(bool createIfMissing)
+ => global::ProtoBuf.Extensible.GetExtensionObject(ref __pbn__extensionData, createIfMissing);
+
+ [global::ProtoBuf.ProtoMember(1, Name = @"request_id", IsRequired = true)]
+ public ulong RequestId { get; set; }
+
+ [global::ProtoBuf.ProtoMember(2, Name = @"txnid_least_bits")]
+ [global::System.ComponentModel.DefaultValue(typeof(ulong), "0")]
+ public ulong TxnidLeastBits
+ {
+ get => __pbn__TxnidLeastBits ?? 0;
+ set => __pbn__TxnidLeastBits = value;
+ }
+ public bool ShouldSerializeTxnidLeastBits() => __pbn__TxnidLeastBits != null;
+ public void ResetTxnidLeastBits() => __pbn__TxnidLeastBits = null;
+ private ulong? __pbn__TxnidLeastBits;
+
+ [global::ProtoBuf.ProtoMember(3, Name = @"txnid_most_bits")]
+ [global::System.ComponentModel.DefaultValue(typeof(ulong), "0")]
+ public ulong TxnidMostBits
+ {
+ get => __pbn__TxnidMostBits ?? 0;
+ set => __pbn__TxnidMostBits = value;
+ }
+ public bool ShouldSerializeTxnidMostBits() => __pbn__TxnidMostBits != null;
+ public void ResetTxnidMostBits() => __pbn__TxnidMostBits = null;
+ private ulong? __pbn__TxnidMostBits;
+
+ [global::ProtoBuf.ProtoMember(4, Name = @"error")]
+ [global::System.ComponentModel.DefaultValue(ServerError.UnknownError)]
+ public ServerError Error
+ {
+ get => __pbn__Error ?? ServerError.UnknownError;
+ set => __pbn__Error = value;
+ }
+ public bool ShouldSerializeError() => __pbn__Error != null;
+ public void ResetError() => __pbn__Error = null;
+ private ServerError? __pbn__Error;
+
+ [global::ProtoBuf.ProtoMember(5, Name = @"message")]
+ [global::System.ComponentModel.DefaultValue("")]
+ public string Message
+ {
+ get => __pbn__Message ?? "";
+ set => __pbn__Message = value;
+ }
+ public bool ShouldSerializeMessage() => __pbn__Message != null;
+ public void ResetMessage() => __pbn__Message = null;
+ private string __pbn__Message;
+
+ }
+
+ [global::ProtoBuf.ProtoContract()]
+ public partial class CommandEndTxn : global::ProtoBuf.IExtensible
+ {
+ private global::ProtoBuf.IExtension __pbn__extensionData;
+ global::ProtoBuf.IExtension global::ProtoBuf.IExtensible.GetExtensionObject(bool createIfMissing)
+ => global::ProtoBuf.Extensible.GetExtensionObject(ref __pbn__extensionData, createIfMissing);
+
+ [global::ProtoBuf.ProtoMember(1, Name = @"request_id", IsRequired = true)]
+ public ulong RequestId { get; set; }
+
+ [global::ProtoBuf.ProtoMember(2, Name = @"txnid_least_bits")]
+ [global::System.ComponentModel.DefaultValue(typeof(ulong), "0")]
+ public ulong TxnidLeastBits
+ {
+ get => __pbn__TxnidLeastBits ?? 0;
+ set => __pbn__TxnidLeastBits = value;
+ }
+ public bool ShouldSerializeTxnidLeastBits() => __pbn__TxnidLeastBits != null;
+ public void ResetTxnidLeastBits() => __pbn__TxnidLeastBits = null;
+ private ulong? __pbn__TxnidLeastBits;
+
+ [global::ProtoBuf.ProtoMember(3, Name = @"txnid_most_bits")]
+ [global::System.ComponentModel.DefaultValue(typeof(ulong), "0")]
+ public ulong TxnidMostBits
+ {
+ get => __pbn__TxnidMostBits ?? 0;
+ set => __pbn__TxnidMostBits = value;
+ }
+ public bool ShouldSerializeTxnidMostBits() => __pbn__TxnidMostBits != null;
+ public void ResetTxnidMostBits() => __pbn__TxnidMostBits = null;
+ private ulong? __pbn__TxnidMostBits;
+
+ [global::ProtoBuf.ProtoMember(4, Name = @"txn_action")]
+ [global::System.ComponentModel.DefaultValue(TxnAction.Commit)]
+ public TxnAction TxnAction
+ {
+ get => __pbn__TxnAction ?? TxnAction.Commit;
+ set => __pbn__TxnAction = value;
+ }
+ public bool ShouldSerializeTxnAction() => __pbn__TxnAction != null;
+ public void ResetTxnAction() => __pbn__TxnAction = null;
+ private TxnAction? __pbn__TxnAction;
+
+ [global::ProtoBuf.ProtoMember(5, Name = @"message_id")]
+ public global::System.Collections.Generic.List<MessageIdData> MessageIds { get; } = new global::System.Collections.Generic.List<MessageIdData>();
+
+ }
+
+ [global::ProtoBuf.ProtoContract()]
+ public partial class CommandEndTxnResponse : global::ProtoBuf.IExtensible
+ {
+ private global::ProtoBuf.IExtension __pbn__extensionData;
+ global::ProtoBuf.IExtension global::ProtoBuf.IExtensible.GetExtensionObject(bool createIfMissing)
+ => global::ProtoBuf.Extensible.GetExtensionObject(ref __pbn__extensionData, createIfMissing);
+
+ [global::ProtoBuf.ProtoMember(1, Name = @"request_id", IsRequired = true)]
+ public ulong RequestId { get; set; }
+
+ [global::ProtoBuf.ProtoMember(2, Name = @"txnid_least_bits")]
+ [global::System.ComponentModel.DefaultValue(typeof(ulong), "0")]
+ public ulong TxnidLeastBits
+ {
+ get => __pbn__TxnidLeastBits ?? 0;
+ set => __pbn__TxnidLeastBits = value;
+ }
+ public bool ShouldSerializeTxnidLeastBits() => __pbn__TxnidLeastBits != null;
+ public void ResetTxnidLeastBits() => __pbn__TxnidLeastBits = null;
+ private ulong? __pbn__TxnidLeastBits;
+
+ [global::ProtoBuf.ProtoMember(3, Name = @"txnid_most_bits")]
+ [global::System.ComponentModel.DefaultValue(typeof(ulong), "0")]
+ public ulong TxnidMostBits
+ {
+ get => __pbn__TxnidMostBits ?? 0;
+ set => __pbn__TxnidMostBits = value;
+ }
+ public bool ShouldSerializeTxnidMostBits() => __pbn__TxnidMostBits != null;
+ public void ResetTxnidMostBits() => __pbn__TxnidMostBits = null;
+ private ulong? __pbn__TxnidMostBits;
+
+ [global::ProtoBuf.ProtoMember(4, Name = @"error")]
+ [global::System.ComponentModel.DefaultValue(ServerError.UnknownError)]
+ public ServerError Error
+ {
+ get => __pbn__Error ?? ServerError.UnknownError;
+ set => __pbn__Error = value;
+ }
+ public bool ShouldSerializeError() => __pbn__Error != null;
+ public void ResetError() => __pbn__Error = null;
+ private ServerError? __pbn__Error;
+
+ [global::ProtoBuf.ProtoMember(5, Name = @"message")]
+ [global::System.ComponentModel.DefaultValue("")]
+ public string Message
+ {
+ get => __pbn__Message ?? "";
+ set => __pbn__Message = value;
+ }
+ public bool ShouldSerializeMessage() => __pbn__Message != null;
+ public void ResetMessage() => __pbn__Message = null;
+ private string __pbn__Message;
+
+ }
+
+ [global::ProtoBuf.ProtoContract()]
+ public partial class CommandEndTxnOnPartition : global::ProtoBuf.IExtensible
+ {
+ private global::ProtoBuf.IExtension __pbn__extensionData;
+ global::ProtoBuf.IExtension global::ProtoBuf.IExtensible.GetExtensionObject(bool createIfMissing)
+ => global::ProtoBuf.Extensible.GetExtensionObject(ref __pbn__extensionData, createIfMissing);
+
+ [global::ProtoBuf.ProtoMember(1, Name = @"request_id", IsRequired = true)]
+ public ulong RequestId { get; set; }
+
+ [global::ProtoBuf.ProtoMember(2, Name = @"txnid_least_bits")]
+ [global::System.ComponentModel.DefaultValue(typeof(ulong), "0")]
+ public ulong TxnidLeastBits
+ {
+ get => __pbn__TxnidLeastBits ?? 0;
+ set => __pbn__TxnidLeastBits = value;
+ }
+ public bool ShouldSerializeTxnidLeastBits() => __pbn__TxnidLeastBits != null;
+ public void ResetTxnidLeastBits() => __pbn__TxnidLeastBits = null;
+ private ulong? __pbn__TxnidLeastBits;
+
+ [global::ProtoBuf.ProtoMember(3, Name = @"txnid_most_bits")]
+ [global::System.ComponentModel.DefaultValue(typeof(ulong), "0")]
+ public ulong TxnidMostBits
+ {
+ get => __pbn__TxnidMostBits ?? 0;
+ set => __pbn__TxnidMostBits = value;
+ }
+ public bool ShouldSerializeTxnidMostBits() => __pbn__TxnidMostBits != null;
+ public void ResetTxnidMostBits() => __pbn__TxnidMostBits = null;
+ private ulong? __pbn__TxnidMostBits;
+
+ [global::ProtoBuf.ProtoMember(4, Name = @"topic")]
+ [global::System.ComponentModel.DefaultValue("")]
+ public string Topic
+ {
+ get => __pbn__Topic ?? "";
+ set => __pbn__Topic = value;
+ }
+ public bool ShouldSerializeTopic() => __pbn__Topic != null;
+ public void ResetTopic() => __pbn__Topic = null;
+ private string __pbn__Topic;
+
+ [global::ProtoBuf.ProtoMember(5, Name = @"txn_action")]
+ [global::System.ComponentModel.DefaultValue(TxnAction.Commit)]
+ public TxnAction TxnAction
+ {
+ get => __pbn__TxnAction ?? TxnAction.Commit;
+ set => __pbn__TxnAction = value;
+ }
+ public bool ShouldSerializeTxnAction() => __pbn__TxnAction != null;
+ public void ResetTxnAction() => __pbn__TxnAction = null;
+ private TxnAction? __pbn__TxnAction;
+
+ [global::ProtoBuf.ProtoMember(6, Name = @"message_id")]
+ public global::System.Collections.Generic.List<MessageIdData> MessageIds { get; } = new global::System.Collections.Generic.List<MessageIdData>();
+
+ }
+
+ [global::ProtoBuf.ProtoContract()]
+ public partial class CommandEndTxnOnPartitionResponse : global::ProtoBuf.IExtensible
+ {
+ private global::ProtoBuf.IExtension __pbn__extensionData;
+ global::ProtoBuf.IExtension global::ProtoBuf.IExtensible.GetExtensionObject(bool createIfMissing)
+ => global::ProtoBuf.Extensible.GetExtensionObject(ref __pbn__extensionData, createIfMissing);
+
+ [global::ProtoBuf.ProtoMember(1, Name = @"request_id", IsRequired = true)]
+ public ulong RequestId { get; set; }
+
+ [global::ProtoBuf.ProtoMember(2, Name = @"txnid_least_bits")]
+ [global::System.ComponentModel.DefaultValue(typeof(ulong), "0")]
+ public ulong TxnidLeastBits
+ {
+ get => __pbn__TxnidLeastBits ?? 0;
+ set => __pbn__TxnidLeastBits = value;
+ }
+ public bool ShouldSerializeTxnidLeastBits() => __pbn__TxnidLeastBits != null;
+ public void ResetTxnidLeastBits() => __pbn__TxnidLeastBits = null;
+ private ulong? __pbn__TxnidLeastBits;
+
+ [global::ProtoBuf.ProtoMember(3, Name = @"txnid_most_bits")]
+ [global::System.ComponentModel.DefaultValue(typeof(ulong), "0")]
+ public ulong TxnidMostBits
+ {
+ get => __pbn__TxnidMostBits ?? 0;
+ set => __pbn__TxnidMostBits = value;
+ }
+ public bool ShouldSerializeTxnidMostBits() => __pbn__TxnidMostBits != null;
+ public void ResetTxnidMostBits() => __pbn__TxnidMostBits = null;
+ private ulong? __pbn__TxnidMostBits;
+
+ [global::ProtoBuf.ProtoMember(4, Name = @"error")]
+ [global::System.ComponentModel.DefaultValue(ServerError.UnknownError)]
+ public ServerError Error
+ {
+ get => __pbn__Error ?? ServerError.UnknownError;
+ set => __pbn__Error = value;
+ }
+ public bool ShouldSerializeError() => __pbn__Error != null;
+ public void ResetError() => __pbn__Error = null;
+ private ServerError? __pbn__Error;
+
+ [global::ProtoBuf.ProtoMember(5, Name = @"message")]
+ [global::System.ComponentModel.DefaultValue("")]
+ public string Message
+ {
+ get => __pbn__Message ?? "";
+ set => __pbn__Message = value;
+ }
+ public bool ShouldSerializeMessage() => __pbn__Message != null;
+ public void ResetMessage() => __pbn__Message = null;
+ private string __pbn__Message;
+
+ }
+
+ [global::ProtoBuf.ProtoContract()]
+ public partial class CommandEndTxnOnSubscription : global::ProtoBuf.IExtensible
+ {
+ private global::ProtoBuf.IExtension __pbn__extensionData;
+ global::ProtoBuf.IExtension global::ProtoBuf.IExtensible.GetExtensionObject(bool createIfMissing)
+ => global::ProtoBuf.Extensible.GetExtensionObject(ref __pbn__extensionData, createIfMissing);
+
+ [global::ProtoBuf.ProtoMember(1, Name = @"request_id", IsRequired = true)]
+ public ulong RequestId { get; set; }
+
+ [global::ProtoBuf.ProtoMember(2, Name = @"txnid_least_bits")]
+ [global::System.ComponentModel.DefaultValue(typeof(ulong), "0")]
+ public ulong TxnidLeastBits
+ {
+ get => __pbn__TxnidLeastBits ?? 0;
+ set => __pbn__TxnidLeastBits = value;
+ }
+ public bool ShouldSerializeTxnidLeastBits() => __pbn__TxnidLeastBits != null;
+ public void ResetTxnidLeastBits() => __pbn__TxnidLeastBits = null;
+ private ulong? __pbn__TxnidLeastBits;
+
+ [global::ProtoBuf.ProtoMember(3, Name = @"txnid_most_bits")]
+ [global::System.ComponentModel.DefaultValue(typeof(ulong), "0")]
+ public ulong TxnidMostBits
+ {
+ get => __pbn__TxnidMostBits ?? 0;
+ set => __pbn__TxnidMostBits = value;
+ }
+ public bool ShouldSerializeTxnidMostBits() => __pbn__TxnidMostBits != null;
+ public void ResetTxnidMostBits() => __pbn__TxnidMostBits = null;
+ private ulong? __pbn__TxnidMostBits;
+
+ [global::ProtoBuf.ProtoMember(4, Name = @"subscription")]
+ public Subscription Subscription { get; set; }
+
+ [global::ProtoBuf.ProtoMember(5, Name = @"txn_action")]
+ [global::System.ComponentModel.DefaultValue(TxnAction.Commit)]
+ public TxnAction TxnAction
+ {
+ get => __pbn__TxnAction ?? TxnAction.Commit;
+ set => __pbn__TxnAction = value;
+ }
+ public bool ShouldSerializeTxnAction() => __pbn__TxnAction != null;
+ public void ResetTxnAction() => __pbn__TxnAction = null;
+ private TxnAction? __pbn__TxnAction;
+
+ }
+
+ [global::ProtoBuf.ProtoContract()]
+ public partial class CommandEndTxnOnSubscriptionResponse : global::ProtoBuf.IExtensible
+ {
+ private global::ProtoBuf.IExtension __pbn__extensionData;
+ global::ProtoBuf.IExtension global::ProtoBuf.IExtensible.GetExtensionObject(bool createIfMissing)
+ => global::ProtoBuf.Extensible.GetExtensionObject(ref __pbn__extensionData, createIfMissing);
+
+ [global::ProtoBuf.ProtoMember(1, Name = @"request_id", IsRequired = true)]
+ public ulong RequestId { get; set; }
+
+ [global::ProtoBuf.ProtoMember(2, Name = @"txnid_least_bits")]
+ [global::System.ComponentModel.DefaultValue(typeof(ulong), "0")]
+ public ulong TxnidLeastBits
+ {
+ get => __pbn__TxnidLeastBits ?? 0;
+ set => __pbn__TxnidLeastBits = value;
+ }
+ public bool ShouldSerializeTxnidLeastBits() => __pbn__TxnidLeastBits != null;
+ public void ResetTxnidLeastBits() => __pbn__TxnidLeastBits = null;
+ private ulong? __pbn__TxnidLeastBits;
+
+ [global::ProtoBuf.ProtoMember(3, Name = @"txnid_most_bits")]
+ [global::System.ComponentModel.DefaultValue(typeof(ulong), "0")]
+ public ulong TxnidMostBits
+ {
+ get => __pbn__TxnidMostBits ?? 0;
+ set => __pbn__TxnidMostBits = value;
+ }
+ public bool ShouldSerializeTxnidMostBits() => __pbn__TxnidMostBits != null;
+ public void ResetTxnidMostBits() => __pbn__TxnidMostBits = null;
+ private ulong? __pbn__TxnidMostBits;
+
+ [global::ProtoBuf.ProtoMember(4, Name = @"error")]
+ [global::System.ComponentModel.DefaultValue(ServerError.UnknownError)]
+ public ServerError Error
+ {
+ get => __pbn__Error ?? ServerError.UnknownError;
+ set => __pbn__Error = value;
+ }
+ public bool ShouldSerializeError() => __pbn__Error != null;
+ public void ResetError() => __pbn__Error = null;
+ private ServerError? __pbn__Error;
+
+ [global::ProtoBuf.ProtoMember(5, Name = @"message")]
+ [global::System.ComponentModel.DefaultValue("")]
+ public string Message
+ {
+ get => __pbn__Message ?? "";
+ set => __pbn__Message = value;
+ }
+ public bool ShouldSerializeMessage() => __pbn__Message != null;
+ public void ResetMessage() => __pbn__Message = null;
+ private string __pbn__Message;
+
}
[global::ProtoBuf.ProtoContract()]
@@ -1813,6 +2948,51 @@
[global::ProtoBuf.ProtoMember(37)]
public CommandAuthResponse AuthResponse { get; set; }
+ [global::ProtoBuf.ProtoMember(38)]
+ public CommandAckResponse AckResponse { get; set; }
+
+ [global::ProtoBuf.ProtoMember(39)]
+ public CommandGetOrCreateSchema GetOrCreateSchema { get; set; }
+
+ [global::ProtoBuf.ProtoMember(40)]
+ public CommandGetOrCreateSchemaResponse GetOrCreateSchemaResponse { get; set; }
+
+ [global::ProtoBuf.ProtoMember(50)]
+ public CommandNewTxn NewTxn { get; set; }
+
+ [global::ProtoBuf.ProtoMember(51)]
+ public CommandNewTxnResponse NewTxnResponse { get; set; }
+
+ [global::ProtoBuf.ProtoMember(52)]
+ public CommandAddPartitionToTxn AddPartitionToTxn { get; set; }
+
+ [global::ProtoBuf.ProtoMember(53)]
+ public CommandAddPartitionToTxnResponse AddPartitionToTxnResponse { get; set; }
+
+ [global::ProtoBuf.ProtoMember(54)]
+ public CommandAddSubscriptionToTxn AddSubscriptionToTxn { get; set; }
+
+ [global::ProtoBuf.ProtoMember(55)]
+ public CommandAddSubscriptionToTxnResponse AddSubscriptionToTxnResponse { get; set; }
+
+ [global::ProtoBuf.ProtoMember(56)]
+ public CommandEndTxn EndTxn { get; set; }
+
+ [global::ProtoBuf.ProtoMember(57)]
+ public CommandEndTxnResponse EndTxnResponse { get; set; }
+
+ [global::ProtoBuf.ProtoMember(58)]
+ public CommandEndTxnOnPartition EndTxnOnPartition { get; set; }
+
+ [global::ProtoBuf.ProtoMember(59)]
+ public CommandEndTxnOnPartitionResponse EndTxnOnPartitionResponse { get; set; }
+
+ [global::ProtoBuf.ProtoMember(60)]
+ public CommandEndTxnOnSubscription EndTxnOnSubscription { get; set; }
+
+ [global::ProtoBuf.ProtoMember(61)]
+ public CommandEndTxnOnSubscriptionResponse EndTxnOnSubscriptionResponse { get; set; }
+
[global::ProtoBuf.ProtoContract()]
public enum Type
{
@@ -1888,7 +3068,38 @@
AuthChallenge = 36,
[global::ProtoBuf.ProtoEnum(Name = @"AUTH_RESPONSE")]
AuthResponse = 37,
+ [global::ProtoBuf.ProtoEnum(Name = @"ACK_RESPONSE")]
+ AckResponse = 38,
+ [global::ProtoBuf.ProtoEnum(Name = @"GET_OR_CREATE_SCHEMA")]
+ GetOrCreateSchema = 39,
+ [global::ProtoBuf.ProtoEnum(Name = @"GET_OR_CREATE_SCHEMA_RESPONSE")]
+ GetOrCreateSchemaResponse = 40,
+ [global::ProtoBuf.ProtoEnum(Name = @"NEW_TXN")]
+ NewTxn = 50,
+ [global::ProtoBuf.ProtoEnum(Name = @"NEW_TXN_RESPONSE")]
+ NewTxnResponse = 51,
+ [global::ProtoBuf.ProtoEnum(Name = @"ADD_PARTITION_TO_TXN")]
+ AddPartitionToTxn = 52,
+ [global::ProtoBuf.ProtoEnum(Name = @"ADD_PARTITION_TO_TXN_RESPONSE")]
+ AddPartitionToTxnResponse = 53,
+ [global::ProtoBuf.ProtoEnum(Name = @"ADD_SUBSCRIPTION_TO_TXN")]
+ AddSubscriptionToTxn = 54,
+ [global::ProtoBuf.ProtoEnum(Name = @"ADD_SUBSCRIPTION_TO_TXN_RESPONSE")]
+ AddSubscriptionToTxnResponse = 55,
+ [global::ProtoBuf.ProtoEnum(Name = @"END_TXN")]
+ EndTxn = 56,
+ [global::ProtoBuf.ProtoEnum(Name = @"END_TXN_RESPONSE")]
+ EndTxnResponse = 57,
+ [global::ProtoBuf.ProtoEnum(Name = @"END_TXN_ON_PARTITION")]
+ EndTxnOnPartition = 58,
+ [global::ProtoBuf.ProtoEnum(Name = @"END_TXN_ON_PARTITION_RESPONSE")]
+ EndTxnOnPartitionResponse = 59,
+ [global::ProtoBuf.ProtoEnum(Name = @"END_TXN_ON_SUBSCRIPTION")]
+ EndTxnOnSubscription = 60,
+ [global::ProtoBuf.ProtoEnum(Name = @"END_TXN_ON_SUBSCRIPTION_RESPONSE")]
+ EndTxnOnSubscriptionResponse = 61,
}
+
}
[global::ProtoBuf.ProtoContract()]
@@ -1929,6 +3140,10 @@
InvalidTopicName = 17,
IncompatibleSchema = 18,
ConsumerAssignError = 19,
+ TransactionCoordinatorNotFound = 20,
+ InvalidTxnStatus = 21,
+ NotAllowedError = 22,
+ TransactionConflict = 23,
}
[global::ProtoBuf.ProtoContract()]
@@ -1972,8 +3187,29 @@
V13 = 13,
[global::ProtoBuf.ProtoEnum(Name = @"v14")]
V14 = 14,
+ [global::ProtoBuf.ProtoEnum(Name = @"v15")]
+ V15 = 15,
+ }
+
+ [global::ProtoBuf.ProtoContract()]
+ public enum KeySharedMode
+ {
+ [global::ProtoBuf.ProtoEnum(Name = @"AUTO_SPLIT")]
+ AutoSplit = 0,
+ [global::ProtoBuf.ProtoEnum(Name = @"STICKY")]
+ Sticky = 1,
+ }
+
+ [global::ProtoBuf.ProtoContract()]
+ public enum TxnAction
+ {
+ [global::ProtoBuf.ProtoEnum(Name = @"COMMIT")]
+ Commit = 0,
+ [global::ProtoBuf.ProtoEnum(Name = @"ABORT")]
+ Abort = 1,
}
}
-#pragma warning restore CS1591, CS0612, CS3021, IDE1006
+#pragma warning restore CS0612, CS0618, CS1591, CS3021, IDE0079, IDE1006, RCS1036, RCS1057, RCS1085, RCS1192
+#endregion
#nullable restore
