blob: e5ca9aaeda793efd026552e76cb44b8073c778cf [file] [log] [blame]
/*
* 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