ydb-php-sdk/protos/GPBMetadata/Protos/YdbTopic.php

<?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.protoprotos/ydb_status_codes.protoprotos/ydb_issue_message.protoprotos/ydb_table.proto#protos/annotations/validation.protogoogle/protobuf/duration.protogoogle/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 
(	:8
B
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_WRITTEN
B
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 
(	:8
o

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 
(	:8
B
_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 
(	:8
J"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 
(	:8
B
_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;
    }
}