src/DotPulsar/Internal/PulsarApi/GeneratedCode.cs

/*
 * 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