| /* |
| * Licensed under the Apache License, Version 2.0 (the "License"); |
| * you may not use this file except in compliance with the License. |
| * You may obtain a copy of the License at |
| * |
| * http://www.apache.org/licenses/LICENSE-2.0 |
| * |
| * Unless required by applicable law or agreed to in writing, software |
| * distributed under the License is distributed on an "AS IS" BASIS, |
| * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
| * See the License for the specific language governing permissions and |
| * limitations under the License. |
| */ |
| |
| #nullable disable |
| #region Designer generated code |
| #pragma warning disable CS0612, CS0618, CS1591, CS3021, IDE0079, IDE1006, RCS1036, RCS1057, RCS1085, RCS1192 |
| |
| namespace DotPulsar.Internal.PulsarApi |
| { |
| // <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 |
| { |
| 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 = @"name", IsRequired = true)] |
| public string Name { get; set; } |
| |
| [global::ProtoBuf.ProtoMember(3, Name = @"schema_data", IsRequired = true)] |
| public byte[] SchemaData { get; set; } |
| |
| [global::ProtoBuf.ProtoMember(4, IsRequired = true)] |
| public SchemaType Type { get; set; } |
| |
| [global::ProtoBuf.ProtoMember(5, Name = @"properties")] |
| public global::System.Collections.Generic.List<KeyValue> Properties { get; } = new global::System.Collections.Generic.List<KeyValue>(); |
| |
| [global::ProtoBuf.ProtoContract()] |
| public enum SchemaType |
| { |
| None = 0, |
| String = 1, |
| Json = 2, |
| Protobuf = 3, |
| Avro = 4, |
| Bool = 5, |
| Int8 = 6, |
| Int16 = 7, |
| Int32 = 8, |
| Int64 = 9, |
| Float = 10, |
| Double = 11, |
| Date = 12, |
| Time = 13, |
| Timestamp = 14, |
| KeyValue = 15, |
| Instant = 16, |
| LocalDate = 17, |
| LocalTime = 18, |
| LocalDateTime = 19, |
| ProtobufNative = 20, |
| } |
| |
| } |
| |
| [global::ProtoBuf.ProtoContract()] |
| public partial class MessageIdData : 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 ulong LedgerId { get; set; } |
| |
| [global::ProtoBuf.ProtoMember(2, IsRequired = true)] |
| public ulong EntryId { get; set; } |
| |
| [global::ProtoBuf.ProtoMember(3, Name = @"partition")] |
| [global::System.ComponentModel.DefaultValue(-1)] |
| public int Partition |
| { |
| get => __pbn__Partition ?? -1; |
| set => __pbn__Partition = value; |
| } |
| public bool ShouldSerializePartition() => __pbn__Partition != null; |
| public void ResetPartition() => __pbn__Partition = null; |
| private int? __pbn__Partition; |
| |
| [global::ProtoBuf.ProtoMember(4, Name = @"batch_index")] |
| [global::System.ComponentModel.DefaultValue(-1)] |
| public int BatchIndex |
| { |
| 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()] |
| public partial class KeyValue : 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 = @"key", IsRequired = true)] |
| public string Key { get; set; } |
| |
| [global::ProtoBuf.ProtoMember(2, Name = @"value", IsRequired = true)] |
| public string Value { get; set; } |
| |
| } |
| |
| [global::ProtoBuf.ProtoContract()] |
| public partial class KeyLongValue : 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 = @"key", IsRequired = true)] |
| public string Key { get; set; } |
| |
| [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()] |
| public partial class EncryptionKeys : 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 = @"key", IsRequired = true)] |
| public string Key { get; set; } |
| |
| [global::ProtoBuf.ProtoMember(2, Name = @"value", IsRequired = true)] |
| public byte[] Value { get; set; } |
| |
| [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()] |
| public partial class MessageMetadata : 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 = @"producer_name", IsRequired = true)] |
| public string ProducerName { get; set; } |
| |
| [global::ProtoBuf.ProtoMember(2, Name = @"sequence_id", IsRequired = true)] |
| public ulong SequenceId { get; set; } |
| |
| [global::ProtoBuf.ProtoMember(3, Name = @"publish_time", IsRequired = true)] |
| public ulong PublishTime { get; set; } |
| |
| [global::ProtoBuf.ProtoMember(4, Name = @"properties")] |
| public global::System.Collections.Generic.List<KeyValue> Properties { get; } = new global::System.Collections.Generic.List<KeyValue>(); |
| |
| [global::ProtoBuf.ProtoMember(5, Name = @"replicated_from")] |
| [global::System.ComponentModel.DefaultValue("")] |
| public string ReplicatedFrom |
| { |
| get => __pbn__ReplicatedFrom ?? ""; |
| set => __pbn__ReplicatedFrom = value; |
| } |
| public bool ShouldSerializeReplicatedFrom() => __pbn__ReplicatedFrom != null; |
| public void ResetReplicatedFrom() => __pbn__ReplicatedFrom = null; |
| private string __pbn__ReplicatedFrom; |
| |
| [global::ProtoBuf.ProtoMember(6, Name = @"partition_key")] |
| [global::System.ComponentModel.DefaultValue("")] |
| public string PartitionKey |
| { |
| get => __pbn__PartitionKey ?? ""; |
| set => __pbn__PartitionKey = value; |
| } |
| public bool ShouldSerializePartitionKey() => __pbn__PartitionKey != null; |
| public void ResetPartitionKey() => __pbn__PartitionKey = null; |
| private string __pbn__PartitionKey; |
| |
| [global::ProtoBuf.ProtoMember(7, Name = @"replicate_to")] |
| public global::System.Collections.Generic.List<string> ReplicateToes { get; } = new global::System.Collections.Generic.List<string>(); |
| |
| [global::ProtoBuf.ProtoMember(8, Name = @"compression")] |
| [global::System.ComponentModel.DefaultValue(CompressionType.None)] |
| public CompressionType Compression |
| { |
| get => __pbn__Compression ?? CompressionType.None; |
| set => __pbn__Compression = value; |
| } |
| public bool ShouldSerializeCompression() => __pbn__Compression != null; |
| public void ResetCompression() => __pbn__Compression = null; |
| private CompressionType? __pbn__Compression; |
| |
| [global::ProtoBuf.ProtoMember(9, Name = @"uncompressed_size")] |
| [global::System.ComponentModel.DefaultValue(0)] |
| public uint UncompressedSize |
| { |
| get => __pbn__UncompressedSize ?? 0; |
| set => __pbn__UncompressedSize = value; |
| } |
| public bool ShouldSerializeUncompressedSize() => __pbn__UncompressedSize != null; |
| public void ResetUncompressedSize() => __pbn__UncompressedSize = null; |
| private uint? __pbn__UncompressedSize; |
| |
| [global::ProtoBuf.ProtoMember(11, Name = @"num_messages_in_batch")] |
| [global::System.ComponentModel.DefaultValue(1)] |
| public int NumMessagesInBatch |
| { |
| 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(typeof(ulong), "0")] |
| public ulong EventTime |
| { |
| get => __pbn__EventTime ?? 0; |
| set => __pbn__EventTime = value; |
| } |
| public bool ShouldSerializeEventTime() => __pbn__EventTime != null; |
| public void ResetEventTime() => __pbn__EventTime = null; |
| private ulong? __pbn__EventTime; |
| |
| [global::ProtoBuf.ProtoMember(13, Name = @"encryption_keys")] |
| public global::System.Collections.Generic.List<EncryptionKeys> EncryptionKeys { get; } = new global::System.Collections.Generic.List<EncryptionKeys>(); |
| |
| [global::ProtoBuf.ProtoMember(14, Name = @"encryption_algo")] |
| [global::System.ComponentModel.DefaultValue("")] |
| public string EncryptionAlgo |
| { |
| get => __pbn__EncryptionAlgo ?? ""; |
| set => __pbn__EncryptionAlgo = value; |
| } |
| public bool ShouldSerializeEncryptionAlgo() => __pbn__EncryptionAlgo != null; |
| public void ResetEncryptionAlgo() => __pbn__EncryptionAlgo = null; |
| private string __pbn__EncryptionAlgo; |
| |
| [global::ProtoBuf.ProtoMember(15, Name = @"encryption_param")] |
| public byte[] EncryptionParam |
| { |
| get => __pbn__EncryptionParam; |
| set => __pbn__EncryptionParam = value; |
| } |
| public bool ShouldSerializeEncryptionParam() => __pbn__EncryptionParam != null; |
| public void ResetEncryptionParam() => __pbn__EncryptionParam = null; |
| private byte[] __pbn__EncryptionParam; |
| |
| [global::ProtoBuf.ProtoMember(16, 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.ProtoMember(17, Name = @"partition_key_b64_encoded")] |
| [global::System.ComponentModel.DefaultValue(false)] |
| public bool PartitionKeyB64Encoded |
| { |
| get => __pbn__PartitionKeyB64Encoded ?? false; |
| set => __pbn__PartitionKeyB64Encoded = value; |
| } |
| public bool ShouldSerializePartitionKeyB64Encoded() => __pbn__PartitionKeyB64Encoded != null; |
| public void ResetPartitionKeyB64Encoded() => __pbn__PartitionKeyB64Encoded = null; |
| private bool? __pbn__PartitionKeyB64Encoded; |
| |
| [global::ProtoBuf.ProtoMember(18, Name = @"ordering_key")] |
| public byte[] OrderingKey |
| { |
| get => __pbn__OrderingKey; |
| set => __pbn__OrderingKey = value; |
| } |
| public bool ShouldSerializeOrderingKey() => __pbn__OrderingKey != null; |
| public void ResetOrderingKey() => __pbn__OrderingKey = null; |
| private byte[] __pbn__OrderingKey; |
| |
| [global::ProtoBuf.ProtoMember(19, Name = @"deliver_at_time")] |
| public long DeliverAtTime |
| { |
| get => __pbn__DeliverAtTime.GetValueOrDefault(); |
| set => __pbn__DeliverAtTime = value; |
| } |
| public bool ShouldSerializeDeliverAtTime() => __pbn__DeliverAtTime != null; |
| public void ResetDeliverAtTime() => __pbn__DeliverAtTime = null; |
| private long? __pbn__DeliverAtTime; |
| |
| [global::ProtoBuf.ProtoMember(20, Name = @"marker_type")] |
| public int MarkerType |
| { |
| 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()] |
| public partial class SingleMessageMetadata : 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 = @"properties")] |
| public global::System.Collections.Generic.List<KeyValue> Properties { get; } = new global::System.Collections.Generic.List<KeyValue>(); |
| |
| [global::ProtoBuf.ProtoMember(2, Name = @"partition_key")] |
| [global::System.ComponentModel.DefaultValue("")] |
| public string PartitionKey |
| { |
| get => __pbn__PartitionKey ?? ""; |
| set => __pbn__PartitionKey = value; |
| } |
| public bool ShouldSerializePartitionKey() => __pbn__PartitionKey != null; |
| public void ResetPartitionKey() => __pbn__PartitionKey = null; |
| private string __pbn__PartitionKey; |
| |
| [global::ProtoBuf.ProtoMember(3, Name = @"payload_size", IsRequired = true)] |
| public int PayloadSize { get; set; } |
| |
| [global::ProtoBuf.ProtoMember(4, Name = @"compacted_out")] |
| [global::System.ComponentModel.DefaultValue(false)] |
| public bool CompactedOut |
| { |
| 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(typeof(ulong), "0")] |
| public ulong EventTime |
| { |
| get => __pbn__EventTime ?? 0; |
| set => __pbn__EventTime = value; |
| } |
| public bool ShouldSerializeEventTime() => __pbn__EventTime != null; |
| public void ResetEventTime() => __pbn__EventTime = null; |
| private ulong? __pbn__EventTime; |
| |
| [global::ProtoBuf.ProtoMember(6, Name = @"partition_key_b64_encoded")] |
| [global::System.ComponentModel.DefaultValue(false)] |
| public bool PartitionKeyB64Encoded |
| { |
| get => __pbn__PartitionKeyB64Encoded ?? false; |
| set => __pbn__PartitionKeyB64Encoded = value; |
| } |
| public bool ShouldSerializePartitionKeyB64Encoded() => __pbn__PartitionKeyB64Encoded != null; |
| public void ResetPartitionKeyB64Encoded() => __pbn__PartitionKeyB64Encoded = null; |
| private bool? __pbn__PartitionKeyB64Encoded; |
| |
| [global::ProtoBuf.ProtoMember(7, Name = @"ordering_key")] |
| public byte[] OrderingKey |
| { |
| get => __pbn__OrderingKey; |
| set => __pbn__OrderingKey = value; |
| } |
| public bool ShouldSerializeOrderingKey() => __pbn__OrderingKey != null; |
| public void ResetOrderingKey() => __pbn__OrderingKey = null; |
| private byte[] __pbn__OrderingKey; |
| |
| [global::ProtoBuf.ProtoMember(8, Name = @"sequence_id")] |
| public ulong SequenceId |
| { |
| 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()] |
| public partial class CommandConnect : 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 = @"client_version", IsRequired = true)] |
| public string ClientVersion { get; set; } |
| |
| [global::ProtoBuf.ProtoMember(2, Name = @"auth_method")] |
| [global::System.ComponentModel.DefaultValue(AuthMethod.AuthMethodNone)] |
| public AuthMethod AuthMethod |
| { |
| get => __pbn__AuthMethod ?? AuthMethod.AuthMethodNone; |
| set => __pbn__AuthMethod = value; |
| } |
| public bool ShouldSerializeAuthMethod() => __pbn__AuthMethod != null; |
| public void ResetAuthMethod() => __pbn__AuthMethod = null; |
| private AuthMethod? __pbn__AuthMethod; |
| |
| [global::ProtoBuf.ProtoMember(5, Name = @"auth_method_name")] |
| [global::System.ComponentModel.DefaultValue("")] |
| public string AuthMethodName |
| { |
| 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(3, Name = @"auth_data")] |
| public byte[] AuthData |
| { |
| get => __pbn__AuthData; |
| set => __pbn__AuthData = value; |
| } |
| public bool ShouldSerializeAuthData() => __pbn__AuthData != null; |
| public void ResetAuthData() => __pbn__AuthData = null; |
| private byte[] __pbn__AuthData; |
| |
| [global::ProtoBuf.ProtoMember(4, Name = @"protocol_version")] |
| [global::System.ComponentModel.DefaultValue(0)] |
| public int ProtocolVersion |
| { |
| 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.ProtoMember(6, Name = @"proxy_to_broker_url")] |
| [global::System.ComponentModel.DefaultValue("")] |
| public string ProxyToBrokerUrl |
| { |
| get => __pbn__ProxyToBrokerUrl ?? ""; |
| set => __pbn__ProxyToBrokerUrl = value; |
| } |
| public bool ShouldSerializeProxyToBrokerUrl() => __pbn__ProxyToBrokerUrl != null; |
| public void ResetProxyToBrokerUrl() => __pbn__ProxyToBrokerUrl = null; |
| private string __pbn__ProxyToBrokerUrl; |
| |
| [global::ProtoBuf.ProtoMember(7, Name = @"original_principal")] |
| [global::System.ComponentModel.DefaultValue("")] |
| public string OriginalPrincipal |
| { |
| get => __pbn__OriginalPrincipal ?? ""; |
| set => __pbn__OriginalPrincipal = value; |
| } |
| public bool ShouldSerializeOriginalPrincipal() => __pbn__OriginalPrincipal != null; |
| public void ResetOriginalPrincipal() => __pbn__OriginalPrincipal = null; |
| private string __pbn__OriginalPrincipal; |
| |
| [global::ProtoBuf.ProtoMember(8, Name = @"original_auth_data")] |
| [global::System.ComponentModel.DefaultValue("")] |
| public string OriginalAuthData |
| { |
| get => __pbn__OriginalAuthData ?? ""; |
| set => __pbn__OriginalAuthData = value; |
| } |
| public bool ShouldSerializeOriginalAuthData() => __pbn__OriginalAuthData != null; |
| public void ResetOriginalAuthData() => __pbn__OriginalAuthData = null; |
| private string __pbn__OriginalAuthData; |
| |
| [global::ProtoBuf.ProtoMember(9, Name = @"original_auth_method")] |
| [global::System.ComponentModel.DefaultValue("")] |
| public string OriginalAuthMethod |
| { |
| 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()] |
| public partial class CommandConnected : 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 = @"server_version", IsRequired = true)] |
| public string ServerVersion { get; set; } |
| |
| [global::ProtoBuf.ProtoMember(2, Name = @"protocol_version")] |
| [global::System.ComponentModel.DefaultValue(0)] |
| public int ProtocolVersion |
| { |
| 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.ProtoMember(3, Name = @"max_message_size")] |
| public int MaxMessageSize |
| { |
| 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()] |
| public partial class CommandAuthResponse : 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 = @"client_version")] |
| [global::System.ComponentModel.DefaultValue("")] |
| public string ClientVersion |
| { |
| get => __pbn__ClientVersion ?? ""; |
| set => __pbn__ClientVersion = value; |
| } |
| public bool ShouldSerializeClientVersion() => __pbn__ClientVersion != null; |
| public void ResetClientVersion() => __pbn__ClientVersion = null; |
| private string __pbn__ClientVersion; |
| |
| [global::ProtoBuf.ProtoMember(2, Name = @"response")] |
| public AuthData Response { get; set; } |
| |
| [global::ProtoBuf.ProtoMember(3, Name = @"protocol_version")] |
| [global::System.ComponentModel.DefaultValue(0)] |
| public int ProtocolVersion |
| { |
| 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()] |
| public partial class CommandAuthChallenge : 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 = @"server_version")] |
| [global::System.ComponentModel.DefaultValue("")] |
| public string ServerVersion |
| { |
| get => __pbn__ServerVersion ?? ""; |
| set => __pbn__ServerVersion = value; |
| } |
| public bool ShouldSerializeServerVersion() => __pbn__ServerVersion != null; |
| public void ResetServerVersion() => __pbn__ServerVersion = null; |
| private string __pbn__ServerVersion; |
| |
| [global::ProtoBuf.ProtoMember(2, Name = @"challenge")] |
| public AuthData Challenge { get; set; } |
| |
| [global::ProtoBuf.ProtoMember(3, Name = @"protocol_version")] |
| [global::System.ComponentModel.DefaultValue(0)] |
| public int ProtocolVersion |
| { |
| 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()] |
| public partial class AuthData : 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 = @"auth_method_name")] |
| [global::System.ComponentModel.DefaultValue("")] |
| public string AuthMethodName |
| { |
| 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[] Data |
| { |
| 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()] |
| public partial class CommandSubscribe : 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, Name = @"subscription", IsRequired = true)] |
| public string Subscription { get; set; } |
| |
| [global::ProtoBuf.ProtoMember(3, IsRequired = true)] |
| public SubType Type { get; set; } |
| |
| [global::ProtoBuf.ProtoMember(4, Name = @"consumer_id", IsRequired = true)] |
| public ulong ConsumerId { get; set; } |
| |
| [global::ProtoBuf.ProtoMember(5, Name = @"request_id", IsRequired = true)] |
| public ulong RequestId { get; set; } |
| |
| [global::ProtoBuf.ProtoMember(6, Name = @"consumer_name")] |
| [global::System.ComponentModel.DefaultValue("")] |
| public string ConsumerName |
| { |
| get => __pbn__ConsumerName ?? ""; |
| set => __pbn__ConsumerName = value; |
| } |
| public bool ShouldSerializeConsumerName() => __pbn__ConsumerName != null; |
| public void ResetConsumerName() => __pbn__ConsumerName = null; |
| private string __pbn__ConsumerName; |
| |
| [global::ProtoBuf.ProtoMember(7, Name = @"priority_level")] |
| public int PriorityLevel |
| { |
| get => __pbn__PriorityLevel.GetValueOrDefault(); |
| set => __pbn__PriorityLevel = value; |
| } |
| public bool ShouldSerializePriorityLevel() => __pbn__PriorityLevel != null; |
| public void ResetPriorityLevel() => __pbn__PriorityLevel = null; |
| private int? __pbn__PriorityLevel; |
| |
| [global::ProtoBuf.ProtoMember(8, Name = @"durable")] |
| [global::System.ComponentModel.DefaultValue(true)] |
| public bool Durable |
| { |
| get => __pbn__Durable ?? true; |
| set => __pbn__Durable = value; |
| } |
| public bool ShouldSerializeDurable() => __pbn__Durable != null; |
| public void ResetDurable() => __pbn__Durable = null; |
| private bool? __pbn__Durable; |
| |
| [global::ProtoBuf.ProtoMember(9, Name = @"start_message_id")] |
| public MessageIdData StartMessageId { get; set; } |
| |
| [global::ProtoBuf.ProtoMember(10, Name = @"metadata")] |
| public global::System.Collections.Generic.List<KeyValue> Metadatas { get; } = new global::System.Collections.Generic.List<KeyValue>(); |
| |
| [global::ProtoBuf.ProtoMember(11, Name = @"read_compacted")] |
| public bool ReadCompacted |
| { |
| get => __pbn__ReadCompacted.GetValueOrDefault(); |
| set => __pbn__ReadCompacted = value; |
| } |
| public bool ShouldSerializeReadCompacted() => __pbn__ReadCompacted != null; |
| public void ResetReadCompacted() => __pbn__ReadCompacted = null; |
| private bool? __pbn__ReadCompacted; |
| |
| [global::ProtoBuf.ProtoMember(12, Name = @"schema")] |
| public Schema Schema { get; set; } |
| |
| [global::ProtoBuf.ProtoMember(13)] |
| [global::System.ComponentModel.DefaultValue(InitialPositionType.Latest)] |
| public InitialPositionType InitialPosition |
| { |
| get => __pbn__initialPosition ?? InitialPositionType.Latest; |
| set => __pbn__initialPosition = value; |
| } |
| public bool ShouldSerializeinitialPosition() => __pbn__initialPosition != null; |
| public void ResetinitialPosition() => __pbn__initialPosition = null; |
| private InitialPositionType? __pbn__initialPosition; |
| |
| [global::ProtoBuf.ProtoMember(14, Name = @"replicate_subscription_state")] |
| public bool ReplicateSubscriptionState |
| { |
| 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 |
| { |
| Exclusive = 0, |
| Shared = 1, |
| Failover = 2, |
| [global::ProtoBuf.ProtoEnum(Name = @"Key_Shared")] |
| KeyShared = 3, |
| } |
| |
| [global::ProtoBuf.ProtoContract()] |
| public enum InitialPositionType |
| { |
| Latest = 0, |
| Earliest = 1, |
| } |
| |
| } |
| |
| [global::ProtoBuf.ProtoContract()] |
| public partial class CommandPartitionedTopicMetadata : 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, Name = @"request_id", IsRequired = true)] |
| public ulong RequestId { get; set; } |
| |
| [global::ProtoBuf.ProtoMember(3, Name = @"original_principal")] |
| [global::System.ComponentModel.DefaultValue("")] |
| public string OriginalPrincipal |
| { |
| get => __pbn__OriginalPrincipal ?? ""; |
| set => __pbn__OriginalPrincipal = value; |
| } |
| public bool ShouldSerializeOriginalPrincipal() => __pbn__OriginalPrincipal != null; |
| public void ResetOriginalPrincipal() => __pbn__OriginalPrincipal = null; |
| private string __pbn__OriginalPrincipal; |
| |
| [global::ProtoBuf.ProtoMember(4, Name = @"original_auth_data")] |
| [global::System.ComponentModel.DefaultValue("")] |
| public string OriginalAuthData |
| { |
| get => __pbn__OriginalAuthData ?? ""; |
| set => __pbn__OriginalAuthData = value; |
| } |
| public bool ShouldSerializeOriginalAuthData() => __pbn__OriginalAuthData != null; |
| public void ResetOriginalAuthData() => __pbn__OriginalAuthData = null; |
| private string __pbn__OriginalAuthData; |
| |
| [global::ProtoBuf.ProtoMember(5, Name = @"original_auth_method")] |
| [global::System.ComponentModel.DefaultValue("")] |
| public string OriginalAuthMethod |
| { |
| 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()] |
| public partial class CommandPartitionedTopicMetadataResponse : 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 = @"partitions")] |
| public uint Partitions |
| { |
| get => __pbn__Partitions.GetValueOrDefault(); |
| set => __pbn__Partitions = value; |
| } |
| public bool ShouldSerializePartitions() => __pbn__Partitions != null; |
| public void ResetPartitions() => __pbn__Partitions = null; |
| private uint? __pbn__Partitions; |
| |
| [global::ProtoBuf.ProtoMember(2, Name = @"request_id", IsRequired = true)] |
| public ulong RequestId { get; set; } |
| |
| [global::ProtoBuf.ProtoMember(3, Name = @"response")] |
| [global::System.ComponentModel.DefaultValue(LookupType.Success)] |
| public LookupType Response |
| { |
| get => __pbn__Response ?? LookupType.Success; |
| set => __pbn__Response = value; |
| } |
| public bool ShouldSerializeResponse() => __pbn__Response != null; |
| public void ResetResponse() => __pbn__Response = null; |
| private LookupType? __pbn__Response; |
| |
| [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 enum LookupType |
| { |
| Success = 0, |
| Failed = 1, |
| } |
| |
| } |
| |
| [global::ProtoBuf.ProtoContract()] |
| public partial class CommandLookupTopic : 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, Name = @"request_id", IsRequired = true)] |
| public ulong RequestId { get; set; } |
| |
| [global::ProtoBuf.ProtoMember(3, Name = @"authoritative")] |
| [global::System.ComponentModel.DefaultValue(false)] |
| public bool Authoritative |
| { |
| get => __pbn__Authoritative ?? false; |
| set => __pbn__Authoritative = value; |
| } |
| public bool ShouldSerializeAuthoritative() => __pbn__Authoritative != null; |
| public void ResetAuthoritative() => __pbn__Authoritative = null; |
| private bool? __pbn__Authoritative; |
| |
| [global::ProtoBuf.ProtoMember(4, Name = @"original_principal")] |
| [global::System.ComponentModel.DefaultValue("")] |
| public string OriginalPrincipal |
| { |
| get => __pbn__OriginalPrincipal ?? ""; |
| set => __pbn__OriginalPrincipal = value; |
| } |
| public bool ShouldSerializeOriginalPrincipal() => __pbn__OriginalPrincipal != null; |
| public void ResetOriginalPrincipal() => __pbn__OriginalPrincipal = null; |
| private string __pbn__OriginalPrincipal; |
| |
| [global::ProtoBuf.ProtoMember(5, Name = @"original_auth_data")] |
| [global::System.ComponentModel.DefaultValue("")] |
| public string OriginalAuthData |
| { |
| get => __pbn__OriginalAuthData ?? ""; |
| set => __pbn__OriginalAuthData = value; |
| } |
| public bool ShouldSerializeOriginalAuthData() => __pbn__OriginalAuthData != null; |
| public void ResetOriginalAuthData() => __pbn__OriginalAuthData = null; |
| private string __pbn__OriginalAuthData; |
| |
| [global::ProtoBuf.ProtoMember(6, Name = @"original_auth_method")] |
| [global::System.ComponentModel.DefaultValue("")] |
| public string OriginalAuthMethod |
| { |
| 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()] |
| public partial class CommandLookupTopicResponse : 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)] |
| [global::System.ComponentModel.DefaultValue("")] |
| public string BrokerServiceUrl |
| { |
| get => __pbn__brokerServiceUrl ?? ""; |
| set => __pbn__brokerServiceUrl = value; |
| } |
| public bool ShouldSerializebrokerServiceUrl() => __pbn__brokerServiceUrl != null; |
| public void ResetbrokerServiceUrl() => __pbn__brokerServiceUrl = null; |
| private string __pbn__brokerServiceUrl; |
| |
| [global::ProtoBuf.ProtoMember(2)] |
| [global::System.ComponentModel.DefaultValue("")] |
| public string BrokerServiceUrlTls |
| { |
| get => __pbn__brokerServiceUrlTls ?? ""; |
| set => __pbn__brokerServiceUrlTls = value; |
| } |
| public bool ShouldSerializebrokerServiceUrlTls() => __pbn__brokerServiceUrlTls != null; |
| public void ResetbrokerServiceUrlTls() => __pbn__brokerServiceUrlTls = null; |
| private string __pbn__brokerServiceUrlTls; |
| |
| [global::ProtoBuf.ProtoMember(3, Name = @"response")] |
| [global::System.ComponentModel.DefaultValue(LookupType.Redirect)] |
| public LookupType Response |
| { |
| get => __pbn__Response ?? LookupType.Redirect; |
| set => __pbn__Response = value; |
| } |
| public bool ShouldSerializeResponse() => __pbn__Response != null; |
| public void ResetResponse() => __pbn__Response = null; |
| private LookupType? __pbn__Response; |
| |
| [global::ProtoBuf.ProtoMember(4, Name = @"request_id", IsRequired = true)] |
| public ulong RequestId { get; set; } |
| |
| [global::ProtoBuf.ProtoMember(5, Name = @"authoritative")] |
| [global::System.ComponentModel.DefaultValue(false)] |
| public bool Authoritative |
| { |
| get => __pbn__Authoritative ?? false; |
| set => __pbn__Authoritative = value; |
| } |
| public bool ShouldSerializeAuthoritative() => __pbn__Authoritative != null; |
| public void ResetAuthoritative() => __pbn__Authoritative = null; |
| private bool? __pbn__Authoritative; |
| |
| [global::ProtoBuf.ProtoMember(6, 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(7, 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(8, Name = @"proxy_through_service_url")] |
| [global::System.ComponentModel.DefaultValue(false)] |
| public bool ProxyThroughServiceUrl |
| { |
| get => __pbn__ProxyThroughServiceUrl ?? false; |
| set => __pbn__ProxyThroughServiceUrl = value; |
| } |
| public bool ShouldSerializeProxyThroughServiceUrl() => __pbn__ProxyThroughServiceUrl != null; |
| public void ResetProxyThroughServiceUrl() => __pbn__ProxyThroughServiceUrl = null; |
| private bool? __pbn__ProxyThroughServiceUrl; |
| |
| [global::ProtoBuf.ProtoContract()] |
| public enum LookupType |
| { |
| Redirect = 0, |
| Connect = 1, |
| Failed = 2, |
| } |
| |
| } |
| |
| [global::ProtoBuf.ProtoContract()] |
| public partial class CommandProducer : 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, Name = @"producer_id", IsRequired = true)] |
| public ulong ProducerId { get; set; } |
| |
| [global::ProtoBuf.ProtoMember(3, Name = @"request_id", IsRequired = true)] |
| public ulong RequestId { get; set; } |
| |
| [global::ProtoBuf.ProtoMember(4, Name = @"producer_name")] |
| [global::System.ComponentModel.DefaultValue("")] |
| public string ProducerName |
| { |
| get => __pbn__ProducerName ?? ""; |
| set => __pbn__ProducerName = value; |
| } |
| public bool ShouldSerializeProducerName() => __pbn__ProducerName != null; |
| public void ResetProducerName() => __pbn__ProducerName = null; |
| private string __pbn__ProducerName; |
| |
| [global::ProtoBuf.ProtoMember(5, Name = @"encrypted")] |
| [global::System.ComponentModel.DefaultValue(false)] |
| public bool Encrypted |
| { |
| get => __pbn__Encrypted ?? false; |
| set => __pbn__Encrypted = value; |
| } |
| public bool ShouldSerializeEncrypted() => __pbn__Encrypted != null; |
| public void ResetEncrypted() => __pbn__Encrypted = null; |
| private bool? __pbn__Encrypted; |
| |
| [global::ProtoBuf.ProtoMember(6, Name = @"metadata")] |
| public global::System.Collections.Generic.List<KeyValue> Metadatas { get; } = new global::System.Collections.Generic.List<KeyValue>(); |
| |
| [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()] |
| public partial class CommandSend : 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 = @"producer_id", IsRequired = true)] |
| public ulong ProducerId { get; set; } |
| |
| [global::ProtoBuf.ProtoMember(2, Name = @"sequence_id", IsRequired = true)] |
| public ulong SequenceId { get; set; } |
| |
| [global::ProtoBuf.ProtoMember(3, Name = @"num_messages")] |
| [global::System.ComponentModel.DefaultValue(1)] |
| public int NumMessages |
| { |
| 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()] |
| public partial class CommandSendReceipt : 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 = @"producer_id", IsRequired = true)] |
| public ulong ProducerId { get; set; } |
| |
| [global::ProtoBuf.ProtoMember(2, Name = @"sequence_id", IsRequired = true)] |
| public ulong SequenceId { get; set; } |
| |
| [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()] |
| public partial class CommandSendError : 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 = @"producer_id", IsRequired = true)] |
| public ulong ProducerId { get; set; } |
| |
| [global::ProtoBuf.ProtoMember(2, Name = @"sequence_id", IsRequired = true)] |
| public ulong SequenceId { get; set; } |
| |
| [global::ProtoBuf.ProtoMember(3, Name = @"error", IsRequired = true)] |
| public ServerError Error { get; set; } |
| |
| [global::ProtoBuf.ProtoMember(4, Name = @"message", IsRequired = true)] |
| public string Message { get; set; } |
| |
| } |
| |
| [global::ProtoBuf.ProtoContract()] |
| public partial class CommandMessage : 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 = @"message_id", IsRequired = true)] |
| public MessageIdData MessageId { get; set; } |
| |
| [global::ProtoBuf.ProtoMember(3, Name = @"redelivery_count")] |
| [global::System.ComponentModel.DefaultValue(0)] |
| public uint RedeliveryCount |
| { |
| 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()] |
| public partial class CommandAck : 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, IsRequired = true)] |
| 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>(); |
| |
| [global::ProtoBuf.ProtoMember(4)] |
| [global::System.ComponentModel.DefaultValue(ValidationErrorType.UncompressedSizeCorruption)] |
| public ValidationErrorType ValidationError |
| { |
| 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 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 |
| { |
| Individual = 0, |
| Cumulative = 1, |
| } |
| |
| [global::ProtoBuf.ProtoContract()] |
| public enum ValidationErrorType |
| { |
| UncompressedSizeCorruption = 0, |
| DecompressionError = 1, |
| ChecksumMismatch = 2, |
| 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()] |
| public partial class CommandActiveConsumerChange : 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 = @"is_active")] |
| [global::System.ComponentModel.DefaultValue(false)] |
| public bool IsActive |
| { |
| 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()] |
| public partial class CommandFlow : 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, IsRequired = true)] |
| public uint MessagePermits { get; set; } |
| |
| } |
| |
| [global::ProtoBuf.ProtoContract()] |
| public partial class CommandUnsubscribe : 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 = @"request_id", IsRequired = true)] |
| public ulong RequestId { get; set; } |
| |
| } |
| |
| [global::ProtoBuf.ProtoContract()] |
| public partial class CommandSeek : 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 = @"request_id", IsRequired = true)] |
| public ulong RequestId { get; set; } |
| |
| [global::ProtoBuf.ProtoMember(3, Name = @"message_id")] |
| public MessageIdData MessageId { get; set; } |
| |
| [global::ProtoBuf.ProtoMember(4, Name = @"message_publish_time")] |
| public ulong MessagePublishTime |
| { |
| 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()] |
| public partial class CommandReachedEndOfTopic : 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.ProtoContract()] |
| public partial class CommandCloseProducer : 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 = @"producer_id", IsRequired = true)] |
| public ulong ProducerId { get; set; } |
| |
| [global::ProtoBuf.ProtoMember(2, Name = @"request_id", IsRequired = true)] |
| public ulong RequestId { get; set; } |
| |
| } |
| |
| [global::ProtoBuf.ProtoContract()] |
| public partial class CommandCloseConsumer : 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 = @"request_id", IsRequired = true)] |
| public ulong RequestId { get; set; } |
| |
| } |
| |
| [global::ProtoBuf.ProtoContract()] |
| public partial class CommandRedeliverUnacknowledgedMessages : 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 = @"message_ids")] |
| public global::System.Collections.Generic.List<MessageIdData> MessageIds { get; } = new global::System.Collections.Generic.List<MessageIdData>(); |
| |
| } |
| |
| [global::ProtoBuf.ProtoContract()] |
| public partial class CommandSuccess : 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 = @"schema")] |
| public Schema Schema { get; set; } |
| |
| } |
| |
| [global::ProtoBuf.ProtoContract()] |
| public partial class CommandProducerSuccess : 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 = @"producer_name", IsRequired = true)] |
| public string ProducerName { get; set; } |
| |
| [global::ProtoBuf.ProtoMember(3, Name = @"last_sequence_id")] |
| [global::System.ComponentModel.DefaultValue(-1)] |
| public long LastSequenceId |
| { |
| get => __pbn__LastSequenceId ?? -1; |
| set => __pbn__LastSequenceId = value; |
| } |
| public bool ShouldSerializeLastSequenceId() => __pbn__LastSequenceId != null; |
| public void ResetLastSequenceId() => __pbn__LastSequenceId = null; |
| private long? __pbn__LastSequenceId; |
| |
| [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 CommandError : 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", IsRequired = true)] |
| public ServerError Error { get; set; } |
| |
| [global::ProtoBuf.ProtoMember(3, Name = @"message", IsRequired = true)] |
| public string Message { get; set; } |
| |
| } |
| |
| [global::ProtoBuf.ProtoContract()] |
| public partial class CommandPing : 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.ProtoContract()] |
| public partial class CommandPong : 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.ProtoContract()] |
| public partial class CommandConsumerStats : 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(4, Name = @"consumer_id", IsRequired = true)] |
| public ulong ConsumerId { get; set; } |
| |
| } |
| |
| [global::ProtoBuf.ProtoContract()] |
| public partial class CommandConsumerStatsResponse : 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)] |
| public double MsgRateOut |
| { |
| get => __pbn__msgRateOut.GetValueOrDefault(); |
| set => __pbn__msgRateOut = value; |
| } |
| public bool ShouldSerializemsgRateOut() => __pbn__msgRateOut != null; |
| public void ResetmsgRateOut() => __pbn__msgRateOut = null; |
| private double? __pbn__msgRateOut; |
| |
| [global::ProtoBuf.ProtoMember(5)] |
| public double MsgThroughputOut |
| { |
| get => __pbn__msgThroughputOut.GetValueOrDefault(); |
| set => __pbn__msgThroughputOut = value; |
| } |
| public bool ShouldSerializemsgThroughputOut() => __pbn__msgThroughputOut != null; |
| public void ResetmsgThroughputOut() => __pbn__msgThroughputOut = null; |
| private double? __pbn__msgThroughputOut; |
| |
| [global::ProtoBuf.ProtoMember(6)] |
| public double MsgRateRedeliver |
| { |
| get => __pbn__msgRateRedeliver.GetValueOrDefault(); |
| set => __pbn__msgRateRedeliver = value; |
| } |
| public bool ShouldSerializemsgRateRedeliver() => __pbn__msgRateRedeliver != null; |
| public void ResetmsgRateRedeliver() => __pbn__msgRateRedeliver = null; |
| private double? __pbn__msgRateRedeliver; |
| |
| [global::ProtoBuf.ProtoMember(7)] |
| [global::System.ComponentModel.DefaultValue("")] |
| public string ConsumerName |
| { |
| get => __pbn__consumerName ?? ""; |
| set => __pbn__consumerName = value; |
| } |
| public bool ShouldSerializeconsumerName() => __pbn__consumerName != null; |
| public void ResetconsumerName() => __pbn__consumerName = null; |
| private string __pbn__consumerName; |
| |
| [global::ProtoBuf.ProtoMember(8)] |
| public ulong AvailablePermits |
| { |
| get => __pbn__availablePermits.GetValueOrDefault(); |
| set => __pbn__availablePermits = value; |
| } |
| public bool ShouldSerializeavailablePermits() => __pbn__availablePermits != null; |
| public void ResetavailablePermits() => __pbn__availablePermits = null; |
| private ulong? __pbn__availablePermits; |
| |
| [global::ProtoBuf.ProtoMember(9)] |
| public ulong UnackedMessages |
| { |
| get => __pbn__unackedMessages.GetValueOrDefault(); |
| set => __pbn__unackedMessages = value; |
| } |
| public bool ShouldSerializeunackedMessages() => __pbn__unackedMessages != null; |
| public void ResetunackedMessages() => __pbn__unackedMessages = null; |
| private ulong? __pbn__unackedMessages; |
| |
| [global::ProtoBuf.ProtoMember(10)] |
| public bool BlockedConsumerOnUnackedMsgs |
| { |
| get => __pbn__blockedConsumerOnUnackedMsgs.GetValueOrDefault(); |
| set => __pbn__blockedConsumerOnUnackedMsgs = value; |
| } |
| public bool ShouldSerializeblockedConsumerOnUnackedMsgs() => __pbn__blockedConsumerOnUnackedMsgs != null; |
| public void ResetblockedConsumerOnUnackedMsgs() => __pbn__blockedConsumerOnUnackedMsgs = null; |
| private bool? __pbn__blockedConsumerOnUnackedMsgs; |
| |
| [global::ProtoBuf.ProtoMember(11, Name = @"address")] |
| [global::System.ComponentModel.DefaultValue("")] |
| public string Address |
| { |
| get => __pbn__Address ?? ""; |
| set => __pbn__Address = value; |
| } |
| public bool ShouldSerializeAddress() => __pbn__Address != null; |
| public void ResetAddress() => __pbn__Address = null; |
| private string __pbn__Address; |
| |
| [global::ProtoBuf.ProtoMember(12)] |
| [global::System.ComponentModel.DefaultValue("")] |
| public string ConnectedSince |
| { |
| get => __pbn__connectedSince ?? ""; |
| set => __pbn__connectedSince = value; |
| } |
| public bool ShouldSerializeconnectedSince() => __pbn__connectedSince != null; |
| public void ResetconnectedSince() => __pbn__connectedSince = null; |
| private string __pbn__connectedSince; |
| |
| [global::ProtoBuf.ProtoMember(13, Name = @"type")] |
| [global::System.ComponentModel.DefaultValue("")] |
| public string Type |
| { |
| get => __pbn__Type ?? ""; |
| set => __pbn__Type = value; |
| } |
| public bool ShouldSerializeType() => __pbn__Type != null; |
| public void ResetType() => __pbn__Type = null; |
| private string __pbn__Type; |
| |
| [global::ProtoBuf.ProtoMember(14)] |
| public double MsgRateExpired |
| { |
| get => __pbn__msgRateExpired.GetValueOrDefault(); |
| set => __pbn__msgRateExpired = value; |
| } |
| public bool ShouldSerializemsgRateExpired() => __pbn__msgRateExpired != null; |
| public void ResetmsgRateExpired() => __pbn__msgRateExpired = null; |
| private double? __pbn__msgRateExpired; |
| |
| [global::ProtoBuf.ProtoMember(15)] |
| public ulong MsgBacklog |
| { |
| 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()] |
| public partial class CommandGetLastMessageId : 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 = @"request_id", IsRequired = true)] |
| public ulong RequestId { get; set; } |
| |
| } |
| |
| [global::ProtoBuf.ProtoContract()] |
| public partial class CommandGetLastMessageIdResponse : 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 = @"last_message_id", IsRequired = true)] |
| public MessageIdData LastMessageId { get; set; } |
| |
| [global::ProtoBuf.ProtoMember(2, Name = @"request_id", IsRequired = true)] |
| public ulong RequestId { get; set; } |
| |
| } |
| |
| [global::ProtoBuf.ProtoContract()] |
| public partial class CommandGetTopicsOfNamespace : 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 = @"namespace", IsRequired = true)] |
| public string Namespace { get; set; } |
| |
| [global::ProtoBuf.ProtoMember(3)] |
| [global::System.ComponentModel.DefaultValue(ModeType.Persistent)] |
| public ModeType Mode |
| { |
| get => __pbn__mode ?? ModeType.Persistent; |
| set => __pbn__mode = value; |
| } |
| public bool ShouldSerializemode() => __pbn__mode != null; |
| public void Resetmode() => __pbn__mode = null; |
| private ModeType? __pbn__mode; |
| |
| [global::ProtoBuf.ProtoContract()] |
| public enum ModeType |
| { |
| [global::ProtoBuf.ProtoEnum(Name = @"PERSISTENT")] |
| Persistent = 0, |
| [global::ProtoBuf.ProtoEnum(Name = @"NON_PERSISTENT")] |
| NonPersistent = 1, |
| [global::ProtoBuf.ProtoEnum(Name = @"ALL")] |
| All = 2, |
| } |
| |
| } |
| |
| [global::ProtoBuf.ProtoContract()] |
| public partial class CommandGetTopicsOfNamespaceResponse : 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 = @"topics")] |
| public global::System.Collections.Generic.List<string> Topics { get; } = new global::System.Collections.Generic.List<string>(); |
| |
| } |
| |
| [global::ProtoBuf.ProtoContract()] |
| public partial class CommandGetSchema : 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_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 CommandGetSchemaResponse : 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")] |
| public Schema Schema { get; set; } |
| |
| [global::ProtoBuf.ProtoMember(5, 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 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()] |
| public partial class BaseCommand : 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 Type CommandType { get; set; } = Type.Connect; |
| |
| [global::ProtoBuf.ProtoMember(2, Name = @"connect")] |
| public CommandConnect Connect { get; set; } |
| |
| [global::ProtoBuf.ProtoMember(3, Name = @"connected")] |
| public CommandConnected Connected { get; set; } |
| |
| [global::ProtoBuf.ProtoMember(4, Name = @"subscribe")] |
| public CommandSubscribe Subscribe { get; set; } |
| |
| [global::ProtoBuf.ProtoMember(5, Name = @"producer")] |
| public CommandProducer Producer { get; set; } |
| |
| [global::ProtoBuf.ProtoMember(6, Name = @"send")] |
| public CommandSend Send { get; set; } |
| |
| [global::ProtoBuf.ProtoMember(7, Name = @"send_receipt")] |
| public CommandSendReceipt SendReceipt { get; set; } |
| |
| [global::ProtoBuf.ProtoMember(8, Name = @"send_error")] |
| public CommandSendError SendError { get; set; } |
| |
| [global::ProtoBuf.ProtoMember(9, Name = @"message")] |
| public CommandMessage Message { get; set; } |
| |
| [global::ProtoBuf.ProtoMember(10, Name = @"ack")] |
| public CommandAck Ack { get; set; } |
| |
| [global::ProtoBuf.ProtoMember(11, Name = @"flow")] |
| public CommandFlow Flow { get; set; } |
| |
| [global::ProtoBuf.ProtoMember(12, Name = @"unsubscribe")] |
| public CommandUnsubscribe Unsubscribe { get; set; } |
| |
| [global::ProtoBuf.ProtoMember(13, Name = @"success")] |
| public CommandSuccess Success { get; set; } |
| |
| [global::ProtoBuf.ProtoMember(14, Name = @"error")] |
| public CommandError Error { get; set; } |
| |
| [global::ProtoBuf.ProtoMember(15, Name = @"close_producer")] |
| public CommandCloseProducer CloseProducer { get; set; } |
| |
| [global::ProtoBuf.ProtoMember(16, Name = @"close_consumer")] |
| public CommandCloseConsumer CloseConsumer { get; set; } |
| |
| [global::ProtoBuf.ProtoMember(17, Name = @"producer_success")] |
| public CommandProducerSuccess ProducerSuccess { get; set; } |
| |
| [global::ProtoBuf.ProtoMember(18, Name = @"ping")] |
| public CommandPing Ping { get; set; } |
| |
| [global::ProtoBuf.ProtoMember(19, Name = @"pong")] |
| public CommandPong Pong { get; set; } |
| |
| [global::ProtoBuf.ProtoMember(20)] |
| public CommandRedeliverUnacknowledgedMessages RedeliverUnacknowledgedMessages { get; set; } |
| |
| [global::ProtoBuf.ProtoMember(21)] |
| public CommandPartitionedTopicMetadata PartitionMetadata { get; set; } |
| |
| [global::ProtoBuf.ProtoMember(22)] |
| public CommandPartitionedTopicMetadataResponse PartitionMetadataResponse { get; set; } |
| |
| [global::ProtoBuf.ProtoMember(23)] |
| public CommandLookupTopic LookupTopic { get; set; } |
| |
| [global::ProtoBuf.ProtoMember(24)] |
| public CommandLookupTopicResponse LookupTopicResponse { get; set; } |
| |
| [global::ProtoBuf.ProtoMember(25)] |
| public CommandConsumerStats ConsumerStats { get; set; } |
| |
| [global::ProtoBuf.ProtoMember(26)] |
| public CommandConsumerStatsResponse ConsumerStatsResponse { get; set; } |
| |
| [global::ProtoBuf.ProtoMember(27)] |
| public CommandReachedEndOfTopic ReachedEndOfTopic { get; set; } |
| |
| [global::ProtoBuf.ProtoMember(28, Name = @"seek")] |
| public CommandSeek Seek { get; set; } |
| |
| [global::ProtoBuf.ProtoMember(29)] |
| public CommandGetLastMessageId GetLastMessageId { get; set; } |
| |
| [global::ProtoBuf.ProtoMember(30)] |
| public CommandGetLastMessageIdResponse GetLastMessageIdResponse { get; set; } |
| |
| [global::ProtoBuf.ProtoMember(31, Name = @"active_consumer_change")] |
| public CommandActiveConsumerChange ActiveConsumerChange { get; set; } |
| |
| [global::ProtoBuf.ProtoMember(32)] |
| public CommandGetTopicsOfNamespace GetTopicsOfNamespace { get; set; } |
| |
| [global::ProtoBuf.ProtoMember(33)] |
| public CommandGetTopicsOfNamespaceResponse GetTopicsOfNamespaceResponse { get; set; } |
| |
| [global::ProtoBuf.ProtoMember(34)] |
| public CommandGetSchema GetSchema { get; set; } |
| |
| [global::ProtoBuf.ProtoMember(35)] |
| public CommandGetSchemaResponse GetSchemaResponse { get; set; } |
| |
| [global::ProtoBuf.ProtoMember(36)] |
| public CommandAuthChallenge AuthChallenge { get; set; } |
| |
| [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 |
| { |
| [global::ProtoBuf.ProtoEnum(Name = @"CONNECT")] |
| Connect = 2, |
| [global::ProtoBuf.ProtoEnum(Name = @"CONNECTED")] |
| Connected = 3, |
| [global::ProtoBuf.ProtoEnum(Name = @"SUBSCRIBE")] |
| Subscribe = 4, |
| [global::ProtoBuf.ProtoEnum(Name = @"PRODUCER")] |
| Producer = 5, |
| [global::ProtoBuf.ProtoEnum(Name = @"SEND")] |
| Send = 6, |
| [global::ProtoBuf.ProtoEnum(Name = @"SEND_RECEIPT")] |
| SendReceipt = 7, |
| [global::ProtoBuf.ProtoEnum(Name = @"SEND_ERROR")] |
| SendError = 8, |
| [global::ProtoBuf.ProtoEnum(Name = @"MESSAGE")] |
| Message = 9, |
| [global::ProtoBuf.ProtoEnum(Name = @"ACK")] |
| Ack = 10, |
| [global::ProtoBuf.ProtoEnum(Name = @"FLOW")] |
| Flow = 11, |
| [global::ProtoBuf.ProtoEnum(Name = @"UNSUBSCRIBE")] |
| Unsubscribe = 12, |
| [global::ProtoBuf.ProtoEnum(Name = @"SUCCESS")] |
| Success = 13, |
| [global::ProtoBuf.ProtoEnum(Name = @"ERROR")] |
| Error = 14, |
| [global::ProtoBuf.ProtoEnum(Name = @"CLOSE_PRODUCER")] |
| CloseProducer = 15, |
| [global::ProtoBuf.ProtoEnum(Name = @"CLOSE_CONSUMER")] |
| CloseConsumer = 16, |
| [global::ProtoBuf.ProtoEnum(Name = @"PRODUCER_SUCCESS")] |
| ProducerSuccess = 17, |
| [global::ProtoBuf.ProtoEnum(Name = @"PING")] |
| Ping = 18, |
| [global::ProtoBuf.ProtoEnum(Name = @"PONG")] |
| Pong = 19, |
| [global::ProtoBuf.ProtoEnum(Name = @"REDELIVER_UNACKNOWLEDGED_MESSAGES")] |
| RedeliverUnacknowledgedMessages = 20, |
| [global::ProtoBuf.ProtoEnum(Name = @"PARTITIONED_METADATA")] |
| PartitionedMetadata = 21, |
| [global::ProtoBuf.ProtoEnum(Name = @"PARTITIONED_METADATA_RESPONSE")] |
| PartitionedMetadataResponse = 22, |
| [global::ProtoBuf.ProtoEnum(Name = @"LOOKUP")] |
| Lookup = 23, |
| [global::ProtoBuf.ProtoEnum(Name = @"LOOKUP_RESPONSE")] |
| LookupResponse = 24, |
| [global::ProtoBuf.ProtoEnum(Name = @"CONSUMER_STATS")] |
| ConsumerStats = 25, |
| [global::ProtoBuf.ProtoEnum(Name = @"CONSUMER_STATS_RESPONSE")] |
| ConsumerStatsResponse = 26, |
| [global::ProtoBuf.ProtoEnum(Name = @"REACHED_END_OF_TOPIC")] |
| ReachedEndOfTopic = 27, |
| [global::ProtoBuf.ProtoEnum(Name = @"SEEK")] |
| Seek = 28, |
| [global::ProtoBuf.ProtoEnum(Name = @"GET_LAST_MESSAGE_ID")] |
| GetLastMessageId = 29, |
| [global::ProtoBuf.ProtoEnum(Name = @"GET_LAST_MESSAGE_ID_RESPONSE")] |
| GetLastMessageIdResponse = 30, |
| [global::ProtoBuf.ProtoEnum(Name = @"ACTIVE_CONSUMER_CHANGE")] |
| ActiveConsumerChange = 31, |
| [global::ProtoBuf.ProtoEnum(Name = @"GET_TOPICS_OF_NAMESPACE")] |
| GetTopicsOfNamespace = 32, |
| [global::ProtoBuf.ProtoEnum(Name = @"GET_TOPICS_OF_NAMESPACE_RESPONSE")] |
| GetTopicsOfNamespaceResponse = 33, |
| [global::ProtoBuf.ProtoEnum(Name = @"GET_SCHEMA")] |
| GetSchema = 34, |
| [global::ProtoBuf.ProtoEnum(Name = @"GET_SCHEMA_RESPONSE")] |
| GetSchemaResponse = 35, |
| [global::ProtoBuf.ProtoEnum(Name = @"AUTH_CHALLENGE")] |
| 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()] |
| public enum CompressionType |
| { |
| [global::ProtoBuf.ProtoEnum(Name = @"NONE")] |
| None = 0, |
| [global::ProtoBuf.ProtoEnum(Name = @"LZ4")] |
| Lz4 = 1, |
| [global::ProtoBuf.ProtoEnum(Name = @"ZLIB")] |
| Zlib = 2, |
| [global::ProtoBuf.ProtoEnum(Name = @"ZSTD")] |
| Zstd = 3, |
| [global::ProtoBuf.ProtoEnum(Name = @"SNAPPY")] |
| Snappy = 4, |
| } |
| |
| [global::ProtoBuf.ProtoContract()] |
| public enum ServerError |
| { |
| UnknownError = 0, |
| MetadataError = 1, |
| PersistenceError = 2, |
| AuthenticationError = 3, |
| AuthorizationError = 4, |
| ConsumerBusy = 5, |
| ServiceNotReady = 6, |
| ProducerBlockedQuotaExceededError = 7, |
| ProducerBlockedQuotaExceededException = 8, |
| ChecksumError = 9, |
| UnsupportedVersionError = 10, |
| TopicNotFound = 11, |
| SubscriptionNotFound = 12, |
| ConsumerNotFound = 13, |
| TooManyRequests = 14, |
| TopicTerminatedError = 15, |
| ProducerBusy = 16, |
| InvalidTopicName = 17, |
| IncompatibleSchema = 18, |
| ConsumerAssignError = 19, |
| TransactionCoordinatorNotFound = 20, |
| InvalidTxnStatus = 21, |
| NotAllowedError = 22, |
| TransactionConflict = 23, |
| } |
| |
| [global::ProtoBuf.ProtoContract()] |
| public enum AuthMethod |
| { |
| AuthMethodNone = 0, |
| AuthMethodYcaV1 = 1, |
| AuthMethodAthens = 2, |
| } |
| |
| [global::ProtoBuf.ProtoContract()] |
| public enum ProtocolVersion |
| { |
| [global::ProtoBuf.ProtoEnum(Name = @"v0")] |
| V0 = 0, |
| [global::ProtoBuf.ProtoEnum(Name = @"v1")] |
| V1 = 1, |
| [global::ProtoBuf.ProtoEnum(Name = @"v2")] |
| V2 = 2, |
| [global::ProtoBuf.ProtoEnum(Name = @"v3")] |
| V3 = 3, |
| [global::ProtoBuf.ProtoEnum(Name = @"v4")] |
| V4 = 4, |
| [global::ProtoBuf.ProtoEnum(Name = @"v5")] |
| V5 = 5, |
| [global::ProtoBuf.ProtoEnum(Name = @"v6")] |
| V6 = 6, |
| [global::ProtoBuf.ProtoEnum(Name = @"v7")] |
| V7 = 7, |
| [global::ProtoBuf.ProtoEnum(Name = @"v8")] |
| V8 = 8, |
| [global::ProtoBuf.ProtoEnum(Name = @"v9")] |
| V9 = 9, |
| [global::ProtoBuf.ProtoEnum(Name = @"v10")] |
| V10 = 10, |
| [global::ProtoBuf.ProtoEnum(Name = @"v11")] |
| V11 = 11, |
| [global::ProtoBuf.ProtoEnum(Name = @"v12")] |
| V12 = 12, |
| [global::ProtoBuf.ProtoEnum(Name = @"v13")] |
| 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 CS0612, CS0618, CS1591, CS3021, IDE0079, IDE1006, RCS1036, RCS1057, RCS1085, RCS1192 |
| #endregion |
| #nullable restore |