/
githubmirror
/
ydb-php-sdk
Обзор
Документация
Войти
/
githubmirror
/
ydb-php-sdk
Код
Запросы
0
Пакеты
0
Релизы
0
Аналитика
Безопасность
main
protos/GPBMetadata/Protos/YdbTopic.php
407 строк
14 KB
Alexei Shabalin
updated protos
17 фев 2023, 13:31
17 фев 2023, 13:31
ae6a264
Код
Авторство
О чём код?
<?php # Generated by the protocol buffer compiler. DO NOT EDIT! # source: protos/ydb_topic.proto namespace GPBMetadata\Protos; class YdbTopic { public static $is_initialized = false; public static function initOnce() { $pool = \Google\Protobuf\Internal\DescriptorPool::getGeneratedPool(); if (static::$is_initialized == true) { return; } \GPBMetadata\Protos\YdbOperation::initOnce(); \GPBMetadata\Protos\YdbScheme::initOnce(); \GPBMetadata\Protos\YdbStatusCodes::initOnce(); \GPBMetadata\Protos\YdbIssueMessage::initOnce(); \GPBMetadata\Protos\YdbTable::initOnce(); \GPBMetadata\Protos\Annotations\Validation::initOnce(); \GPBMetadata\Google\Protobuf\Duration::initOnce(); \GPBMetadata\Google\Protobuf\Timestamp::initOnce(); $pool->internalAddGeneratedFile( ' �e protos/ydb_topic.proto Ydb.Topicprotos/ydb_scheme.proto protos/ydb_status_codes.proto protos/ydb_issue_message.protoprotos/ydb_table.proto#protos/annotations/validation.proto google/protobuf/duration.proto google/protobuf/timestamp.proto"7 SupportedCodecs$ codecs (B��* [1; 19999]��*d"* OffsetsRange start ( end ("# UpdateTokenRequest token ( " UpdateTokenResponse"� StreamWriteMessage� FromClientA init_request ( 2).Ydb.Topic.StreamWriteMessage.InitRequestH C write_request ( 2*.Ydb.Topic.StreamWriteMessage.WriteRequestH = update_token_request ( 2 .Ydb.Topic.UpdateTokenRequestH B client_message� FromServer) status (2.Ydb.StatusIds.StatusCode\' issues ( 2.Ydb.Issue.IssueMessageC init_response ( 2*.Ydb.Topic.StreamWriteMessage.InitResponseH E write_response ( 2+.Ydb.Topic.StreamWriteMessage.WriteResponseH ? update_token_response ( 2 .Ydb.Topic.UpdateTokenResponseH B server_message� InitRequest path ( producer_id ( [ write_session_meta ( 2?.Ydb.Topic.StreamWriteMessage.InitRequest.WriteSessionMetaEntry message_group_id ( H partition_id (H get_last_seq_no (7 WriteSessionMetaEntry key ( value ( :8B partitioning� InitResponse last_seq_no ( session_id ( partition_id (4 supported_codecs ( 2.Ydb.Topic.SupportedCodecs� WriteRequestH messages ( 26.Ydb.Topic.StreamWriteMessage.WriteRequest.MessageData codec (� MessageData seq_no (. created_at ( 2.google.protobuf.Timestamp data ( uncompressed_size ( message_group_id ( H partition_id (H B partitioning� WriteResponseB acks ( 24.Ydb.Topic.StreamWriteMessage.WriteResponse.WriteAck partition_id (U write_statistics ( 2;.Ydb.Topic.StreamWriteMessage.WriteResponse.WriteStatistics� WriteAck seq_no (O written ( 2<.Ydb.Topic.StreamWriteMessage.WriteResponse.WriteAck.WrittenH O skipped ( 2<.Ydb.Topic.StreamWriteMessage.WriteResponse.WriteAck.SkippedH Written offset (� SkippedS reason (2C.Ydb.Topic.StreamWriteMessage.WriteResponse.WriteAck.Skipped.Reason"< Reason REASON_UNSPECIFIED REASON_ALREADY_WRITTENB message_write_status� WriteStatistics2 persisting_time ( 2.google.protobuf.Duration6 min_queue_wait_time ( 2.google.protobuf.Duration6 max_queue_wait_time ( 2.google.protobuf.Duration< partition_quota_wait_time ( 2.google.protobuf.Duration8 topic_quota_wait_time ( 2.google.protobuf.Duration"� StreamReadMessageT PartitionSession partition_session_id ( path ( partition_id (� FromClient@ init_request ( 2(.Ydb.Topic.StreamReadMessage.InitRequestH @ read_request ( 2(.Ydb.Topic.StreamReadMessage.ReadRequestH Q commit_offset_request ( 20.Ydb.Topic.StreamReadMessage.CommitOffsetRequestH f partition_session_status_request ( 2:.Ydb.Topic.StreamReadMessage.PartitionSessionStatusRequestH = update_token_request ( 2 .Ydb.Topic.UpdateTokenRequestH f start_partition_session_response ( 2:.Ydb.Topic.StreamReadMessage.StartPartitionSessionResponseH d stop_partition_session_response ( 29.Ydb.Topic.StreamReadMessage.StopPartitionSessionResponseH B client_message� FromServer) status (2.Ydb.StatusIds.StatusCode\' issues ( 2.Ydb.Issue.IssueMessageB init_response ( 2).Ydb.Topic.StreamReadMessage.InitResponseH B read_response ( 2).Ydb.Topic.StreamReadMessage.ReadResponseH S commit_offset_response ( 21.Ydb.Topic.StreamReadMessage.CommitOffsetResponseH h !partition_session_status_response ( 2;.Ydb.Topic.StreamReadMessage.PartitionSessionStatusResponseH ? update_token_response ( 2 .Ydb.Topic.UpdateTokenResponseH d start_partition_session_request ( 29.Ydb.Topic.StreamReadMessage.StartPartitionSessionRequestH b stop_partition_session_request ( 28.Ydb.Topic.StreamReadMessage.StopPartitionSessionRequestH B server_message� InitRequestX topics_read_settings ( 2:.Ydb.Topic.StreamReadMessage.InitRequest.TopicReadSettings consumer ( reader_name ( � TopicReadSettings path ( partition_ids (* max_lag ( 2.google.protobuf.Duration- read_from ( 2.google.protobuf.Timestamp" InitResponse session_id ( ! ReadRequest bytes_size (� ReadResponseO partition_data ( 27.Ydb.Topic.StreamReadMessage.ReadResponse.PartitionData bytes_size (� MessageData offset ( seq_no (. created_at ( 2.google.protobuf.Timestamp data ( uncompressed_size ( message_group_id ( � BatchK message_data ( 25.Ydb.Topic.StreamReadMessage.ReadResponse.MessageData producer_id ( a write_session_meta ( 2E.Ydb.Topic.StreamReadMessage.ReadResponse.Batch.WriteSessionMetaEntry codec (. written_at ( 2.google.protobuf.Timestamp7 WriteSessionMetaEntry key ( value ( :8o PartitionData partition_session_id (@ batches ( 2/.Ydb.Topic.StreamReadMessage.ReadResponse.Batch� CommitOffsetRequest^ commit_offsets ( 2F.Ydb.Topic.StreamReadMessage.CommitOffsetRequest.PartitionCommitOffset_ PartitionCommitOffset partition_session_id (( offsets ( 2.Ydb.Topic.OffsetsRange� CommitOffsetResponsep partitions_committed_offsets ( 2J.Ydb.Topic.StreamReadMessage.CommitOffsetResponse.PartitionCommittedOffsetR PartitionCommittedOffset partition_session_id ( committed_offset (= PartitionSessionStatusRequest partition_session_id (� PartitionSessionStatusResponse partition_session_id (2 partition_offsets ( 2.Ydb.Topic.OffsetsRange committed_offset (= write_time_high_watermark ( 2.google.protobuf.Timestamp� StartPartitionSessionRequestH partition_session ( 2-.Ydb.Topic.StreamReadMessage.PartitionSession committed_offset (2 partition_offsets ( 2.Ydb.Topic.OffsetsRange� StartPartitionSessionResponse partition_session_id ( read_offset (H � commit_offset (H�B _read_offsetB _commit_offsetg StopPartitionSessionRequest partition_session_id ( graceful ( committed_offset (< StopPartitionSessionResponse partition_session_id ("� AddOffsetsToTransactionRequest9 operation_params ( 2 .Ydb.Operations.OperationParams session_id ( 1 tx_control ( 2 .Ydb.Table.TransactionControlF topics ( 26.Ydb.Topic.AddOffsetsToTransactionRequest.TopicOffsets consumer ( � TopicOffsets path ( [ partitions ( 2G.Ydb.Topic.AddOffsetsToTransactionRequest.TopicOffsets.PartitionOffsets\\ PartitionOffsets partition_id (2 partition_offsets ( 2.Ydb.Topic.OffsetsRange"O AddOffsetsToTransactionResponse, operation ( 2.Ydb.Operations.Operation" AddOffsetsToTransactionResult"L MultipleWindowsStat per_minute ( per_hour ( per_day ("� Consumer name ( important (- read_from ( 2.google.protobuf.Timestamp4 supported_codecs ( 2.Ydb.Topic.SupportedCodecs7 attributes ( 2#.Ydb.Topic.Consumer.AttributesEntry9 consumer_stats ( 2!.Ydb.Topic.Consumer.ConsumerStats1 AttributesEntry key ( value ( :8� ConsumerStatsA min_partitions_last_read_time ( 2.google.protobuf.Timestamp4 max_read_time_lag ( 2.google.protobuf.Duration5 max_write_time_lag ( 2.google.protobuf.Duration2 bytes_read ( 2 .Ydb.Topic.MultipleWindowsStatJ"� AlterConsumer name ( set_important (H �1 set_read_from ( 2.google.protobuf.Timestamp8 set_supported_codecs ( 2.Ydb.Topic.SupportedCodecsG alter_attributes ( 2-.Ydb.Topic.AlterConsumer.AlterAttributesEntry6 AlterAttributesEntry key ( value ( :8B _set_importantJ"h PartitioningSettings\' min_active_partitions (B��*>= 0\' partition_count_limit (B��*>= 0"� AlterPartitioningSettings0 set_min_active_partitions (B��*>= 0H �0 set_partition_count_limit (B��*>= 0H�B _set_min_active_partitionsB _set_partition_count_limit"� CreateTopicRequest9 operation_params ( 2 .Ydb.Operations.OperationParams path ( > partitioning_settings ( 2 .Ydb.Topic.PartitioningSettings3 retention_period ( 2.google.protobuf.Duration& retention_storage_mb (B��*>= 04 supported_codecs ( 2.Ydb.Topic.SupportedCodecs8 &partition_write_speed_bytes_per_second (B��*>= 0- partition_write_burst_bytes (B��*>= 0A attributes ( 2-.Ydb.Topic.CreateTopicRequest.AttributesEntry/ consumers ( 2.Ydb.Topic.ConsumerB��*�. metering_mode (2.Ydb.Topic.MeteringMode1 AttributesEntry key ( value ( :8J"C CreateTopicResponse, operation ( 2.Ydb.Operations.Operation" CreateTopicResult"v DescribeTopicRequest9 operation_params ( 2 .Ydb.Operations.OperationParams path ( include_stats ("E DescribeTopicResponse, operation ( 2.Ydb.Operations.Operation"� DescribeTopicResult self ( 2.Ydb.Scheme.Entry> partitioning_settings ( 2 .Ydb.Topic.PartitioningSettings@ partitions ( 2,.Ydb.Topic.DescribeTopicResult.PartitionInfo3 retention_period ( 2.google.protobuf.Duration retention_storage_mb (4 supported_codecs ( 2.Ydb.Topic.SupportedCodecs. &partition_write_speed_bytes_per_second (# partition_write_burst_bytes (B attributes ( 2..Ydb.Topic.DescribeTopicResult.AttributesEntry& consumers ( 2.Ydb.Topic.Consumer. metering_mode (2.Ydb.Topic.MeteringMode> topic_stats ( 2).Ydb.Topic.DescribeTopicResult.TopicStats1 AttributesEntry key ( value ( :8� PartitionInfo partition_id ( active ( child_partition_ids ( parent_partition_ids (2 partition_stats ( 2.Ydb.Topic.PartitionStats� TopicStats store_size_bytes (7 min_last_write_time ( 2.google.protobuf.Timestamp5 max_write_time_lag ( 2.google.protobuf.Duration5 bytes_written ( 2 .Ydb.Topic.MultipleWindowsStatJ"� DescribeConsumerRequest9 operation_params ( 2 .Ydb.Operations.OperationParams path ( consumer ( include_stats ("H DescribeConsumerResponse, operation ( 2.Ydb.Operations.Operation"� DescribeConsumerResult self ( 2.Ydb.Scheme.Entry% consumer ( 2.Ydb.Topic.ConsumerC partitions ( 2/.Ydb.Topic.DescribeConsumerResult.PartitionInfo� PartitionInfo partition_id ( active ( child_partition_ids ( parent_partition_ids (2 partition_stats ( 2.Ydb.Topic.PartitionStatsZ partition_consumer_stats ( 28.Ydb.Topic.DescribeConsumerResult.PartitionConsumerStats� PartitionConsumerStats last_read_offset ( committed_offset ( read_session_id ( F "partition_read_session_create_time ( 2.google.protobuf.Timestamp2 last_read_time ( 2.google.protobuf.Timestamp4 max_read_time_lag ( 2.google.protobuf.Duration5 max_write_time_lag ( 2.google.protobuf.Duration2 bytes_read ( 2 .Ydb.Topic.MultipleWindowsStat reader_name ( connection_node_id ("� PartitionStats2 partition_offsets ( 2.Ydb.Topic.OffsetsRange store_size_bytes (3 last_write_time ( 2.google.protobuf.Timestamp5 max_write_time_lag ( 2.google.protobuf.Duration5 bytes_written ( 2 .Ydb.Topic.MultipleWindowsStat partition_node_id ("� AlterTopicRequest9 operation_params ( 2 .Ydb.Operations.OperationParams path ( I alter_partitioning_settings ( 2$.Ydb.Topic.AlterPartitioningSettings7 set_retention_period ( 2.google.protobuf.Duration/ set_retention_storage_mb (B��*>= 0H �8 set_supported_codecs ( 2.Ydb.Topic.SupportedCodecsA *set_partition_write_speed_bytes_per_second (B��*>= 0H�6 set_partition_write_burst_bytes (B��*>= 0H�K alter_attributes ( 21.Ydb.Topic.AlterTopicRequest.AlterAttributesEntry3 add_consumers ( 2.Ydb.Topic.ConsumerB��*� drop_consumers ( B��*�: alter_consumers ( 2.Ydb.Topic.AlterConsumerB��*�2 set_metering_mode (2.Ydb.Topic.MeteringMode6 AlterAttributesEntry key ( value ( :8B _set_retention_storage_mbB- +_set_partition_write_speed_bytes_per_secondB" _set_partition_write_burst_bytesJ"B AlterTopicResponse, operation ( 2.Ydb.Operations.Operation" AlterTopicResult"[ DropTopicRequest9 operation_params ( 2 .Ydb.Operations.OperationParams path ( "A DropTopicResponse, operation ( 2.Ydb.Operations.Operation" DropTopicResult*� Codec CODEC_UNSPECIFIED CODEC_RAW CODEC_GZIP CODEC_LZOP CODEC_ZSTD CODEC_CUSTOM�N"�N" ������*s MeteringMode METERING_MODE_UNSPECIFIED # METERING_MODE_RESERVED_CAPACITY METERING_MODE_REQUEST_UNITSBM tech.ydb.topicZ8github.com/ydb-platform/ydb-go-genproto/protos/Ydb_Topic�bproto3' , true); static::$is_initialized = true; } }