From 5928e3a295b294b7a1ccfcab1dd5d6160e0843ad Mon Sep 17 00:00:00 2001 From: Lars Hvam Date: Mon, 21 Aug 2023 11:43:13 +0200 Subject: [PATCH] update --- .../zcl_protobuf_generate_clas.clas.xml | 16 ++++ .../zcl_protobuf_generate_intf.clas.abap | 2 + .../zif_protobuf_generated.intf.abap | 89 +++++++++++++++++++ 3 files changed, 107 insertions(+) create mode 100644 src/generator/zcl_protobuf_generate_clas.clas.xml diff --git a/src/generator/zcl_protobuf_generate_clas.clas.xml b/src/generator/zcl_protobuf_generate_clas.clas.xml new file mode 100644 index 0000000..add6adf --- /dev/null +++ b/src/generator/zcl_protobuf_generate_clas.clas.xml @@ -0,0 +1,16 @@ + + + + + + ZCL_PROTOBUF_GENERATE_CLAS + E + ZCL_PROTOBUF_GENERATOR CLAS + 1 + X + X + X + + + + diff --git a/src/generator/zcl_protobuf_generate_intf.clas.abap b/src/generator/zcl_protobuf_generate_intf.clas.abap index 15ac8f6..e33b1f1 100644 --- a/src/generator/zcl_protobuf_generate_intf.clas.abap +++ b/src/generator/zcl_protobuf_generate_intf.clas.abap @@ -71,6 +71,7 @@ CLASS zcl_protobuf_generate_intf IMPLEMENTATION. ENDCASE. ENDLOOP. + rv_abap = rv_abap && |* Message "| && io_message->mv_name && |",\n|. rv_abap = rv_abap && |TYPES: BEGIN OF { io_message->mv_name },\n|. LOOP AT io_message->mt_artefacts INTO lo_artefact. @@ -92,6 +93,7 @@ CLASS zcl_protobuf_generate_intf IMPLEMENTATION. METHOD enum. * targeting 750, so cannot use ENUM, + rv_abap = rv_abap && |* Enum "| && io_enum->mv_name && |",\n|. rv_abap = rv_abap && |TYPES { io_enum->mv_name } TYPE i.\n|. rv_abap = rv_abap && |CONSTANTS: BEGIN OF { io_enum->mv_name },\n|. LOOP AT io_enum->mt_fields INTO DATA(ls_field). diff --git a/test/generated/zif_protobuf_generated.intf.abap b/test/generated/zif_protobuf_generated.intf.abap index 9bae5c6..3e8ca34 100644 --- a/test/generated/zif_protobuf_generated.intf.abap +++ b/test/generated/zif_protobuf_generated.intf.abap @@ -7,10 +7,12 @@ TYPES bool TYPE abap_bool. TYPES bytes TYPE xstring. TYPES double TYPE f. TYPES float TYPE f. +* Message "KeyValue", TYPES: BEGIN OF KeyValue, key TYPE string, value TYPE string, END OF KeyValue. +* Enum "Type", TYPES Type TYPE i. CONSTANTS: BEGIN OF Type, None TYPE Type VALUE 0, @@ -36,12 +38,14 @@ CONSTANTS: BEGIN OF Type, ProtobufNative TYPE Type VALUE 20, AutoConsume TYPE Type VALUE 21, END OF Type. +* Message "Schema", TYPES: BEGIN OF Schema, name TYPE string, schema_data TYPE bytes, type TYPE Type, properties TYPE STANDARD TABLE OF KeyValue WITH EMPTY KEY, END OF Schema. +* Message "MessageIdData", TYPES: BEGIN OF MessageIdData, ledgerId TYPE uint64, entryId TYPE uint64, @@ -50,19 +54,23 @@ TYPES: BEGIN OF MessageIdData, ack_set TYPE STANDARD TABLE OF int64 WITH EMPTY KEY, batch_size TYPE int32, END OF MessageIdData. +* Message "KeyLongValue", TYPES: BEGIN OF KeyLongValue, key TYPE string, value TYPE uint64, END OF KeyLongValue. +* Message "IntRange", TYPES: BEGIN OF IntRange, start TYPE int32, end TYPE int32, END OF IntRange. +* Message "EncryptionKeys", TYPES: BEGIN OF EncryptionKeys, key TYPE string, value TYPE bytes, metadata TYPE STANDARD TABLE OF KeyValue WITH EMPTY KEY, END OF EncryptionKeys. +* Enum "CompressionType", TYPES CompressionType TYPE i. CONSTANTS: BEGIN OF CompressionType, NONE TYPE CompressionType VALUE 0, @@ -71,6 +79,7 @@ CONSTANTS: BEGIN OF CompressionType, ZSTD TYPE CompressionType VALUE 3, SNAPPY TYPE CompressionType VALUE 4, END OF CompressionType. +* Enum "ProducerAccessMode", TYPES ProducerAccessMode TYPE i. CONSTANTS: BEGIN OF ProducerAccessMode, Shared TYPE ProducerAccessMode VALUE 0, @@ -78,6 +87,7 @@ CONSTANTS: BEGIN OF ProducerAccessMode, WaitForExclusive TYPE ProducerAccessMode VALUE 2, ExclusiveWithFencing TYPE ProducerAccessMode VALUE 3, END OF ProducerAccessMode. +* Message "MessageMetadata", TYPES: BEGIN OF MessageMetadata, producer_name TYPE string, sequence_id TYPE uint64, @@ -108,6 +118,7 @@ TYPES: BEGIN OF MessageMetadata, chunk_id TYPE int32, null_partition_key TYPE bool, END OF MessageMetadata. +* Message "SingleMessageMetadata", TYPES: BEGIN OF SingleMessageMetadata, properties TYPE STANDARD TABLE OF KeyValue WITH EMPTY KEY, partition_key TYPE string, @@ -120,10 +131,12 @@ TYPES: BEGIN OF SingleMessageMetadata, null_value TYPE bool, null_partition_key TYPE bool, END OF SingleMessageMetadata. +* Message "BrokerEntryMetadata", TYPES: BEGIN OF BrokerEntryMetadata, broker_timestamp TYPE uint64, index TYPE uint64, END OF BrokerEntryMetadata. +* Enum "ServerError", TYPES ServerError TYPE i. CONSTANTS: BEGIN OF ServerError, UnknownError TYPE ServerError VALUE 0, @@ -153,12 +166,14 @@ CONSTANTS: BEGIN OF ServerError, TransactionNotFound TYPE ServerError VALUE 24, ProducerFenced TYPE ServerError VALUE 25, END OF ServerError. +* Enum "AuthMethod", TYPES AuthMethod TYPE i. CONSTANTS: BEGIN OF AuthMethod, AuthMethodNone TYPE AuthMethod VALUE 0, AuthMethodYcaV1 TYPE AuthMethod VALUE 1, AuthMethodAthens TYPE AuthMethod VALUE 2, END OF AuthMethod. +* Enum "ProtocolVersion", TYPES ProtocolVersion TYPE i. CONSTANTS: BEGIN OF ProtocolVersion, v0 TYPE ProtocolVersion VALUE 0, @@ -184,12 +199,14 @@ CONSTANTS: BEGIN OF ProtocolVersion, v20 TYPE ProtocolVersion VALUE 20, v21 TYPE ProtocolVersion VALUE 21, END OF ProtocolVersion. +* Message "FeatureFlags", TYPES: BEGIN OF FeatureFlags, supports_auth_refresh TYPE bool, supports_broker_entry_metadata TYPE bool, supports_partial_producer TYPE bool, supports_topic_watchers TYPE bool, END OF FeatureFlags. +* Message "CommandConnect", TYPES: BEGIN OF CommandConnect, client_version TYPE string, auth_method TYPE AuthMethod, @@ -203,36 +220,43 @@ TYPES: BEGIN OF CommandConnect, feature_flags TYPE FeatureFlags, proxy_version TYPE string, END OF CommandConnect. +* Message "CommandConnected", TYPES: BEGIN OF CommandConnected, server_version TYPE string, protocol_version TYPE int32, max_message_size TYPE int32, feature_flags TYPE FeatureFlags, END OF CommandConnected. +* Message "AuthData", TYPES: BEGIN OF AuthData, auth_method_name TYPE string, auth_data TYPE bytes, END OF AuthData. +* Message "CommandAuthResponse", TYPES: BEGIN OF CommandAuthResponse, client_version TYPE string, response TYPE AuthData, protocol_version TYPE int32, END OF CommandAuthResponse. +* Message "CommandAuthChallenge", TYPES: BEGIN OF CommandAuthChallenge, server_version TYPE string, challenge TYPE AuthData, protocol_version TYPE int32, END OF CommandAuthChallenge. +* Enum "KeySharedMode", TYPES KeySharedMode TYPE i. CONSTANTS: BEGIN OF KeySharedMode, AUTO_SPLIT TYPE KeySharedMode VALUE 0, STICKY TYPE KeySharedMode VALUE 1, END OF KeySharedMode. +* Message "KeySharedMeta", TYPES: BEGIN OF KeySharedMeta, keySharedMode TYPE KeySharedMode, hashRanges TYPE STANDARD TABLE OF IntRange WITH EMPTY KEY, allowOutOfOrderDelivery TYPE bool, END OF KeySharedMeta. +* Enum "SubType", TYPES SubType TYPE i. CONSTANTS: BEGIN OF SubType, Exclusive TYPE SubType VALUE 0, @@ -240,11 +264,13 @@ CONSTANTS: BEGIN OF SubType, Failover TYPE SubType VALUE 2, Key_Shared TYPE SubType VALUE 3, END OF SubType. +* Enum "InitialPosition", TYPES InitialPosition TYPE i. CONSTANTS: BEGIN OF InitialPosition, Latest TYPE InitialPosition VALUE 0, Earliest TYPE InitialPosition VALUE 1, END OF InitialPosition. +* Message "CommandSubscribe", TYPES: BEGIN OF CommandSubscribe, topic TYPE string, subscription TYPE string, @@ -266,6 +292,7 @@ TYPES: BEGIN OF CommandSubscribe, subscription_properties TYPE STANDARD TABLE OF KeyValue WITH EMPTY KEY, consumer_epoch TYPE uint64, END OF CommandSubscribe. +* Message "CommandPartitionedTopicMetadata", TYPES: BEGIN OF CommandPartitionedTopicMetadata, topic TYPE string, request_id TYPE uint64, @@ -273,11 +300,13 @@ TYPES: BEGIN OF CommandPartitionedTopicMetadata, original_auth_data TYPE string, original_auth_method TYPE string, END OF CommandPartitionedTopicMetadata. +* Enum "CLookupType", TYPES CLookupType TYPE i. CONSTANTS: BEGIN OF CLookupType, Success TYPE CLookupType VALUE 0, Failed TYPE CLookupType VALUE 1, END OF CLookupType. +* Message "CommandPartitionedTopicMetadataResponse", TYPES: BEGIN OF CommandPartitionedTopicMetadataResponse, partitions TYPE uint32, request_id TYPE uint64, @@ -285,6 +314,7 @@ TYPES: BEGIN OF CommandPartitionedTopicMetadataResponse, error TYPE ServerError, message TYPE string, END OF CommandPartitionedTopicMetadataResponse. +* Message "CommandLookupTopic", TYPES: BEGIN OF CommandLookupTopic, topic TYPE string, request_id TYPE uint64, @@ -294,12 +324,14 @@ TYPES: BEGIN OF CommandLookupTopic, original_auth_method TYPE string, advertised_listener_name TYPE string, END OF CommandLookupTopic. +* Enum "LookupType", TYPES LookupType TYPE i. CONSTANTS: BEGIN OF LookupType, Redirect TYPE LookupType VALUE 0, Connect TYPE LookupType VALUE 1, Failed TYPE LookupType VALUE 2, END OF LookupType. +* Message "CommandLookupTopicResponse", TYPES: BEGIN OF CommandLookupTopicResponse, brokerServiceUrl TYPE string, brokerServiceUrlTls TYPE string, @@ -310,6 +342,7 @@ TYPES: BEGIN OF CommandLookupTopicResponse, message TYPE string, proxy_through_service_url TYPE bool, END OF CommandLookupTopicResponse. +* Message "CommandProducer", TYPES: BEGIN OF CommandProducer, topic TYPE string, producer_id TYPE uint64, @@ -325,6 +358,7 @@ TYPES: BEGIN OF CommandProducer, txn_enabled TYPE bool, initial_subscription_name TYPE string, END OF CommandProducer. +* Message "CommandSend", TYPES: BEGIN OF CommandSend, producer_id TYPE uint64, sequence_id TYPE uint64, @@ -336,18 +370,21 @@ TYPES: BEGIN OF CommandSend, marker TYPE bool, message_id TYPE MessageIdData, END OF CommandSend. +* Message "CommandSendReceipt", TYPES: BEGIN OF CommandSendReceipt, producer_id TYPE uint64, sequence_id TYPE uint64, message_id TYPE MessageIdData, highest_sequence_id TYPE uint64, END OF CommandSendReceipt. +* Message "CommandSendError", TYPES: BEGIN OF CommandSendError, producer_id TYPE uint64, sequence_id TYPE uint64, error TYPE ServerError, message TYPE string, END OF CommandSendError. +* Message "CommandMessage", TYPES: BEGIN OF CommandMessage, consumer_id TYPE uint64, message_id TYPE MessageIdData, @@ -355,11 +392,13 @@ TYPES: BEGIN OF CommandMessage, ack_set TYPE STANDARD TABLE OF int64 WITH EMPTY KEY, consumer_epoch TYPE uint64, END OF CommandMessage. +* Enum "AckType", TYPES AckType TYPE i. CONSTANTS: BEGIN OF AckType, Individual TYPE AckType VALUE 0, Cumulative TYPE AckType VALUE 1, END OF AckType. +* Enum "ValidationError", TYPES ValidationError TYPE i. CONSTANTS: BEGIN OF ValidationError, UncompressedSizeCorruption TYPE ValidationError VALUE 0, @@ -368,6 +407,7 @@ CONSTANTS: BEGIN OF ValidationError, BatchDeSerializeError TYPE ValidationError VALUE 3, DecryptionError TYPE ValidationError VALUE 4, END OF ValidationError. +* Message "CommandAck", TYPES: BEGIN OF CommandAck, consumer_id TYPE uint64, ack_type TYPE AckType, @@ -378,6 +418,7 @@ TYPES: BEGIN OF CommandAck, txnid_most_bits TYPE uint64, request_id TYPE uint64, END OF CommandAck. +* Message "CommandAckResponse", TYPES: BEGIN OF CommandAckResponse, consumer_id TYPE uint64, txnid_least_bits TYPE uint64, @@ -386,55 +427,67 @@ TYPES: BEGIN OF CommandAckResponse, message TYPE string, request_id TYPE uint64, END OF CommandAckResponse. +* Message "CommandActiveConsumerChange", TYPES: BEGIN OF CommandActiveConsumerChange, consumer_id TYPE uint64, is_active TYPE bool, END OF CommandActiveConsumerChange. +* Message "CommandFlow", TYPES: BEGIN OF CommandFlow, consumer_id TYPE uint64, messagePermits TYPE uint32, END OF CommandFlow. +* Message "CommandUnsubscribe", TYPES: BEGIN OF CommandUnsubscribe, consumer_id TYPE uint64, request_id TYPE uint64, END OF CommandUnsubscribe. +* Message "CommandSeek", TYPES: BEGIN OF CommandSeek, consumer_id TYPE uint64, request_id TYPE uint64, message_id TYPE MessageIdData, message_publish_time TYPE uint64, END OF CommandSeek. +* Message "CommandReachedEndOfTopic", TYPES: BEGIN OF CommandReachedEndOfTopic, consumer_id TYPE uint64, END OF CommandReachedEndOfTopic. +* Enum "ResourceType", TYPES ResourceType TYPE i. CONSTANTS: BEGIN OF ResourceType, Producer TYPE ResourceType VALUE 0, Consumer TYPE ResourceType VALUE 1, END OF ResourceType. +* Message "CommandTopicMigrated", TYPES: BEGIN OF CommandTopicMigrated, resource_id TYPE uint64, resource_type TYPE ResourceType, brokerServiceUrl TYPE string, brokerServiceUrlTls TYPE string, END OF CommandTopicMigrated. +* Message "CommandCloseProducer", TYPES: BEGIN OF CommandCloseProducer, producer_id TYPE uint64, request_id TYPE uint64, END OF CommandCloseProducer. +* Message "CommandCloseConsumer", TYPES: BEGIN OF CommandCloseConsumer, consumer_id TYPE uint64, request_id TYPE uint64, END OF CommandCloseConsumer. +* Message "CommandRedeliverUnacknowledgedMessages", TYPES: BEGIN OF CommandRedeliverUnacknowledgedMessages, consumer_id TYPE uint64, message_ids TYPE STANDARD TABLE OF MessageIdData WITH EMPTY KEY, consumer_epoch TYPE uint64, END OF CommandRedeliverUnacknowledgedMessages. +* Message "CommandSuccess", TYPES: BEGIN OF CommandSuccess, request_id TYPE uint64, schema TYPE Schema, END OF CommandSuccess. +* Message "CommandProducerSuccess", TYPES: BEGIN OF CommandProducerSuccess, request_id TYPE uint64, producer_name TYPE string, @@ -443,21 +496,26 @@ TYPES: BEGIN OF CommandProducerSuccess, topic_epoch TYPE uint64, producer_ready TYPE bool, END OF CommandProducerSuccess. +* Message "CommandError", TYPES: BEGIN OF CommandError, request_id TYPE uint64, error TYPE ServerError, message TYPE string, END OF CommandError. +* Message "CommandPing", TYPES: BEGIN OF CommandPing, dummy TYPE string, END OF CommandPing. +* Message "CommandPong", TYPES: BEGIN OF CommandPong, dummy TYPE string, END OF CommandPong. +* Message "CommandConsumerStats", TYPES: BEGIN OF CommandConsumerStats, request_id TYPE uint64, consumer_id TYPE uint64, END OF CommandConsumerStats. +* Message "CommandConsumerStatsResponse", TYPES: BEGIN OF CommandConsumerStatsResponse, request_id TYPE uint64, error_code TYPE ServerError, @@ -476,21 +534,25 @@ TYPES: BEGIN OF CommandConsumerStatsResponse, msgBacklog TYPE uint64, messageAckRate TYPE double, END OF CommandConsumerStatsResponse. +* Message "CommandGetLastMessageId", TYPES: BEGIN OF CommandGetLastMessageId, consumer_id TYPE uint64, request_id TYPE uint64, END OF CommandGetLastMessageId. +* Message "CommandGetLastMessageIdResponse", TYPES: BEGIN OF CommandGetLastMessageIdResponse, last_message_id TYPE MessageIdData, request_id TYPE uint64, consumer_mark_delete_position TYPE MessageIdData, END OF CommandGetLastMessageIdResponse. +* Enum "Mode", TYPES Mode TYPE i. CONSTANTS: BEGIN OF Mode, PERSISTENT TYPE Mode VALUE 0, NON_PERSISTENT TYPE Mode VALUE 1, ALL TYPE Mode VALUE 2, END OF Mode. +* Message "CommandGetTopicsOfNamespace", TYPES: BEGIN OF CommandGetTopicsOfNamespace, request_id TYPE uint64, namespace TYPE string, @@ -498,6 +560,7 @@ TYPES: BEGIN OF CommandGetTopicsOfNamespace, topics_pattern TYPE string, topics_hash TYPE string, END OF CommandGetTopicsOfNamespace. +* Message "CommandGetTopicsOfNamespaceResponse", TYPES: BEGIN OF CommandGetTopicsOfNamespaceResponse, request_id TYPE uint64, topics TYPE STANDARD TABLE OF string WITH EMPTY KEY, @@ -505,6 +568,7 @@ TYPES: BEGIN OF CommandGetTopicsOfNamespaceResponse, topics_hash TYPE string, changed TYPE bool, END OF CommandGetTopicsOfNamespaceResponse. +* Message "CommandWatchTopicList", TYPES: BEGIN OF CommandWatchTopicList, request_id TYPE uint64, watcher_id TYPE uint64, @@ -512,27 +576,32 @@ TYPES: BEGIN OF CommandWatchTopicList, topics_pattern TYPE string, topics_hash TYPE string, END OF CommandWatchTopicList. +* Message "CommandWatchTopicListSuccess", TYPES: BEGIN OF CommandWatchTopicListSuccess, request_id TYPE uint64, watcher_id TYPE uint64, topic TYPE STANDARD TABLE OF string WITH EMPTY KEY, topics_hash TYPE string, END OF CommandWatchTopicListSuccess. +* Message "CommandWatchTopicUpdate", TYPES: BEGIN OF CommandWatchTopicUpdate, watcher_id TYPE uint64, new_topics TYPE STANDARD TABLE OF string WITH EMPTY KEY, deleted_topics TYPE STANDARD TABLE OF string WITH EMPTY KEY, topics_hash TYPE string, END OF CommandWatchTopicUpdate. +* Message "CommandWatchTopicListClose", TYPES: BEGIN OF CommandWatchTopicListClose, request_id TYPE uint64, watcher_id TYPE uint64, END OF CommandWatchTopicListClose. +* Message "CommandGetSchema", TYPES: BEGIN OF CommandGetSchema, request_id TYPE uint64, topic TYPE string, schema_version TYPE bytes, END OF CommandGetSchema. +* Message "CommandGetSchemaResponse", TYPES: BEGIN OF CommandGetSchemaResponse, request_id TYPE uint64, error_code TYPE ServerError, @@ -540,36 +609,43 @@ TYPES: BEGIN OF CommandGetSchemaResponse, schema TYPE Schema, schema_version TYPE bytes, END OF CommandGetSchemaResponse. +* Message "CommandGetOrCreateSchema", TYPES: BEGIN OF CommandGetOrCreateSchema, request_id TYPE uint64, topic TYPE string, schema TYPE Schema, END OF CommandGetOrCreateSchema. +* Message "CommandGetOrCreateSchemaResponse", TYPES: BEGIN OF CommandGetOrCreateSchemaResponse, request_id TYPE uint64, error_code TYPE ServerError, error_message TYPE string, schema_version TYPE bytes, END OF CommandGetOrCreateSchemaResponse. +* Enum "TxnAction", TYPES TxnAction TYPE i. CONSTANTS: BEGIN OF TxnAction, COMMIT TYPE TxnAction VALUE 0, ABORT TYPE TxnAction VALUE 1, END OF TxnAction. +* Message "CommandTcClientConnectRequest", TYPES: BEGIN OF CommandTcClientConnectRequest, request_id TYPE uint64, tc_id TYPE uint64, END OF CommandTcClientConnectRequest. +* Message "CommandTcClientConnectResponse", TYPES: BEGIN OF CommandTcClientConnectResponse, request_id TYPE uint64, error TYPE ServerError, message TYPE string, END OF CommandTcClientConnectResponse. +* Message "CommandNewTxn", TYPES: BEGIN OF CommandNewTxn, request_id TYPE uint64, txn_ttl_seconds TYPE uint64, tc_id TYPE uint64, END OF CommandNewTxn. +* Message "CommandNewTxnResponse", TYPES: BEGIN OF CommandNewTxnResponse, request_id TYPE uint64, txnid_least_bits TYPE uint64, @@ -577,12 +653,14 @@ TYPES: BEGIN OF CommandNewTxnResponse, error TYPE ServerError, message TYPE string, END OF CommandNewTxnResponse. +* Message "CommandAddPartitionToTxn", TYPES: BEGIN OF CommandAddPartitionToTxn, request_id TYPE uint64, txnid_least_bits TYPE uint64, txnid_most_bits TYPE uint64, partitions TYPE STANDARD TABLE OF string WITH EMPTY KEY, END OF CommandAddPartitionToTxn. +* Message "CommandAddPartitionToTxnResponse", TYPES: BEGIN OF CommandAddPartitionToTxnResponse, request_id TYPE uint64, txnid_least_bits TYPE uint64, @@ -590,16 +668,19 @@ TYPES: BEGIN OF CommandAddPartitionToTxnResponse, error TYPE ServerError, message TYPE string, END OF CommandAddPartitionToTxnResponse. +* Message "Subscription", TYPES: BEGIN OF Subscription, topic TYPE string, subscription TYPE string, END OF Subscription. +* Message "CommandAddSubscriptionToTxn", TYPES: BEGIN OF CommandAddSubscriptionToTxn, request_id TYPE uint64, txnid_least_bits TYPE uint64, txnid_most_bits TYPE uint64, subscription TYPE STANDARD TABLE OF Subscription WITH EMPTY KEY, END OF CommandAddSubscriptionToTxn. +* Message "CommandAddSubscriptionToTxnResponse", TYPES: BEGIN OF CommandAddSubscriptionToTxnResponse, request_id TYPE uint64, txnid_least_bits TYPE uint64, @@ -607,12 +688,14 @@ TYPES: BEGIN OF CommandAddSubscriptionToTxnResponse, error TYPE ServerError, message TYPE string, END OF CommandAddSubscriptionToTxnResponse. +* Message "CommandEndTxn", TYPES: BEGIN OF CommandEndTxn, request_id TYPE uint64, txnid_least_bits TYPE uint64, txnid_most_bits TYPE uint64, txn_action TYPE TxnAction, END OF CommandEndTxn. +* Message "CommandEndTxnResponse", TYPES: BEGIN OF CommandEndTxnResponse, request_id TYPE uint64, txnid_least_bits TYPE uint64, @@ -620,6 +703,7 @@ TYPES: BEGIN OF CommandEndTxnResponse, error TYPE ServerError, message TYPE string, END OF CommandEndTxnResponse. +* Message "CommandEndTxnOnPartition", TYPES: BEGIN OF CommandEndTxnOnPartition, request_id TYPE uint64, txnid_least_bits TYPE uint64, @@ -628,6 +712,7 @@ TYPES: BEGIN OF CommandEndTxnOnPartition, txn_action TYPE TxnAction, txnid_least_bits_of_low_watermark TYPE uint64, END OF CommandEndTxnOnPartition. +* Message "CommandEndTxnOnPartitionResponse", TYPES: BEGIN OF CommandEndTxnOnPartitionResponse, request_id TYPE uint64, txnid_least_bits TYPE uint64, @@ -635,6 +720,7 @@ TYPES: BEGIN OF CommandEndTxnOnPartitionResponse, error TYPE ServerError, message TYPE string, END OF CommandEndTxnOnPartitionResponse. +* Message "CommandEndTxnOnSubscription", TYPES: BEGIN OF CommandEndTxnOnSubscription, request_id TYPE uint64, txnid_least_bits TYPE uint64, @@ -643,6 +729,7 @@ TYPES: BEGIN OF CommandEndTxnOnSubscription, txn_action TYPE TxnAction, txnid_least_bits_of_low_watermark TYPE uint64, END OF CommandEndTxnOnSubscription. +* Message "CommandEndTxnOnSubscriptionResponse", TYPES: BEGIN OF CommandEndTxnOnSubscriptionResponse, request_id TYPE uint64, txnid_least_bits TYPE uint64, @@ -650,6 +737,7 @@ TYPES: BEGIN OF CommandEndTxnOnSubscriptionResponse, error TYPE ServerError, message TYPE string, END OF CommandEndTxnOnSubscriptionResponse. +* Enum "BaseCommandType", TYPES BaseCommandType TYPE i. CONSTANTS: BEGIN OF BaseCommandType, CONNECT TYPE BaseCommandType VALUE 2, @@ -711,6 +799,7 @@ CONSTANTS: BEGIN OF BaseCommandType, WATCH_TOPIC_LIST_CLOSE TYPE BaseCommandType VALUE 67, TOPIC_MIGRATED TYPE BaseCommandType VALUE 68, END OF BaseCommandType. +* Message "BaseCommand", TYPES: BEGIN OF BaseCommand, type TYPE BaseCommandType, connect TYPE CommandConnect,