Ydb_Topic

package
v0.0.0-...-8dd88c8 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 9, 2024 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	Codec_name = map[int32]string{
		0:     "CODEC_UNSPECIFIED",
		1:     "CODEC_RAW",
		2:     "CODEC_GZIP",
		3:     "CODEC_LZOP",
		4:     "CODEC_ZSTD",
		10000: "CODEC_CUSTOM",
	}
	Codec_value = map[string]int32{
		"CODEC_UNSPECIFIED": 0,
		"CODEC_RAW":         1,
		"CODEC_GZIP":        2,
		"CODEC_LZOP":        3,
		"CODEC_ZSTD":        4,
		"CODEC_CUSTOM":      10000,
	}
)

Enum value maps for Codec.

View Source 
var (
	MeteringMode_name = map[int32]string{
		0: "METERING_MODE_UNSPECIFIED",
		1: "METERING_MODE_RESERVED_CAPACITY",
		2: "METERING_MODE_REQUEST_UNITS",
	}
	MeteringMode_value = map[string]int32{
		"METERING_MODE_UNSPECIFIED":       0,
		"METERING_MODE_RESERVED_CAPACITY": 1,
		"METERING_MODE_REQUEST_UNITS":     2,
	}
)

Enum value maps for MeteringMode.

View Source 
var (
	StreamWriteMessage_WriteResponse_WriteAck_Skipped_Reason_name = map[int32]string{
		0: "REASON_UNSPECIFIED",
		1: "REASON_ALREADY_WRITTEN",
	}
	StreamWriteMessage_WriteResponse_WriteAck_Skipped_Reason_value = map[string]int32{
		"REASON_UNSPECIFIED":     0,
		"REASON_ALREADY_WRITTEN": 1,
	}
)

Enum value maps for StreamWriteMessage_WriteResponse_WriteAck_Skipped_Reason.

View Source 
var File_protos_ydb_topic_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type AlterConsumer 

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
}

Consumer alter description.

func (*AlterConsumer) Descriptor deprecated 

func (*AlterConsumer) Descriptor() ([]byte, []int)

Deprecated: Use AlterConsumer.ProtoReflect.Descriptor instead.

func (*AlterConsumer) GetAlterAttributes 

func (x *AlterConsumer) GetAlterAttributes() map[string]string

func (*AlterConsumer) GetName 

func (x *AlterConsumer) GetName() string

func (*AlterConsumer) GetSetImportant 

func (x *AlterConsumer) GetSetImportant() bool

func (*AlterConsumer) GetSetReadFrom 

func (x *AlterConsumer) GetSetReadFrom() *timestamppb.Timestamp

func (*AlterConsumer) GetSetSupportedCodecs 

func (x *AlterConsumer) GetSetSupportedCodecs() *SupportedCodecs

func (*AlterConsumer) ProtoMessage 

func (*AlterConsumer) ProtoMessage()

func (*AlterConsumer) ProtoReflect 

func (x *AlterConsumer) ProtoReflect() protoreflect.Message

func (*AlterConsumer) Reset 

func (x *AlterConsumer) Reset()

func (*AlterConsumer) String 

func (x *AlterConsumer) String() string

type AlterPartitioningSettings 

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
}

Partitioning settings for topic.

func (*AlterPartitioningSettings) Descriptor deprecated 

func (*AlterPartitioningSettings) Descriptor() ([]byte, []int)

Deprecated: Use AlterPartitioningSettings.ProtoReflect.Descriptor instead.

func (*AlterPartitioningSettings) GetSetMinActivePartitions 

func (x *AlterPartitioningSettings) GetSetMinActivePartitions() int64

func (*AlterPartitioningSettings) GetSetPartitionCountLimit 

func (x *AlterPartitioningSettings) GetSetPartitionCountLimit() int64

func (*AlterPartitioningSettings) ProtoMessage 

func (*AlterPartitioningSettings) ProtoMessage()

func (*AlterPartitioningSettings) ProtoReflect 

func (x *AlterPartitioningSettings) ProtoReflect() protoreflect.Message

func (*AlterPartitioningSettings) Reset 

func (x *AlterPartitioningSettings) Reset()

func (*AlterPartitioningSettings) String 

func (x *AlterPartitioningSettings) String() string

type AlterTopicRequest 

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
}

Update existing topic request sent from client to server.

func (*AlterTopicRequest) Descriptor deprecated 

func (*AlterTopicRequest) Descriptor() ([]byte, []int)

Deprecated: Use AlterTopicRequest.ProtoReflect.Descriptor instead.

func (*AlterTopicRequest) GetAddConsumers 

func (x *AlterTopicRequest) GetAddConsumers() []*Consumer

func (*AlterTopicRequest) GetAlterAttributes 

func (x *AlterTopicRequest) GetAlterAttributes() map[string]string

func (*AlterTopicRequest) GetAlterConsumers 

func (x *AlterTopicRequest) GetAlterConsumers() []*AlterConsumer

func (*AlterTopicRequest) GetAlterPartitioningSettings 

func (x *AlterTopicRequest) GetAlterPartitioningSettings() *AlterPartitioningSettings

func (*AlterTopicRequest) GetDropConsumers 

func (x *AlterTopicRequest) GetDropConsumers() []string

func (*AlterTopicRequest) GetOperationParams 

func (x *AlterTopicRequest) GetOperationParams() *Ydb_Operations.OperationParams

func (*AlterTopicRequest) GetPath 

func (x *AlterTopicRequest) GetPath() string

func (*AlterTopicRequest) GetSetMeteringMode 

func (x *AlterTopicRequest) GetSetMeteringMode() MeteringMode

func (*AlterTopicRequest) GetSetPartitionWriteBurstBytes 

func (x *AlterTopicRequest) GetSetPartitionWriteBurstBytes() int64

func (*AlterTopicRequest) GetSetPartitionWriteSpeedBytesPerSecond 

func (x *AlterTopicRequest) GetSetPartitionWriteSpeedBytesPerSecond() int64

func (*AlterTopicRequest) GetSetRetentionPeriod 

func (x *AlterTopicRequest) GetSetRetentionPeriod() *durationpb.Duration

func (*AlterTopicRequest) GetSetRetentionStorageMb 

func (x *AlterTopicRequest) GetSetRetentionStorageMb() int64

func (*AlterTopicRequest) GetSetSupportedCodecs 

func (x *AlterTopicRequest) GetSetSupportedCodecs() *SupportedCodecs

func (*AlterTopicRequest) ProtoMessage 

func (*AlterTopicRequest) ProtoMessage()

func (*AlterTopicRequest) ProtoReflect 

func (x *AlterTopicRequest) ProtoReflect() protoreflect.Message

func (*AlterTopicRequest) Reset 

func (x *AlterTopicRequest) Reset()

func (*AlterTopicRequest) String 

func (x *AlterTopicRequest) String() string

type AlterTopicResponse 

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
}

Update topic response sent from server to client.

func (*AlterTopicResponse) Descriptor deprecated 

func (*AlterTopicResponse) Descriptor() ([]byte, []int)

Deprecated: Use AlterTopicResponse.ProtoReflect.Descriptor instead.

func (*AlterTopicResponse) GetOperation 

func (x *AlterTopicResponse) GetOperation() *Ydb_Operations.Operation

func (*AlterTopicResponse) ProtoMessage 

func (*AlterTopicResponse) ProtoMessage()

func (*AlterTopicResponse) ProtoReflect 

func (x *AlterTopicResponse) ProtoReflect() protoreflect.Message

func (*AlterTopicResponse) Reset 

func (x *AlterTopicResponse) Reset()

func (*AlterTopicResponse) String 

func (x *AlterTopicResponse) String() string

type AlterTopicResult 

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

Update topic result message that will be inside UpdateTopicResponse.operation.

func (*AlterTopicResult) Descriptor deprecated 

func (*AlterTopicResult) Descriptor() ([]byte, []int)

Deprecated: Use AlterTopicResult.ProtoReflect.Descriptor instead.

func (*AlterTopicResult) ProtoMessage 

func (*AlterTopicResult) ProtoMessage()

func (*AlterTopicResult) ProtoReflect 

func (x *AlterTopicResult) ProtoReflect() protoreflect.Message

func (*AlterTopicResult) Reset 

func (x *AlterTopicResult) Reset()

func (*AlterTopicResult) String 

func (x *AlterTopicResult) String() string

type Codec 

type Codec int32
const (
	Codec_CODEC_UNSPECIFIED Codec = 0
	Codec_CODEC_RAW         Codec = 1
	Codec_CODEC_GZIP        Codec = 2
	Codec_CODEC_LZOP        Codec = 3
	Codec_CODEC_ZSTD        Codec = 4
	// User-defined codecs from 10000 to 19999
	Codec_CODEC_CUSTOM Codec = 10000
)

func (Codec) Descriptor 

func (Codec) Descriptor() protoreflect.EnumDescriptor

func (Codec) Enum 

func (x Codec) Enum() *Codec

func (Codec) EnumDescriptor deprecated 

func (Codec) EnumDescriptor() ([]byte, []int)

Deprecated: Use Codec.Descriptor instead.

func (Codec) Number 

func (x Codec) Number() protoreflect.EnumNumber

func (Codec) String 

func (x Codec) String() string

func (Codec) Type 

func (Codec) Type() protoreflect.EnumType

type CommitOffsetRequest 

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
}

Commit offset request sent from client to server.

func (*CommitOffsetRequest) Descriptor deprecated 

func (*CommitOffsetRequest) Descriptor() ([]byte, []int)

Deprecated: Use CommitOffsetRequest.ProtoReflect.Descriptor instead.

func (*CommitOffsetRequest) GetConsumer 

func (x *CommitOffsetRequest) GetConsumer() string

func (*CommitOffsetRequest) GetOffset 

func (x *CommitOffsetRequest) GetOffset() int64

func (*CommitOffsetRequest) GetOperationParams 

func (x *CommitOffsetRequest) GetOperationParams() *Ydb_Operations.OperationParams

func (*CommitOffsetRequest) GetPartitionId 

func (x *CommitOffsetRequest) GetPartitionId() int64

func (*CommitOffsetRequest) GetPath 

func (x *CommitOffsetRequest) GetPath() string

func (*CommitOffsetRequest) ProtoMessage 

func (*CommitOffsetRequest) ProtoMessage()

func (*CommitOffsetRequest) ProtoReflect 

func (x *CommitOffsetRequest) ProtoReflect() protoreflect.Message

func (*CommitOffsetRequest) Reset 

func (x *CommitOffsetRequest) Reset()

func (*CommitOffsetRequest) String 

func (x *CommitOffsetRequest) String() string

type CommitOffsetResponse 

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
}

Commit offset response sent from server to client.

func (*CommitOffsetResponse) Descriptor deprecated 

func (*CommitOffsetResponse) Descriptor() ([]byte, []int)

Deprecated: Use CommitOffsetResponse.ProtoReflect.Descriptor instead.

func (*CommitOffsetResponse) GetOperation 

func (x *CommitOffsetResponse) GetOperation() *Ydb_Operations.Operation

func (*CommitOffsetResponse) ProtoMessage 

func (*CommitOffsetResponse) ProtoMessage()

func (*CommitOffsetResponse) ProtoReflect 

func (x *CommitOffsetResponse) ProtoReflect() protoreflect.Message

func (*CommitOffsetResponse) Reset 

func (x *CommitOffsetResponse) Reset()

func (*CommitOffsetResponse) String 

func (x *CommitOffsetResponse) String() string

type CommitOffsetResult 

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

Commit offset result message inside CommitOffsetResponse.operation.

func (*CommitOffsetResult) Descriptor deprecated 

func (*CommitOffsetResult) Descriptor() ([]byte, []int)

Deprecated: Use CommitOffsetResult.ProtoReflect.Descriptor instead.

func (*CommitOffsetResult) ProtoMessage 

func (*CommitOffsetResult) ProtoMessage()

func (*CommitOffsetResult) ProtoReflect 

func (x *CommitOffsetResult) ProtoReflect() protoreflect.Message

func (*CommitOffsetResult) Reset 

func (x *CommitOffsetResult) Reset()

func (*CommitOffsetResult) String 

func (x *CommitOffsetResult) String() string

type Consumer 

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
}

Consumer description.

func (*Consumer) Descriptor deprecated 

func (*Consumer) Descriptor() ([]byte, []int)

Deprecated: Use Consumer.ProtoReflect.Descriptor instead.

func (*Consumer) GetAttributes 

func (x *Consumer) GetAttributes() map[string]string

func (*Consumer) GetConsumerStats 

func (x *Consumer) GetConsumerStats() *Consumer_ConsumerStats

func (*Consumer) GetImportant 

func (x *Consumer) GetImportant() bool

func (*Consumer) GetName 

func (x *Consumer) GetName() string

func (*Consumer) GetReadFrom 

func (x *Consumer) GetReadFrom() *timestamppb.Timestamp

func (*Consumer) GetSupportedCodecs 

func (x *Consumer) GetSupportedCodecs() *SupportedCodecs

func (*Consumer) ProtoMessage 

func (*Consumer) ProtoMessage()

func (*Consumer) ProtoReflect 

func (x *Consumer) ProtoReflect() protoreflect.Message

func (*Consumer) Reset 

func (x *Consumer) Reset()

func (*Consumer) String 

func (x *Consumer) String() string

type Consumer_ConsumerStats 

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
}

func (*Consumer_ConsumerStats) Descriptor deprecated 

func (*Consumer_ConsumerStats) Descriptor() ([]byte, []int)

Deprecated: Use Consumer_ConsumerStats.ProtoReflect.Descriptor instead.

func (*Consumer_ConsumerStats) GetBytesRead 

func (x *Consumer_ConsumerStats) GetBytesRead() *MultipleWindowsStat

func (*Consumer_ConsumerStats) GetMaxReadTimeLag 

func (x *Consumer_ConsumerStats) GetMaxReadTimeLag() *durationpb.Duration

func (*Consumer_ConsumerStats) GetMaxWriteTimeLag 

func (x *Consumer_ConsumerStats) GetMaxWriteTimeLag() *durationpb.Duration

func (*Consumer_ConsumerStats) GetMinPartitionsLastReadTime 

func (x *Consumer_ConsumerStats) GetMinPartitionsLastReadTime() *timestamppb.Timestamp

func (*Consumer_ConsumerStats) ProtoMessage 

func (*Consumer_ConsumerStats) ProtoMessage()

func (*Consumer_ConsumerStats) ProtoReflect 

func (x *Consumer_ConsumerStats) ProtoReflect() protoreflect.Message

func (*Consumer_ConsumerStats) Reset 

func (x *Consumer_ConsumerStats) Reset()

func (*Consumer_ConsumerStats) String 

func (x *Consumer_ConsumerStats) String() string

type CreateTopicRequest 

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
}

Create topic request sent from client to server.

func (*CreateTopicRequest) Descriptor deprecated 

func (*CreateTopicRequest) Descriptor() ([]byte, []int)

Deprecated: Use CreateTopicRequest.ProtoReflect.Descriptor instead.

func (*CreateTopicRequest) GetAttributes 

func (x *CreateTopicRequest) GetAttributes() map[string]string

func (*CreateTopicRequest) GetConsumers 

func (x *CreateTopicRequest) GetConsumers() []*Consumer

func (*CreateTopicRequest) GetMeteringMode 

func (x *CreateTopicRequest) GetMeteringMode() MeteringMode

func (*CreateTopicRequest) GetOperationParams 

func (x *CreateTopicRequest) GetOperationParams() *Ydb_Operations.OperationParams

func (*CreateTopicRequest) GetPartitionWriteBurstBytes 

func (x *CreateTopicRequest) GetPartitionWriteBurstBytes() int64

func (*CreateTopicRequest) GetPartitionWriteSpeedBytesPerSecond 

func (x *CreateTopicRequest) GetPartitionWriteSpeedBytesPerSecond() int64

func (*CreateTopicRequest) GetPartitioningSettings 

func (x *CreateTopicRequest) GetPartitioningSettings() *PartitioningSettings

func (*CreateTopicRequest) GetPath 

func (x *CreateTopicRequest) GetPath() string

func (*CreateTopicRequest) GetRetentionPeriod 

func (x *CreateTopicRequest) GetRetentionPeriod() *durationpb.Duration

func (*CreateTopicRequest) GetRetentionStorageMb 

func (x *CreateTopicRequest) GetRetentionStorageMb() int64

func (*CreateTopicRequest) GetSupportedCodecs 

func (x *CreateTopicRequest) GetSupportedCodecs() *SupportedCodecs

func (*CreateTopicRequest) ProtoMessage 

func (*CreateTopicRequest) ProtoMessage()

func (*CreateTopicRequest) ProtoReflect 

func (x *CreateTopicRequest) ProtoReflect() protoreflect.Message

func (*CreateTopicRequest) Reset 

func (x *CreateTopicRequest) Reset()

func (*CreateTopicRequest) String 

func (x *CreateTopicRequest) String() string

type CreateTopicResponse 

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
}

Create topic response sent from server to client. If topic is already exists then response status will be "ALREADY_EXISTS".

func (*CreateTopicResponse) Descriptor deprecated 

func (*CreateTopicResponse) Descriptor() ([]byte, []int)

Deprecated: Use CreateTopicResponse.ProtoReflect.Descriptor instead.

func (*CreateTopicResponse) GetOperation 

func (x *CreateTopicResponse) GetOperation() *Ydb_Operations.Operation

func (*CreateTopicResponse) ProtoMessage 

func (*CreateTopicResponse) ProtoMessage()

func (*CreateTopicResponse) ProtoReflect 

func (x *CreateTopicResponse) ProtoReflect() protoreflect.Message

func (*CreateTopicResponse) Reset 

func (x *CreateTopicResponse) Reset()

func (*CreateTopicResponse) String 

func (x *CreateTopicResponse) String() string

type CreateTopicResult 

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

Create topic result message that will be inside CreateTopicResponse.operation.

func (*CreateTopicResult) Descriptor deprecated 

func (*CreateTopicResult) Descriptor() ([]byte, []int)

Deprecated: Use CreateTopicResult.ProtoReflect.Descriptor instead.

func (*CreateTopicResult) ProtoMessage 

func (*CreateTopicResult) ProtoMessage()

func (*CreateTopicResult) ProtoReflect 

func (x *CreateTopicResult) ProtoReflect() protoreflect.Message

func (*CreateTopicResult) Reset 

func (x *CreateTopicResult) Reset()

func (*CreateTopicResult) String 

func (x *CreateTopicResult) String() string

type DescribeConsumerRequest 

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
}

Describe topic's consumer request sent from client to server.

func (*DescribeConsumerRequest) Descriptor deprecated 

func (*DescribeConsumerRequest) Descriptor() ([]byte, []int)

Deprecated: Use DescribeConsumerRequest.ProtoReflect.Descriptor instead.

func (*DescribeConsumerRequest) GetConsumer 

func (x *DescribeConsumerRequest) GetConsumer() string

func (*DescribeConsumerRequest) GetIncludeStats 

func (x *DescribeConsumerRequest) GetIncludeStats() bool

func (*DescribeConsumerRequest) GetOperationParams 

func (x *DescribeConsumerRequest) GetOperationParams() *Ydb_Operations.OperationParams

func (*DescribeConsumerRequest) GetPath 

func (x *DescribeConsumerRequest) GetPath() string

func (*DescribeConsumerRequest) ProtoMessage 

func (*DescribeConsumerRequest) ProtoMessage()

func (*DescribeConsumerRequest) ProtoReflect 

func (x *DescribeConsumerRequest) ProtoReflect() protoreflect.Message

func (*DescribeConsumerRequest) Reset 

func (x *DescribeConsumerRequest) Reset()

func (*DescribeConsumerRequest) String 

func (x *DescribeConsumerRequest) String() string

type DescribeConsumerResponse 

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
}

Describe topic's consumer response sent from server to client. If topic is not existed then response status will be "SCHEME_ERROR".

func (*DescribeConsumerResponse) Descriptor deprecated 

func (*DescribeConsumerResponse) Descriptor() ([]byte, []int)

Deprecated: Use DescribeConsumerResponse.ProtoReflect.Descriptor instead.

func (*DescribeConsumerResponse) GetOperation 

func (x *DescribeConsumerResponse) GetOperation() *Ydb_Operations.Operation

func (*DescribeConsumerResponse) ProtoMessage 

func (*DescribeConsumerResponse) ProtoMessage()

func (*DescribeConsumerResponse) ProtoReflect 

func (x *DescribeConsumerResponse) ProtoReflect() protoreflect.Message

func (*DescribeConsumerResponse) Reset 

func (x *DescribeConsumerResponse) Reset()

func (*DescribeConsumerResponse) String 

func (x *DescribeConsumerResponse) String() string

type DescribeConsumerResult 

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
}

Describe topic's consumer result message that will be inside DescribeConsumerResponse.operation.

func (*DescribeConsumerResult) Descriptor deprecated 

func (*DescribeConsumerResult) Descriptor() ([]byte, []int)

Deprecated: Use DescribeConsumerResult.ProtoReflect.Descriptor instead.

func (*DescribeConsumerResult) GetConsumer 

func (x *DescribeConsumerResult) GetConsumer() *Consumer

func (*DescribeConsumerResult) GetPartitions 

func (x *DescribeConsumerResult) GetPartitions() []*DescribeConsumerResult_PartitionInfo

func (*DescribeConsumerResult) GetSelf 

func (x *DescribeConsumerResult) GetSelf() *Ydb_Scheme.Entry

func (*DescribeConsumerResult) ProtoMessage 

func (*DescribeConsumerResult) ProtoMessage()

func (*DescribeConsumerResult) ProtoReflect 

func (x *DescribeConsumerResult) ProtoReflect() protoreflect.Message

func (*DescribeConsumerResult) Reset 

func (x *DescribeConsumerResult) Reset()

func (*DescribeConsumerResult) String 

func (x *DescribeConsumerResult) String() string

type DescribeConsumerResult_PartitionConsumerStats 

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
}

func (*DescribeConsumerResult_PartitionConsumerStats) Descriptor deprecated 

func (*DescribeConsumerResult_PartitionConsumerStats) Descriptor() ([]byte, []int)

Deprecated: Use DescribeConsumerResult_PartitionConsumerStats.ProtoReflect.Descriptor instead.

func (*DescribeConsumerResult_PartitionConsumerStats) GetBytesRead 

func (x *DescribeConsumerResult_PartitionConsumerStats) GetBytesRead() *MultipleWindowsStat

func (*DescribeConsumerResult_PartitionConsumerStats) GetCommittedOffset 

func (x *DescribeConsumerResult_PartitionConsumerStats) GetCommittedOffset() int64

func (*DescribeConsumerResult_PartitionConsumerStats) GetConnectionNodeId 

func (x *DescribeConsumerResult_PartitionConsumerStats) GetConnectionNodeId() int32

func (*DescribeConsumerResult_PartitionConsumerStats) GetLastReadOffset 

func (x *DescribeConsumerResult_PartitionConsumerStats) GetLastReadOffset() int64

func (*DescribeConsumerResult_PartitionConsumerStats) GetLastReadTime 

func (x *DescribeConsumerResult_PartitionConsumerStats) GetLastReadTime() *timestamppb.Timestamp

func (*DescribeConsumerResult_PartitionConsumerStats) GetMaxReadTimeLag 

func (x *DescribeConsumerResult_PartitionConsumerStats) GetMaxReadTimeLag() *durationpb.Duration

func (*DescribeConsumerResult_PartitionConsumerStats) GetMaxWriteTimeLag 

func (x *DescribeConsumerResult_PartitionConsumerStats) GetMaxWriteTimeLag() *durationpb.Duration

func (*DescribeConsumerResult_PartitionConsumerStats) GetPartitionReadSessionCreateTime 

func (x *DescribeConsumerResult_PartitionConsumerStats) GetPartitionReadSessionCreateTime() *timestamppb.Timestamp

func (*DescribeConsumerResult_PartitionConsumerStats) GetReadSessionId 

func (x *DescribeConsumerResult_PartitionConsumerStats) GetReadSessionId() string

func (*DescribeConsumerResult_PartitionConsumerStats) GetReaderName 

func (x *DescribeConsumerResult_PartitionConsumerStats) GetReaderName() string

func (*DescribeConsumerResult_PartitionConsumerStats) ProtoMessage 

func (*DescribeConsumerResult_PartitionConsumerStats) ProtoMessage()

func (*DescribeConsumerResult_PartitionConsumerStats) ProtoReflect 

func (x *DescribeConsumerResult_PartitionConsumerStats) ProtoReflect() protoreflect.Message

func (*DescribeConsumerResult_PartitionConsumerStats) Reset 

func (x *DescribeConsumerResult_PartitionConsumerStats) Reset()

func (*DescribeConsumerResult_PartitionConsumerStats) String 

func (x *DescribeConsumerResult_PartitionConsumerStats) String() string

type DescribeConsumerResult_PartitionInfo 

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
}

func (*DescribeConsumerResult_PartitionInfo) Descriptor deprecated 

func (*DescribeConsumerResult_PartitionInfo) Descriptor() ([]byte, []int)

Deprecated: Use DescribeConsumerResult_PartitionInfo.ProtoReflect.Descriptor instead.

func (*DescribeConsumerResult_PartitionInfo) GetActive 

func (x *DescribeConsumerResult_PartitionInfo) GetActive() bool

func (*DescribeConsumerResult_PartitionInfo) GetChildPartitionIds 

func (x *DescribeConsumerResult_PartitionInfo) GetChildPartitionIds() []int64

func (*DescribeConsumerResult_PartitionInfo) GetParentPartitionIds 

func (x *DescribeConsumerResult_PartitionInfo) GetParentPartitionIds() []int64

func (*DescribeConsumerResult_PartitionInfo) GetPartitionConsumerStats 

func (x *DescribeConsumerResult_PartitionInfo) GetPartitionConsumerStats() *DescribeConsumerResult_PartitionConsumerStats

func (*DescribeConsumerResult_PartitionInfo) GetPartitionId 

func (x *DescribeConsumerResult_PartitionInfo) GetPartitionId() int64

func (*DescribeConsumerResult_PartitionInfo) GetPartitionStats 

func (x *DescribeConsumerResult_PartitionInfo) GetPartitionStats() *PartitionStats

func (*DescribeConsumerResult_PartitionInfo) ProtoMessage 

func (*DescribeConsumerResult_PartitionInfo) ProtoMessage()

func (*DescribeConsumerResult_PartitionInfo) ProtoReflect 

func (x *DescribeConsumerResult_PartitionInfo) ProtoReflect() protoreflect.Message

func (*DescribeConsumerResult_PartitionInfo) Reset 

func (x *DescribeConsumerResult_PartitionInfo) Reset()

func (*DescribeConsumerResult_PartitionInfo) String 

func (x *DescribeConsumerResult_PartitionInfo) String() string

type DescribeTopicRequest 

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
}

Describe topic request sent from client to server.

func (*DescribeTopicRequest) Descriptor deprecated 

func (*DescribeTopicRequest) Descriptor() ([]byte, []int)

Deprecated: Use DescribeTopicRequest.ProtoReflect.Descriptor instead.

func (*DescribeTopicRequest) GetIncludeStats 

func (x *DescribeTopicRequest) GetIncludeStats() bool

func (*DescribeTopicRequest) GetOperationParams 

func (x *DescribeTopicRequest) GetOperationParams() *Ydb_Operations.OperationParams

func (*DescribeTopicRequest) GetPath 

func (x *DescribeTopicRequest) GetPath() string

func (*DescribeTopicRequest) ProtoMessage 

func (*DescribeTopicRequest) ProtoMessage()

func (*DescribeTopicRequest) ProtoReflect 

func (x *DescribeTopicRequest) ProtoReflect() protoreflect.Message

func (*DescribeTopicRequest) Reset 

func (x *DescribeTopicRequest) Reset()

func (*DescribeTopicRequest) String 

func (x *DescribeTopicRequest) String() string

type DescribeTopicResponse 

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
}

Describe topic response sent from server to client. If topic is not existed then response status will be "SCHEME_ERROR".

func (*DescribeTopicResponse) Descriptor deprecated 

func (*DescribeTopicResponse) Descriptor() ([]byte, []int)

Deprecated: Use DescribeTopicResponse.ProtoReflect.Descriptor instead.

func (*DescribeTopicResponse) GetOperation 

func (x *DescribeTopicResponse) GetOperation() *Ydb_Operations.Operation

func (*DescribeTopicResponse) ProtoMessage 

func (*DescribeTopicResponse) ProtoMessage()

func (*DescribeTopicResponse) ProtoReflect 

func (x *DescribeTopicResponse) ProtoReflect() protoreflect.Message

func (*DescribeTopicResponse) Reset 

func (x *DescribeTopicResponse) Reset()

func (*DescribeTopicResponse) String 

func (x *DescribeTopicResponse) String() string

type DescribeTopicResult 

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
}

Describe topic result message that will be inside DescribeTopicResponse.operation.

func (*DescribeTopicResult) Descriptor deprecated 

func (*DescribeTopicResult) Descriptor() ([]byte, []int)

Deprecated: Use DescribeTopicResult.ProtoReflect.Descriptor instead.

func (*DescribeTopicResult) GetAttributes 

func (x *DescribeTopicResult) GetAttributes() map[string]string

func (*DescribeTopicResult) GetConsumers 

func (x *DescribeTopicResult) GetConsumers() []*Consumer

func (*DescribeTopicResult) GetMeteringMode 

func (x *DescribeTopicResult) GetMeteringMode() MeteringMode

func (*DescribeTopicResult) GetPartitionWriteBurstBytes 

func (x *DescribeTopicResult) GetPartitionWriteBurstBytes() int64

func (*DescribeTopicResult) GetPartitionWriteSpeedBytesPerSecond 

func (x *DescribeTopicResult) GetPartitionWriteSpeedBytesPerSecond() int64

func (*DescribeTopicResult) GetPartitioningSettings 

func (x *DescribeTopicResult) GetPartitioningSettings() *PartitioningSettings

func (*DescribeTopicResult) GetPartitions 

func (x *DescribeTopicResult) GetPartitions() []*DescribeTopicResult_PartitionInfo

func (*DescribeTopicResult) GetRetentionPeriod 

func (x *DescribeTopicResult) GetRetentionPeriod() *durationpb.Duration

func (*DescribeTopicResult) GetRetentionStorageMb 

func (x *DescribeTopicResult) GetRetentionStorageMb() int64

func (*DescribeTopicResult) GetSelf 

func (x *DescribeTopicResult) GetSelf() *Ydb_Scheme.Entry

func (*DescribeTopicResult) GetSupportedCodecs 

func (x *DescribeTopicResult) GetSupportedCodecs() *SupportedCodecs

func (*DescribeTopicResult) GetTopicStats 

func (x *DescribeTopicResult) GetTopicStats() *DescribeTopicResult_TopicStats

func (*DescribeTopicResult) ProtoMessage 

func (*DescribeTopicResult) ProtoMessage()

func (*DescribeTopicResult) ProtoReflect 

func (x *DescribeTopicResult) ProtoReflect() protoreflect.Message

func (*DescribeTopicResult) Reset 

func (x *DescribeTopicResult) Reset()

func (*DescribeTopicResult) String 

func (x *DescribeTopicResult) String() string

type DescribeTopicResult_PartitionInfo 

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
}

func (*DescribeTopicResult_PartitionInfo) Descriptor deprecated 

func (*DescribeTopicResult_PartitionInfo) Descriptor() ([]byte, []int)

Deprecated: Use DescribeTopicResult_PartitionInfo.ProtoReflect.Descriptor instead.

func (*DescribeTopicResult_PartitionInfo) GetActive 

func (x *DescribeTopicResult_PartitionInfo) GetActive() bool

func (*DescribeTopicResult_PartitionInfo) GetChildPartitionIds 

func (x *DescribeTopicResult_PartitionInfo) GetChildPartitionIds() []int64

func (*DescribeTopicResult_PartitionInfo) GetParentPartitionIds 

func (x *DescribeTopicResult_PartitionInfo) GetParentPartitionIds() []int64

func (*DescribeTopicResult_PartitionInfo) GetPartitionId 

func (x *DescribeTopicResult_PartitionInfo) GetPartitionId() int64

func (*DescribeTopicResult_PartitionInfo) GetPartitionStats 

func (x *DescribeTopicResult_PartitionInfo) GetPartitionStats() *PartitionStats

func (*DescribeTopicResult_PartitionInfo) ProtoMessage 

func (*DescribeTopicResult_PartitionInfo) ProtoMessage()

func (*DescribeTopicResult_PartitionInfo) ProtoReflect 

func (x *DescribeTopicResult_PartitionInfo) ProtoReflect() protoreflect.Message

func (*DescribeTopicResult_PartitionInfo) Reset 

func (x *DescribeTopicResult_PartitionInfo) Reset()

func (*DescribeTopicResult_PartitionInfo) String 

func (x *DescribeTopicResult_PartitionInfo) String() string

type DescribeTopicResult_TopicStats 

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
}

func (*DescribeTopicResult_TopicStats) Descriptor deprecated 

func (*DescribeTopicResult_TopicStats) Descriptor() ([]byte, []int)

Deprecated: Use DescribeTopicResult_TopicStats.ProtoReflect.Descriptor instead.

func (*DescribeTopicResult_TopicStats) GetBytesWritten 

func (x *DescribeTopicResult_TopicStats) GetBytesWritten() *MultipleWindowsStat

func (*DescribeTopicResult_TopicStats) GetMaxWriteTimeLag 

func (x *DescribeTopicResult_TopicStats) GetMaxWriteTimeLag() *durationpb.Duration

func (*DescribeTopicResult_TopicStats) GetMinLastWriteTime 

func (x *DescribeTopicResult_TopicStats) GetMinLastWriteTime() *timestamppb.Timestamp

func (*DescribeTopicResult_TopicStats) GetStoreSizeBytes 

func (x *DescribeTopicResult_TopicStats) GetStoreSizeBytes() int64

func (*DescribeTopicResult_TopicStats) ProtoMessage 

func (*DescribeTopicResult_TopicStats) ProtoMessage()

func (*DescribeTopicResult_TopicStats) ProtoReflect 

func (x *DescribeTopicResult_TopicStats) ProtoReflect() protoreflect.Message

func (*DescribeTopicResult_TopicStats) Reset 

func (x *DescribeTopicResult_TopicStats) Reset()

func (*DescribeTopicResult_TopicStats) String 

func (x *DescribeTopicResult_TopicStats) String() string

type DropTopicRequest 

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
}

Drop topic request sent from client to server.

func (*DropTopicRequest) Descriptor deprecated 

func (*DropTopicRequest) Descriptor() ([]byte, []int)

Deprecated: Use DropTopicRequest.ProtoReflect.Descriptor instead.

func (*DropTopicRequest) GetOperationParams 

func (x *DropTopicRequest) GetOperationParams() *Ydb_Operations.OperationParams

func (*DropTopicRequest) GetPath 

func (x *DropTopicRequest) GetPath() string

func (*DropTopicRequest) ProtoMessage 

func (*DropTopicRequest) ProtoMessage()

func (*DropTopicRequest) ProtoReflect 

func (x *DropTopicRequest) ProtoReflect() protoreflect.Message

func (*DropTopicRequest) Reset 

func (x *DropTopicRequest) Reset()

func (*DropTopicRequest) String 

func (x *DropTopicRequest) String() string

type DropTopicResponse 

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
}

Drop topic response sent from server to client. If topic not exists then response status will be "SCHEME_ERROR".

func (*DropTopicResponse) Descriptor deprecated 

func (*DropTopicResponse) Descriptor() ([]byte, []int)

Deprecated: Use DropTopicResponse.ProtoReflect.Descriptor instead.

func (*DropTopicResponse) GetOperation 

func (x *DropTopicResponse) GetOperation() *Ydb_Operations.Operation

func (*DropTopicResponse) ProtoMessage 

func (*DropTopicResponse) ProtoMessage()

func (*DropTopicResponse) ProtoReflect 

func (x *DropTopicResponse) ProtoReflect() protoreflect.Message

func (*DropTopicResponse) Reset 

func (x *DropTopicResponse) Reset()

func (*DropTopicResponse) String 

func (x *DropTopicResponse) String() string

type DropTopicResult 

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

Drop topic result message that will be inside DropTopicResponse.operation.

func (*DropTopicResult) Descriptor deprecated 

func (*DropTopicResult) Descriptor() ([]byte, []int)

Deprecated: Use DropTopicResult.ProtoReflect.Descriptor instead.

func (*DropTopicResult) ProtoMessage 

func (*DropTopicResult) ProtoMessage()

func (*DropTopicResult) ProtoReflect 

func (x *DropTopicResult) ProtoReflect() protoreflect.Message

func (*DropTopicResult) Reset 

func (x *DropTopicResult) Reset()

func (*DropTopicResult) String 

func (x *DropTopicResult) String() string

type MetadataItem 

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
}

func (*MetadataItem) Descriptor deprecated 

func (*MetadataItem) Descriptor() ([]byte, []int)

Deprecated: Use MetadataItem.ProtoReflect.Descriptor instead.

func (*MetadataItem) GetKey 

func (x *MetadataItem) GetKey() string

func (*MetadataItem) GetValue 

func (x *MetadataItem) GetValue() []byte

func (*MetadataItem) ProtoMessage 

func (*MetadataItem) ProtoMessage()

func (*MetadataItem) ProtoReflect 

func (x *MetadataItem) ProtoReflect() protoreflect.Message

func (*MetadataItem) Reset 

func (x *MetadataItem) Reset()

func (*MetadataItem) String 

func (x *MetadataItem) String() string

type MeteringMode 

type MeteringMode int32

Metering mode specifies the method used to determine consumption of resources by the topic. This settings will have an effect only in a serverless database. 

const (
	// Use default
	MeteringMode_METERING_MODE_UNSPECIFIED MeteringMode = 0
	// Metering based on resource reservation
	MeteringMode_METERING_MODE_RESERVED_CAPACITY MeteringMode = 1
	// Metering based on actual consumption. Default.
	MeteringMode_METERING_MODE_REQUEST_UNITS MeteringMode = 2
)

func (MeteringMode) Descriptor 

func (MeteringMode) Descriptor() protoreflect.EnumDescriptor

func (MeteringMode) Enum 

func (x MeteringMode) Enum() *MeteringMode

func (MeteringMode) EnumDescriptor deprecated 

func (MeteringMode) EnumDescriptor() ([]byte, []int)

Deprecated: Use MeteringMode.Descriptor instead.

func (MeteringMode) Number 

func (x MeteringMode) Number() protoreflect.EnumNumber

func (MeteringMode) String 

func (x MeteringMode) String() string

func (MeteringMode) Type 

func (MeteringMode) Type() protoreflect.EnumType

type MultipleWindowsStat 

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
}

message representing statistics by seleveral windows

func (*MultipleWindowsStat) Descriptor deprecated 

func (*MultipleWindowsStat) Descriptor() ([]byte, []int)

Deprecated: Use MultipleWindowsStat.ProtoReflect.Descriptor instead.

func (*MultipleWindowsStat) GetPerDay 

func (x *MultipleWindowsStat) GetPerDay() int64

func (*MultipleWindowsStat) GetPerHour 

func (x *MultipleWindowsStat) GetPerHour() int64

func (*MultipleWindowsStat) GetPerMinute 

func (x *MultipleWindowsStat) GetPerMinute() int64

func (*MultipleWindowsStat) ProtoMessage 

func (*MultipleWindowsStat) ProtoMessage()

func (*MultipleWindowsStat) ProtoReflect 

func (x *MultipleWindowsStat) ProtoReflect() protoreflect.Message

func (*MultipleWindowsStat) Reset 

func (x *MultipleWindowsStat) Reset()

func (*MultipleWindowsStat) String 

func (x *MultipleWindowsStat) String() string

type OffsetsRange 

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
}

Represents range [start, end). I.e. (end - 1) is the greatest of offsets, included in non-empty range.

func (*OffsetsRange) Descriptor deprecated 

func (*OffsetsRange) Descriptor() ([]byte, []int)

Deprecated: Use OffsetsRange.ProtoReflect.Descriptor instead.

func (*OffsetsRange) GetEnd 

func (x *OffsetsRange) GetEnd() int64

func (*OffsetsRange) GetStart 

func (x *OffsetsRange) GetStart() int64

func (*OffsetsRange) ProtoMessage 

func (*OffsetsRange) ProtoMessage()

func (*OffsetsRange) ProtoReflect 

func (x *OffsetsRange) ProtoReflect() protoreflect.Message

func (*OffsetsRange) Reset 

func (x *OffsetsRange) Reset()

func (*OffsetsRange) String 

func (x *OffsetsRange) String() string

type PartitionStats 

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
}

func (*PartitionStats) Descriptor deprecated 

func (*PartitionStats) Descriptor() ([]byte, []int)

Deprecated: Use PartitionStats.ProtoReflect.Descriptor instead.

func (*PartitionStats) GetBytesWritten 

func (x *PartitionStats) GetBytesWritten() *MultipleWindowsStat

func (*PartitionStats) GetLastWriteTime 

func (x *PartitionStats) GetLastWriteTime() *timestamppb.Timestamp

func (*PartitionStats) GetMaxWriteTimeLag 

func (x *PartitionStats) GetMaxWriteTimeLag() *durationpb.Duration

func (*PartitionStats) GetPartitionNodeId 

func (x *PartitionStats) GetPartitionNodeId() int32

func (*PartitionStats) GetPartitionOffsets 

func (x *PartitionStats) GetPartitionOffsets() *OffsetsRange

func (*PartitionStats) GetStoreSizeBytes 

func (x *PartitionStats) GetStoreSizeBytes() int64

func (*PartitionStats) ProtoMessage 

func (*PartitionStats) ProtoMessage()

func (*PartitionStats) ProtoReflect 

func (x *PartitionStats) ProtoReflect() protoreflect.Message

func (*PartitionStats) Reset 

func (x *PartitionStats) Reset()

func (*PartitionStats) String 

func (x *PartitionStats) String() string

type PartitioningSettings 

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
}

Partitioning settings for topic.

func (*PartitioningSettings) Descriptor deprecated 

func (*PartitioningSettings) Descriptor() ([]byte, []int)

Deprecated: Use PartitioningSettings.ProtoReflect.Descriptor instead.

func (*PartitioningSettings) GetMinActivePartitions 

func (x *PartitioningSettings) GetMinActivePartitions() int64

func (*PartitioningSettings) GetPartitionCountLimit 

func (x *PartitioningSettings) GetPartitionCountLimit() int64

func (*PartitioningSettings) ProtoMessage 

func (*PartitioningSettings) ProtoMessage()

func (*PartitioningSettings) ProtoReflect 

func (x *PartitioningSettings) ProtoReflect() protoreflect.Message

func (*PartitioningSettings) Reset 

func (x *PartitioningSettings) Reset()

func (*PartitioningSettings) String 

func (x *PartitioningSettings) String() string

type StreamReadMessage 

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

Messages for bidirectional streaming rpc StreamRead

func (*StreamReadMessage) Descriptor deprecated 

func (*StreamReadMessage) Descriptor() ([]byte, []int)

Deprecated: Use StreamReadMessage.ProtoReflect.Descriptor instead.

func (*StreamReadMessage) ProtoMessage 

func (*StreamReadMessage) ProtoMessage()

func (*StreamReadMessage) ProtoReflect 

func (x *StreamReadMessage) ProtoReflect() protoreflect.Message

func (*StreamReadMessage) Reset 

func (x *StreamReadMessage) Reset()

func (*StreamReadMessage) String 

func (x *StreamReadMessage) String() string

type StreamReadMessage_CommitOffsetRequest 

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
}

Signal for server that client processed some read data.

func (*StreamReadMessage_CommitOffsetRequest) Descriptor deprecated 

func (*StreamReadMessage_CommitOffsetRequest) Descriptor() ([]byte, []int)

Deprecated: Use StreamReadMessage_CommitOffsetRequest.ProtoReflect.Descriptor instead.

func (*StreamReadMessage_CommitOffsetRequest) GetCommitOffsets 

func (x *StreamReadMessage_CommitOffsetRequest) GetCommitOffsets() []*StreamReadMessage_CommitOffsetRequest_PartitionCommitOffset

func (*StreamReadMessage_CommitOffsetRequest) ProtoMessage 

func (*StreamReadMessage_CommitOffsetRequest) ProtoMessage()

func (*StreamReadMessage_CommitOffsetRequest) ProtoReflect 

func (x *StreamReadMessage_CommitOffsetRequest) ProtoReflect() protoreflect.Message

func (*StreamReadMessage_CommitOffsetRequest) Reset 

func (x *StreamReadMessage_CommitOffsetRequest) Reset()

func (*StreamReadMessage_CommitOffsetRequest) String 

func (x *StreamReadMessage_CommitOffsetRequest) String() string

type StreamReadMessage_CommitOffsetRequest_PartitionCommitOffset 

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
}

Message that is used for describing commit.

func (*StreamReadMessage_CommitOffsetRequest_PartitionCommitOffset) Descriptor deprecated 

func (*StreamReadMessage_CommitOffsetRequest_PartitionCommitOffset) Descriptor() ([]byte, []int)

Deprecated: Use StreamReadMessage_CommitOffsetRequest_PartitionCommitOffset.ProtoReflect.Descriptor instead.

func (*StreamReadMessage_CommitOffsetRequest_PartitionCommitOffset) GetOffsets 

func (x *StreamReadMessage_CommitOffsetRequest_PartitionCommitOffset) GetOffsets() []*OffsetsRange

func (*StreamReadMessage_CommitOffsetRequest_PartitionCommitOffset) GetPartitionSessionId 

func (x *StreamReadMessage_CommitOffsetRequest_PartitionCommitOffset) GetPartitionSessionId() int64

func (*StreamReadMessage_CommitOffsetRequest_PartitionCommitOffset) ProtoMessage 

func (*StreamReadMessage_CommitOffsetRequest_PartitionCommitOffset) ProtoMessage()

func (*StreamReadMessage_CommitOffsetRequest_PartitionCommitOffset) ProtoReflect 

func (x *StreamReadMessage_CommitOffsetRequest_PartitionCommitOffset) ProtoReflect() protoreflect.Message

func (*StreamReadMessage_CommitOffsetRequest_PartitionCommitOffset) Reset 

func (x *StreamReadMessage_CommitOffsetRequest_PartitionCommitOffset) Reset()

func (*StreamReadMessage_CommitOffsetRequest_PartitionCommitOffset) String 

func (x *StreamReadMessage_CommitOffsetRequest_PartitionCommitOffset) String() string

type StreamReadMessage_CommitOffsetResponse 

type StreamReadMessage_CommitOffsetResponse struct {

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

Acknowledgement for commits.

func (*StreamReadMessage_CommitOffsetResponse) Descriptor deprecated 

func (*StreamReadMessage_CommitOffsetResponse) Descriptor() ([]byte, []int)

Deprecated: Use StreamReadMessage_CommitOffsetResponse.ProtoReflect.Descriptor instead.

func (*StreamReadMessage_CommitOffsetResponse) GetPartitionsCommittedOffsets 

func (x *StreamReadMessage_CommitOffsetResponse) GetPartitionsCommittedOffsets() []*StreamReadMessage_CommitOffsetResponse_PartitionCommittedOffset

func (*StreamReadMessage_CommitOffsetResponse) ProtoMessage 

func (*StreamReadMessage_CommitOffsetResponse) ProtoMessage()

func (*StreamReadMessage_CommitOffsetResponse) ProtoReflect 

func (x *StreamReadMessage_CommitOffsetResponse) ProtoReflect() protoreflect.Message

func (*StreamReadMessage_CommitOffsetResponse) Reset 

func (x *StreamReadMessage_CommitOffsetResponse) Reset()

func (*StreamReadMessage_CommitOffsetResponse) String 

func (x *StreamReadMessage_CommitOffsetResponse) String() string

type StreamReadMessage_CommitOffsetResponse_PartitionCommittedOffset 

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
}

Per-partition commit representation.

func (*StreamReadMessage_CommitOffsetResponse_PartitionCommittedOffset) Descriptor deprecated 

func (*StreamReadMessage_CommitOffsetResponse_PartitionCommittedOffset) Descriptor() ([]byte, []int)

Deprecated: Use StreamReadMessage_CommitOffsetResponse_PartitionCommittedOffset.ProtoReflect.Descriptor instead.

func (*StreamReadMessage_CommitOffsetResponse_PartitionCommittedOffset) GetCommittedOffset 

func (x *StreamReadMessage_CommitOffsetResponse_PartitionCommittedOffset) GetCommittedOffset() int64

func (*StreamReadMessage_CommitOffsetResponse_PartitionCommittedOffset) GetPartitionSessionId 

func (x *StreamReadMessage_CommitOffsetResponse_PartitionCommittedOffset) GetPartitionSessionId() int64

func (*StreamReadMessage_CommitOffsetResponse_PartitionCommittedOffset) ProtoMessage 

func (*StreamReadMessage_CommitOffsetResponse_PartitionCommittedOffset) ProtoMessage()

func (*StreamReadMessage_CommitOffsetResponse_PartitionCommittedOffset) ProtoReflect 

func (x *StreamReadMessage_CommitOffsetResponse_PartitionCommittedOffset) ProtoReflect() protoreflect.Message

func (*StreamReadMessage_CommitOffsetResponse_PartitionCommittedOffset) Reset 

func (x *StreamReadMessage_CommitOffsetResponse_PartitionCommittedOffset) Reset()

func (*StreamReadMessage_CommitOffsetResponse_PartitionCommittedOffset) String 

func (x *StreamReadMessage_CommitOffsetResponse_PartitionCommittedOffset) String() string

type StreamReadMessage_FromClient 

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
}

Client-server message for read session. Contains one of: 

InitRequest - handshake request.
ReadRequest - request for data.
CommitOffsetRequest - request for commit of some read data.
PartitionSessionStatusRequest - request for session status
UpdateTokenRequest - request to update auth token

StartPartitionSessionResponse - Response to StreamReadServerMessage.StartPartitionSessionRequest.
    Client signals it is ready to get data from partition.
StopPartitionSessionResponse - Response to StreamReadServerMessage.StopPartitionSessionRequest.
    Client signals it has finished working with partition. Mandatory for graceful stop, optional otherwise.

func (*StreamReadMessage_FromClient) Descriptor deprecated 

func (*StreamReadMessage_FromClient) Descriptor() ([]byte, []int)

Deprecated: Use StreamReadMessage_FromClient.ProtoReflect.Descriptor instead.

func (*StreamReadMessage_FromClient) GetClientMessage 

func (m *StreamReadMessage_FromClient) GetClientMessage() isStreamReadMessage_FromClient_ClientMessage

func (*StreamReadMessage_FromClient) GetCommitOffsetRequest 

func (x *StreamReadMessage_FromClient) GetCommitOffsetRequest() *StreamReadMessage_CommitOffsetRequest

func (*StreamReadMessage_FromClient) GetInitRequest 

func (x *StreamReadMessage_FromClient) GetInitRequest() *StreamReadMessage_InitRequest

func (*StreamReadMessage_FromClient) GetPartitionSessionStatusRequest 

func (x *StreamReadMessage_FromClient) GetPartitionSessionStatusRequest() *StreamReadMessage_PartitionSessionStatusRequest

func (*StreamReadMessage_FromClient) GetReadRequest 

func (x *StreamReadMessage_FromClient) GetReadRequest() *StreamReadMessage_ReadRequest

func (*StreamReadMessage_FromClient) GetStartPartitionSessionResponse 

func (x *StreamReadMessage_FromClient) GetStartPartitionSessionResponse() *StreamReadMessage_StartPartitionSessionResponse

func (*StreamReadMessage_FromClient) GetStopPartitionSessionResponse 

func (x *StreamReadMessage_FromClient) GetStopPartitionSessionResponse() *StreamReadMessage_StopPartitionSessionResponse

func (*StreamReadMessage_FromClient) GetUpdateTokenRequest 

func (x *StreamReadMessage_FromClient) GetUpdateTokenRequest() *UpdateTokenRequest

func (*StreamReadMessage_FromClient) ProtoMessage 

func (*StreamReadMessage_FromClient) ProtoMessage()

func (*StreamReadMessage_FromClient) ProtoReflect 

func (x *StreamReadMessage_FromClient) ProtoReflect() protoreflect.Message

func (*StreamReadMessage_FromClient) Reset 

func (x *StreamReadMessage_FromClient) Reset()

func (*StreamReadMessage_FromClient) String 

func (x *StreamReadMessage_FromClient) String() string

type StreamReadMessage_FromClient_CommitOffsetRequest 

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

type StreamReadMessage_FromClient_InitRequest 

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 

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 

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

type StreamReadMessage_FromClient_StartPartitionSessionResponse 

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 

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 

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

type StreamReadMessage_FromServer 

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
}

Server-client message for read session. Contains one of: 

InitResponse - handshake response from server.
ReadResponse - portion of data.
CommitOffsetResponse - acknowledgment for commit.
PartitionSessionStatusResponse - server response with partition session status.
UpdateTokenResponse - acknowledgment of token update.

StartPartitionSessionRequest - command from server to create a partition session.
StopPartitionSessionRequest - command from server to destroy a partition session.

func (*StreamReadMessage_FromServer) Descriptor deprecated 

func (*StreamReadMessage_FromServer) Descriptor() ([]byte, []int)

Deprecated: Use StreamReadMessage_FromServer.ProtoReflect.Descriptor instead.

func (*StreamReadMessage_FromServer) GetCommitOffsetResponse 

func (x *StreamReadMessage_FromServer) GetCommitOffsetResponse() *StreamReadMessage_CommitOffsetResponse

func (*StreamReadMessage_FromServer) GetInitResponse 

func (x *StreamReadMessage_FromServer) GetInitResponse() *StreamReadMessage_InitResponse

func (*StreamReadMessage_FromServer) GetIssues 

func (x *StreamReadMessage_FromServer) GetIssues() []*Ydb_Issue.IssueMessage

func (*StreamReadMessage_FromServer) GetPartitionSessionStatusResponse 

func (x *StreamReadMessage_FromServer) GetPartitionSessionStatusResponse() *StreamReadMessage_PartitionSessionStatusResponse

func (*StreamReadMessage_FromServer) GetReadResponse 

func (x *StreamReadMessage_FromServer) GetReadResponse() *StreamReadMessage_ReadResponse

func (*StreamReadMessage_FromServer) GetServerMessage 

func (m *StreamReadMessage_FromServer) GetServerMessage() isStreamReadMessage_FromServer_ServerMessage

func (*StreamReadMessage_FromServer) GetStartPartitionSessionRequest 

func (x *StreamReadMessage_FromServer) GetStartPartitionSessionRequest() *StreamReadMessage_StartPartitionSessionRequest

func (*StreamReadMessage_FromServer) GetStatus 

func (x *StreamReadMessage_FromServer) GetStatus() Ydb.StatusIds_StatusCode

func (*StreamReadMessage_FromServer) GetStopPartitionSessionRequest 

func (x *StreamReadMessage_FromServer) GetStopPartitionSessionRequest() *StreamReadMessage_StopPartitionSessionRequest

func (*StreamReadMessage_FromServer) GetUpdateTokenResponse 

func (x *StreamReadMessage_FromServer) GetUpdateTokenResponse() *UpdateTokenResponse

func (*StreamReadMessage_FromServer) ProtoMessage 

func (*StreamReadMessage_FromServer) ProtoMessage()

func (*StreamReadMessage_FromServer) ProtoReflect 

func (x *StreamReadMessage_FromServer) ProtoReflect() protoreflect.Message

func (*StreamReadMessage_FromServer) Reset 

func (x *StreamReadMessage_FromServer) Reset()

func (*StreamReadMessage_FromServer) String 

func (x *StreamReadMessage_FromServer) String() string

type StreamReadMessage_FromServer_CommitOffsetResponse 

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

type StreamReadMessage_FromServer_InitResponse 

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 

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 

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

type StreamReadMessage_FromServer_StartPartitionSessionRequest 

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 

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 

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

type StreamReadMessage_InitRequest 

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
}

Handshake request.

func (*StreamReadMessage_InitRequest) Descriptor deprecated 

func (*StreamReadMessage_InitRequest) Descriptor() ([]byte, []int)

Deprecated: Use StreamReadMessage_InitRequest.ProtoReflect.Descriptor instead.

func (*StreamReadMessage_InitRequest) GetConsumer 

func (x *StreamReadMessage_InitRequest) GetConsumer() string

func (*StreamReadMessage_InitRequest) GetReaderName 

func (x *StreamReadMessage_InitRequest) GetReaderName() string

func (*StreamReadMessage_InitRequest) GetTopicsReadSettings 

func (x *StreamReadMessage_InitRequest) GetTopicsReadSettings() []*StreamReadMessage_InitRequest_TopicReadSettings

func (*StreamReadMessage_InitRequest) ProtoMessage 

func (*StreamReadMessage_InitRequest) ProtoMessage()

func (*StreamReadMessage_InitRequest) ProtoReflect 

func (x *StreamReadMessage_InitRequest) ProtoReflect() protoreflect.Message

func (*StreamReadMessage_InitRequest) Reset 

func (x *StreamReadMessage_InitRequest) Reset()

func (*StreamReadMessage_InitRequest) String 

func (x *StreamReadMessage_InitRequest) String() string

type StreamReadMessage_InitRequest_TopicReadSettings 

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
}

func (*StreamReadMessage_InitRequest_TopicReadSettings) Descriptor deprecated 

func (*StreamReadMessage_InitRequest_TopicReadSettings) Descriptor() ([]byte, []int)

Deprecated: Use StreamReadMessage_InitRequest_TopicReadSettings.ProtoReflect.Descriptor instead.

func (*StreamReadMessage_InitRequest_TopicReadSettings) GetMaxLag 

func (x *StreamReadMessage_InitRequest_TopicReadSettings) GetMaxLag() *durationpb.Duration

func (*StreamReadMessage_InitRequest_TopicReadSettings) GetPartitionIds 

func (x *StreamReadMessage_InitRequest_TopicReadSettings) GetPartitionIds() []int64

func (*StreamReadMessage_InitRequest_TopicReadSettings) GetPath 

func (x *StreamReadMessage_InitRequest_TopicReadSettings) GetPath() string

func (*StreamReadMessage_InitRequest_TopicReadSettings) GetReadFrom 

func (x *StreamReadMessage_InitRequest_TopicReadSettings) GetReadFrom() *timestamppb.Timestamp

func (*StreamReadMessage_InitRequest_TopicReadSettings) ProtoMessage 

func (*StreamReadMessage_InitRequest_TopicReadSettings) ProtoMessage()

func (*StreamReadMessage_InitRequest_TopicReadSettings) ProtoReflect 

func (x *StreamReadMessage_InitRequest_TopicReadSettings) ProtoReflect() protoreflect.Message

func (*StreamReadMessage_InitRequest_TopicReadSettings) Reset 

func (x *StreamReadMessage_InitRequest_TopicReadSettings) Reset()

func (*StreamReadMessage_InitRequest_TopicReadSettings) String 

func (x *StreamReadMessage_InitRequest_TopicReadSettings) String() string

type StreamReadMessage_InitResponse 

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
}

Handshake response.

func (*StreamReadMessage_InitResponse) Descriptor deprecated 

func (*StreamReadMessage_InitResponse) Descriptor() ([]byte, []int)

Deprecated: Use StreamReadMessage_InitResponse.ProtoReflect.Descriptor instead.

func (*StreamReadMessage_InitResponse) GetSessionId 

func (x *StreamReadMessage_InitResponse) GetSessionId() string

func (*StreamReadMessage_InitResponse) ProtoMessage 

func (*StreamReadMessage_InitResponse) ProtoMessage()

func (*StreamReadMessage_InitResponse) ProtoReflect 

func (x *StreamReadMessage_InitResponse) ProtoReflect() protoreflect.Message

func (*StreamReadMessage_InitResponse) Reset 

func (x *StreamReadMessage_InitResponse) Reset()

func (*StreamReadMessage_InitResponse) String 

func (x *StreamReadMessage_InitResponse) String() string

type StreamReadMessage_PartitionSession 

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
}

Within a StreamRead session delivered messages are separated by partition. Reads from a single partition are represented by a partition session.

func (*StreamReadMessage_PartitionSession) Descriptor deprecated 

func (*StreamReadMessage_PartitionSession) Descriptor() ([]byte, []int)

Deprecated: Use StreamReadMessage_PartitionSession.ProtoReflect.Descriptor instead.

func (*StreamReadMessage_PartitionSession) GetPartitionId 

func (x *StreamReadMessage_PartitionSession) GetPartitionId() int64

func (*StreamReadMessage_PartitionSession) GetPartitionSessionId 

func (x *StreamReadMessage_PartitionSession) GetPartitionSessionId() int64

func (*StreamReadMessage_PartitionSession) GetPath 

func (x *StreamReadMessage_PartitionSession) GetPath() string

func (*StreamReadMessage_PartitionSession) ProtoMessage 

func (*StreamReadMessage_PartitionSession) ProtoMessage()

func (*StreamReadMessage_PartitionSession) ProtoReflect 

func (x *StreamReadMessage_PartitionSession) ProtoReflect() protoreflect.Message

func (*StreamReadMessage_PartitionSession) Reset 

func (x *StreamReadMessage_PartitionSession) Reset()

func (*StreamReadMessage_PartitionSession) String 

func (x *StreamReadMessage_PartitionSession) String() string

type StreamReadMessage_PartitionSessionStatusRequest 

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
}

func (*StreamReadMessage_PartitionSessionStatusRequest) Descriptor deprecated 

func (*StreamReadMessage_PartitionSessionStatusRequest) Descriptor() ([]byte, []int)

Deprecated: Use StreamReadMessage_PartitionSessionStatusRequest.ProtoReflect.Descriptor instead.

func (*StreamReadMessage_PartitionSessionStatusRequest) GetPartitionSessionId 

func (x *StreamReadMessage_PartitionSessionStatusRequest) GetPartitionSessionId() int64

func (*StreamReadMessage_PartitionSessionStatusRequest) ProtoMessage 

func (*StreamReadMessage_PartitionSessionStatusRequest) ProtoMessage()

func (*StreamReadMessage_PartitionSessionStatusRequest) ProtoReflect 

func (x *StreamReadMessage_PartitionSessionStatusRequest) ProtoReflect() protoreflect.Message

func (*StreamReadMessage_PartitionSessionStatusRequest) Reset 

func (x *StreamReadMessage_PartitionSessionStatusRequest) Reset()

func (*StreamReadMessage_PartitionSessionStatusRequest) String 

func (x *StreamReadMessage_PartitionSessionStatusRequest) String() string

type StreamReadMessage_PartitionSessionStatusResponse 

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
}

Response for status request.

func (*StreamReadMessage_PartitionSessionStatusResponse) Descriptor deprecated 

func (*StreamReadMessage_PartitionSessionStatusResponse) Descriptor() ([]byte, []int)

Deprecated: Use StreamReadMessage_PartitionSessionStatusResponse.ProtoReflect.Descriptor instead.

func (*StreamReadMessage_PartitionSessionStatusResponse) GetCommittedOffset 

func (x *StreamReadMessage_PartitionSessionStatusResponse) GetCommittedOffset() int64

func (*StreamReadMessage_PartitionSessionStatusResponse) GetPartitionOffsets 

func (x *StreamReadMessage_PartitionSessionStatusResponse) GetPartitionOffsets() *OffsetsRange

func (*StreamReadMessage_PartitionSessionStatusResponse) GetPartitionSessionId 

func (x *StreamReadMessage_PartitionSessionStatusResponse) GetPartitionSessionId() int64

func (*StreamReadMessage_PartitionSessionStatusResponse) GetWriteTimeHighWatermark 

func (x *StreamReadMessage_PartitionSessionStatusResponse) GetWriteTimeHighWatermark() *timestamppb.Timestamp

func (*StreamReadMessage_PartitionSessionStatusResponse) ProtoMessage 

func (*StreamReadMessage_PartitionSessionStatusResponse) ProtoMessage()

func (*StreamReadMessage_PartitionSessionStatusResponse) ProtoReflect 

func (x *StreamReadMessage_PartitionSessionStatusResponse) ProtoReflect() protoreflect.Message

func (*StreamReadMessage_PartitionSessionStatusResponse) Reset 

func (x *StreamReadMessage_PartitionSessionStatusResponse) Reset()

func (*StreamReadMessage_PartitionSessionStatusResponse) String 

func (x *StreamReadMessage_PartitionSessionStatusResponse) String() string

type StreamReadMessage_ReadRequest 

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
}

Message that represents client readiness for receiving more data.

func (*StreamReadMessage_ReadRequest) Descriptor deprecated 

func (*StreamReadMessage_ReadRequest) Descriptor() ([]byte, []int)

Deprecated: Use StreamReadMessage_ReadRequest.ProtoReflect.Descriptor instead.

func (*StreamReadMessage_ReadRequest) GetBytesSize 

func (x *StreamReadMessage_ReadRequest) GetBytesSize() int64

func (*StreamReadMessage_ReadRequest) ProtoMessage 

func (*StreamReadMessage_ReadRequest) ProtoMessage()

func (*StreamReadMessage_ReadRequest) ProtoReflect 

func (x *StreamReadMessage_ReadRequest) ProtoReflect() protoreflect.Message

func (*StreamReadMessage_ReadRequest) Reset 

func (x *StreamReadMessage_ReadRequest) Reset()

func (*StreamReadMessage_ReadRequest) String 

func (x *StreamReadMessage_ReadRequest) String() string

type StreamReadMessage_ReadResponse 

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
}

Data read.

func (*StreamReadMessage_ReadResponse) Descriptor deprecated 

func (*StreamReadMessage_ReadResponse) Descriptor() ([]byte, []int)

Deprecated: Use StreamReadMessage_ReadResponse.ProtoReflect.Descriptor instead.

func (*StreamReadMessage_ReadResponse) GetBytesSize 

func (x *StreamReadMessage_ReadResponse) GetBytesSize() int64

func (*StreamReadMessage_ReadResponse) GetPartitionData 

func (x *StreamReadMessage_ReadResponse) GetPartitionData() []*StreamReadMessage_ReadResponse_PartitionData

func (*StreamReadMessage_ReadResponse) ProtoMessage 

func (*StreamReadMessage_ReadResponse) ProtoMessage()

func (*StreamReadMessage_ReadResponse) ProtoReflect 

func (x *StreamReadMessage_ReadResponse) ProtoReflect() protoreflect.Message

func (*StreamReadMessage_ReadResponse) Reset 

func (x *StreamReadMessage_ReadResponse) Reset()

func (*StreamReadMessage_ReadResponse) String 

func (x *StreamReadMessage_ReadResponse) String() string

type StreamReadMessage_ReadResponse_Batch 

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
}

Representation of sequence of client messages from one write session.

func (*StreamReadMessage_ReadResponse_Batch) Descriptor deprecated 

func (*StreamReadMessage_ReadResponse_Batch) Descriptor() ([]byte, []int)

Deprecated: Use StreamReadMessage_ReadResponse_Batch.ProtoReflect.Descriptor instead.

func (*StreamReadMessage_ReadResponse_Batch) GetCodec 

func (x *StreamReadMessage_ReadResponse_Batch) GetCodec() int32

func (*StreamReadMessage_ReadResponse_Batch) GetMessageData 

func (x *StreamReadMessage_ReadResponse_Batch) GetMessageData() []*StreamReadMessage_ReadResponse_MessageData

func (*StreamReadMessage_ReadResponse_Batch) GetProducerId 

func (x *StreamReadMessage_ReadResponse_Batch) GetProducerId() string

func (*StreamReadMessage_ReadResponse_Batch) GetWriteSessionMeta 

func (x *StreamReadMessage_ReadResponse_Batch) GetWriteSessionMeta() map[string]string

func (*StreamReadMessage_ReadResponse_Batch) GetWrittenAt 

func (x *StreamReadMessage_ReadResponse_Batch) GetWrittenAt() *timestamppb.Timestamp

func (*StreamReadMessage_ReadResponse_Batch) ProtoMessage 

func (*StreamReadMessage_ReadResponse_Batch) ProtoMessage()

func (*StreamReadMessage_ReadResponse_Batch) ProtoReflect 

func (x *StreamReadMessage_ReadResponse_Batch) ProtoReflect() protoreflect.Message

func (*StreamReadMessage_ReadResponse_Batch) Reset 

func (x *StreamReadMessage_ReadResponse_Batch) Reset()

func (*StreamReadMessage_ReadResponse_Batch) String 

func (x *StreamReadMessage_ReadResponse_Batch) String() string

type StreamReadMessage_ReadResponse_MessageData 

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
}

One client message representation.

func (*StreamReadMessage_ReadResponse_MessageData) Descriptor deprecated 

func (*StreamReadMessage_ReadResponse_MessageData) Descriptor() ([]byte, []int)

Deprecated: Use StreamReadMessage_ReadResponse_MessageData.ProtoReflect.Descriptor instead.

func (*StreamReadMessage_ReadResponse_MessageData) GetCreatedAt 

func (x *StreamReadMessage_ReadResponse_MessageData) GetCreatedAt() *timestamppb.Timestamp

func (*StreamReadMessage_ReadResponse_MessageData) GetData 

func (x *StreamReadMessage_ReadResponse_MessageData) GetData() []byte

func (*StreamReadMessage_ReadResponse_MessageData) GetMessageGroupId 

func (x *StreamReadMessage_ReadResponse_MessageData) GetMessageGroupId() string

func (*StreamReadMessage_ReadResponse_MessageData) GetMetadataItems 

func (x *StreamReadMessage_ReadResponse_MessageData) GetMetadataItems() []*MetadataItem

func (*StreamReadMessage_ReadResponse_MessageData) GetOffset 

func (x *StreamReadMessage_ReadResponse_MessageData) GetOffset() int64

func (*StreamReadMessage_ReadResponse_MessageData) GetSeqNo 

func (x *StreamReadMessage_ReadResponse_MessageData) GetSeqNo() int64

func (*StreamReadMessage_ReadResponse_MessageData) GetUncompressedSize 

func (x *StreamReadMessage_ReadResponse_MessageData) GetUncompressedSize() int64

func (*StreamReadMessage_ReadResponse_MessageData) ProtoMessage 

func (*StreamReadMessage_ReadResponse_MessageData) ProtoMessage()

func (*StreamReadMessage_ReadResponse_MessageData) ProtoReflect 

func (x *StreamReadMessage_ReadResponse_MessageData) ProtoReflect() protoreflect.Message

func (*StreamReadMessage_ReadResponse_MessageData) Reset 

func (x *StreamReadMessage_ReadResponse_MessageData) Reset()

func (*StreamReadMessage_ReadResponse_MessageData) String 

func (x *StreamReadMessage_ReadResponse_MessageData) String() string

type StreamReadMessage_ReadResponse_PartitionData 

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
}

Representation of sequence of messages from one partition.

func (*StreamReadMessage_ReadResponse_PartitionData) Descriptor deprecated 

func (*StreamReadMessage_ReadResponse_PartitionData) Descriptor() ([]byte, []int)

Deprecated: Use StreamReadMessage_ReadResponse_PartitionData.ProtoReflect.Descriptor instead.

func (*StreamReadMessage_ReadResponse_PartitionData) GetBatches 

func (x *StreamReadMessage_ReadResponse_PartitionData) GetBatches() []*StreamReadMessage_ReadResponse_Batch

func (*StreamReadMessage_ReadResponse_PartitionData) GetPartitionSessionId 

func (x *StreamReadMessage_ReadResponse_PartitionData) GetPartitionSessionId() int64

func (*StreamReadMessage_ReadResponse_PartitionData) ProtoMessage 

func (*StreamReadMessage_ReadResponse_PartitionData) ProtoMessage()

func (*StreamReadMessage_ReadResponse_PartitionData) ProtoReflect 

func (x *StreamReadMessage_ReadResponse_PartitionData) ProtoReflect() protoreflect.Message

func (*StreamReadMessage_ReadResponse_PartitionData) Reset 

func (x *StreamReadMessage_ReadResponse_PartitionData) Reset()

func (*StreamReadMessage_ReadResponse_PartitionData) String 

func (x *StreamReadMessage_ReadResponse_PartitionData) String() string

type StreamReadMessage_StartPartitionSessionRequest 

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
}

Command from server to create and start a partition session. Client must respond with StartPartitionSessionResponse when ready to receive data from this partition.

func (*StreamReadMessage_StartPartitionSessionRequest) Descriptor deprecated 

func (*StreamReadMessage_StartPartitionSessionRequest) Descriptor() ([]byte, []int)

Deprecated: Use StreamReadMessage_StartPartitionSessionRequest.ProtoReflect.Descriptor instead.

func (*StreamReadMessage_StartPartitionSessionRequest) GetCommittedOffset 

func (x *StreamReadMessage_StartPartitionSessionRequest) GetCommittedOffset() int64

func (*StreamReadMessage_StartPartitionSessionRequest) GetPartitionOffsets 

func (x *StreamReadMessage_StartPartitionSessionRequest) GetPartitionOffsets() *OffsetsRange

func (*StreamReadMessage_StartPartitionSessionRequest) GetPartitionSession 

func (x *StreamReadMessage_StartPartitionSessionRequest) GetPartitionSession() *StreamReadMessage_PartitionSession

func (*StreamReadMessage_StartPartitionSessionRequest) ProtoMessage 

func (*StreamReadMessage_StartPartitionSessionRequest) ProtoMessage()

func (*StreamReadMessage_StartPartitionSessionRequest) ProtoReflect 

func (x *StreamReadMessage_StartPartitionSessionRequest) ProtoReflect() protoreflect.Message

func (*StreamReadMessage_StartPartitionSessionRequest) Reset 

func (x *StreamReadMessage_StartPartitionSessionRequest) Reset()

func (*StreamReadMessage_StartPartitionSessionRequest) String 

func (x *StreamReadMessage_StartPartitionSessionRequest) String() string

type StreamReadMessage_StartPartitionSessionResponse 

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
}

Signal for server that cient is ready to recive data for partition.

func (*StreamReadMessage_StartPartitionSessionResponse) Descriptor deprecated 

func (*StreamReadMessage_StartPartitionSessionResponse) Descriptor() ([]byte, []int)

Deprecated: Use StreamReadMessage_StartPartitionSessionResponse.ProtoReflect.Descriptor instead.

func (*StreamReadMessage_StartPartitionSessionResponse) GetCommitOffset 

func (x *StreamReadMessage_StartPartitionSessionResponse) GetCommitOffset() int64

func (*StreamReadMessage_StartPartitionSessionResponse) GetPartitionSessionId 

func (x *StreamReadMessage_StartPartitionSessionResponse) GetPartitionSessionId() int64

func (*StreamReadMessage_StartPartitionSessionResponse) GetReadOffset 

func (x *StreamReadMessage_StartPartitionSessionResponse) GetReadOffset() int64

func (*StreamReadMessage_StartPartitionSessionResponse) ProtoMessage 

func (*StreamReadMessage_StartPartitionSessionResponse) ProtoMessage()

func (*StreamReadMessage_StartPartitionSessionResponse) ProtoReflect 

func (x *StreamReadMessage_StartPartitionSessionResponse) ProtoReflect() protoreflect.Message

func (*StreamReadMessage_StartPartitionSessionResponse) Reset 

func (x *StreamReadMessage_StartPartitionSessionResponse) Reset()

func (*StreamReadMessage_StartPartitionSessionResponse) String 

func (x *StreamReadMessage_StartPartitionSessionResponse) String() string

type StreamReadMessage_StopPartitionSessionRequest 

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
}

Command from server to stop and destroy concrete partition session.

func (*StreamReadMessage_StopPartitionSessionRequest) Descriptor deprecated 

func (*StreamReadMessage_StopPartitionSessionRequest) Descriptor() ([]byte, []int)

Deprecated: Use StreamReadMessage_StopPartitionSessionRequest.ProtoReflect.Descriptor instead.

func (*StreamReadMessage_StopPartitionSessionRequest) GetCommittedOffset 

func (x *StreamReadMessage_StopPartitionSessionRequest) GetCommittedOffset() int64

func (*StreamReadMessage_StopPartitionSessionRequest) GetGraceful 

func (x *StreamReadMessage_StopPartitionSessionRequest) GetGraceful() bool

func (*StreamReadMessage_StopPartitionSessionRequest) GetPartitionSessionId 

func (x *StreamReadMessage_StopPartitionSessionRequest) GetPartitionSessionId() int64

func (*StreamReadMessage_StopPartitionSessionRequest) ProtoMessage 

func (*StreamReadMessage_StopPartitionSessionRequest) ProtoMessage()

func (*StreamReadMessage_StopPartitionSessionRequest) ProtoReflect 

func (x *StreamReadMessage_StopPartitionSessionRequest) ProtoReflect() protoreflect.Message

func (*StreamReadMessage_StopPartitionSessionRequest) Reset 

func (x *StreamReadMessage_StopPartitionSessionRequest) Reset()

func (*StreamReadMessage_StopPartitionSessionRequest) String 

func (x *StreamReadMessage_StopPartitionSessionRequest) String() string

type StreamReadMessage_StopPartitionSessionResponse 

type StreamReadMessage_StopPartitionSessionResponse struct {

	// Partition session identifier of partition session that is released by client.
	PartitionSessionId int64 `protobuf:"varint,1,opt,name=partition_session_id,json=partitionSessionId,proto3" json:"partition_session_id,omitempty"`
	// contains filtered or unexported fields
}

Signal for server that client finished working with this partition. Must be sent only after corresponding StopPartitionSessionRequest from server. Server will give this partition to other read session only after StopPartitionSessionResponse signal.

func (*StreamReadMessage_StopPartitionSessionResponse) Descriptor deprecated 

func (*StreamReadMessage_StopPartitionSessionResponse) Descriptor() ([]byte, []int)

Deprecated: Use StreamReadMessage_StopPartitionSessionResponse.ProtoReflect.Descriptor instead.

func (*StreamReadMessage_StopPartitionSessionResponse) GetPartitionSessionId 

func (x *StreamReadMessage_StopPartitionSessionResponse) GetPartitionSessionId() int64

func (*StreamReadMessage_StopPartitionSessionResponse) ProtoMessage 

func (*StreamReadMessage_StopPartitionSessionResponse) ProtoMessage()

func (*StreamReadMessage_StopPartitionSessionResponse) ProtoReflect 

func (x *StreamReadMessage_StopPartitionSessionResponse) ProtoReflect() protoreflect.Message

func (*StreamReadMessage_StopPartitionSessionResponse) Reset 

func (x *StreamReadMessage_StopPartitionSessionResponse) Reset()

func (*StreamReadMessage_StopPartitionSessionResponse) String 

func (x *StreamReadMessage_StopPartitionSessionResponse) String() string

type StreamWriteMessage 

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

Messages for bidirectional streaming rpc StreamWrite

func (*StreamWriteMessage) Descriptor deprecated 

func (*StreamWriteMessage) Descriptor() ([]byte, []int)

Deprecated: Use StreamWriteMessage.ProtoReflect.Descriptor instead.

func (*StreamWriteMessage) ProtoMessage 

func (*StreamWriteMessage) ProtoMessage()

func (*StreamWriteMessage) ProtoReflect 

func (x *StreamWriteMessage) ProtoReflect() protoreflect.Message

func (*StreamWriteMessage) Reset 

func (x *StreamWriteMessage) Reset()

func (*StreamWriteMessage) String 

func (x *StreamWriteMessage) String() string

type StreamWriteMessage_FromClient 

type StreamWriteMessage_FromClient struct {

	// Types that are assignable to ClientMessage:
	//
	//	*StreamWriteMessage_FromClient_InitRequest
	//	*StreamWriteMessage_FromClient_WriteRequest
	//	*StreamWriteMessage_FromClient_UpdateTokenRequest
	ClientMessage isStreamWriteMessage_FromClient_ClientMessage `protobuf_oneof:"client_message"`
	// contains filtered or unexported fields
}

Client-server message for write session. Contains one of: 

InitRequest - handshake request.
WriteRequest - portion of data to be written.
UpdateTokenRequest - user credentials if update is needed.

func (*StreamWriteMessage_FromClient) Descriptor deprecated 

func (*StreamWriteMessage_FromClient) Descriptor() ([]byte, []int)

Deprecated: Use StreamWriteMessage_FromClient.ProtoReflect.Descriptor instead.

func (*StreamWriteMessage_FromClient) GetClientMessage 

func (m *StreamWriteMessage_FromClient) GetClientMessage() isStreamWriteMessage_FromClient_ClientMessage

func (*StreamWriteMessage_FromClient) GetInitRequest 

func (x *StreamWriteMessage_FromClient) GetInitRequest() *StreamWriteMessage_InitRequest

func (*StreamWriteMessage_FromClient) GetUpdateTokenRequest 

func (x *StreamWriteMessage_FromClient) GetUpdateTokenRequest() *UpdateTokenRequest

func (*StreamWriteMessage_FromClient) GetWriteRequest 

func (x *StreamWriteMessage_FromClient) GetWriteRequest() *StreamWriteMessage_WriteRequest

func (*StreamWriteMessage_FromClient) ProtoMessage 

func (*StreamWriteMessage_FromClient) ProtoMessage()

func (*StreamWriteMessage_FromClient) ProtoReflect 

func (x *StreamWriteMessage_FromClient) ProtoReflect() protoreflect.Message

func (*StreamWriteMessage_FromClient) Reset 

func (x *StreamWriteMessage_FromClient) Reset()

func (*StreamWriteMessage_FromClient) String 

func (x *StreamWriteMessage_FromClient) String() string

type StreamWriteMessage_FromClient_InitRequest 

type StreamWriteMessage_FromClient_InitRequest struct {
	InitRequest *StreamWriteMessage_InitRequest `protobuf:"bytes,1,opt,name=init_request,json=initRequest,proto3,oneof"`
}

type StreamWriteMessage_FromClient_UpdateTokenRequest 

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

type StreamWriteMessage_FromClient_WriteRequest 

type StreamWriteMessage_FromClient_WriteRequest struct {
	WriteRequest *StreamWriteMessage_WriteRequest `protobuf:"bytes,2,opt,name=write_request,json=writeRequest,proto3,oneof"`
}

type StreamWriteMessage_FromServer 

type StreamWriteMessage_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:
	//
	//	*StreamWriteMessage_FromServer_InitResponse
	//	*StreamWriteMessage_FromServer_WriteResponse
	//	*StreamWriteMessage_FromServer_UpdateTokenResponse
	ServerMessage isStreamWriteMessage_FromServer_ServerMessage `protobuf_oneof:"server_message"`
	// contains filtered or unexported fields
}

Server-client message for write session. Contains either non-success status, or one of: 

InitResponse - correct handshake response.
WriteResponse - acknowledgment of storing client messages.
UpdateTokenResponse - acknowledgment of reauthentication and reauthorization.

func (*StreamWriteMessage_FromServer) Descriptor deprecated 

func (*StreamWriteMessage_FromServer) Descriptor() ([]byte, []int)

Deprecated: Use StreamWriteMessage_FromServer.ProtoReflect.Descriptor instead.

func (*StreamWriteMessage_FromServer) GetInitResponse 

func (x *StreamWriteMessage_FromServer) GetInitResponse() *StreamWriteMessage_InitResponse

func (*StreamWriteMessage_FromServer) GetIssues 

func (x *StreamWriteMessage_FromServer) GetIssues() []*Ydb_Issue.IssueMessage

func (*StreamWriteMessage_FromServer) GetServerMessage 

func (m *StreamWriteMessage_FromServer) GetServerMessage() isStreamWriteMessage_FromServer_ServerMessage

func (*StreamWriteMessage_FromServer) GetStatus 

func (x *StreamWriteMessage_FromServer) GetStatus() Ydb.StatusIds_StatusCode

func (*StreamWriteMessage_FromServer) GetUpdateTokenResponse 

func (x *StreamWriteMessage_FromServer) GetUpdateTokenResponse() *UpdateTokenResponse

func (*StreamWriteMessage_FromServer) GetWriteResponse 

func (x *StreamWriteMessage_FromServer) GetWriteResponse() *StreamWriteMessage_WriteResponse

func (*StreamWriteMessage_FromServer) ProtoMessage 

func (*StreamWriteMessage_FromServer) ProtoMessage()

func (*StreamWriteMessage_FromServer) ProtoReflect 

func (x *StreamWriteMessage_FromServer) ProtoReflect() protoreflect.Message

func (*StreamWriteMessage_FromServer) Reset 

func (x *StreamWriteMessage_FromServer) Reset()

func (*StreamWriteMessage_FromServer) String 

func (x *StreamWriteMessage_FromServer) String() string

type StreamWriteMessage_FromServer_InitResponse 

type StreamWriteMessage_FromServer_InitResponse struct {
	InitResponse *StreamWriteMessage_InitResponse `protobuf:"bytes,3,opt,name=init_response,json=initResponse,proto3,oneof"`
}

type StreamWriteMessage_FromServer_UpdateTokenResponse 

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

type StreamWriteMessage_FromServer_WriteResponse 

type StreamWriteMessage_FromServer_WriteResponse struct {
	WriteResponse *StreamWriteMessage_WriteResponse `protobuf:"bytes,4,opt,name=write_response,json=writeResponse,proto3,oneof"`
}

type StreamWriteMessage_InitRequest 

type StreamWriteMessage_InitRequest struct {

	// Full path of topic to write to.
	Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	// Producer identifier of client data stream.
	// Used for message deduplication by sequence numbers.
	ProducerId string `protobuf:"bytes,2,opt,name=producer_id,json=producerId,proto3" json:"producer_id,omitempty"`
	// User metadata attached to this write session.
	// Reader will get this session meta data with each message read.
	WriteSessionMeta map[string]string `` /* 199-byte string literal not displayed */
	// Option for setting order on messages.
	// If neither is set, no guarantees on ordering or partitions to write to.
	//
	// Types that are assignable to Partitioning:
	//
	//	*StreamWriteMessage_InitRequest_MessageGroupId
	//	*StreamWriteMessage_InitRequest_PartitionId
	Partitioning isStreamWriteMessage_InitRequest_Partitioning `protobuf_oneof:"partitioning"`
	// Explicitly request for last sequential number
	// It may be expensive, if producer wrote to many partitions before.
	GetLastSeqNo bool `protobuf:"varint,6,opt,name=get_last_seq_no,json=getLastSeqNo,proto3" json:"get_last_seq_no,omitempty"`
	// contains filtered or unexported fields
}

Handshake request that must be sent to server first.

func (*StreamWriteMessage_InitRequest) Descriptor deprecated 

func (*StreamWriteMessage_InitRequest) Descriptor() ([]byte, []int)

Deprecated: Use StreamWriteMessage_InitRequest.ProtoReflect.Descriptor instead.

func (*StreamWriteMessage_InitRequest) GetGetLastSeqNo 

func (x *StreamWriteMessage_InitRequest) GetGetLastSeqNo() bool

func (*StreamWriteMessage_InitRequest) GetMessageGroupId 

func (x *StreamWriteMessage_InitRequest) GetMessageGroupId() string

func (*StreamWriteMessage_InitRequest) GetPartitionId 

func (x *StreamWriteMessage_InitRequest) GetPartitionId() int64

func (*StreamWriteMessage_InitRequest) GetPartitioning 

func (m *StreamWriteMessage_InitRequest) GetPartitioning() isStreamWriteMessage_InitRequest_Partitioning

func (*StreamWriteMessage_InitRequest) GetPath 

func (x *StreamWriteMessage_InitRequest) GetPath() string

func (*StreamWriteMessage_InitRequest) GetProducerId 

func (x *StreamWriteMessage_InitRequest) GetProducerId() string

func (*StreamWriteMessage_InitRequest) GetWriteSessionMeta 

func (x *StreamWriteMessage_InitRequest) GetWriteSessionMeta() map[string]string

func (*StreamWriteMessage_InitRequest) ProtoMessage 

func (*StreamWriteMessage_InitRequest) ProtoMessage()

func (*StreamWriteMessage_InitRequest) ProtoReflect 

func (x *StreamWriteMessage_InitRequest) ProtoReflect() protoreflect.Message

func (*StreamWriteMessage_InitRequest) Reset 

func (x *StreamWriteMessage_InitRequest) Reset()

func (*StreamWriteMessage_InitRequest) String 

func (x *StreamWriteMessage_InitRequest) String() string

type StreamWriteMessage_InitRequest_MessageGroupId 

type StreamWriteMessage_InitRequest_MessageGroupId struct {
	// All messages with given pair (producer_id, message_group_id) go to single partition in order of writes.
	MessageGroupId string `protobuf:"bytes,4,opt,name=message_group_id,json=messageGroupId,proto3,oneof"`
}

type StreamWriteMessage_InitRequest_PartitionId 

type StreamWriteMessage_InitRequest_PartitionId struct {
	// Explicit partition id to write to.
	PartitionId int64 `protobuf:"varint,5,opt,name=partition_id,json=partitionId,proto3,oneof"`
}

type StreamWriteMessage_InitResponse 

type StreamWriteMessage_InitResponse struct {

	// Last persisted message's sequence number for this producer.
	// Zero for new producer.
	LastSeqNo int64 `protobuf:"varint,1,opt,name=last_seq_no,json=lastSeqNo,proto3" json:"last_seq_no,omitempty"`
	// Unique identifier of write session. Used for debug purposes.
	SessionId string `protobuf:"bytes,2,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	// Identifier of partition that is matched for this write session.
	PartitionId int64 `protobuf:"varint,3,opt,name=partition_id,json=partitionId,proto3" json:"partition_id,omitempty"`
	// Client can only use compression codecs from this set to write messages to topic.
	// Otherwise session will be closed with BAD_REQUEST.
	SupportedCodecs *SupportedCodecs `protobuf:"bytes,4,opt,name=supported_codecs,json=supportedCodecs,proto3" json:"supported_codecs,omitempty"`
	// contains filtered or unexported fields
}

Response for handshake.

func (*StreamWriteMessage_InitResponse) Descriptor deprecated 

func (*StreamWriteMessage_InitResponse) Descriptor() ([]byte, []int)

Deprecated: Use StreamWriteMessage_InitResponse.ProtoReflect.Descriptor instead.

func (*StreamWriteMessage_InitResponse) GetLastSeqNo 

func (x *StreamWriteMessage_InitResponse) GetLastSeqNo() int64

func (*StreamWriteMessage_InitResponse) GetPartitionId 

func (x *StreamWriteMessage_InitResponse) GetPartitionId() int64

func (*StreamWriteMessage_InitResponse) GetSessionId 

func (x *StreamWriteMessage_InitResponse) GetSessionId() string

func (*StreamWriteMessage_InitResponse) GetSupportedCodecs 

func (x *StreamWriteMessage_InitResponse) GetSupportedCodecs() *SupportedCodecs

func (*StreamWriteMessage_InitResponse) ProtoMessage 

func (*StreamWriteMessage_InitResponse) ProtoMessage()

func (*StreamWriteMessage_InitResponse) ProtoReflect 

func (x *StreamWriteMessage_InitResponse) ProtoReflect() protoreflect.Message

func (*StreamWriteMessage_InitResponse) Reset 

func (x *StreamWriteMessage_InitResponse) Reset()

func (*StreamWriteMessage_InitResponse) String 

func (x *StreamWriteMessage_InitResponse) String() string

type StreamWriteMessage_WriteRequest 

type StreamWriteMessage_WriteRequest struct {
	Messages []*StreamWriteMessage_WriteRequest_MessageData `protobuf:"bytes,1,rep,name=messages,proto3" json:"messages,omitempty"`
	// Codec that is used for data compression.
	// See enum Codec above for values.
	Codec int32                `protobuf:"varint,2,opt,name=codec,proto3" json:"codec,omitempty"`
	Tx    *TransactionIdentity `protobuf:"bytes,3,opt,name=tx,proto3,oneof" json:"tx,omitempty"`
	// contains filtered or unexported fields
}

Represents portion of client messages.

func (*StreamWriteMessage_WriteRequest) Descriptor deprecated 

func (*StreamWriteMessage_WriteRequest) Descriptor() ([]byte, []int)

Deprecated: Use StreamWriteMessage_WriteRequest.ProtoReflect.Descriptor instead.

func (*StreamWriteMessage_WriteRequest) GetCodec 

func (x *StreamWriteMessage_WriteRequest) GetCodec() int32

func (*StreamWriteMessage_WriteRequest) GetMessages 

func (x *StreamWriteMessage_WriteRequest) GetMessages() []*StreamWriteMessage_WriteRequest_MessageData

func (*StreamWriteMessage_WriteRequest) GetTx 

func (x *StreamWriteMessage_WriteRequest) GetTx() *TransactionIdentity

func (*StreamWriteMessage_WriteRequest) ProtoMessage 

func (*StreamWriteMessage_WriteRequest) ProtoMessage()

func (*StreamWriteMessage_WriteRequest) ProtoReflect 

func (x *StreamWriteMessage_WriteRequest) ProtoReflect() protoreflect.Message

func (*StreamWriteMessage_WriteRequest) Reset 

func (x *StreamWriteMessage_WriteRequest) Reset()

func (*StreamWriteMessage_WriteRequest) String 

func (x *StreamWriteMessage_WriteRequest) String() string

type StreamWriteMessage_WriteRequest_MessageData 

type StreamWriteMessage_WriteRequest_MessageData struct {

	// Message sequence number, provided by client for deduplication.
	// Starts at 1
	SeqNo int64 `protobuf:"varint,1,opt,name=seq_no,json=seqNo,proto3" json:"seq_no,omitempty"`
	// Creation timestamp
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// Compressed client message body.
	Data []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	// Uncompressed size of client message body.
	UncompressedSize int64 `protobuf:"varint,4,opt,name=uncompressed_size,json=uncompressedSize,proto3" json:"uncompressed_size,omitempty"`
	// Per-message override for respective write session settings.
	//
	// Types that are assignable to Partitioning:
	//
	//	*StreamWriteMessage_WriteRequest_MessageData_MessageGroupId
	//	*StreamWriteMessage_WriteRequest_MessageData_PartitionId
	Partitioning isStreamWriteMessage_WriteRequest_MessageData_Partitioning `protobuf_oneof:"partitioning"`
	// Message metadata. Overall size is limited to 4096 symbols (all keys and values combined).
	MetadataItems []*MetadataItem `protobuf:"bytes,7,rep,name=metadata_items,json=metadataItems,proto3" json:"metadata_items,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamWriteMessage_WriteRequest_MessageData) Descriptor deprecated 

func (*StreamWriteMessage_WriteRequest_MessageData) Descriptor() ([]byte, []int)

Deprecated: Use StreamWriteMessage_WriteRequest_MessageData.ProtoReflect.Descriptor instead.

func (*StreamWriteMessage_WriteRequest_MessageData) GetCreatedAt 

func (x *StreamWriteMessage_WriteRequest_MessageData) GetCreatedAt() *timestamppb.Timestamp

func (*StreamWriteMessage_WriteRequest_MessageData) GetData 

func (x *StreamWriteMessage_WriteRequest_MessageData) GetData() []byte

func (*StreamWriteMessage_WriteRequest_MessageData) GetMessageGroupId 

func (x *StreamWriteMessage_WriteRequest_MessageData) GetMessageGroupId() string

func (*StreamWriteMessage_WriteRequest_MessageData) GetMetadataItems 

func (x *StreamWriteMessage_WriteRequest_MessageData) GetMetadataItems() []*MetadataItem

func (*StreamWriteMessage_WriteRequest_MessageData) GetPartitionId 

func (x *StreamWriteMessage_WriteRequest_MessageData) GetPartitionId() int64

func (*StreamWriteMessage_WriteRequest_MessageData) GetPartitioning 

func (m *StreamWriteMessage_WriteRequest_MessageData) GetPartitioning() isStreamWriteMessage_WriteRequest_MessageData_Partitioning

func (*StreamWriteMessage_WriteRequest_MessageData) GetSeqNo 

func (x *StreamWriteMessage_WriteRequest_MessageData) GetSeqNo() int64

func (*StreamWriteMessage_WriteRequest_MessageData) GetUncompressedSize 

func (x *StreamWriteMessage_WriteRequest_MessageData) GetUncompressedSize() int64

func (*StreamWriteMessage_WriteRequest_MessageData) ProtoMessage 

func (*StreamWriteMessage_WriteRequest_MessageData) ProtoMessage()

func (*StreamWriteMessage_WriteRequest_MessageData) ProtoReflect 

func (x *StreamWriteMessage_WriteRequest_MessageData) ProtoReflect() protoreflect.Message

func (*StreamWriteMessage_WriteRequest_MessageData) Reset 

func (x *StreamWriteMessage_WriteRequest_MessageData) Reset()

func (*StreamWriteMessage_WriteRequest_MessageData) String 

func (x *StreamWriteMessage_WriteRequest_MessageData) String() string

type StreamWriteMessage_WriteRequest_MessageData_MessageGroupId 

type StreamWriteMessage_WriteRequest_MessageData_MessageGroupId struct {
	// All messages with given pair (producer_id, message_group_id) go to single partition in order of writes.
	MessageGroupId string `protobuf:"bytes,5,opt,name=message_group_id,json=messageGroupId,proto3,oneof"`
}

type StreamWriteMessage_WriteRequest_MessageData_PartitionId 

type StreamWriteMessage_WriteRequest_MessageData_PartitionId struct {
	// Explicit partition id to write to.
	PartitionId int64 `protobuf:"varint,6,opt,name=partition_id,json=partitionId,proto3,oneof"`
}

type StreamWriteMessage_WriteResponse 

type StreamWriteMessage_WriteResponse struct {

	// Number of acks is equal to number of messages in the corresponding WriteRequests.
	Acks []*StreamWriteMessage_WriteResponse_WriteAck `protobuf:"bytes,1,rep,name=acks,proto3" json:"acks,omitempty"`
	// Assigned partition for all client messages inside this batch.
	// This actual partition may differ from that returned in InitResponse
	// or other WriteResponses in this write session.
	PartitionId int64 `protobuf:"varint,2,opt,name=partition_id,json=partitionId,proto3" json:"partition_id,omitempty"`
	// Write statistics for this sequence of client messages.
	WriteStatistics *StreamWriteMessage_WriteResponse_WriteStatistics `protobuf:"bytes,3,opt,name=write_statistics,json=writeStatistics,proto3" json:"write_statistics,omitempty"`
	// contains filtered or unexported fields
}

Message that represents acknowledgment for sequence of client messages. This sequence is persisted together so write statistics is for messages batch.

func (*StreamWriteMessage_WriteResponse) Descriptor deprecated 

func (*StreamWriteMessage_WriteResponse) Descriptor() ([]byte, []int)

Deprecated: Use StreamWriteMessage_WriteResponse.ProtoReflect.Descriptor instead.

func (*StreamWriteMessage_WriteResponse) GetAcks 

func (x *StreamWriteMessage_WriteResponse) GetAcks() []*StreamWriteMessage_WriteResponse_WriteAck

func (*StreamWriteMessage_WriteResponse) GetPartitionId 

func (x *StreamWriteMessage_WriteResponse) GetPartitionId() int64

func (*StreamWriteMessage_WriteResponse) GetWriteStatistics 

func (x *StreamWriteMessage_WriteResponse) GetWriteStatistics() *StreamWriteMessage_WriteResponse_WriteStatistics

func (*StreamWriteMessage_WriteResponse) ProtoMessage 

func (*StreamWriteMessage_WriteResponse) ProtoMessage()

func (*StreamWriteMessage_WriteResponse) ProtoReflect 

func (x *StreamWriteMessage_WriteResponse) ProtoReflect() protoreflect.Message

func (*StreamWriteMessage_WriteResponse) Reset 

func (x *StreamWriteMessage_WriteResponse) Reset()

func (*StreamWriteMessage_WriteResponse) String 

func (x *StreamWriteMessage_WriteResponse) String() string

type StreamWriteMessage_WriteResponse_WriteAck 

type StreamWriteMessage_WriteResponse_WriteAck struct {

	// Sequence number as in WriteRequest.
	SeqNo int64 `protobuf:"varint,1,opt,name=seq_no,json=seqNo,proto3" json:"seq_no,omitempty"`
	// Either message is written for the first time or duplicate.
	//
	// Types that are assignable to MessageWriteStatus:
	//
	//	*StreamWriteMessage_WriteResponse_WriteAck_Written_
	//	*StreamWriteMessage_WriteResponse_WriteAck_Skipped_
	MessageWriteStatus isStreamWriteMessage_WriteResponse_WriteAck_MessageWriteStatus `protobuf_oneof:"message_write_status"`
	// contains filtered or unexported fields
}

Acknowledgment for one persistently written message.

func (*StreamWriteMessage_WriteResponse_WriteAck) Descriptor deprecated 

func (*StreamWriteMessage_WriteResponse_WriteAck) Descriptor() ([]byte, []int)

Deprecated: Use StreamWriteMessage_WriteResponse_WriteAck.ProtoReflect.Descriptor instead.

func (*StreamWriteMessage_WriteResponse_WriteAck) GetMessageWriteStatus 

func (m *StreamWriteMessage_WriteResponse_WriteAck) GetMessageWriteStatus() isStreamWriteMessage_WriteResponse_WriteAck_MessageWriteStatus

func (*StreamWriteMessage_WriteResponse_WriteAck) GetSeqNo 

func (x *StreamWriteMessage_WriteResponse_WriteAck) GetSeqNo() int64

func (*StreamWriteMessage_WriteResponse_WriteAck) GetSkipped 

func (x *StreamWriteMessage_WriteResponse_WriteAck) GetSkipped() *StreamWriteMessage_WriteResponse_WriteAck_Skipped

func (*StreamWriteMessage_WriteResponse_WriteAck) GetWritten 

func (x *StreamWriteMessage_WriteResponse_WriteAck) GetWritten() *StreamWriteMessage_WriteResponse_WriteAck_Written

func (*StreamWriteMessage_WriteResponse_WriteAck) ProtoMessage 

func (*StreamWriteMessage_WriteResponse_WriteAck) ProtoMessage()

func (*StreamWriteMessage_WriteResponse_WriteAck) ProtoReflect 

func (x *StreamWriteMessage_WriteResponse_WriteAck) ProtoReflect() protoreflect.Message

func (*StreamWriteMessage_WriteResponse_WriteAck) Reset 

func (x *StreamWriteMessage_WriteResponse_WriteAck) Reset()

func (*StreamWriteMessage_WriteResponse_WriteAck) String 

func (x *StreamWriteMessage_WriteResponse_WriteAck) String() string

type StreamWriteMessage_WriteResponse_WriteAck_Skipped 

type StreamWriteMessage_WriteResponse_WriteAck_Skipped struct {
	Reason StreamWriteMessage_WriteResponse_WriteAck_Skipped_Reason `` /* 138-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*StreamWriteMessage_WriteResponse_WriteAck_Skipped) Descriptor deprecated 

func (*StreamWriteMessage_WriteResponse_WriteAck_Skipped) Descriptor() ([]byte, []int)

Deprecated: Use StreamWriteMessage_WriteResponse_WriteAck_Skipped.ProtoReflect.Descriptor instead.

func (*StreamWriteMessage_WriteResponse_WriteAck_Skipped) GetReason 

func (x *StreamWriteMessage_WriteResponse_WriteAck_Skipped) GetReason() StreamWriteMessage_WriteResponse_WriteAck_Skipped_Reason

func (*StreamWriteMessage_WriteResponse_WriteAck_Skipped) ProtoMessage 

func (*StreamWriteMessage_WriteResponse_WriteAck_Skipped) ProtoMessage()

func (*StreamWriteMessage_WriteResponse_WriteAck_Skipped) ProtoReflect 

func (x *StreamWriteMessage_WriteResponse_WriteAck_Skipped) ProtoReflect() protoreflect.Message

func (*StreamWriteMessage_WriteResponse_WriteAck_Skipped) Reset 

func (x *StreamWriteMessage_WriteResponse_WriteAck_Skipped) Reset()

func (*StreamWriteMessage_WriteResponse_WriteAck_Skipped) String 

func (x *StreamWriteMessage_WriteResponse_WriteAck_Skipped) String() string

type StreamWriteMessage_WriteResponse_WriteAck_Skipped_ 

type StreamWriteMessage_WriteResponse_WriteAck_Skipped_ struct {
	Skipped *StreamWriteMessage_WriteResponse_WriteAck_Skipped `protobuf:"bytes,3,opt,name=skipped,proto3,oneof"`
}

type StreamWriteMessage_WriteResponse_WriteAck_Skipped_Reason 

type StreamWriteMessage_WriteResponse_WriteAck_Skipped_Reason int32
const (
	StreamWriteMessage_WriteResponse_WriteAck_Skipped_REASON_UNSPECIFIED     StreamWriteMessage_WriteResponse_WriteAck_Skipped_Reason = 0
	StreamWriteMessage_WriteResponse_WriteAck_Skipped_REASON_ALREADY_WRITTEN StreamWriteMessage_WriteResponse_WriteAck_Skipped_Reason = 1
)

func (StreamWriteMessage_WriteResponse_WriteAck_Skipped_Reason) Descriptor 

func (StreamWriteMessage_WriteResponse_WriteAck_Skipped_Reason) Descriptor() protoreflect.EnumDescriptor

func (StreamWriteMessage_WriteResponse_WriteAck_Skipped_Reason) Enum 

func (x StreamWriteMessage_WriteResponse_WriteAck_Skipped_Reason) Enum() *StreamWriteMessage_WriteResponse_WriteAck_Skipped_Reason

func (StreamWriteMessage_WriteResponse_WriteAck_Skipped_Reason) EnumDescriptor deprecated 

func (StreamWriteMessage_WriteResponse_WriteAck_Skipped_Reason) EnumDescriptor() ([]byte, []int)

Deprecated: Use StreamWriteMessage_WriteResponse_WriteAck_Skipped_Reason.Descriptor instead.

func (StreamWriteMessage_WriteResponse_WriteAck_Skipped_Reason) Number 

func (x StreamWriteMessage_WriteResponse_WriteAck_Skipped_Reason) Number() protoreflect.EnumNumber

func (StreamWriteMessage_WriteResponse_WriteAck_Skipped_Reason) String 

func (x StreamWriteMessage_WriteResponse_WriteAck_Skipped_Reason) String() string

func (StreamWriteMessage_WriteResponse_WriteAck_Skipped_Reason) Type 

func (StreamWriteMessage_WriteResponse_WriteAck_Skipped_Reason) Type() protoreflect.EnumType

type StreamWriteMessage_WriteResponse_WriteAck_Written 

type StreamWriteMessage_WriteResponse_WriteAck_Written struct {

	// Assigned partition offset.
	Offset int64 `protobuf:"varint,1,opt,name=offset,proto3" json:"offset,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamWriteMessage_WriteResponse_WriteAck_Written) Descriptor deprecated 

func (*StreamWriteMessage_WriteResponse_WriteAck_Written) Descriptor() ([]byte, []int)

Deprecated: Use StreamWriteMessage_WriteResponse_WriteAck_Written.ProtoReflect.Descriptor instead.

func (*StreamWriteMessage_WriteResponse_WriteAck_Written) GetOffset 

func (x *StreamWriteMessage_WriteResponse_WriteAck_Written) GetOffset() int64

func (*StreamWriteMessage_WriteResponse_WriteAck_Written) ProtoMessage 

func (*StreamWriteMessage_WriteResponse_WriteAck_Written) ProtoMessage()

func (*StreamWriteMessage_WriteResponse_WriteAck_Written) ProtoReflect 

func (x *StreamWriteMessage_WriteResponse_WriteAck_Written) ProtoReflect() protoreflect.Message

func (*StreamWriteMessage_WriteResponse_WriteAck_Written) Reset 

func (x *StreamWriteMessage_WriteResponse_WriteAck_Written) Reset()

func (*StreamWriteMessage_WriteResponse_WriteAck_Written) String 

func (x *StreamWriteMessage_WriteResponse_WriteAck_Written) String() string

type StreamWriteMessage_WriteResponse_WriteAck_Written_ 

type StreamWriteMessage_WriteResponse_WriteAck_Written_ struct {
	Written *StreamWriteMessage_WriteResponse_WriteAck_Written `protobuf:"bytes,2,opt,name=written,proto3,oneof"`
}

type StreamWriteMessage_WriteResponse_WriteStatistics 

type StreamWriteMessage_WriteResponse_WriteStatistics struct {

	// Time spent in persisting of data. Same for each message in response.
	PersistingTime *durationpb.Duration `protobuf:"bytes,1,opt,name=persisting_time,json=persistingTime,proto3" json:"persisting_time,omitempty"`
	// Time spent in queue before persisting, minimal of all messages in response.
	MinQueueWaitTime *durationpb.Duration `protobuf:"bytes,2,opt,name=min_queue_wait_time,json=minQueueWaitTime,proto3" json:"min_queue_wait_time,omitempty"`
	// Time spent in queue before persisting, maximal of all messages in response.
	MaxQueueWaitTime *durationpb.Duration `protobuf:"bytes,3,opt,name=max_queue_wait_time,json=maxQueueWaitTime,proto3" json:"max_queue_wait_time,omitempty"`
	// Time spent awaiting for partition write quota. Same for each message in response.
	PartitionQuotaWaitTime *durationpb.Duration `` /* 131-byte string literal not displayed */
	// Time spent awaiting for topic write quota. Same for each message in response.
	TopicQuotaWaitTime *durationpb.Duration `protobuf:"bytes,5,opt,name=topic_quota_wait_time,json=topicQuotaWaitTime,proto3" json:"topic_quota_wait_time,omitempty"`
	// contains filtered or unexported fields
}

Message with write statistics.

func (*StreamWriteMessage_WriteResponse_WriteStatistics) Descriptor deprecated 

func (*StreamWriteMessage_WriteResponse_WriteStatistics) Descriptor() ([]byte, []int)

Deprecated: Use StreamWriteMessage_WriteResponse_WriteStatistics.ProtoReflect.Descriptor instead.

func (*StreamWriteMessage_WriteResponse_WriteStatistics) GetMaxQueueWaitTime 

func (x *StreamWriteMessage_WriteResponse_WriteStatistics) GetMaxQueueWaitTime() *durationpb.Duration

func (*StreamWriteMessage_WriteResponse_WriteStatistics) GetMinQueueWaitTime 

func (x *StreamWriteMessage_WriteResponse_WriteStatistics) GetMinQueueWaitTime() *durationpb.Duration

func (*StreamWriteMessage_WriteResponse_WriteStatistics) GetPartitionQuotaWaitTime 

func (x *StreamWriteMessage_WriteResponse_WriteStatistics) GetPartitionQuotaWaitTime() *durationpb.Duration

func (*StreamWriteMessage_WriteResponse_WriteStatistics) GetPersistingTime 

func (x *StreamWriteMessage_WriteResponse_WriteStatistics) GetPersistingTime() *durationpb.Duration

func (*StreamWriteMessage_WriteResponse_WriteStatistics) GetTopicQuotaWaitTime 

func (x *StreamWriteMessage_WriteResponse_WriteStatistics) GetTopicQuotaWaitTime() *durationpb.Duration

func (*StreamWriteMessage_WriteResponse_WriteStatistics) ProtoMessage 

func (*StreamWriteMessage_WriteResponse_WriteStatistics) ProtoMessage()

func (*StreamWriteMessage_WriteResponse_WriteStatistics) ProtoReflect 

func (x *StreamWriteMessage_WriteResponse_WriteStatistics) ProtoReflect() protoreflect.Message

func (*StreamWriteMessage_WriteResponse_WriteStatistics) Reset 

func (x *StreamWriteMessage_WriteResponse_WriteStatistics) Reset()

func (*StreamWriteMessage_WriteResponse_WriteStatistics) String 

func (x *StreamWriteMessage_WriteResponse_WriteStatistics) String() string

type SupportedCodecs 

type SupportedCodecs struct {

	// List of supported codecs.
	// See enum Codec above for values.
	Codecs []int32 `protobuf:"varint,1,rep,packed,name=codecs,proto3" json:"codecs,omitempty"`
	// contains filtered or unexported fields
}

Description of supported codecs.

func (*SupportedCodecs) Descriptor deprecated 

func (*SupportedCodecs) Descriptor() ([]byte, []int)

Deprecated: Use SupportedCodecs.ProtoReflect.Descriptor instead.

func (*SupportedCodecs) GetCodecs 

func (x *SupportedCodecs) GetCodecs() []int32

func (*SupportedCodecs) ProtoMessage 

func (*SupportedCodecs) ProtoMessage()

func (*SupportedCodecs) ProtoReflect 

func (x *SupportedCodecs) ProtoReflect() protoreflect.Message

func (*SupportedCodecs) Reset 

func (x *SupportedCodecs) Reset()

func (*SupportedCodecs) String 

func (x *SupportedCodecs) String() string

type TransactionIdentity 

type TransactionIdentity struct {

	// Transaction identifier from TableService.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Session identifier from TableService.
	Session string `protobuf:"bytes,2,opt,name=session,proto3" json:"session,omitempty"`
	// contains filtered or unexported fields
}

func (*TransactionIdentity) Descriptor deprecated 

func (*TransactionIdentity) Descriptor() ([]byte, []int)

Deprecated: Use TransactionIdentity.ProtoReflect.Descriptor instead.

func (*TransactionIdentity) GetId 

func (x *TransactionIdentity) GetId() string

func (*TransactionIdentity) GetSession 

func (x *TransactionIdentity) GetSession() string

func (*TransactionIdentity) ProtoMessage 

func (*TransactionIdentity) ProtoMessage()

func (*TransactionIdentity) ProtoReflect 

func (x *TransactionIdentity) ProtoReflect() protoreflect.Message

func (*TransactionIdentity) Reset 

func (x *TransactionIdentity) Reset()

func (*TransactionIdentity) String 

func (x *TransactionIdentity) String() string

type UpdateOffsetsInTransactionRequest 

type UpdateOffsetsInTransactionRequest struct {
	OperationParams *Ydb_Operations.OperationParams `protobuf:"bytes,1,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"`
	Tx              *TransactionIdentity            `protobuf:"bytes,2,opt,name=tx,proto3" json:"tx,omitempty"`
	// Ranges of offsets by topics.
	Topics   []*UpdateOffsetsInTransactionRequest_TopicOffsets `protobuf:"bytes,3,rep,name=topics,proto3" json:"topics,omitempty"`
	Consumer string                                            `protobuf:"bytes,4,opt,name=consumer,proto3" json:"consumer,omitempty"`
	// contains filtered or unexported fields
}

Add offsets to transaction request sent from client to server.

func (*UpdateOffsetsInTransactionRequest) Descriptor deprecated 

func (*UpdateOffsetsInTransactionRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpdateOffsetsInTransactionRequest.ProtoReflect.Descriptor instead.

func (*UpdateOffsetsInTransactionRequest) GetConsumer 

func (x *UpdateOffsetsInTransactionRequest) GetConsumer() string

func (*UpdateOffsetsInTransactionRequest) GetOperationParams 

func (x *UpdateOffsetsInTransactionRequest) GetOperationParams() *Ydb_Operations.OperationParams

func (*UpdateOffsetsInTransactionRequest) GetTopics 

func (x *UpdateOffsetsInTransactionRequest) GetTopics() []*UpdateOffsetsInTransactionRequest_TopicOffsets

func (*UpdateOffsetsInTransactionRequest) GetTx 

func (x *UpdateOffsetsInTransactionRequest) GetTx() *TransactionIdentity

func (*UpdateOffsetsInTransactionRequest) ProtoMessage 

func (*UpdateOffsetsInTransactionRequest) ProtoMessage()

func (*UpdateOffsetsInTransactionRequest) ProtoReflect 

func (x *UpdateOffsetsInTransactionRequest) ProtoReflect() protoreflect.Message

func (*UpdateOffsetsInTransactionRequest) Reset 

func (x *UpdateOffsetsInTransactionRequest) Reset()

func (*UpdateOffsetsInTransactionRequest) String 

func (x *UpdateOffsetsInTransactionRequest) String() string

type UpdateOffsetsInTransactionRequest_TopicOffsets 

type UpdateOffsetsInTransactionRequest_TopicOffsets struct {

	// Topic path.
	Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	// Ranges of offsets by partitions.
	Partitions []*UpdateOffsetsInTransactionRequest_TopicOffsets_PartitionOffsets `protobuf:"bytes,2,rep,name=partitions,proto3" json:"partitions,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateOffsetsInTransactionRequest_TopicOffsets) Descriptor deprecated 

func (*UpdateOffsetsInTransactionRequest_TopicOffsets) Descriptor() ([]byte, []int)

Deprecated: Use UpdateOffsetsInTransactionRequest_TopicOffsets.ProtoReflect.Descriptor instead.

func (*UpdateOffsetsInTransactionRequest_TopicOffsets) GetPartitions 

func (x *UpdateOffsetsInTransactionRequest_TopicOffsets) GetPartitions() []*UpdateOffsetsInTransactionRequest_TopicOffsets_PartitionOffsets

func (*UpdateOffsetsInTransactionRequest_TopicOffsets) GetPath 

func (x *UpdateOffsetsInTransactionRequest_TopicOffsets) GetPath() string

func (*UpdateOffsetsInTransactionRequest_TopicOffsets) ProtoMessage 

func (*UpdateOffsetsInTransactionRequest_TopicOffsets) ProtoMessage()

func (*UpdateOffsetsInTransactionRequest_TopicOffsets) ProtoReflect 

func (x *UpdateOffsetsInTransactionRequest_TopicOffsets) ProtoReflect() protoreflect.Message

func (*UpdateOffsetsInTransactionRequest_TopicOffsets) Reset 

func (x *UpdateOffsetsInTransactionRequest_TopicOffsets) Reset()

func (*UpdateOffsetsInTransactionRequest_TopicOffsets) String 

func (x *UpdateOffsetsInTransactionRequest_TopicOffsets) String() string

type UpdateOffsetsInTransactionRequest_TopicOffsets_PartitionOffsets 

type UpdateOffsetsInTransactionRequest_TopicOffsets_PartitionOffsets struct {

	// Partition identifier.
	PartitionId int64 `protobuf:"varint,1,opt,name=partition_id,json=partitionId,proto3" json:"partition_id,omitempty"`
	// List of offset ranges.
	PartitionOffsets []*OffsetsRange `protobuf:"bytes,2,rep,name=partition_offsets,json=partitionOffsets,proto3" json:"partition_offsets,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateOffsetsInTransactionRequest_TopicOffsets_PartitionOffsets) Descriptor deprecated 

func (*UpdateOffsetsInTransactionRequest_TopicOffsets_PartitionOffsets) Descriptor() ([]byte, []int)

Deprecated: Use UpdateOffsetsInTransactionRequest_TopicOffsets_PartitionOffsets.ProtoReflect.Descriptor instead.

func (*UpdateOffsetsInTransactionRequest_TopicOffsets_PartitionOffsets) GetPartitionId 

func (x *UpdateOffsetsInTransactionRequest_TopicOffsets_PartitionOffsets) GetPartitionId() int64

func (*UpdateOffsetsInTransactionRequest_TopicOffsets_PartitionOffsets) GetPartitionOffsets 

func (x *UpdateOffsetsInTransactionRequest_TopicOffsets_PartitionOffsets) GetPartitionOffsets() []*OffsetsRange

func (*UpdateOffsetsInTransactionRequest_TopicOffsets_PartitionOffsets) ProtoMessage 

func (*UpdateOffsetsInTransactionRequest_TopicOffsets_PartitionOffsets) ProtoMessage()

func (*UpdateOffsetsInTransactionRequest_TopicOffsets_PartitionOffsets) ProtoReflect 

func (x *UpdateOffsetsInTransactionRequest_TopicOffsets_PartitionOffsets) ProtoReflect() protoreflect.Message

func (*UpdateOffsetsInTransactionRequest_TopicOffsets_PartitionOffsets) Reset 

func (x *UpdateOffsetsInTransactionRequest_TopicOffsets_PartitionOffsets) Reset()

func (*UpdateOffsetsInTransactionRequest_TopicOffsets_PartitionOffsets) String 

func (x *UpdateOffsetsInTransactionRequest_TopicOffsets_PartitionOffsets) String() string

type UpdateOffsetsInTransactionResponse 

type UpdateOffsetsInTransactionResponse 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
}

Add offsets to transaction response sent from server to client.

func (*UpdateOffsetsInTransactionResponse) Descriptor deprecated 

func (*UpdateOffsetsInTransactionResponse) Descriptor() ([]byte, []int)

Deprecated: Use UpdateOffsetsInTransactionResponse.ProtoReflect.Descriptor instead.

func (*UpdateOffsetsInTransactionResponse) GetOperation 

func (x *UpdateOffsetsInTransactionResponse) GetOperation() *Ydb_Operations.Operation

func (*UpdateOffsetsInTransactionResponse) ProtoMessage 

func (*UpdateOffsetsInTransactionResponse) ProtoMessage()

func (*UpdateOffsetsInTransactionResponse) ProtoReflect 

func (x *UpdateOffsetsInTransactionResponse) ProtoReflect() protoreflect.Message

func (*UpdateOffsetsInTransactionResponse) Reset 

func (x *UpdateOffsetsInTransactionResponse) Reset()

func (*UpdateOffsetsInTransactionResponse) String 

func (x *UpdateOffsetsInTransactionResponse) String() string

type UpdateOffsetsInTransactionResult 

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

Add offsets to transaction result message that will be inside UpdateOffsetsInTransactionResponse.operation.

func (*UpdateOffsetsInTransactionResult) Descriptor deprecated 

func (*UpdateOffsetsInTransactionResult) Descriptor() ([]byte, []int)

Deprecated: Use UpdateOffsetsInTransactionResult.ProtoReflect.Descriptor instead.

func (*UpdateOffsetsInTransactionResult) ProtoMessage 

func (*UpdateOffsetsInTransactionResult) ProtoMessage()

func (*UpdateOffsetsInTransactionResult) ProtoReflect 

func (x *UpdateOffsetsInTransactionResult) ProtoReflect() protoreflect.Message

func (*UpdateOffsetsInTransactionResult) Reset 

func (x *UpdateOffsetsInTransactionResult) Reset()

func (*UpdateOffsetsInTransactionResult) String 

func (x *UpdateOffsetsInTransactionResult) String() string

type UpdateTokenRequest 

type UpdateTokenRequest struct {
	Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"`
	// contains filtered or unexported fields
}

In-session reauthentication and reauthorization, lets user increase session lifetime. Client should wait for UpdateTokenResponse before sending next UpdateTokenRequest.

func (*UpdateTokenRequest) Descriptor deprecated 

func (*UpdateTokenRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpdateTokenRequest.ProtoReflect.Descriptor instead.

func (*UpdateTokenRequest) GetToken 

func (x *UpdateTokenRequest) GetToken() string

func (*UpdateTokenRequest) ProtoMessage 

func (*UpdateTokenRequest) ProtoMessage()

func (*UpdateTokenRequest) ProtoReflect 

func (x *UpdateTokenRequest) ProtoReflect() protoreflect.Message

func (*UpdateTokenRequest) Reset 

func (x *UpdateTokenRequest) Reset()

func (*UpdateTokenRequest) String 

func (x *UpdateTokenRequest) String() string

type UpdateTokenResponse 

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

func (*UpdateTokenResponse) Descriptor deprecated 

func (*UpdateTokenResponse) Descriptor() ([]byte, []int)

Deprecated: Use UpdateTokenResponse.ProtoReflect.Descriptor instead.

func (*UpdateTokenResponse) ProtoMessage 

func (*UpdateTokenResponse) ProtoMessage()

func (*UpdateTokenResponse) ProtoReflect 

func (x *UpdateTokenResponse) ProtoReflect() protoreflect.Message

func (*UpdateTokenResponse) Reset 

func (x *UpdateTokenResponse) Reset()

func (*UpdateTokenResponse) String 

func (x *UpdateTokenResponse) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.