Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Fix seek chunked messages #205

Merged
merged 3 commits into from
Mar 9, 2022
Merged

Fix seek chunked messages #205

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
3 commits
Select commit Hold shift + click to select a range
ed52431
fix seek chunked messages
RobertIndie Mar 2, 2022
edc77a4
Update pulsar proto and add serialization
RobertIndie Mar 9, 2022
0614b34
Refactoring
Lanayx Mar 9, 2022
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
132 changes: 132 additions & 0 deletions src/Pulsar.Client.Proto/Generated.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -104,6 +104,9 @@ internal int BatchSize
internal void ResetBatchSize() => __pbn__BatchSize = null;
private int? __pbn__BatchSize;

[global::ProtoBuf.ProtoMember(7, Name = @"first_chunk_message_id")]
internal MessageIdData FirstChunkMessageId { get; set; }

}

[global::ProtoBuf.ProtoContract()]
Expand Down Expand Up @@ -689,6 +692,17 @@ internal bool SupportsBrokerEntryMetadata
internal void ResetSupportsBrokerEntryMetadata() => __pbn__SupportsBrokerEntryMetadata = null;
private bool? __pbn__SupportsBrokerEntryMetadata;

[global::ProtoBuf.ProtoMember(3, Name = @"supports_partial_producer")]
[global::System.ComponentModel.DefaultValue(false)]
internal bool SupportsPartialProducer
{
get => __pbn__SupportsPartialProducer ?? false;
set => __pbn__SupportsPartialProducer = value;
}
internal bool ShouldSerializeSupportsPartialProducer() => __pbn__SupportsPartialProducer != null;
internal void ResetSupportsPartialProducer() => __pbn__SupportsPartialProducer = null;
private bool? __pbn__SupportsPartialProducer;

}

[global::ProtoBuf.ProtoContract()]
Expand Down Expand Up @@ -967,6 +981,19 @@ internal ulong StartMessageRollbackDurationSec
[global::ProtoBuf.ProtoMember(17)]
internal KeySharedMeta keySharedMeta { get; set; }

[global::ProtoBuf.ProtoMember(18, Name = @"subscription_properties")]
internal global::System.Collections.Generic.List<KeyValue> SubscriptionProperties { get; } = new global::System.Collections.Generic.List<KeyValue>();

[global::ProtoBuf.ProtoMember(19, Name = @"consumer_epoch")]
internal ulong ConsumerEpoch
{
get => __pbn__ConsumerEpoch.GetValueOrDefault();
set => __pbn__ConsumerEpoch = value;
}
internal bool ShouldSerializeConsumerEpoch() => __pbn__ConsumerEpoch != null;
internal void ResetConsumerEpoch() => __pbn__ConsumerEpoch = null;
private ulong? __pbn__ConsumerEpoch;

[global::ProtoBuf.ProtoContract()]
internal enum SubType
{
Expand Down Expand Up @@ -1350,6 +1377,28 @@ internal ulong TopicEpoch
internal void ResetTopicEpoch() => __pbn__TopicEpoch = null;
private ulong? __pbn__TopicEpoch;

[global::ProtoBuf.ProtoMember(12, Name = @"txn_enabled")]
[global::System.ComponentModel.DefaultValue(false)]
internal bool TxnEnabled
{
get => __pbn__TxnEnabled ?? false;
set => __pbn__TxnEnabled = value;
}
internal bool ShouldSerializeTxnEnabled() => __pbn__TxnEnabled != null;
internal void ResetTxnEnabled() => __pbn__TxnEnabled = null;
private bool? __pbn__TxnEnabled;

[global::ProtoBuf.ProtoMember(13, Name = @"initial_subscription_name")]
[global::System.ComponentModel.DefaultValue("")]
internal string InitialSubscriptionName
{
get => __pbn__InitialSubscriptionName ?? "";
set => __pbn__InitialSubscriptionName = value;
}
internal bool ShouldSerializeInitialSubscriptionName() => __pbn__InitialSubscriptionName != null;
internal void ResetInitialSubscriptionName() => __pbn__InitialSubscriptionName = null;
private string __pbn__InitialSubscriptionName;

}

[global::ProtoBuf.ProtoContract()]
Expand Down Expand Up @@ -1510,6 +1559,16 @@ internal uint RedeliveryCount
[global::ProtoBuf.ProtoMember(4, Name = @"ack_set")]
internal long[] AckSets { get; set; }

[global::ProtoBuf.ProtoMember(5, Name = @"consumer_epoch")]
internal ulong ConsumerEpoch
{
get => __pbn__ConsumerEpoch.GetValueOrDefault();
set => __pbn__ConsumerEpoch = value;
}
internal bool ShouldSerializeConsumerEpoch() => __pbn__ConsumerEpoch != null;
internal void ResetConsumerEpoch() => __pbn__ConsumerEpoch = null;
private ulong? __pbn__ConsumerEpoch;

}

[global::ProtoBuf.ProtoContract()]
Expand Down Expand Up @@ -1795,6 +1854,16 @@ internal partial class CommandRedeliverUnacknowledgedMessages : global::ProtoBuf
[global::ProtoBuf.ProtoMember(2, Name = @"message_ids")]
internal global::System.Collections.Generic.List<MessageIdData> MessageIds { get; } = new global::System.Collections.Generic.List<MessageIdData>();

[global::ProtoBuf.ProtoMember(3, Name = @"consumer_epoch")]
internal ulong ConsumerEpoch
{
get => __pbn__ConsumerEpoch.GetValueOrDefault();
set => __pbn__ConsumerEpoch = value;
}
internal bool ShouldSerializeConsumerEpoch() => __pbn__ConsumerEpoch != null;
internal void ResetConsumerEpoch() => __pbn__ConsumerEpoch = null;
private ulong? __pbn__ConsumerEpoch;

}

[global::ProtoBuf.ProtoContract()]
Expand Down Expand Up @@ -2297,6 +2366,55 @@ internal byte[] SchemaVersion

}

[global::ProtoBuf.ProtoContract()]
internal partial class CommandTcClientConnectRequest : 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)]
internal ulong RequestId { get; set; }

[global::ProtoBuf.ProtoMember(2, Name = @"tc_id", IsRequired = true)]
internal ulong TcId { get; set; }

}

[global::ProtoBuf.ProtoContract()]
internal partial class CommandTcClientConnectResponse : 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)]
internal ulong RequestId { get; set; }

[global::ProtoBuf.ProtoMember(2, Name = @"error")]
[global::System.ComponentModel.DefaultValue(ServerError.UnknownError)]
internal ServerError Error
{
get => __pbn__Error ?? ServerError.UnknownError;
set => __pbn__Error = value;
}
internal bool ShouldSerializeError() => __pbn__Error != null;
internal void ResetError() => __pbn__Error = null;
private ServerError? __pbn__Error;

[global::ProtoBuf.ProtoMember(3, Name = @"message")]
[global::System.ComponentModel.DefaultValue("")]
internal string Message
{
get => __pbn__Message ?? "";
set => __pbn__Message = value;
}
internal bool ShouldSerializeMessage() => __pbn__Message != null;
internal void ResetMessage() => __pbn__Message = null;
private string __pbn__Message;

}

[global::ProtoBuf.ProtoContract()]
internal partial class CommandNewTxn : global::ProtoBuf.IExtensible
{
Expand Down Expand Up @@ -3088,6 +3206,12 @@ internal partial class BaseCommand : global::ProtoBuf.IExtensible
[global::ProtoBuf.ProtoMember(61)]
internal CommandEndTxnOnSubscriptionResponse endTxnOnSubscriptionResponse { get; set; }

[global::ProtoBuf.ProtoMember(62)]
internal CommandTcClientConnectRequest tcClientConnectRequest { get; set; }

[global::ProtoBuf.ProtoMember(63)]
internal CommandTcClientConnectResponse tcClientConnectResponse { get; set; }

[global::ProtoBuf.ProtoContract()]
internal enum Type
{
Expand Down Expand Up @@ -3193,6 +3317,10 @@ internal enum Type
EndTxnOnSubscription = 60,
[global::ProtoBuf.ProtoEnum(Name = @"END_TXN_ON_SUBSCRIPTION_RESPONSE")]
EndTxnOnSubscriptionResponse = 61,
[global::ProtoBuf.ProtoEnum(Name = @"TC_CLIENT_CONNECT_REQUEST")]
TcClientConnectRequest = 62,
[global::ProtoBuf.ProtoEnum(Name = @"TC_CLIENT_CONNECT_RESPONSE")]
TcClientConnectResponse = 63,
}

}
Expand Down Expand Up @@ -3298,6 +3426,10 @@ internal enum ProtocolVersion
V16 = 16,
[global::ProtoBuf.ProtoEnum(Name = @"v17")]
V17 = 17,
[global::ProtoBuf.ProtoEnum(Name = @"v18")]
V18 = 18,
[global::ProtoBuf.ProtoEnum(Name = @"v19")]
V19 = 19,
}

[global::ProtoBuf.ProtoContract()]
Expand Down
Loading