Ydb_Topic

type AlterConsumer struct {

	// Must have valid not empty name as a key.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Consumer may be marked as 'important'. It means messages for this consumer will never expire due to retention.
	// User should take care that such consumer never stalls, to prevent running out of disk space.
	// Flag that this consumer is important.
	SetImportant *bool `protobuf:"varint,2,opt,name=set_important,json=setImportant,proto3,oneof" json:"set_important,omitempty"`
	// All messages with smaller server written_at timestamp will be skipped.
	SetReadFrom *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=set_read_from,json=setReadFrom,proto3" json:"set_read_from,omitempty"`
	// List of supported codecs by this consumer.
	// supported_codecs on topic must be contained inside this list.
	SetSupportedCodecs *SupportedCodecs `protobuf:"bytes,5,opt,name=set_supported_codecs,json=setSupportedCodecs,proto3" json:"set_supported_codecs,omitempty"`
	// User and server attributes of consumer. Server attributes starts from "_" and will be validated by server.
	// Leave the value blank to drop an attribute.
	AlterAttributes map[string]string `` /* 194-byte string literal not displayed */
	// contains filtered or unexported fields
}

type AlterPartitioningSettings struct {

	// Minimum partition count auto merge would stop working at.
	// Zero value means default - 1.
	SetMinActivePartitions *int64 `` /* 138-byte string literal not displayed */
	// Limit for total partition count, including active (open for write) and read-only partitions.
	// Zero value means default - 100.
	SetPartitionCountLimit *int64 `` /* 138-byte string literal not displayed */
	// contains filtered or unexported fields
}

type AlterTopicRequest struct {
	OperationParams *Ydb_Operations.OperationParams `protobuf:"bytes,1,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"`
	// Topic path.
	Path                      string                     `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	AlterPartitioningSettings *AlterPartitioningSettings `` // partitioning_settings
	/* 138-byte string literal not displayed */
	// Retention settings.
	// Currently, only one limit may be set, so other should not be set.
	//
	// How long data in partition should be stored. Must be greater than 0 and less than limit for this database.
	// Default limit - 36 hours.
	SetRetentionPeriod *durationpb.Duration `protobuf:"bytes,4,opt,name=set_retention_period,json=setRetentionPeriod,proto3" json:"set_retention_period,omitempty"`
	// How much data in partition should be stored. Must be greater than 0 and less than limit for this database.
	SetRetentionStorageMb *int64 `` /* 135-byte string literal not displayed */
	// List of allowed codecs for writers.
	// Writes with codec not from this list are forbidden.
	SetSupportedCodecs *SupportedCodecs `protobuf:"bytes,7,opt,name=set_supported_codecs,json=setSupportedCodecs,proto3" json:"set_supported_codecs,omitempty"`
	// Partition write speed in bytes per second. Must be less than database limit. Default limit - 1 MB/s.
	SetPartitionWriteSpeedBytesPerSecond *int64 `` /* 186-byte string literal not displayed */
	// Burst size for write in partition, in bytes. Must be less than database limit. Default limit - 1 MB.
	SetPartitionWriteBurstBytes *int64 `` /* 155-byte string literal not displayed */
	// User and server attributes of topic. Server attributes starts from "_" and will be validated by server.
	// Leave the value blank to drop an attribute.
	AlterAttributes map[string]string `` /* 195-byte string literal not displayed */
	// Add consumers.
	AddConsumers []*Consumer `protobuf:"bytes,11,rep,name=add_consumers,json=addConsumers,proto3" json:"add_consumers,omitempty"`
	// Remove consumers (by their names)
	DropConsumers []string `protobuf:"bytes,12,rep,name=drop_consumers,json=dropConsumers,proto3" json:"drop_consumers,omitempty"`
	// Alter consumers
	AlterConsumers []*AlterConsumer `protobuf:"bytes,13,rep,name=alter_consumers,json=alterConsumers,proto3" json:"alter_consumers,omitempty"`
	// Set metering mode for topic in serverless database.
	SetMeteringMode MeteringMode `` /* 138-byte string literal not displayed */
	// contains filtered or unexported fields
}

type AlterTopicResponse struct {

	// Result of request will be inside operation.
	Operation *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"`
	// contains filtered or unexported fields
}

type AlterTopicResult struct {
	// contains filtered or unexported fields
}

type Codec int32

type CommitOffsetRequest struct {
	OperationParams *Ydb_Operations.OperationParams `protobuf:"bytes,1,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"`
	// Topic path of partition.
	Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	// Partition identifier.
	PartitionId int64 `protobuf:"varint,3,opt,name=partition_id,json=partitionId,proto3" json:"partition_id,omitempty"`
	// Path of consumer.
	Consumer string `protobuf:"bytes,4,opt,name=consumer,proto3" json:"consumer,omitempty"`
	// Processed offset.
	Offset int64 `protobuf:"varint,5,opt,name=offset,proto3" json:"offset,omitempty"`
	// contains filtered or unexported fields
}

type CommitOffsetResponse struct {

	// Result of request will be inside operation.
	Operation *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"`
	// contains filtered or unexported fields
}

type CommitOffsetResult struct {
	// contains filtered or unexported fields
}

type Consumer struct {

	// Must have valid not empty name as a key.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Consumer may be marked as 'important'. It means messages for this consumer will never expire due to retention.
	// User should take care that such consumer never stalls, to prevent running out of disk space.
	// Flag that this consumer is important.
	Important bool `protobuf:"varint,2,opt,name=important,proto3" json:"important,omitempty"`
	// All messages with smaller server written_at timestamp will be skipped.
	ReadFrom *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=read_from,json=readFrom,proto3" json:"read_from,omitempty"`
	// List of supported codecs by this consumer.
	// supported_codecs on topic must be contained inside this list.
	SupportedCodecs *SupportedCodecs `protobuf:"bytes,5,opt,name=supported_codecs,json=supportedCodecs,proto3" json:"supported_codecs,omitempty"`
	// Attributes of consumer
	Attributes map[string]string `` /* 161-byte string literal not displayed */
	// Filled only when requested statistics in Describe*Request.
	ConsumerStats *Consumer_ConsumerStats `protobuf:"bytes,7,opt,name=consumer_stats,json=consumerStats,proto3" json:"consumer_stats,omitempty"`
	// contains filtered or unexported fields
}

type Consumer_ConsumerStats struct {

	// Minimal timestamp of last read from partitions.
	MinPartitionsLastReadTime *timestamppb.Timestamp `` /* 142-byte string literal not displayed */
	// Maximum of differences between timestamp of read and write timestamp for all messages, read during last minute.
	MaxReadTimeLag *durationpb.Duration `protobuf:"bytes,2,opt,name=max_read_time_lag,json=maxReadTimeLag,proto3" json:"max_read_time_lag,omitempty"`
	// Maximum of differences between write timestamp and create timestamp for all messages, read during last minute.
	MaxWriteTimeLag *durationpb.Duration `protobuf:"bytes,3,opt,name=max_write_time_lag,json=maxWriteTimeLag,proto3" json:"max_write_time_lag,omitempty"`
	// Bytes read stastics.
	BytesRead *MultipleWindowsStat `protobuf:"bytes,4,opt,name=bytes_read,json=bytesRead,proto3" json:"bytes_read,omitempty"`
	// contains filtered or unexported fields
}

type CreateTopicRequest struct {
	OperationParams *Ydb_Operations.OperationParams `protobuf:"bytes,1,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"`
	// Topic path.
	Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	// Settings for partitioning
	PartitioningSettings *PartitioningSettings `protobuf:"bytes,3,opt,name=partitioning_settings,json=partitioningSettings,proto3" json:"partitioning_settings,omitempty"`
	// Retention settings.
	// Currently, only one limit may be set, so other should not be set.
	//
	// How long data in partition should be stored. Must be greater than 0 and less than limit for this database.
	// Default limit - 36 hours.
	RetentionPeriod *durationpb.Duration `protobuf:"bytes,4,opt,name=retention_period,json=retentionPeriod,proto3" json:"retention_period,omitempty"`
	// How much data in partition should be stored. Must be greater than 0 and less than limit for this database.
	// Zero value means infinite limit.
	RetentionStorageMb int64 `protobuf:"varint,5,opt,name=retention_storage_mb,json=retentionStorageMb,proto3" json:"retention_storage_mb,omitempty"`
	// List of allowed codecs for writers.
	// Writes with codec not from this list are forbidden.
	SupportedCodecs *SupportedCodecs `protobuf:"bytes,7,opt,name=supported_codecs,json=supportedCodecs,proto3" json:"supported_codecs,omitempty"`
	// Partition write speed in bytes per second. Must be less than database limit.
	// Zero value means default limit: 1 MB per second.
	PartitionWriteSpeedBytesPerSecond int64 `` /* 169-byte string literal not displayed */
	// Burst size for write in partition, in bytes. Must be less than database limit.
	// Zero value means default limit: 1 MB.
	PartitionWriteBurstBytes int64 `` /* 138-byte string literal not displayed */
	// User and server attributes of topic. Server attributes starts from "_" and will be validated by server.
	Attributes map[string]string `` /* 162-byte string literal not displayed */
	// List of consumers for this topic.
	Consumers []*Consumer `protobuf:"bytes,11,rep,name=consumers,proto3" json:"consumers,omitempty"`
	// Metering mode for the topic in a serverless database.
	MeteringMode MeteringMode `` /* 127-byte string literal not displayed */
	// contains filtered or unexported fields
}

type CreateTopicResponse struct {

	// Result of request will be inside operation.
	Operation *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"`
	// contains filtered or unexported fields
}

type CreateTopicResult struct {
	// contains filtered or unexported fields
}

type DescribeConsumerRequest struct {
	OperationParams *Ydb_Operations.OperationParams `protobuf:"bytes,1,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"`
	// Topic path.
	Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	// Consumer name;
	Consumer string `protobuf:"bytes,3,opt,name=consumer,proto3" json:"consumer,omitempty"`
	// Include consumer statistics.
	IncludeStats bool `protobuf:"varint,4,opt,name=include_stats,json=includeStats,proto3" json:"include_stats,omitempty"`
	// contains filtered or unexported fields
}

type DescribeConsumerResponse struct {

	// Result of request will be inside operation.
	Operation *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"`
	// contains filtered or unexported fields
}

type DescribeConsumerResult struct {

	// Description of scheme object.
	Self       *Ydb_Scheme.Entry                       `protobuf:"bytes,1,opt,name=self,proto3" json:"self,omitempty"`
	Consumer   *Consumer                               `protobuf:"bytes,2,opt,name=consumer,proto3" json:"consumer,omitempty"`
	Partitions []*DescribeConsumerResult_PartitionInfo `protobuf:"bytes,3,rep,name=partitions,proto3" json:"partitions,omitempty"`
	// contains filtered or unexported fields
}

type DescribeConsumerResult_PartitionConsumerStats struct {

	// Last read offset from this partition.
	LastReadOffset int64 `protobuf:"varint,1,opt,name=last_read_offset,json=lastReadOffset,proto3" json:"last_read_offset,omitempty"`
	// Committed offset for this partition.
	CommittedOffset int64 `protobuf:"varint,2,opt,name=committed_offset,json=committedOffset,proto3" json:"committed_offset,omitempty"`
	// Reading this partition read session identifier.
	ReadSessionId string `protobuf:"bytes,3,opt,name=read_session_id,json=readSessionId,proto3" json:"read_session_id,omitempty"`
	// Timestamp of providing this partition to this session by server.
	PartitionReadSessionCreateTime *timestamppb.Timestamp `` /* 157-byte string literal not displayed */
	// Timestamp of last read from this partition.
	LastReadTime *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=last_read_time,json=lastReadTime,proto3" json:"last_read_time,omitempty"`
	// Maximum of differences between timestamp of read and write timestamp for all messages, read during last minute.
	MaxReadTimeLag *durationpb.Duration `protobuf:"bytes,6,opt,name=max_read_time_lag,json=maxReadTimeLag,proto3" json:"max_read_time_lag,omitempty"`
	// Maximum of differences between write timestamp and create timestamp for all messages, read during last minute.
	MaxWriteTimeLag *durationpb.Duration `protobuf:"bytes,7,opt,name=max_write_time_lag,json=maxWriteTimeLag,proto3" json:"max_write_time_lag,omitempty"`
	// How much bytes were read during several windows statistics from this partiton.
	BytesRead *MultipleWindowsStat `protobuf:"bytes,8,opt,name=bytes_read,json=bytesRead,proto3" json:"bytes_read,omitempty"`
	// Read session name, provided by client.
	ReaderName string `protobuf:"bytes,11,opt,name=reader_name,json=readerName,proto3" json:"reader_name,omitempty"`
	// Host where read session connected.
	ConnectionNodeId int32 `protobuf:"varint,12,opt,name=connection_node_id,json=connectionNodeId,proto3" json:"connection_node_id,omitempty"`
	// contains filtered or unexported fields
}

type DescribeConsumerResult_PartitionInfo struct {

	// Partition identifier.
	PartitionId int64 `protobuf:"varint,1,opt,name=partition_id,json=partitionId,proto3" json:"partition_id,omitempty"`
	// Is partition open for write.
	Active bool `protobuf:"varint,2,opt,name=active,proto3" json:"active,omitempty"`
	// Ids of partitions which was formed when this partition was split or merged.
	ChildPartitionIds []int64 `protobuf:"varint,3,rep,packed,name=child_partition_ids,json=childPartitionIds,proto3" json:"child_partition_ids,omitempty"`
	// Ids of partitions from which this partition was formed by split or merge.
	ParentPartitionIds []int64 `protobuf:"varint,4,rep,packed,name=parent_partition_ids,json=parentPartitionIds,proto3" json:"parent_partition_ids,omitempty"`
	// Stats for partition, filled only when include_stats in request is true.
	PartitionStats *PartitionStats `protobuf:"bytes,5,opt,name=partition_stats,json=partitionStats,proto3" json:"partition_stats,omitempty"`
	// Stats for consumer of this partition, filled only when include_stats in request is true.
	PartitionConsumerStats *DescribeConsumerResult_PartitionConsumerStats `` /* 129-byte string literal not displayed */
	// contains filtered or unexported fields
}

type DescribeTopicRequest struct {
	OperationParams *Ydb_Operations.OperationParams `protobuf:"bytes,1,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"`
	// Topic path.
	Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	// Include topic statistics.
	IncludeStats bool `protobuf:"varint,3,opt,name=include_stats,json=includeStats,proto3" json:"include_stats,omitempty"`
	// contains filtered or unexported fields
}

type DescribeTopicResponse struct {

	// Result of request will be inside operation.
	Operation *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"`
	// contains filtered or unexported fields
}

type DescribeTopicResult struct {

	// Description of scheme object.
	Self *Ydb_Scheme.Entry `protobuf:"bytes,1,opt,name=self,proto3" json:"self,omitempty"`
	// Settings for partitioning
	PartitioningSettings *PartitioningSettings `protobuf:"bytes,2,opt,name=partitioning_settings,json=partitioningSettings,proto3" json:"partitioning_settings,omitempty"`
	// Partitions description.
	Partitions []*DescribeTopicResult_PartitionInfo `protobuf:"bytes,3,rep,name=partitions,proto3" json:"partitions,omitempty"`
	// Retention settings.
	// Currently, only one limit may be set, so other should not be set.
	//
	// How long data in partition should be stored.
	RetentionPeriod *durationpb.Duration `protobuf:"bytes,4,opt,name=retention_period,json=retentionPeriod,proto3" json:"retention_period,omitempty"`
	// How much data in partition should be stored.
	// Zero value means infinite limit.
	RetentionStorageMb int64 `protobuf:"varint,5,opt,name=retention_storage_mb,json=retentionStorageMb,proto3" json:"retention_storage_mb,omitempty"`
	// List of allowed codecs for writers.
	// Writes with codec not from this list are forbidden.
	SupportedCodecs *SupportedCodecs `protobuf:"bytes,7,opt,name=supported_codecs,json=supportedCodecs,proto3" json:"supported_codecs,omitempty"`
	// Partition write speed in bytes per second.
	// Zero value means default limit: 1 MB per second.
	PartitionWriteSpeedBytesPerSecond int64 `` /* 169-byte string literal not displayed */
	// Burst size for write in partition, in bytes.
	// Zero value means default limit: 1 MB.
	PartitionWriteBurstBytes int64 `` /* 138-byte string literal not displayed */
	// User and server attributes of topic. Server attributes starts from "_" and will be validated by server.
	Attributes map[string]string `` /* 162-byte string literal not displayed */
	// List of consumers for this topic.
	Consumers []*Consumer `protobuf:"bytes,11,rep,name=consumers,proto3" json:"consumers,omitempty"`
	// Metering settings.
	MeteringMode MeteringMode `` /* 127-byte string literal not displayed */
	// Statistics of topic.
	TopicStats *DescribeTopicResult_TopicStats `protobuf:"bytes,13,opt,name=topic_stats,json=topicStats,proto3" json:"topic_stats,omitempty"`
	// contains filtered or unexported fields
}

type DescribeTopicResult_PartitionInfo struct {

	// Partition identifier.
	PartitionId int64 `protobuf:"varint,1,opt,name=partition_id,json=partitionId,proto3" json:"partition_id,omitempty"`
	// Is partition open for write.
	Active bool `protobuf:"varint,2,opt,name=active,proto3" json:"active,omitempty"`
	// Ids of partitions which was formed when this partition was split or merged.
	ChildPartitionIds []int64 `protobuf:"varint,3,rep,packed,name=child_partition_ids,json=childPartitionIds,proto3" json:"child_partition_ids,omitempty"`
	// Ids of partitions from which this partition was formed by split or merge.
	ParentPartitionIds []int64 `protobuf:"varint,4,rep,packed,name=parent_partition_ids,json=parentPartitionIds,proto3" json:"parent_partition_ids,omitempty"`
	// Stats for partition, filled only when include_stats in request is true.
	PartitionStats *PartitionStats `protobuf:"bytes,5,opt,name=partition_stats,json=partitionStats,proto3" json:"partition_stats,omitempty"`
	// contains filtered or unexported fields
}

type DescribeTopicResult_TopicStats struct {

	// Approximate size of topic.
	StoreSizeBytes int64 `protobuf:"varint,1,opt,name=store_size_bytes,json=storeSizeBytes,proto3" json:"store_size_bytes,omitempty"`
	// Minimum of timestamps of last write among all partitions.
	MinLastWriteTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=min_last_write_time,json=minLastWriteTime,proto3" json:"min_last_write_time,omitempty"`
	// Maximum of differences between write timestamp and create timestamp for all messages, written during last minute.
	MaxWriteTimeLag *durationpb.Duration `protobuf:"bytes,3,opt,name=max_write_time_lag,json=maxWriteTimeLag,proto3" json:"max_write_time_lag,omitempty"`
	// How much bytes were written statistics.
	BytesWritten *MultipleWindowsStat `protobuf:"bytes,4,opt,name=bytes_written,json=bytesWritten,proto3" json:"bytes_written,omitempty"`
	// contains filtered or unexported fields
}

type DropTopicRequest struct {
	OperationParams *Ydb_Operations.OperationParams `protobuf:"bytes,1,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"`
	// Topic path.
	Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	// contains filtered or unexported fields
}

type DropTopicResponse struct {

	// Result of request will be inside operation.
	Operation *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"`
	// contains filtered or unexported fields
}

type DropTopicResult struct {
	// contains filtered or unexported fields
}

type MetadataItem struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

type MeteringMode int32

type MultipleWindowsStat struct {
	PerMinute int64 `protobuf:"varint,1,opt,name=per_minute,json=perMinute,proto3" json:"per_minute,omitempty"`
	PerHour   int64 `protobuf:"varint,2,opt,name=per_hour,json=perHour,proto3" json:"per_hour,omitempty"`
	PerDay    int64 `protobuf:"varint,3,opt,name=per_day,json=perDay,proto3" json:"per_day,omitempty"`
	// contains filtered or unexported fields
}

type OffsetsRange struct {
	Start int64 `protobuf:"varint,1,opt,name=start,proto3" json:"start,omitempty"`
	End   int64 `protobuf:"varint,2,opt,name=end,proto3" json:"end,omitempty"`
	// contains filtered or unexported fields
}

type PartitionStats struct {

	// Partition contains messages with offsets in range [start, end).
	PartitionOffsets *OffsetsRange `protobuf:"bytes,1,opt,name=partition_offsets,json=partitionOffsets,proto3" json:"partition_offsets,omitempty"`
	// Approximate size of partition.
	StoreSizeBytes int64 `protobuf:"varint,2,opt,name=store_size_bytes,json=storeSizeBytes,proto3" json:"store_size_bytes,omitempty"`
	// Timestamp of last write.
	LastWriteTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=last_write_time,json=lastWriteTime,proto3" json:"last_write_time,omitempty"`
	// Maximum of differences between write timestamp and create timestamp for all messages, written during last minute.
	MaxWriteTimeLag *durationpb.Duration `protobuf:"bytes,4,opt,name=max_write_time_lag,json=maxWriteTimeLag,proto3" json:"max_write_time_lag,omitempty"`
	// How much bytes were written during several windows in this partition.
	BytesWritten *MultipleWindowsStat `protobuf:"bytes,5,opt,name=bytes_written,json=bytesWritten,proto3" json:"bytes_written,omitempty"`
	// Host where tablet for this partition works. Useful for debugging purposes.
	PartitionNodeId int32 `protobuf:"varint,8,opt,name=partition_node_id,json=partitionNodeId,proto3" json:"partition_node_id,omitempty"`
	// contains filtered or unexported fields
}

type PartitioningSettings struct {

	// Minimum partition count auto merge would stop working at.
	// Zero value means default - 1.
	MinActivePartitions int64 `protobuf:"varint,1,opt,name=min_active_partitions,json=minActivePartitions,proto3" json:"min_active_partitions,omitempty"`
	// Limit for total partition count, including active (open for write) and read-only partitions.
	// Zero value means default - 100.
	PartitionCountLimit int64 `protobuf:"varint,2,opt,name=partition_count_limit,json=partitionCountLimit,proto3" json:"partition_count_limit,omitempty"`
	// contains filtered or unexported fields
}

type StreamReadMessage struct {
	// contains filtered or unexported fields
}

type StreamReadMessage_CommitOffsetRequest struct {

	// Partition offsets that indicates processed data.
	CommitOffsets []*StreamReadMessage_CommitOffsetRequest_PartitionCommitOffset `protobuf:"bytes,1,rep,name=commit_offsets,json=commitOffsets,proto3" json:"commit_offsets,omitempty"`
	// contains filtered or unexported fields
}

type StreamReadMessage_CommitOffsetRequest_PartitionCommitOffset struct {

	// Identifier of partition session with data to commit.
	PartitionSessionId int64 `protobuf:"varint,1,opt,name=partition_session_id,json=partitionSessionId,proto3" json:"partition_session_id,omitempty"`
	// Processed offsets ranges, repeated in case of disjoint ranges.
	Offsets []*OffsetsRange `protobuf:"bytes,2,rep,name=offsets,proto3" json:"offsets,omitempty"`
	// contains filtered or unexported fields
}

type StreamReadMessage_CommitOffsetResponse struct {

	// Partitions with progress.
	PartitionsCommittedOffsets []*StreamReadMessage_CommitOffsetResponse_PartitionCommittedOffset `` /* 141-byte string literal not displayed */
	// contains filtered or unexported fields
}

type StreamReadMessage_CommitOffsetResponse_PartitionCommittedOffset struct {

	// Partition session identifier.
	PartitionSessionId int64 `protobuf:"varint,1,opt,name=partition_session_id,json=partitionSessionId,proto3" json:"partition_session_id,omitempty"`
	// Upper bound for committed offsets.
	CommittedOffset int64 `protobuf:"varint,2,opt,name=committed_offset,json=committedOffset,proto3" json:"committed_offset,omitempty"`
	// contains filtered or unexported fields
}

type StreamReadMessage_FromClient struct {

	// Types that are assignable to ClientMessage:
	//
	//	*StreamReadMessage_FromClient_InitRequest
	//	*StreamReadMessage_FromClient_ReadRequest
	//	*StreamReadMessage_FromClient_CommitOffsetRequest
	//	*StreamReadMessage_FromClient_PartitionSessionStatusRequest
	//	*StreamReadMessage_FromClient_UpdateTokenRequest
	//	*StreamReadMessage_FromClient_StartPartitionSessionResponse
	//	*StreamReadMessage_FromClient_StopPartitionSessionResponse
	ClientMessage isStreamReadMessage_FromClient_ClientMessage `protobuf_oneof:"client_message"`
	// contains filtered or unexported fields
}

type StreamReadMessage_FromClient_CommitOffsetRequest struct {
	CommitOffsetRequest *StreamReadMessage_CommitOffsetRequest `protobuf:"bytes,3,opt,name=commit_offset_request,json=commitOffsetRequest,proto3,oneof"`
}

type StreamReadMessage_FromClient_InitRequest struct {
	// Client requests.
	InitRequest *StreamReadMessage_InitRequest `protobuf:"bytes,1,opt,name=init_request,json=initRequest,proto3,oneof"`
}

type StreamReadMessage_FromClient_PartitionSessionStatusRequest struct {
	PartitionSessionStatusRequest *StreamReadMessage_PartitionSessionStatusRequest `protobuf:"bytes,4,opt,name=partition_session_status_request,json=partitionSessionStatusRequest,proto3,oneof"`
}

type StreamReadMessage_FromClient_ReadRequest struct {
	ReadRequest *StreamReadMessage_ReadRequest `protobuf:"bytes,2,opt,name=read_request,json=readRequest,proto3,oneof"`
}

type StreamReadMessage_FromClient_StartPartitionSessionResponse struct {
	// Responses to respective server commands.
	StartPartitionSessionResponse *StreamReadMessage_StartPartitionSessionResponse `protobuf:"bytes,6,opt,name=start_partition_session_response,json=startPartitionSessionResponse,proto3,oneof"`
}

type StreamReadMessage_FromClient_StopPartitionSessionResponse struct {
	StopPartitionSessionResponse *StreamReadMessage_StopPartitionSessionResponse `protobuf:"bytes,7,opt,name=stop_partition_session_response,json=stopPartitionSessionResponse,proto3,oneof"`
}

type StreamReadMessage_FromClient_UpdateTokenRequest struct {
	UpdateTokenRequest *UpdateTokenRequest `protobuf:"bytes,5,opt,name=update_token_request,json=updateTokenRequest,proto3,oneof"`
}

type StreamReadMessage_FromServer struct {

	// Server status of response.
	Status Ydb.StatusIds_StatusCode `protobuf:"varint,1,opt,name=status,proto3,enum=Ydb.StatusIds_StatusCode" json:"status,omitempty"`
	// Issues if any.
	Issues []*Ydb_Issue.IssueMessage `protobuf:"bytes,2,rep,name=issues,proto3" json:"issues,omitempty"`
	// Types that are assignable to ServerMessage:
	//
	//	*StreamReadMessage_FromServer_InitResponse
	//	*StreamReadMessage_FromServer_ReadResponse
	//	*StreamReadMessage_FromServer_CommitOffsetResponse
	//	*StreamReadMessage_FromServer_PartitionSessionStatusResponse
	//	*StreamReadMessage_FromServer_UpdateTokenResponse
	//	*StreamReadMessage_FromServer_StartPartitionSessionRequest
	//	*StreamReadMessage_FromServer_StopPartitionSessionRequest
	ServerMessage isStreamReadMessage_FromServer_ServerMessage `protobuf_oneof:"server_message"`
	// contains filtered or unexported fields
}

type StreamReadMessage_FromServer_CommitOffsetResponse struct {
	CommitOffsetResponse *StreamReadMessage_CommitOffsetResponse `protobuf:"bytes,5,opt,name=commit_offset_response,json=commitOffsetResponse,proto3,oneof"`
}

type StreamReadMessage_FromServer_InitResponse struct {
	// Responses to respective client requests.
	InitResponse *StreamReadMessage_InitResponse `protobuf:"bytes,3,opt,name=init_response,json=initResponse,proto3,oneof"`
}

type StreamReadMessage_FromServer_PartitionSessionStatusResponse struct {
	PartitionSessionStatusResponse *StreamReadMessage_PartitionSessionStatusResponse `protobuf:"bytes,6,opt,name=partition_session_status_response,json=partitionSessionStatusResponse,proto3,oneof"`
}

type StreamReadMessage_FromServer_ReadResponse struct {
	ReadResponse *StreamReadMessage_ReadResponse `protobuf:"bytes,4,opt,name=read_response,json=readResponse,proto3,oneof"`
}

type StreamReadMessage_FromServer_StartPartitionSessionRequest struct {
	// Server commands.
	StartPartitionSessionRequest *StreamReadMessage_StartPartitionSessionRequest `protobuf:"bytes,8,opt,name=start_partition_session_request,json=startPartitionSessionRequest,proto3,oneof"`
}

type StreamReadMessage_FromServer_StopPartitionSessionRequest struct {
	StopPartitionSessionRequest *StreamReadMessage_StopPartitionSessionRequest `protobuf:"bytes,9,opt,name=stop_partition_session_request,json=stopPartitionSessionRequest,proto3,oneof"`
}

type StreamReadMessage_FromServer_UpdateTokenResponse struct {
	UpdateTokenResponse *UpdateTokenResponse `protobuf:"bytes,7,opt,name=update_token_response,json=updateTokenResponse,proto3,oneof"`
}

type StreamReadMessage_InitRequest struct {

	// Message that describes topic to read.
	// Topics that will be read by this session.
	TopicsReadSettings []*StreamReadMessage_InitRequest_TopicReadSettings `protobuf:"bytes,1,rep,name=topics_read_settings,json=topicsReadSettings,proto3" json:"topics_read_settings,omitempty"`
	// Path of consumer that is used for reading by this session.
	Consumer string `protobuf:"bytes,2,opt,name=consumer,proto3" json:"consumer,omitempty"`
	// Optional name. Will be shown in debug stat.
	ReaderName string `protobuf:"bytes,3,opt,name=reader_name,json=readerName,proto3" json:"reader_name,omitempty"`
	// contains filtered or unexported fields
}

type StreamReadMessage_InitRequest_TopicReadSettings struct {

	// Topic path.
	Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	// Partitions that will be read by this session.
	// If list is empty - then session will read all partitions.
	PartitionIds []int64 `protobuf:"varint,2,rep,packed,name=partition_ids,json=partitionIds,proto3" json:"partition_ids,omitempty"`
	// Skip all messages that has write timestamp smaller than now - max_lag.
	// Zero means infinite lag.
	MaxLag *durationpb.Duration `protobuf:"bytes,3,opt,name=max_lag,json=maxLag,proto3" json:"max_lag,omitempty"`
	// Read data only after this timestamp from this topic.
	// Read only messages with 'written_at' value greater or equal than this timestamp.
	ReadFrom *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=read_from,json=readFrom,proto3" json:"read_from,omitempty"`
	// contains filtered or unexported fields
}

type StreamReadMessage_InitResponse struct {

	// Read session identifier for debug purposes.
	SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	// contains filtered or unexported fields
}

type StreamReadMessage_PartitionSession struct {

	// Identitifier of partition session. Unique inside one RPC call.
	PartitionSessionId int64 `protobuf:"varint,1,opt,name=partition_session_id,json=partitionSessionId,proto3" json:"partition_session_id,omitempty"`
	// Topic path of partition.
	Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	// Partition identifier.
	PartitionId int64 `protobuf:"varint,3,opt,name=partition_id,json=partitionId,proto3" json:"partition_id,omitempty"`
	// contains filtered or unexported fields
}

type StreamReadMessage_PartitionSessionStatusRequest struct {
	PartitionSessionId int64 `protobuf:"varint,1,opt,name=partition_session_id,json=partitionSessionId,proto3" json:"partition_session_id,omitempty"`
	// contains filtered or unexported fields
}

type StreamReadMessage_PartitionSessionStatusResponse struct {

	// Identifier of partition session whose status was requested.
	PartitionSessionId int64 `protobuf:"varint,1,opt,name=partition_session_id,json=partitionSessionId,proto3" json:"partition_session_id,omitempty"`
	// Partition contains messages with offsets in range [start, end).
	PartitionOffsets *OffsetsRange `protobuf:"bytes,2,opt,name=partition_offsets,json=partitionOffsets,proto3" json:"partition_offsets,omitempty"`
	// Each offset up to and including (committed_offset - 1) was fully processed.
	CommittedOffset int64 `protobuf:"varint,3,opt,name=committed_offset,json=committedOffset,proto3" json:"committed_offset,omitempty"`
	// Write timestamp of next message written to this partition will be no less than write_time_high_watermark.
	WriteTimeHighWatermark *timestamppb.Timestamp `` /* 131-byte string literal not displayed */
	// contains filtered or unexported fields
}

type StreamReadMessage_ReadRequest struct {

	// Server and client each keep track of total bytes size of all ReadResponses.
	// When client is ready to receive N more bytes in responses (to increment possible total by N),
	// it sends a ReadRequest with bytes_size = N.
	// bytes_size value must be positive.
	// So in expression 'A = (sum of bytes_size in all ReadRequests) - (sum of bytes_size in all ReadResponses)'
	//
	//	server will keep A (available size for responses) non-negative.
	//
	// But there is an exception. If server receives ReadRequest, and the first message in response exceeds A -
	// then it will still be delivered, and A will become negative until enough additional ReadRequests.
	//
	// Example:
	//  1. Let client have 200 bytes buffer. It sends ReadRequest with bytes_size = 200;
	//  2. Server may return one ReadResponse with bytes_size = 70 and than another 80 bytes response;
	//     now client buffer has 50 free bytes, server is free to send up to 50 bytes in responses.
	//  3. Client processes 100 bytes from buffer, now buffer free space is 150 bytes,
	//     so client sends ReadRequest with bytes_size = 100;
	//  4. Server is free to send up to 50 + 100 = 150 bytes. But the next read message is too big,
	//     and it sends 160 bytes ReadResponse.
	//  5. Let's assume client somehow processes it, and its 200 bytes buffer is free again.
	//     It shoud account for excess 10 bytes and send ReadRequest with bytes_size = 210.
	BytesSize int64 `protobuf:"varint,1,opt,name=bytes_size,json=bytesSize,proto3" json:"bytes_size,omitempty"`
	// contains filtered or unexported fields
}

type StreamReadMessage_ReadResponse struct {

	// Client messages, divided by partitions.
	PartitionData []*StreamReadMessage_ReadResponse_PartitionData `protobuf:"bytes,1,rep,name=partition_data,json=partitionData,proto3" json:"partition_data,omitempty"`
	// Total size in bytes of this response as calculated by server.
	// See ReadRequest comment above.
	BytesSize int64 `protobuf:"varint,2,opt,name=bytes_size,json=bytesSize,proto3" json:"bytes_size,omitempty"`
	// contains filtered or unexported fields
}

type StreamReadMessage_ReadResponse_Batch struct {

	// List of client messages.
	MessageData []*StreamReadMessage_ReadResponse_MessageData `protobuf:"bytes,1,rep,name=message_data,json=messageData,proto3" json:"message_data,omitempty"`
	// Producer identifier provided by client for this batch of client messages.
	ProducerId string `protobuf:"bytes,2,opt,name=producer_id,json=producerId,proto3" json:"producer_id,omitempty"`
	// Client metadata attached to write session, the same for all messages in batch.
	WriteSessionMeta map[string]string `` /* 199-byte string literal not displayed */
	// Codec that is used for data compression.
	// See enum Codec above for values.
	Codec int32 `protobuf:"varint,4,opt,name=codec,proto3" json:"codec,omitempty"`
	// Persist timestamp on server for batch.
	WrittenAt *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=written_at,json=writtenAt,proto3" json:"written_at,omitempty"`
	// contains filtered or unexported fields
}

type StreamReadMessage_ReadResponse_MessageData struct {

	// Partition offset in partition that assigned for message.
	Offset int64 `protobuf:"varint,1,opt,name=offset,proto3" json:"offset,omitempty"` //unique value for clientside deduplication - Topic:Partition:Offset
	// Sequence number that provided with message on write from client.
	SeqNo int64 `protobuf:"varint,2,opt,name=seq_no,json=seqNo,proto3" json:"seq_no,omitempty"`
	// Timestamp of creation of message provided on write from client.
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// Compressed client message body.
	Data []byte `protobuf:"bytes,5,opt,name=data,proto3" json:"data,omitempty"`
	// Uncompressed size of client message body.
	// sent as is from WriteRequest, without check on server side. May be empty (for writes from old client) or wrong (if bug in writer).
	// Use it for optimization purposes only, don't trust it.
	UncompressedSize int64 `protobuf:"varint,6,opt,name=uncompressed_size,json=uncompressedSize,proto3" json:"uncompressed_size,omitempty"`
	// Filled if message_group_id was set on message write.
	MessageGroupId string          `protobuf:"bytes,7,opt,name=message_group_id,json=messageGroupId,proto3" json:"message_group_id,omitempty"`
	MetadataItems  []*MetadataItem `protobuf:"bytes,8,rep,name=metadata_items,json=metadataItems,proto3" json:"metadata_items,omitempty"`
	// contains filtered or unexported fields
}

type StreamReadMessage_ReadResponse_PartitionData struct {
	PartitionSessionId int64 `protobuf:"varint,1,opt,name=partition_session_id,json=partitionSessionId,proto3" json:"partition_session_id,omitempty"`
	// Client messages, divided by write sessions.
	Batches []*StreamReadMessage_ReadResponse_Batch `protobuf:"bytes,2,rep,name=batches,proto3" json:"batches,omitempty"`
	// contains filtered or unexported fields
}

type StreamReadMessage_StartPartitionSessionRequest struct {

	// Partition session description.
	PartitionSession *StreamReadMessage_PartitionSession `protobuf:"bytes,1,opt,name=partition_session,json=partitionSession,proto3" json:"partition_session,omitempty"`
	// Each offset up to and including (committed_offset - 1) was fully processed.
	CommittedOffset int64 `protobuf:"varint,2,opt,name=committed_offset,json=committedOffset,proto3" json:"committed_offset,omitempty"`
	// Partition contains messages with offsets in range [start, end).
	PartitionOffsets *OffsetsRange `protobuf:"bytes,3,opt,name=partition_offsets,json=partitionOffsets,proto3" json:"partition_offsets,omitempty"`
	// contains filtered or unexported fields
}

type StreamReadMessage_StartPartitionSessionResponse struct {

	// Partition session identifier of partition to start read.
	PartitionSessionId int64 `protobuf:"varint,1,opt,name=partition_session_id,json=partitionSessionId,proto3" json:"partition_session_id,omitempty"`
	// Reads in this partition session will start from offset no less than read_offset.
	// If read_offset is set, server will check that read_offset is no less that actual committed offset.
	// If check fails then server will send an error message (status != SUCCESS) and close stream.
	//
	// If read_offset is not set, no check will be made.
	// InitRequest.max_lag and InitRequest.read_from could lead to skip of more messages.
	// Server will return data starting from offset that is maximum of actual committed offset, read_offset (if set)
	// and offsets calculated from InitRequest.max_lag and InitRequest.read_from.
	ReadOffset *int64 `protobuf:"varint,2,opt,name=read_offset,json=readOffset,proto3,oneof" json:"read_offset,omitempty"`
	// All messages with offset less than commit_offset are processed by client.
	// Server will commit this position if this is not done yet.
	CommitOffset *int64 `protobuf:"varint,3,opt,name=commit_offset,json=commitOffset,proto3,oneof" json:"commit_offset,omitempty"`
	// contains filtered or unexported fields
}

type StreamReadMessage_StopPartitionSessionRequest struct {

	// Identifier of partition session that is ready to be closed by server.
	PartitionSessionId int64 `protobuf:"varint,1,opt,name=partition_session_id,json=partitionSessionId,proto3" json:"partition_session_id,omitempty"`
	// Flag of graceful stop.
	// If set, server will wait for response from client before giving this partition to other read session.
	// Server will not send more data from this partition.
	// Client can process all received data and wait for commit and only after send response.
	// If False then server gives partition for other session right now.
	// All further commits for this partition session has no effect. Server is not waiting for response.
	Graceful bool `protobuf:"varint,2,opt,name=graceful,proto3" json:"graceful,omitempty"`
	// Upper bound for committed offsets.
	CommittedOffset int64 `protobuf:"varint,3,opt,name=committed_offset,json=committedOffset,proto3" json:"committed_offset,omitempty"`
	// contains filtered or unexported fields
}