Current section
Files
Jump to
Current section
Files
lib/pulsar/protocol/binary.ex
defmodule Pulsar.Protocol.Binary.Pulsar.Proto.CompressionType do
@moduledoc false
use Protobuf, enum: true, protoc_gen_elixir_version: "0.15.0", syntax: :proto2
field(:NONE, 0)
field(:LZ4, 1)
field(:ZLIB, 2)
field(:ZSTD, 3)
field(:SNAPPY, 4)
end
defmodule Pulsar.Protocol.Binary.Pulsar.Proto.ProducerAccessMode do
@moduledoc false
use Protobuf, enum: true, protoc_gen_elixir_version: "0.15.0", syntax: :proto2
field(:Shared, 0)
field(:Exclusive, 1)
field(:WaitForExclusive, 2)
field(:ExclusiveWithFencing, 3)
end
defmodule Pulsar.Protocol.Binary.Pulsar.Proto.ServerError do
@moduledoc false
use Protobuf, enum: true, protoc_gen_elixir_version: "0.15.0", syntax: :proto2
field(:UnknownError, 0)
field(:MetadataError, 1)
field(:PersistenceError, 2)
field(:AuthenticationError, 3)
field(:AuthorizationError, 4)
field(:ConsumerBusy, 5)
field(:ServiceNotReady, 6)
field(:ProducerBlockedQuotaExceededError, 7)
field(:ProducerBlockedQuotaExceededException, 8)
field(:ChecksumError, 9)
field(:UnsupportedVersionError, 10)
field(:TopicNotFound, 11)
field(:SubscriptionNotFound, 12)
field(:ConsumerNotFound, 13)
field(:TooManyRequests, 14)
field(:TopicTerminatedError, 15)
field(:ProducerBusy, 16)
field(:InvalidTopicName, 17)
field(:IncompatibleSchema, 18)
field(:ConsumerAssignError, 19)
field(:TransactionCoordinatorNotFound, 20)
field(:InvalidTxnStatus, 21)
field(:NotAllowedError, 22)
field(:TransactionConflict, 23)
field(:TransactionNotFound, 24)
field(:ProducerFenced, 25)
end
defmodule Pulsar.Protocol.Binary.Pulsar.Proto.AuthMethod do
@moduledoc false
use Protobuf, enum: true, protoc_gen_elixir_version: "0.15.0", syntax: :proto2
field(:AuthMethodNone, 0)
field(:AuthMethodYcaV1, 1)
field(:AuthMethodAthens, 2)
end
defmodule Pulsar.Protocol.Binary.Pulsar.Proto.ProtocolVersion do
@moduledoc false
use Protobuf, enum: true, protoc_gen_elixir_version: "0.15.0", syntax: :proto2
field(:v0, 0)
field(:v1, 1)
field(:v2, 2)
field(:v3, 3)
field(:v4, 4)
field(:v5, 5)
field(:v6, 6)
field(:v7, 7)
field(:v8, 8)
field(:v9, 9)
field(:v10, 10)
field(:v11, 11)
field(:v12, 12)
field(:v13, 13)
field(:v14, 14)
field(:v15, 15)
field(:v16, 16)
field(:v17, 17)
field(:v18, 18)
field(:v19, 19)
field(:v20, 20)
field(:v21, 21)
end
defmodule Pulsar.Protocol.Binary.Pulsar.Proto.KeySharedMode do
@moduledoc false
use Protobuf, enum: true, protoc_gen_elixir_version: "0.15.0", syntax: :proto2
field(:AUTO_SPLIT, 0)
field(:STICKY, 1)
end
defmodule Pulsar.Protocol.Binary.Pulsar.Proto.TxnAction do
@moduledoc false
use Protobuf, enum: true, protoc_gen_elixir_version: "0.15.0", syntax: :proto2
field(:COMMIT, 0)
field(:ABORT, 1)
end
defmodule Pulsar.Protocol.Binary.Pulsar.Proto.Schema.Type do
@moduledoc false
use Protobuf, enum: true, protoc_gen_elixir_version: "0.15.0", syntax: :proto2
field(:None, 0)
field(:String, 1)
field(:Json, 2)
field(:Protobuf, 3)
field(:Avro, 4)
field(:Bool, 5)
field(:Int8, 6)
field(:Int16, 7)
field(:Int32, 8)
field(:Int64, 9)
field(:Float, 10)
field(:Double, 11)
field(:Date, 12)
field(:Time, 13)
field(:Timestamp, 14)
field(:KeyValue, 15)
field(:Instant, 16)
field(:LocalDate, 17)
field(:LocalTime, 18)
field(:LocalDateTime, 19)
field(:ProtobufNative, 20)
field(:AutoConsume, 21)
end
defmodule Pulsar.Protocol.Binary.Pulsar.Proto.CommandSubscribe.SubType do
@moduledoc false
use Protobuf, enum: true, protoc_gen_elixir_version: "0.15.0", syntax: :proto2
field(:Exclusive, 0)
field(:Shared, 1)
field(:Failover, 2)
field(:Key_Shared, 3)
end
defmodule Pulsar.Protocol.Binary.Pulsar.Proto.CommandSubscribe.InitialPosition do
@moduledoc false
use Protobuf, enum: true, protoc_gen_elixir_version: "0.15.0", syntax: :proto2
field(:Latest, 0)
field(:Earliest, 1)
end
defmodule Pulsar.Protocol.Binary.Pulsar.Proto.CommandPartitionedTopicMetadataResponse.LookupType do
@moduledoc false
use Protobuf, enum: true, protoc_gen_elixir_version: "0.15.0", syntax: :proto2
field(:Success, 0)
field(:Failed, 1)
end
defmodule Pulsar.Protocol.Binary.Pulsar.Proto.CommandLookupTopicResponse.LookupType do
@moduledoc false
use Protobuf, enum: true, protoc_gen_elixir_version: "0.15.0", syntax: :proto2
field(:Redirect, 0)
field(:Connect, 1)
field(:Failed, 2)
end
defmodule Pulsar.Protocol.Binary.Pulsar.Proto.CommandAck.AckType do
@moduledoc false
use Protobuf, enum: true, protoc_gen_elixir_version: "0.15.0", syntax: :proto2
field(:Individual, 0)
field(:Cumulative, 1)
end
defmodule Pulsar.Protocol.Binary.Pulsar.Proto.CommandAck.ValidationError do
@moduledoc false
use Protobuf, enum: true, protoc_gen_elixir_version: "0.15.0", syntax: :proto2
field(:UncompressedSizeCorruption, 0)
field(:DecompressionError, 1)
field(:ChecksumMismatch, 2)
field(:BatchDeSerializeError, 3)
field(:DecryptionError, 4)
end
defmodule Pulsar.Protocol.Binary.Pulsar.Proto.CommandTopicMigrated.ResourceType do
@moduledoc false
use Protobuf, enum: true, protoc_gen_elixir_version: "0.15.0", syntax: :proto2
field(:Producer, 0)
field(:Consumer, 1)
end
defmodule Pulsar.Protocol.Binary.Pulsar.Proto.CommandGetTopicsOfNamespace.Mode do
@moduledoc false
use Protobuf, enum: true, protoc_gen_elixir_version: "0.15.0", syntax: :proto2
field(:PERSISTENT, 0)
field(:NON_PERSISTENT, 1)
field(:ALL, 2)
end
defmodule Pulsar.Protocol.Binary.Pulsar.Proto.BaseCommand.Type do
@moduledoc false
use Protobuf, enum: true, protoc_gen_elixir_version: "0.15.0", syntax: :proto2
field(:CONNECT, 2)
field(:CONNECTED, 3)
field(:SUBSCRIBE, 4)
field(:PRODUCER, 5)
field(:SEND, 6)
field(:SEND_RECEIPT, 7)
field(:SEND_ERROR, 8)
field(:MESSAGE, 9)
field(:ACK, 10)
field(:FLOW, 11)
field(:UNSUBSCRIBE, 12)
field(:SUCCESS, 13)
field(:ERROR, 14)
field(:CLOSE_PRODUCER, 15)
field(:CLOSE_CONSUMER, 16)
field(:PRODUCER_SUCCESS, 17)
field(:PING, 18)
field(:PONG, 19)
field(:REDELIVER_UNACKNOWLEDGED_MESSAGES, 20)
field(:PARTITIONED_METADATA, 21)
field(:PARTITIONED_METADATA_RESPONSE, 22)
field(:LOOKUP, 23)
field(:LOOKUP_RESPONSE, 24)
field(:CONSUMER_STATS, 25)
field(:CONSUMER_STATS_RESPONSE, 26)
field(:REACHED_END_OF_TOPIC, 27)
field(:SEEK, 28)
field(:GET_LAST_MESSAGE_ID, 29)
field(:GET_LAST_MESSAGE_ID_RESPONSE, 30)
field(:ACTIVE_CONSUMER_CHANGE, 31)
field(:GET_TOPICS_OF_NAMESPACE, 32)
field(:GET_TOPICS_OF_NAMESPACE_RESPONSE, 33)
field(:GET_SCHEMA, 34)
field(:GET_SCHEMA_RESPONSE, 35)
field(:AUTH_CHALLENGE, 36)
field(:AUTH_RESPONSE, 37)
field(:ACK_RESPONSE, 38)
field(:GET_OR_CREATE_SCHEMA, 39)
field(:GET_OR_CREATE_SCHEMA_RESPONSE, 40)
field(:NEW_TXN, 50)
field(:NEW_TXN_RESPONSE, 51)
field(:ADD_PARTITION_TO_TXN, 52)
field(:ADD_PARTITION_TO_TXN_RESPONSE, 53)
field(:ADD_SUBSCRIPTION_TO_TXN, 54)
field(:ADD_SUBSCRIPTION_TO_TXN_RESPONSE, 55)
field(:END_TXN, 56)
field(:END_TXN_RESPONSE, 57)
field(:END_TXN_ON_PARTITION, 58)
field(:END_TXN_ON_PARTITION_RESPONSE, 59)
field(:END_TXN_ON_SUBSCRIPTION, 60)
field(:END_TXN_ON_SUBSCRIPTION_RESPONSE, 61)
field(:TC_CLIENT_CONNECT_REQUEST, 62)
field(:TC_CLIENT_CONNECT_RESPONSE, 63)
field(:WATCH_TOPIC_LIST, 64)
field(:WATCH_TOPIC_LIST_SUCCESS, 65)
field(:WATCH_TOPIC_UPDATE, 66)
field(:WATCH_TOPIC_LIST_CLOSE, 67)
field(:TOPIC_MIGRATED, 68)
end
defmodule Pulsar.Protocol.Binary.Pulsar.Proto.Schema do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.15.0", syntax: :proto2
field(:name, 1, required: true, type: :string)
field(:schema_data, 3, required: true, type: :bytes, json_name: "schemaData")
field(:type, 4,
required: true,
type: Pulsar.Protocol.Binary.Pulsar.Proto.Schema.Type,
enum: true
)
field(:properties, 5, repeated: true, type: Pulsar.Protocol.Binary.Pulsar.Proto.KeyValue)
end
defmodule Pulsar.Protocol.Binary.Pulsar.Proto.MessageIdData do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.15.0", syntax: :proto2
field(:ledgerId, 1, required: true, type: :uint64)
field(:entryId, 2, required: true, type: :uint64)
field(:partition, 3, optional: true, type: :int32, default: -1)
field(:batch_index, 4, optional: true, type: :int32, json_name: "batchIndex", default: -1)
field(:ack_set, 5, repeated: true, type: :int64, json_name: "ackSet")
field(:batch_size, 6, optional: true, type: :int32, json_name: "batchSize")
field(:first_chunk_message_id, 7,
optional: true,
type: Pulsar.Protocol.Binary.Pulsar.Proto.MessageIdData,
json_name: "firstChunkMessageId"
)
end
defmodule Pulsar.Protocol.Binary.Pulsar.Proto.KeyValue do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.15.0", syntax: :proto2
field(:key, 1, required: true, type: :string)
field(:value, 2, required: true, type: :string)
end
defmodule Pulsar.Protocol.Binary.Pulsar.Proto.KeyLongValue do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.15.0", syntax: :proto2
field(:key, 1, required: true, type: :string)
field(:value, 2, required: true, type: :uint64)
end
defmodule Pulsar.Protocol.Binary.Pulsar.Proto.IntRange do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.15.0", syntax: :proto2
field(:start, 1, required: true, type: :int32)
field(:end, 2, required: true, type: :int32)
end
defmodule Pulsar.Protocol.Binary.Pulsar.Proto.EncryptionKeys do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.15.0", syntax: :proto2
field(:key, 1, required: true, type: :string)
field(:value, 2, required: true, type: :bytes)
field(:metadata, 3, repeated: true, type: Pulsar.Protocol.Binary.Pulsar.Proto.KeyValue)
end
defmodule Pulsar.Protocol.Binary.Pulsar.Proto.MessageMetadata do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.15.0", syntax: :proto2
field(:producer_name, 1, required: true, type: :string, json_name: "producerName")
field(:sequence_id, 2, required: true, type: :uint64, json_name: "sequenceId")
field(:publish_time, 3, required: true, type: :uint64, json_name: "publishTime")
field(:properties, 4, repeated: true, type: Pulsar.Protocol.Binary.Pulsar.Proto.KeyValue)
field(:replicated_from, 5, optional: true, type: :string, json_name: "replicatedFrom")
field(:partition_key, 6, optional: true, type: :string, json_name: "partitionKey")
field(:replicate_to, 7, repeated: true, type: :string, json_name: "replicateTo")
field(:compression, 8,
optional: true,
type: Pulsar.Protocol.Binary.Pulsar.Proto.CompressionType,
default: :NONE,
enum: true
)
field(:uncompressed_size, 9,
optional: true,
type: :uint32,
json_name: "uncompressedSize",
default: 0
)
field(:num_messages_in_batch, 11,
optional: true,
type: :int32,
json_name: "numMessagesInBatch",
default: 1
)
field(:event_time, 12, optional: true, type: :uint64, json_name: "eventTime", default: 0)
field(:encryption_keys, 13,
repeated: true,
type: Pulsar.Protocol.Binary.Pulsar.Proto.EncryptionKeys,
json_name: "encryptionKeys"
)
field(:encryption_algo, 14, optional: true, type: :string, json_name: "encryptionAlgo")
field(:encryption_param, 15, optional: true, type: :bytes, json_name: "encryptionParam")
field(:schema_version, 16, optional: true, type: :bytes, json_name: "schemaVersion")
field(:partition_key_b64_encoded, 17,
optional: true,
type: :bool,
json_name: "partitionKeyB64Encoded",
default: false
)
field(:ordering_key, 18, optional: true, type: :bytes, json_name: "orderingKey")
field(:deliver_at_time, 19, optional: true, type: :int64, json_name: "deliverAtTime")
field(:marker_type, 20, optional: true, type: :int32, json_name: "markerType")
field(:txnid_least_bits, 22, optional: true, type: :uint64, json_name: "txnidLeastBits")
field(:txnid_most_bits, 23, optional: true, type: :uint64, json_name: "txnidMostBits")
field(:highest_sequence_id, 24,
optional: true,
type: :uint64,
json_name: "highestSequenceId",
default: 0
)
field(:null_value, 25, optional: true, type: :bool, json_name: "nullValue", default: false)
field(:uuid, 26, optional: true, type: :string)
field(:num_chunks_from_msg, 27, optional: true, type: :int32, json_name: "numChunksFromMsg")
field(:total_chunk_msg_size, 28, optional: true, type: :int32, json_name: "totalChunkMsgSize")
field(:chunk_id, 29, optional: true, type: :int32, json_name: "chunkId")
field(:null_partition_key, 30,
optional: true,
type: :bool,
json_name: "nullPartitionKey",
default: false
)
end
defmodule Pulsar.Protocol.Binary.Pulsar.Proto.SingleMessageMetadata do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.15.0", syntax: :proto2
field(:properties, 1, repeated: true, type: Pulsar.Protocol.Binary.Pulsar.Proto.KeyValue)
field(:partition_key, 2, optional: true, type: :string, json_name: "partitionKey")
field(:payload_size, 3, required: true, type: :int32, json_name: "payloadSize")
field(:compacted_out, 4, optional: true, type: :bool, json_name: "compactedOut", default: false)
field(:event_time, 5, optional: true, type: :uint64, json_name: "eventTime", default: 0)
field(:partition_key_b64_encoded, 6,
optional: true,
type: :bool,
json_name: "partitionKeyB64Encoded",
default: false
)
field(:ordering_key, 7, optional: true, type: :bytes, json_name: "orderingKey")
field(:sequence_id, 8, optional: true, type: :uint64, json_name: "sequenceId")
field(:null_value, 9, optional: true, type: :bool, json_name: "nullValue", default: false)
field(:null_partition_key, 10,
optional: true,
type: :bool,
json_name: "nullPartitionKey",
default: false
)
end
defmodule Pulsar.Protocol.Binary.Pulsar.Proto.BrokerEntryMetadata do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.15.0", syntax: :proto2
field(:broker_timestamp, 1, optional: true, type: :uint64, json_name: "brokerTimestamp")
field(:index, 2, optional: true, type: :uint64)
end
defmodule Pulsar.Protocol.Binary.Pulsar.Proto.CommandConnect do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.15.0", syntax: :proto2
field(:client_version, 1, required: true, type: :string, json_name: "clientVersion")
field(:auth_method, 2,
optional: true,
type: Pulsar.Protocol.Binary.Pulsar.Proto.AuthMethod,
json_name: "authMethod",
enum: true
)
field(:auth_method_name, 5, optional: true, type: :string, json_name: "authMethodName")
field(:auth_data, 3, optional: true, type: :bytes, json_name: "authData")
field(:protocol_version, 4,
optional: true,
type: :int32,
json_name: "protocolVersion",
default: 0
)
field(:proxy_to_broker_url, 6, optional: true, type: :string, json_name: "proxyToBrokerUrl")
field(:original_principal, 7, optional: true, type: :string, json_name: "originalPrincipal")
field(:original_auth_data, 8, optional: true, type: :string, json_name: "originalAuthData")
field(:original_auth_method, 9, optional: true, type: :string, json_name: "originalAuthMethod")
field(:feature_flags, 10,
optional: true,
type: Pulsar.Protocol.Binary.Pulsar.Proto.FeatureFlags,
json_name: "featureFlags"
)
field(:proxy_version, 11, optional: true, type: :string, json_name: "proxyVersion")
end
defmodule Pulsar.Protocol.Binary.Pulsar.Proto.FeatureFlags do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.15.0", syntax: :proto2
field(:supports_auth_refresh, 1,
optional: true,
type: :bool,
json_name: "supportsAuthRefresh",
default: false
)
field(:supports_broker_entry_metadata, 2,
optional: true,
type: :bool,
json_name: "supportsBrokerEntryMetadata",
default: false
)
field(:supports_partial_producer, 3,
optional: true,
type: :bool,
json_name: "supportsPartialProducer",
default: false
)
field(:supports_topic_watchers, 4,
optional: true,
type: :bool,
json_name: "supportsTopicWatchers",
default: false
)
field(:supports_get_partitioned_metadata_without_auto_creation, 5,
optional: true,
type: :bool,
json_name: "supportsGetPartitionedMetadataWithoutAutoCreation",
default: false
)
end
defmodule Pulsar.Protocol.Binary.Pulsar.Proto.CommandConnected do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.15.0", syntax: :proto2
field(:server_version, 1, required: true, type: :string, json_name: "serverVersion")
field(:protocol_version, 2,
optional: true,
type: :int32,
json_name: "protocolVersion",
default: 0
)
field(:max_message_size, 3, optional: true, type: :int32, json_name: "maxMessageSize")
field(:feature_flags, 4,
optional: true,
type: Pulsar.Protocol.Binary.Pulsar.Proto.FeatureFlags,
json_name: "featureFlags"
)
end
defmodule Pulsar.Protocol.Binary.Pulsar.Proto.CommandAuthResponse do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.15.0", syntax: :proto2
field(:client_version, 1, optional: true, type: :string, json_name: "clientVersion")
field(:response, 2, optional: true, type: Pulsar.Protocol.Binary.Pulsar.Proto.AuthData)
field(:protocol_version, 3,
optional: true,
type: :int32,
json_name: "protocolVersion",
default: 0
)
end
defmodule Pulsar.Protocol.Binary.Pulsar.Proto.CommandAuthChallenge do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.15.0", syntax: :proto2
field(:server_version, 1, optional: true, type: :string, json_name: "serverVersion")
field(:challenge, 2, optional: true, type: Pulsar.Protocol.Binary.Pulsar.Proto.AuthData)
field(:protocol_version, 3,
optional: true,
type: :int32,
json_name: "protocolVersion",
default: 0
)
end
defmodule Pulsar.Protocol.Binary.Pulsar.Proto.AuthData do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.15.0", syntax: :proto2
field(:auth_method_name, 1, optional: true, type: :string, json_name: "authMethodName")
field(:auth_data, 2, optional: true, type: :bytes, json_name: "authData")
end
defmodule Pulsar.Protocol.Binary.Pulsar.Proto.KeySharedMeta do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.15.0", syntax: :proto2
field(:keySharedMode, 1,
required: true,
type: Pulsar.Protocol.Binary.Pulsar.Proto.KeySharedMode,
enum: true
)
field(:hashRanges, 3, repeated: true, type: Pulsar.Protocol.Binary.Pulsar.Proto.IntRange)
field(:allowOutOfOrderDelivery, 4, optional: true, type: :bool, default: false)
end
defmodule Pulsar.Protocol.Binary.Pulsar.Proto.CommandSubscribe do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.15.0", syntax: :proto2
alias Pulsar.Protocol.Binary.Pulsar.Proto.KeyValue
field(:topic, 1, required: true, type: :string)
field(:subscription, 2, required: true, type: :string)
field(:subType, 3,
required: true,
type: Pulsar.Protocol.Binary.Pulsar.Proto.CommandSubscribe.SubType,
enum: true
)
field(:consumer_id, 4, required: true, type: :uint64, json_name: "consumerId")
field(:request_id, 5, required: true, type: :uint64, json_name: "requestId")
field(:consumer_name, 6, optional: true, type: :string, json_name: "consumerName")
field(:priority_level, 7, optional: true, type: :int32, json_name: "priorityLevel")
field(:durable, 8, optional: true, type: :bool, default: true)
field(:start_message_id, 9,
optional: true,
type: Pulsar.Protocol.Binary.Pulsar.Proto.MessageIdData,
json_name: "startMessageId"
)
field(:metadata, 10, repeated: true, type: KeyValue)
field(:read_compacted, 11, optional: true, type: :bool, json_name: "readCompacted")
field(:schema, 12, optional: true, type: Pulsar.Protocol.Binary.Pulsar.Proto.Schema)
field(:initialPosition, 13,
optional: true,
type: Pulsar.Protocol.Binary.Pulsar.Proto.CommandSubscribe.InitialPosition,
default: :Latest,
enum: true
)
field(:replicate_subscription_state, 14,
optional: true,
type: :bool,
json_name: "replicateSubscriptionState"
)
field(:force_topic_creation, 15,
optional: true,
type: :bool,
json_name: "forceTopicCreation",
default: true
)
field(:start_message_rollback_duration_sec, 16,
optional: true,
type: :uint64,
json_name: "startMessageRollbackDurationSec",
default: 0
)
field(:keySharedMeta, 17,
optional: true,
type: Pulsar.Protocol.Binary.Pulsar.Proto.KeySharedMeta
)
field(:subscription_properties, 18,
repeated: true,
type: KeyValue,
json_name: "subscriptionProperties"
)
field(:consumer_epoch, 19, optional: true, type: :uint64, json_name: "consumerEpoch")
end
defmodule Pulsar.Protocol.Binary.Pulsar.Proto.CommandPartitionedTopicMetadata do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.15.0", syntax: :proto2
field(:topic, 1, required: true, type: :string)
field(:request_id, 2, required: true, type: :uint64, json_name: "requestId")
field(:original_principal, 3, optional: true, type: :string, json_name: "originalPrincipal")
field(:original_auth_data, 4, optional: true, type: :string, json_name: "originalAuthData")
field(:original_auth_method, 5, optional: true, type: :string, json_name: "originalAuthMethod")
field(:metadata_auto_creation_enabled, 6,
optional: true,
type: :bool,
json_name: "metadataAutoCreationEnabled",
default: true
)
end
defmodule Pulsar.Protocol.Binary.Pulsar.Proto.CommandPartitionedTopicMetadataResponse do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.15.0", syntax: :proto2
field(:partitions, 1, optional: true, type: :uint32)
field(:request_id, 2, required: true, type: :uint64, json_name: "requestId")
field(:response, 3,
optional: true,
type: Pulsar.Protocol.Binary.Pulsar.Proto.CommandPartitionedTopicMetadataResponse.LookupType,
enum: true
)
field(:error, 4,
optional: true,
type: Pulsar.Protocol.Binary.Pulsar.Proto.ServerError,
enum: true
)
field(:message, 5, optional: true, type: :string)
end
defmodule Pulsar.Protocol.Binary.Pulsar.Proto.CommandLookupTopic do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.15.0", syntax: :proto2
field(:topic, 1, required: true, type: :string)
field(:request_id, 2, required: true, type: :uint64, json_name: "requestId")
field(:authoritative, 3, optional: true, type: :bool, default: false)
field(:original_principal, 4, optional: true, type: :string, json_name: "originalPrincipal")
field(:original_auth_data, 5, optional: true, type: :string, json_name: "originalAuthData")
field(:original_auth_method, 6, optional: true, type: :string, json_name: "originalAuthMethod")
field(:advertised_listener_name, 7,
optional: true,
type: :string,
json_name: "advertisedListenerName"
)
end
defmodule Pulsar.Protocol.Binary.Pulsar.Proto.CommandLookupTopicResponse do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.15.0", syntax: :proto2
field(:brokerServiceUrl, 1, optional: true, type: :string)
field(:brokerServiceUrlTls, 2, optional: true, type: :string)
field(:response, 3,
optional: true,
type: Pulsar.Protocol.Binary.Pulsar.Proto.CommandLookupTopicResponse.LookupType,
enum: true
)
field(:request_id, 4, required: true, type: :uint64, json_name: "requestId")
field(:authoritative, 5, optional: true, type: :bool, default: false)
field(:error, 6,
optional: true,
type: Pulsar.Protocol.Binary.Pulsar.Proto.ServerError,
enum: true
)
field(:message, 7, optional: true, type: :string)
field(:proxy_through_service_url, 8,
optional: true,
type: :bool,
json_name: "proxyThroughServiceUrl",
default: false
)
end
defmodule Pulsar.Protocol.Binary.Pulsar.Proto.CommandProducer do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.15.0", syntax: :proto2
field(:topic, 1, required: true, type: :string)
field(:producer_id, 2, required: true, type: :uint64, json_name: "producerId")
field(:request_id, 3, required: true, type: :uint64, json_name: "requestId")
field(:producer_name, 4, optional: true, type: :string, json_name: "producerName")
field(:encrypted, 5, optional: true, type: :bool, default: false)
field(:metadata, 6, repeated: true, type: Pulsar.Protocol.Binary.Pulsar.Proto.KeyValue)
field(:schema, 7, optional: true, type: Pulsar.Protocol.Binary.Pulsar.Proto.Schema)
field(:epoch, 8, optional: true, type: :uint64, default: 0)
field(:user_provided_producer_name, 9,
optional: true,
type: :bool,
json_name: "userProvidedProducerName",
default: true
)
field(:producer_access_mode, 10,
optional: true,
type: Pulsar.Protocol.Binary.Pulsar.Proto.ProducerAccessMode,
json_name: "producerAccessMode",
default: :Shared,
enum: true
)
field(:topic_epoch, 11, optional: true, type: :uint64, json_name: "topicEpoch")
field(:txn_enabled, 12, optional: true, type: :bool, json_name: "txnEnabled", default: false)
field(:initial_subscription_name, 13,
optional: true,
type: :string,
json_name: "initialSubscriptionName"
)
end
defmodule Pulsar.Protocol.Binary.Pulsar.Proto.CommandSend do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.15.0", syntax: :proto2
field(:producer_id, 1, required: true, type: :uint64, json_name: "producerId")
field(:sequence_id, 2, required: true, type: :uint64, json_name: "sequenceId")
field(:num_messages, 3, optional: true, type: :int32, json_name: "numMessages", default: 1)
field(:txnid_least_bits, 4,
optional: true,
type: :uint64,
json_name: "txnidLeastBits",
default: 0
)
field(:txnid_most_bits, 5, optional: true, type: :uint64, json_name: "txnidMostBits", default: 0)
field(:highest_sequence_id, 6,
optional: true,
type: :uint64,
json_name: "highestSequenceId",
default: 0
)
field(:is_chunk, 7, optional: true, type: :bool, json_name: "isChunk", default: false)
field(:marker, 8, optional: true, type: :bool, default: false)
field(:message_id, 9,
optional: true,
type: Pulsar.Protocol.Binary.Pulsar.Proto.MessageIdData,
json_name: "messageId"
)
end
defmodule Pulsar.Protocol.Binary.Pulsar.Proto.CommandSendReceipt do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.15.0", syntax: :proto2
field(:producer_id, 1, required: true, type: :uint64, json_name: "producerId")
field(:sequence_id, 2, required: true, type: :uint64, json_name: "sequenceId")
field(:message_id, 3,
optional: true,
type: Pulsar.Protocol.Binary.Pulsar.Proto.MessageIdData,
json_name: "messageId"
)
field(:highest_sequence_id, 4,
optional: true,
type: :uint64,
json_name: "highestSequenceId",
default: 0
)
end
defmodule Pulsar.Protocol.Binary.Pulsar.Proto.CommandSendError do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.15.0", syntax: :proto2
field(:producer_id, 1, required: true, type: :uint64, json_name: "producerId")
field(:sequence_id, 2, required: true, type: :uint64, json_name: "sequenceId")
field(:error, 3,
required: true,
type: Pulsar.Protocol.Binary.Pulsar.Proto.ServerError,
enum: true
)
field(:message, 4, required: true, type: :string)
end
defmodule Pulsar.Protocol.Binary.Pulsar.Proto.CommandMessage do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.15.0", syntax: :proto2
field(:consumer_id, 1, required: true, type: :uint64, json_name: "consumerId")
field(:message_id, 2,
required: true,
type: Pulsar.Protocol.Binary.Pulsar.Proto.MessageIdData,
json_name: "messageId"
)
field(:redelivery_count, 3,
optional: true,
type: :uint32,
json_name: "redeliveryCount",
default: 0
)
field(:ack_set, 4, repeated: true, type: :int64, json_name: "ackSet")
field(:consumer_epoch, 5, optional: true, type: :uint64, json_name: "consumerEpoch")
end
defmodule Pulsar.Protocol.Binary.Pulsar.Proto.CommandAck do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.15.0", syntax: :proto2
field(:consumer_id, 1, required: true, type: :uint64, json_name: "consumerId")
field(:ack_type, 2,
required: true,
type: Pulsar.Protocol.Binary.Pulsar.Proto.CommandAck.AckType,
json_name: "ackType",
enum: true
)
field(:message_id, 3,
repeated: true,
type: Pulsar.Protocol.Binary.Pulsar.Proto.MessageIdData,
json_name: "messageId"
)
field(:validation_error, 4,
optional: true,
type: Pulsar.Protocol.Binary.Pulsar.Proto.CommandAck.ValidationError,
json_name: "validationError",
enum: true
)
field(:properties, 5, repeated: true, type: Pulsar.Protocol.Binary.Pulsar.Proto.KeyLongValue)
field(:txnid_least_bits, 6,
optional: true,
type: :uint64,
json_name: "txnidLeastBits",
default: 0
)
field(:txnid_most_bits, 7, optional: true, type: :uint64, json_name: "txnidMostBits", default: 0)
field(:request_id, 8, optional: true, type: :uint64, json_name: "requestId")
end
defmodule Pulsar.Protocol.Binary.Pulsar.Proto.CommandAckResponse do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.15.0", syntax: :proto2
field(:consumer_id, 1, required: true, type: :uint64, json_name: "consumerId")
field(:txnid_least_bits, 2,
optional: true,
type: :uint64,
json_name: "txnidLeastBits",
default: 0
)
field(:txnid_most_bits, 3, optional: true, type: :uint64, json_name: "txnidMostBits", default: 0)
field(:error, 4,
optional: true,
type: Pulsar.Protocol.Binary.Pulsar.Proto.ServerError,
enum: true
)
field(:message, 5, optional: true, type: :string)
field(:request_id, 6, optional: true, type: :uint64, json_name: "requestId")
end
defmodule Pulsar.Protocol.Binary.Pulsar.Proto.CommandActiveConsumerChange do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.15.0", syntax: :proto2
field(:consumer_id, 1, required: true, type: :uint64, json_name: "consumerId")
field(:is_active, 2, optional: true, type: :bool, json_name: "isActive", default: false)
end
defmodule Pulsar.Protocol.Binary.Pulsar.Proto.CommandFlow do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.15.0", syntax: :proto2
field(:consumer_id, 1, required: true, type: :uint64, json_name: "consumerId")
field(:messagePermits, 2, required: true, type: :uint32)
end
defmodule Pulsar.Protocol.Binary.Pulsar.Proto.CommandUnsubscribe do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.15.0", syntax: :proto2
field(:consumer_id, 1, required: true, type: :uint64, json_name: "consumerId")
field(:request_id, 2, required: true, type: :uint64, json_name: "requestId")
field(:force, 3, optional: true, type: :bool, default: false)
end
defmodule Pulsar.Protocol.Binary.Pulsar.Proto.CommandSeek do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.15.0", syntax: :proto2
field(:consumer_id, 1, required: true, type: :uint64, json_name: "consumerId")
field(:request_id, 2, required: true, type: :uint64, json_name: "requestId")
field(:message_id, 3,
optional: true,
type: Pulsar.Protocol.Binary.Pulsar.Proto.MessageIdData,
json_name: "messageId"
)
field(:message_publish_time, 4, optional: true, type: :uint64, json_name: "messagePublishTime")
end
defmodule Pulsar.Protocol.Binary.Pulsar.Proto.CommandReachedEndOfTopic do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.15.0", syntax: :proto2
field(:consumer_id, 1, required: true, type: :uint64, json_name: "consumerId")
end
defmodule Pulsar.Protocol.Binary.Pulsar.Proto.CommandTopicMigrated do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.15.0", syntax: :proto2
field(:resource_id, 1, required: true, type: :uint64, json_name: "resourceId")
field(:resource_type, 2,
required: true,
type: Pulsar.Protocol.Binary.Pulsar.Proto.CommandTopicMigrated.ResourceType,
json_name: "resourceType",
enum: true
)
field(:brokerServiceUrl, 3, optional: true, type: :string)
field(:brokerServiceUrlTls, 4, optional: true, type: :string)
end
defmodule Pulsar.Protocol.Binary.Pulsar.Proto.CommandCloseProducer do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.15.0", syntax: :proto2
field(:producer_id, 1, required: true, type: :uint64, json_name: "producerId")
field(:request_id, 2, required: true, type: :uint64, json_name: "requestId")
field(:assignedBrokerServiceUrl, 3, optional: true, type: :string)
field(:assignedBrokerServiceUrlTls, 4, optional: true, type: :string)
end
defmodule Pulsar.Protocol.Binary.Pulsar.Proto.CommandCloseConsumer do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.15.0", syntax: :proto2
field(:consumer_id, 1, required: true, type: :uint64, json_name: "consumerId")
field(:request_id, 2, required: true, type: :uint64, json_name: "requestId")
field(:assignedBrokerServiceUrl, 3, optional: true, type: :string)
field(:assignedBrokerServiceUrlTls, 4, optional: true, type: :string)
end
defmodule Pulsar.Protocol.Binary.Pulsar.Proto.CommandRedeliverUnacknowledgedMessages do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.15.0", syntax: :proto2
field(:consumer_id, 1, required: true, type: :uint64, json_name: "consumerId")
field(:message_ids, 2,
repeated: true,
type: Pulsar.Protocol.Binary.Pulsar.Proto.MessageIdData,
json_name: "messageIds"
)
field(:consumer_epoch, 3, optional: true, type: :uint64, json_name: "consumerEpoch")
end
defmodule Pulsar.Protocol.Binary.Pulsar.Proto.CommandSuccess do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.15.0", syntax: :proto2
field(:request_id, 1, required: true, type: :uint64, json_name: "requestId")
field(:schema, 2, optional: true, type: Pulsar.Protocol.Binary.Pulsar.Proto.Schema)
end
defmodule Pulsar.Protocol.Binary.Pulsar.Proto.CommandProducerSuccess do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.15.0", syntax: :proto2
field(:request_id, 1, required: true, type: :uint64, json_name: "requestId")
field(:producer_name, 2, required: true, type: :string, json_name: "producerName")
field(:last_sequence_id, 3,
optional: true,
type: :int64,
json_name: "lastSequenceId",
default: -1
)
field(:schema_version, 4, optional: true, type: :bytes, json_name: "schemaVersion")
field(:topic_epoch, 5, optional: true, type: :uint64, json_name: "topicEpoch")
field(:producer_ready, 6, optional: true, type: :bool, json_name: "producerReady", default: true)
end
defmodule Pulsar.Protocol.Binary.Pulsar.Proto.CommandError do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.15.0", syntax: :proto2
field(:request_id, 1, required: true, type: :uint64, json_name: "requestId")
field(:error, 2,
required: true,
type: Pulsar.Protocol.Binary.Pulsar.Proto.ServerError,
enum: true
)
field(:message, 3, required: true, type: :string)
end
defmodule Pulsar.Protocol.Binary.Pulsar.Proto.CommandPing do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.15.0", syntax: :proto2
end
defmodule Pulsar.Protocol.Binary.Pulsar.Proto.CommandPong do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.15.0", syntax: :proto2
end
defmodule Pulsar.Protocol.Binary.Pulsar.Proto.CommandConsumerStats do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.15.0", syntax: :proto2
field(:request_id, 1, required: true, type: :uint64, json_name: "requestId")
field(:consumer_id, 4, required: true, type: :uint64, json_name: "consumerId")
end
defmodule Pulsar.Protocol.Binary.Pulsar.Proto.CommandConsumerStatsResponse do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.15.0", syntax: :proto2
field(:request_id, 1, required: true, type: :uint64, json_name: "requestId")
field(:error_code, 2,
optional: true,
type: Pulsar.Protocol.Binary.Pulsar.Proto.ServerError,
json_name: "errorCode",
enum: true
)
field(:error_message, 3, optional: true, type: :string, json_name: "errorMessage")
field(:msgRateOut, 4, optional: true, type: :double)
field(:msgThroughputOut, 5, optional: true, type: :double)
field(:msgRateRedeliver, 6, optional: true, type: :double)
field(:consumerName, 7, optional: true, type: :string)
field(:availablePermits, 8, optional: true, type: :uint64)
field(:unackedMessages, 9, optional: true, type: :uint64)
field(:blockedConsumerOnUnackedMsgs, 10, optional: true, type: :bool)
field(:address, 11, optional: true, type: :string)
field(:connectedSince, 12, optional: true, type: :string)
field(:type, 13, optional: true, type: :string)
field(:msgRateExpired, 14, optional: true, type: :double)
field(:msgBacklog, 15, optional: true, type: :uint64)
field(:messageAckRate, 16, optional: true, type: :double)
end
defmodule Pulsar.Protocol.Binary.Pulsar.Proto.CommandGetLastMessageId do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.15.0", syntax: :proto2
field(:consumer_id, 1, required: true, type: :uint64, json_name: "consumerId")
field(:request_id, 2, required: true, type: :uint64, json_name: "requestId")
end
defmodule Pulsar.Protocol.Binary.Pulsar.Proto.CommandGetLastMessageIdResponse do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.15.0", syntax: :proto2
alias Pulsar.Protocol.Binary.Pulsar.Proto.MessageIdData
field(:last_message_id, 1,
required: true,
type: MessageIdData,
json_name: "lastMessageId"
)
field(:request_id, 2, required: true, type: :uint64, json_name: "requestId")
field(:consumer_mark_delete_position, 3,
optional: true,
type: MessageIdData,
json_name: "consumerMarkDeletePosition"
)
end
defmodule Pulsar.Protocol.Binary.Pulsar.Proto.CommandGetTopicsOfNamespace do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.15.0", syntax: :proto2
field(:request_id, 1, required: true, type: :uint64, json_name: "requestId")
field(:namespace, 2, required: true, type: :string)
field(:mode, 3,
optional: true,
type: Pulsar.Protocol.Binary.Pulsar.Proto.CommandGetTopicsOfNamespace.Mode,
default: :PERSISTENT,
enum: true
)
field(:topics_pattern, 4, optional: true, type: :string, json_name: "topicsPattern")
field(:topics_hash, 5, optional: true, type: :string, json_name: "topicsHash")
end
defmodule Pulsar.Protocol.Binary.Pulsar.Proto.CommandGetTopicsOfNamespaceResponse do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.15.0", syntax: :proto2
field(:request_id, 1, required: true, type: :uint64, json_name: "requestId")
field(:topics, 2, repeated: true, type: :string)
field(:filtered, 3, optional: true, type: :bool, default: false)
field(:topics_hash, 4, optional: true, type: :string, json_name: "topicsHash")
field(:changed, 5, optional: true, type: :bool, default: true)
end
defmodule Pulsar.Protocol.Binary.Pulsar.Proto.CommandWatchTopicList do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.15.0", syntax: :proto2
field(:request_id, 1, required: true, type: :uint64, json_name: "requestId")
field(:watcher_id, 2, required: true, type: :uint64, json_name: "watcherId")
field(:namespace, 3, required: true, type: :string)
field(:topics_pattern, 4, required: true, type: :string, json_name: "topicsPattern")
field(:topics_hash, 5, optional: true, type: :string, json_name: "topicsHash")
end
defmodule Pulsar.Protocol.Binary.Pulsar.Proto.CommandWatchTopicListSuccess do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.15.0", syntax: :proto2
field(:request_id, 1, required: true, type: :uint64, json_name: "requestId")
field(:watcher_id, 2, required: true, type: :uint64, json_name: "watcherId")
field(:topic, 3, repeated: true, type: :string)
field(:topics_hash, 4, required: true, type: :string, json_name: "topicsHash")
end
defmodule Pulsar.Protocol.Binary.Pulsar.Proto.CommandWatchTopicUpdate do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.15.0", syntax: :proto2
field(:watcher_id, 1, required: true, type: :uint64, json_name: "watcherId")
field(:new_topics, 2, repeated: true, type: :string, json_name: "newTopics")
field(:deleted_topics, 3, repeated: true, type: :string, json_name: "deletedTopics")
field(:topics_hash, 4, required: true, type: :string, json_name: "topicsHash")
end
defmodule Pulsar.Protocol.Binary.Pulsar.Proto.CommandWatchTopicListClose do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.15.0", syntax: :proto2
field(:request_id, 1, required: true, type: :uint64, json_name: "requestId")
field(:watcher_id, 2, required: true, type: :uint64, json_name: "watcherId")
end
defmodule Pulsar.Protocol.Binary.Pulsar.Proto.CommandGetSchema do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.15.0", syntax: :proto2
field(:request_id, 1, required: true, type: :uint64, json_name: "requestId")
field(:topic, 2, required: true, type: :string)
field(:schema_version, 3, optional: true, type: :bytes, json_name: "schemaVersion")
end
defmodule Pulsar.Protocol.Binary.Pulsar.Proto.CommandGetSchemaResponse do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.15.0", syntax: :proto2
field(:request_id, 1, required: true, type: :uint64, json_name: "requestId")
field(:error_code, 2,
optional: true,
type: Pulsar.Protocol.Binary.Pulsar.Proto.ServerError,
json_name: "errorCode",
enum: true
)
field(:error_message, 3, optional: true, type: :string, json_name: "errorMessage")
field(:schema, 4, optional: true, type: Pulsar.Protocol.Binary.Pulsar.Proto.Schema)
field(:schema_version, 5, optional: true, type: :bytes, json_name: "schemaVersion")
end
defmodule Pulsar.Protocol.Binary.Pulsar.Proto.CommandGetOrCreateSchema do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.15.0", syntax: :proto2
field(:request_id, 1, required: true, type: :uint64, json_name: "requestId")
field(:topic, 2, required: true, type: :string)
field(:schema, 3, required: true, type: Pulsar.Protocol.Binary.Pulsar.Proto.Schema)
end
defmodule Pulsar.Protocol.Binary.Pulsar.Proto.CommandGetOrCreateSchemaResponse do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.15.0", syntax: :proto2
field(:request_id, 1, required: true, type: :uint64, json_name: "requestId")
field(:error_code, 2,
optional: true,
type: Pulsar.Protocol.Binary.Pulsar.Proto.ServerError,
json_name: "errorCode",
enum: true
)
field(:error_message, 3, optional: true, type: :string, json_name: "errorMessage")
field(:schema_version, 4, optional: true, type: :bytes, json_name: "schemaVersion")
end
defmodule Pulsar.Protocol.Binary.Pulsar.Proto.CommandTcClientConnectRequest do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.15.0", syntax: :proto2
field(:request_id, 1, required: true, type: :uint64, json_name: "requestId")
field(:tc_id, 2, required: true, type: :uint64, json_name: "tcId", default: 0)
end
defmodule Pulsar.Protocol.Binary.Pulsar.Proto.CommandTcClientConnectResponse do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.15.0", syntax: :proto2
field(:request_id, 1, required: true, type: :uint64, json_name: "requestId")
field(:error, 2,
optional: true,
type: Pulsar.Protocol.Binary.Pulsar.Proto.ServerError,
enum: true
)
field(:message, 3, optional: true, type: :string)
end
defmodule Pulsar.Protocol.Binary.Pulsar.Proto.CommandNewTxn do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.15.0", syntax: :proto2
field(:request_id, 1, required: true, type: :uint64, json_name: "requestId")
field(:txn_ttl_seconds, 2, optional: true, type: :uint64, json_name: "txnTtlSeconds", default: 0)
field(:tc_id, 3, optional: true, type: :uint64, json_name: "tcId", default: 0)
end
defmodule Pulsar.Protocol.Binary.Pulsar.Proto.CommandNewTxnResponse do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.15.0", syntax: :proto2
field(:request_id, 1, required: true, type: :uint64, json_name: "requestId")
field(:txnid_least_bits, 2,
optional: true,
type: :uint64,
json_name: "txnidLeastBits",
default: 0
)
field(:txnid_most_bits, 3, optional: true, type: :uint64, json_name: "txnidMostBits", default: 0)
field(:error, 4,
optional: true,
type: Pulsar.Protocol.Binary.Pulsar.Proto.ServerError,
enum: true
)
field(:message, 5, optional: true, type: :string)
end
defmodule Pulsar.Protocol.Binary.Pulsar.Proto.CommandAddPartitionToTxn do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.15.0", syntax: :proto2
field(:request_id, 1, required: true, type: :uint64, json_name: "requestId")
field(:txnid_least_bits, 2,
optional: true,
type: :uint64,
json_name: "txnidLeastBits",
default: 0
)
field(:txnid_most_bits, 3, optional: true, type: :uint64, json_name: "txnidMostBits", default: 0)
field(:partitions, 4, repeated: true, type: :string)
end
defmodule Pulsar.Protocol.Binary.Pulsar.Proto.CommandAddPartitionToTxnResponse do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.15.0", syntax: :proto2
field(:request_id, 1, required: true, type: :uint64, json_name: "requestId")
field(:txnid_least_bits, 2,
optional: true,
type: :uint64,
json_name: "txnidLeastBits",
default: 0
)
field(:txnid_most_bits, 3, optional: true, type: :uint64, json_name: "txnidMostBits", default: 0)
field(:error, 4,
optional: true,
type: Pulsar.Protocol.Binary.Pulsar.Proto.ServerError,
enum: true
)
field(:message, 5, optional: true, type: :string)
end
defmodule Pulsar.Protocol.Binary.Pulsar.Proto.Subscription do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.15.0", syntax: :proto2
field(:topic, 1, required: true, type: :string)
field(:subscription, 2, required: true, type: :string)
end
defmodule Pulsar.Protocol.Binary.Pulsar.Proto.CommandAddSubscriptionToTxn do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.15.0", syntax: :proto2
field(:request_id, 1, required: true, type: :uint64, json_name: "requestId")
field(:txnid_least_bits, 2,
optional: true,
type: :uint64,
json_name: "txnidLeastBits",
default: 0
)
field(:txnid_most_bits, 3, optional: true, type: :uint64, json_name: "txnidMostBits", default: 0)
field(:subscription, 4, repeated: true, type: Pulsar.Protocol.Binary.Pulsar.Proto.Subscription)
end
defmodule Pulsar.Protocol.Binary.Pulsar.Proto.CommandAddSubscriptionToTxnResponse do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.15.0", syntax: :proto2
field(:request_id, 1, required: true, type: :uint64, json_name: "requestId")
field(:txnid_least_bits, 2,
optional: true,
type: :uint64,
json_name: "txnidLeastBits",
default: 0
)
field(:txnid_most_bits, 3, optional: true, type: :uint64, json_name: "txnidMostBits", default: 0)
field(:error, 4,
optional: true,
type: Pulsar.Protocol.Binary.Pulsar.Proto.ServerError,
enum: true
)
field(:message, 5, optional: true, type: :string)
end
defmodule Pulsar.Protocol.Binary.Pulsar.Proto.CommandEndTxn do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.15.0", syntax: :proto2
field(:request_id, 1, required: true, type: :uint64, json_name: "requestId")
field(:txnid_least_bits, 2,
optional: true,
type: :uint64,
json_name: "txnidLeastBits",
default: 0
)
field(:txnid_most_bits, 3, optional: true, type: :uint64, json_name: "txnidMostBits", default: 0)
field(:txn_action, 4,
optional: true,
type: Pulsar.Protocol.Binary.Pulsar.Proto.TxnAction,
json_name: "txnAction",
enum: true
)
end
defmodule Pulsar.Protocol.Binary.Pulsar.Proto.CommandEndTxnResponse do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.15.0", syntax: :proto2
field(:request_id, 1, required: true, type: :uint64, json_name: "requestId")
field(:txnid_least_bits, 2,
optional: true,
type: :uint64,
json_name: "txnidLeastBits",
default: 0
)
field(:txnid_most_bits, 3, optional: true, type: :uint64, json_name: "txnidMostBits", default: 0)
field(:error, 4,
optional: true,
type: Pulsar.Protocol.Binary.Pulsar.Proto.ServerError,
enum: true
)
field(:message, 5, optional: true, type: :string)
end
defmodule Pulsar.Protocol.Binary.Pulsar.Proto.CommandEndTxnOnPartition do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.15.0", syntax: :proto2
field(:request_id, 1, required: true, type: :uint64, json_name: "requestId")
field(:txnid_least_bits, 2,
optional: true,
type: :uint64,
json_name: "txnidLeastBits",
default: 0
)
field(:txnid_most_bits, 3, optional: true, type: :uint64, json_name: "txnidMostBits", default: 0)
field(:topic, 4, optional: true, type: :string)
field(:txn_action, 5,
optional: true,
type: Pulsar.Protocol.Binary.Pulsar.Proto.TxnAction,
json_name: "txnAction",
enum: true
)
field(:txnid_least_bits_of_low_watermark, 6,
optional: true,
type: :uint64,
json_name: "txnidLeastBitsOfLowWatermark"
)
end
defmodule Pulsar.Protocol.Binary.Pulsar.Proto.CommandEndTxnOnPartitionResponse do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.15.0", syntax: :proto2
field(:request_id, 1, required: true, type: :uint64, json_name: "requestId")
field(:txnid_least_bits, 2,
optional: true,
type: :uint64,
json_name: "txnidLeastBits",
default: 0
)
field(:txnid_most_bits, 3, optional: true, type: :uint64, json_name: "txnidMostBits", default: 0)
field(:error, 4,
optional: true,
type: Pulsar.Protocol.Binary.Pulsar.Proto.ServerError,
enum: true
)
field(:message, 5, optional: true, type: :string)
end
defmodule Pulsar.Protocol.Binary.Pulsar.Proto.CommandEndTxnOnSubscription do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.15.0", syntax: :proto2
field(:request_id, 1, required: true, type: :uint64, json_name: "requestId")
field(:txnid_least_bits, 2,
optional: true,
type: :uint64,
json_name: "txnidLeastBits",
default: 0
)
field(:txnid_most_bits, 3, optional: true, type: :uint64, json_name: "txnidMostBits", default: 0)
field(:subscription, 4, optional: true, type: Pulsar.Protocol.Binary.Pulsar.Proto.Subscription)
field(:txn_action, 5,
optional: true,
type: Pulsar.Protocol.Binary.Pulsar.Proto.TxnAction,
json_name: "txnAction",
enum: true
)
field(:txnid_least_bits_of_low_watermark, 6,
optional: true,
type: :uint64,
json_name: "txnidLeastBitsOfLowWatermark"
)
end
defmodule Pulsar.Protocol.Binary.Pulsar.Proto.CommandEndTxnOnSubscriptionResponse do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.15.0", syntax: :proto2
field(:request_id, 1, required: true, type: :uint64, json_name: "requestId")
field(:txnid_least_bits, 2,
optional: true,
type: :uint64,
json_name: "txnidLeastBits",
default: 0
)
field(:txnid_most_bits, 3, optional: true, type: :uint64, json_name: "txnidMostBits", default: 0)
field(:error, 4,
optional: true,
type: Pulsar.Protocol.Binary.Pulsar.Proto.ServerError,
enum: true
)
field(:message, 5, optional: true, type: :string)
end
defmodule Pulsar.Protocol.Binary.Pulsar.Proto.BaseCommand do
@moduledoc false
use Protobuf, protoc_gen_elixir_version: "0.15.0", syntax: :proto2
field(:type, 1,
required: true,
type: Pulsar.Protocol.Binary.Pulsar.Proto.BaseCommand.Type,
enum: true
)
field(:connect, 2, optional: true, type: Pulsar.Protocol.Binary.Pulsar.Proto.CommandConnect)
field(:connected, 3, optional: true, type: Pulsar.Protocol.Binary.Pulsar.Proto.CommandConnected)
field(:subscribe, 4, optional: true, type: Pulsar.Protocol.Binary.Pulsar.Proto.CommandSubscribe)
field(:producer, 5, optional: true, type: Pulsar.Protocol.Binary.Pulsar.Proto.CommandProducer)
field(:send, 6, optional: true, type: Pulsar.Protocol.Binary.Pulsar.Proto.CommandSend)
field(:send_receipt, 7,
optional: true,
type: Pulsar.Protocol.Binary.Pulsar.Proto.CommandSendReceipt,
json_name: "sendReceipt"
)
field(:send_error, 8,
optional: true,
type: Pulsar.Protocol.Binary.Pulsar.Proto.CommandSendError,
json_name: "sendError"
)
field(:message, 9, optional: true, type: Pulsar.Protocol.Binary.Pulsar.Proto.CommandMessage)
field(:ack, 10, optional: true, type: Pulsar.Protocol.Binary.Pulsar.Proto.CommandAck)
field(:flow, 11, optional: true, type: Pulsar.Protocol.Binary.Pulsar.Proto.CommandFlow)
field(:unsubscribe, 12,
optional: true,
type: Pulsar.Protocol.Binary.Pulsar.Proto.CommandUnsubscribe
)
field(:success, 13, optional: true, type: Pulsar.Protocol.Binary.Pulsar.Proto.CommandSuccess)
field(:error, 14, optional: true, type: Pulsar.Protocol.Binary.Pulsar.Proto.CommandError)
field(:close_producer, 15,
optional: true,
type: Pulsar.Protocol.Binary.Pulsar.Proto.CommandCloseProducer,
json_name: "closeProducer"
)
field(:close_consumer, 16,
optional: true,
type: Pulsar.Protocol.Binary.Pulsar.Proto.CommandCloseConsumer,
json_name: "closeConsumer"
)
field(:producer_success, 17,
optional: true,
type: Pulsar.Protocol.Binary.Pulsar.Proto.CommandProducerSuccess,
json_name: "producerSuccess"
)
field(:ping, 18, optional: true, type: Pulsar.Protocol.Binary.Pulsar.Proto.CommandPing)
field(:pong, 19, optional: true, type: Pulsar.Protocol.Binary.Pulsar.Proto.CommandPong)
field(:redeliverUnacknowledgedMessages, 20,
optional: true,
type: Pulsar.Protocol.Binary.Pulsar.Proto.CommandRedeliverUnacknowledgedMessages
)
field(:partitionMetadata, 21,
optional: true,
type: Pulsar.Protocol.Binary.Pulsar.Proto.CommandPartitionedTopicMetadata
)
field(:partitionMetadataResponse, 22,
optional: true,
type: Pulsar.Protocol.Binary.Pulsar.Proto.CommandPartitionedTopicMetadataResponse
)
field(:lookupTopic, 23,
optional: true,
type: Pulsar.Protocol.Binary.Pulsar.Proto.CommandLookupTopic
)
field(:lookupTopicResponse, 24,
optional: true,
type: Pulsar.Protocol.Binary.Pulsar.Proto.CommandLookupTopicResponse
)
field(:consumerStats, 25,
optional: true,
type: Pulsar.Protocol.Binary.Pulsar.Proto.CommandConsumerStats
)
field(:consumerStatsResponse, 26,
optional: true,
type: Pulsar.Protocol.Binary.Pulsar.Proto.CommandConsumerStatsResponse
)
field(:reachedEndOfTopic, 27,
optional: true,
type: Pulsar.Protocol.Binary.Pulsar.Proto.CommandReachedEndOfTopic
)
field(:seek, 28, optional: true, type: Pulsar.Protocol.Binary.Pulsar.Proto.CommandSeek)
field(:getLastMessageId, 29,
optional: true,
type: Pulsar.Protocol.Binary.Pulsar.Proto.CommandGetLastMessageId
)
field(:getLastMessageIdResponse, 30,
optional: true,
type: Pulsar.Protocol.Binary.Pulsar.Proto.CommandGetLastMessageIdResponse
)
field(:active_consumer_change, 31,
optional: true,
type: Pulsar.Protocol.Binary.Pulsar.Proto.CommandActiveConsumerChange,
json_name: "activeConsumerChange"
)
field(:getTopicsOfNamespace, 32,
optional: true,
type: Pulsar.Protocol.Binary.Pulsar.Proto.CommandGetTopicsOfNamespace
)
field(:getTopicsOfNamespaceResponse, 33,
optional: true,
type: Pulsar.Protocol.Binary.Pulsar.Proto.CommandGetTopicsOfNamespaceResponse
)
field(:getSchema, 34, optional: true, type: Pulsar.Protocol.Binary.Pulsar.Proto.CommandGetSchema)
field(:getSchemaResponse, 35,
optional: true,
type: Pulsar.Protocol.Binary.Pulsar.Proto.CommandGetSchemaResponse
)
field(:authChallenge, 36,
optional: true,
type: Pulsar.Protocol.Binary.Pulsar.Proto.CommandAuthChallenge
)
field(:authResponse, 37,
optional: true,
type: Pulsar.Protocol.Binary.Pulsar.Proto.CommandAuthResponse
)
field(:ackResponse, 38,
optional: true,
type: Pulsar.Protocol.Binary.Pulsar.Proto.CommandAckResponse
)
field(:getOrCreateSchema, 39,
optional: true,
type: Pulsar.Protocol.Binary.Pulsar.Proto.CommandGetOrCreateSchema
)
field(:getOrCreateSchemaResponse, 40,
optional: true,
type: Pulsar.Protocol.Binary.Pulsar.Proto.CommandGetOrCreateSchemaResponse
)
field(:newTxn, 50, optional: true, type: Pulsar.Protocol.Binary.Pulsar.Proto.CommandNewTxn)
field(:newTxnResponse, 51,
optional: true,
type: Pulsar.Protocol.Binary.Pulsar.Proto.CommandNewTxnResponse
)
field(:addPartitionToTxn, 52,
optional: true,
type: Pulsar.Protocol.Binary.Pulsar.Proto.CommandAddPartitionToTxn
)
field(:addPartitionToTxnResponse, 53,
optional: true,
type: Pulsar.Protocol.Binary.Pulsar.Proto.CommandAddPartitionToTxnResponse
)
field(:addSubscriptionToTxn, 54,
optional: true,
type: Pulsar.Protocol.Binary.Pulsar.Proto.CommandAddSubscriptionToTxn
)
field(:addSubscriptionToTxnResponse, 55,
optional: true,
type: Pulsar.Protocol.Binary.Pulsar.Proto.CommandAddSubscriptionToTxnResponse
)
field(:endTxn, 56, optional: true, type: Pulsar.Protocol.Binary.Pulsar.Proto.CommandEndTxn)
field(:endTxnResponse, 57,
optional: true,
type: Pulsar.Protocol.Binary.Pulsar.Proto.CommandEndTxnResponse
)
field(:endTxnOnPartition, 58,
optional: true,
type: Pulsar.Protocol.Binary.Pulsar.Proto.CommandEndTxnOnPartition
)
field(:endTxnOnPartitionResponse, 59,
optional: true,
type: Pulsar.Protocol.Binary.Pulsar.Proto.CommandEndTxnOnPartitionResponse
)
field(:endTxnOnSubscription, 60,
optional: true,
type: Pulsar.Protocol.Binary.Pulsar.Proto.CommandEndTxnOnSubscription
)
field(:endTxnOnSubscriptionResponse, 61,
optional: true,
type: Pulsar.Protocol.Binary.Pulsar.Proto.CommandEndTxnOnSubscriptionResponse
)
field(:tcClientConnectRequest, 62,
optional: true,
type: Pulsar.Protocol.Binary.Pulsar.Proto.CommandTcClientConnectRequest
)
field(:tcClientConnectResponse, 63,
optional: true,
type: Pulsar.Protocol.Binary.Pulsar.Proto.CommandTcClientConnectResponse
)
field(:watchTopicList, 64,
optional: true,
type: Pulsar.Protocol.Binary.Pulsar.Proto.CommandWatchTopicList
)
field(:watchTopicListSuccess, 65,
optional: true,
type: Pulsar.Protocol.Binary.Pulsar.Proto.CommandWatchTopicListSuccess
)
field(:watchTopicUpdate, 66,
optional: true,
type: Pulsar.Protocol.Binary.Pulsar.Proto.CommandWatchTopicUpdate
)
field(:watchTopicListClose, 67,
optional: true,
type: Pulsar.Protocol.Binary.Pulsar.Proto.CommandWatchTopicListClose
)
field(:topicMigrated, 68,
optional: true,
type: Pulsar.Protocol.Binary.Pulsar.Proto.CommandTopicMigrated
)
end