Versions in this module Expand all Collapse all v3 v3.80.13 Sep 25, 2024 v3.80.12 Sep 24, 2024 Changes in this version + const MeteringModeRequestUnits + const MeteringModeReservedCapacity + const MeteringModeUnspecified + type AlterConsumer struct + AlterAttributes map[string]string + Name string + SetImportant rawoptional.Bool + SetReadFrom rawoptional.Time + SetSupportedCodecs rawtopiccommon.SupportedCodecs + func (c *AlterConsumer) ToProto() *Ydb_Topic.AlterConsumer + type AlterPartitioningSettings struct + SetMinActivePartitions rawoptional.Int64 + SetPartitionCountLimit rawoptional.Int64 + func (s *AlterPartitioningSettings) ToProto() *Ydb_Topic.AlterPartitioningSettings + type AlterTopicRequest struct + AddConsumers []Consumer + AlterAttributes map[string]string + AlterConsumers []AlterConsumer + AlterPartitionSettings AlterPartitioningSettings + DropConsumers []string + OperationParams rawydb.OperationParams + Path string + SetMeteringMode MeteringMode + SetPartitionWriteBurstBytes rawoptional.Int64 + SetPartitionWriteSpeedBytesPerSecond rawoptional.Int64 + SetRetentionPeriod rawoptional.Duration + SetRetentionStorageMB rawoptional.Int64 + SetSupportedCodecs bool + SetSupportedCodecsValue rawtopiccommon.SupportedCodecs + func (req *AlterTopicRequest) ToProto() *Ydb_Topic.AlterTopicRequest + type AlterTopicResult struct + Operation rawydb.Operation + func (r *AlterTopicResult) FromProto(proto *Ydb_Topic.AlterTopicResponse) error + type Client struct + func NewClient(service Ydb_Topic_V1.TopicServiceClient) Client + func (c *Client) AlterTopic(ctx context.Context, req *AlterTopicRequest) (res AlterTopicResult, err error) + func (c *Client) CreateTopic(ctx context.Context, req *CreateTopicRequest) (res CreateTopicResult, err error) + func (c *Client) DescribeTopic(ctx context.Context, req DescribeTopicRequest) (res DescribeTopicResult, err error) + func (c *Client) DropTopic(ctx context.Context, req DropTopicRequest) (res DropTopicResult, err error) + func (c *Client) StreamRead(ctxStreamLifeTime context.Context) (rawtopicreader.StreamReader, error) + func (c *Client) StreamWrite(ctxStreamLifeTime context.Context) (*rawtopicwriter.StreamWriter, error) + func (c *Client) UpdateOffsetsInTransaction(ctx context.Context, req *UpdateOffsetsInTransactionRequest) error + type Consumer struct + Attributes map[string]string + Important bool + Name string + ReadFrom rawoptional.Time + SupportedCodecs rawtopiccommon.SupportedCodecs + func (c *Consumer) MustFromProto(consumer *Ydb_Topic.Consumer) + func (c *Consumer) ToProto() *Ydb_Topic.Consumer + type CreateTopicRequest struct + Attributes map[string]string + Consumers []Consumer + MeteringMode MeteringMode + OperationParams rawydb.OperationParams + PartitionSettings PartitioningSettings + PartitionWriteBurstBytes int64 + PartitionWriteSpeedBytesPerSecond int64 + Path string + RetentionPeriod time.Duration + RetentionStorageMB int64 + SupportedCodecs rawtopiccommon.SupportedCodecs + func (req *CreateTopicRequest) ToProto() *Ydb_Topic.CreateTopicRequest + type CreateTopicResult struct + Operation rawydb.Operation + func (r *CreateTopicResult) FromProto(proto *Ydb_Topic.CreateTopicResponse) error + type DescribeTopicRequest struct + OperationParams rawydb.OperationParams + Path string + func (req *DescribeTopicRequest) ToProto() *Ydb_Topic.DescribeTopicRequest + type DescribeTopicResult struct + Attributes map[string]string + Consumers []Consumer + MeteringMode MeteringMode + Operation rawydb.Operation + PartitionWriteBurstBytes int64 + PartitionWriteSpeedBytesPerSecond int64 + PartitioningSettings PartitioningSettings + Partitions []PartitionInfo + RetentionPeriod time.Duration + RetentionStorageMB int64 + Self rawscheme.Entry + SupportedCodecs rawtopiccommon.SupportedCodecs + func (res *DescribeTopicResult) FromProto(response operation.Response) error + type DropTopicRequest struct + OperationParams rawydb.OperationParams + Path string + func (req *DropTopicRequest) ToProto() *Ydb_Topic.DropTopicRequest + type DropTopicResult struct + Operation rawydb.Operation + func (r *DropTopicResult) FromProto(proto *Ydb_Topic.DropTopicResponse) error + type MeteringMode int + type PartitionInfo struct + Active bool + ChildPartitionIDs []int64 + ParentPartitionIDs []int64 + PartitionID int64 + type PartitioningSettings struct + MinActivePartitions int64 + PartitionCountLimit int64 + func (s *PartitioningSettings) FromProto(proto *Ydb_Topic.PartitioningSettings) error + func (s *PartitioningSettings) ToProto() *Ydb_Topic.PartitioningSettings + type UpdateOffsetsInTransactionRequest struct + Consumer string + OperationParams rawydb.OperationParams + Topics []UpdateOffsetsInTransactionRequest_TopicOffsets + Tx rawtopiccommon.TransactionIdentity + func (r *UpdateOffsetsInTransactionRequest) ToProto() *Ydb_Topic.UpdateOffsetsInTransactionRequest + type UpdateOffsetsInTransactionRequest_PartitionOffsets struct + PartitionID int64 + PartitionOffsets []rawtopiccommon.OffsetRange + type UpdateOffsetsInTransactionRequest_TopicOffsets struct + Partitions []UpdateOffsetsInTransactionRequest_PartitionOffsets + Path string
Go to main page