rawtopic

package
v3.90.2 Latest Latest
Warning

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

 Go to latest Published: Nov 8, 2024 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	MeteringModeUnspecified      = MeteringMode(Ydb_Topic.MeteringMode_METERING_MODE_UNSPECIFIED)
	MeteringModeReservedCapacity = MeteringMode(Ydb_Topic.MeteringMode_METERING_MODE_RESERVED_CAPACITY)
	MeteringModeRequestUnits     = MeteringMode(Ydb_Topic.MeteringMode_METERING_MODE_REQUEST_UNITS)
)

Variables

This section is empty.

Functions

This section is empty.

Types

type AlterConsumer 

type AlterConsumer struct {
	Name               string
	SetImportant       rawoptional.Bool
	SetReadFrom        rawoptional.Time
	SetSupportedCodecs rawtopiccommon.SupportedCodecs
	AlterAttributes    map[string]string
}

func (*AlterConsumer) ToProto 

func (c *AlterConsumer) ToProto() *Ydb_Topic.AlterConsumer

type AlterPartitioningSettings 

type AlterPartitioningSettings struct {
	SetMinActivePartitions rawoptional.Int64
	SetPartitionCountLimit rawoptional.Int64
}

func (*AlterPartitioningSettings) ToProto 

func (s *AlterPartitioningSettings) ToProto() *Ydb_Topic.AlterPartitioningSettings

type AlterTopicRequest 

type AlterTopicRequest struct {
	OperationParams rawydb.OperationParams

	Path string

	AlterPartitionSettings               AlterPartitioningSettings
	SetRetentionPeriod                   rawoptional.Duration
	SetRetentionStorageMB                rawoptional.Int64
	SetSupportedCodecs                   bool
	SetSupportedCodecsValue              rawtopiccommon.SupportedCodecs
	SetPartitionWriteSpeedBytesPerSecond rawoptional.Int64
	SetPartitionWriteBurstBytes          rawoptional.Int64
	AlterAttributes                      map[string]string
	AddConsumers                         []Consumer
	DropConsumers                        []string
	AlterConsumers                       []AlterConsumer
	SetMeteringMode                      MeteringMode
}

func (*AlterTopicRequest) ToProto 

func (req *AlterTopicRequest) ToProto() *Ydb_Topic.AlterTopicRequest

type AlterTopicResult 

type AlterTopicResult struct {
	Operation rawydb.Operation
}

func (*AlterTopicResult) FromProto 

func (r *AlterTopicResult) FromProto(proto *Ydb_Topic.AlterTopicResponse) error

type Client 

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

func NewClient 

func NewClient(service Ydb_Topic_V1.TopicServiceClient) Client

func (*Client) AlterTopic 

func (c *Client) AlterTopic(ctx context.Context, req *AlterTopicRequest) (res AlterTopicResult, err error)

func (*Client) CreateTopic 

func (c *Client) CreateTopic(
	ctx context.Context,
	req *CreateTopicRequest,
) (res CreateTopicResult, err error)

func (*Client) DescribeConsumer added in v3.85.0 

func (c *Client) DescribeConsumer(ctx context.Context, req DescribeConsumerRequest) (
	res DescribeConsumerResult, err error,
)

func (*Client) DescribeTopic 

func (c *Client) DescribeTopic(ctx context.Context, req DescribeTopicRequest) (res DescribeTopicResult, err error)

func (*Client) DropTopic 

func (c *Client) DropTopic(
	ctx context.Context,
	req DropTopicRequest,
) (res DropTopicResult, err error)

func (*Client) StreamRead 

func (c *Client) StreamRead(ctxStreamLifeTime context.Context) (rawtopicreader.StreamReader, error)

func (*Client) StreamWrite 

func (c *Client) StreamWrite(ctxStreamLifeTime context.Context) (*rawtopicwriter.StreamWriter, error)

func (*Client) UpdateOffsetsInTransaction added in v3.76.4 

func (c *Client) UpdateOffsetsInTransaction(
	ctx context.Context,
	req *UpdateOffsetsInTransactionRequest,
) error

type Consumer 

type Consumer struct {
	Name            string
	Important       bool
	SupportedCodecs rawtopiccommon.SupportedCodecs
	ReadFrom        rawoptional.Time
	Attributes      map[string]string
}

func (*Consumer) MustFromProto 

func (c *Consumer) MustFromProto(consumer *Ydb_Topic.Consumer)

func (*Consumer) ToProto 

func (c *Consumer) ToProto() *Ydb_Topic.Consumer

type CreateTopicRequest 

type CreateTopicRequest struct {
	OperationParams rawydb.OperationParams

	Path                              string
	PartitionSettings                 PartitioningSettings
	RetentionPeriod                   time.Duration
	RetentionStorageMB                int64
	SupportedCodecs                   rawtopiccommon.SupportedCodecs
	PartitionWriteSpeedBytesPerSecond int64
	PartitionWriteBurstBytes          int64
	Attributes                        map[string]string
	Consumers                         []Consumer
	MeteringMode                      MeteringMode
}

func (*CreateTopicRequest) ToProto 

func (req *CreateTopicRequest) ToProto() *Ydb_Topic.CreateTopicRequest

type CreateTopicResult 

type CreateTopicResult struct {
	Operation rawydb.Operation
}

func (*CreateTopicResult) FromProto 

func (r *CreateTopicResult) FromProto(proto *Ydb_Topic.CreateTopicResponse) error

type DescribeConsumerRequest added in v3.85.0 

type DescribeConsumerRequest struct {
	OperationParams rawydb.OperationParams
	Path            string
	Consumer        string
	IncludeStats    bool
}

func (*DescribeConsumerRequest) ToProto added in v3.85.0 

func (req *DescribeConsumerRequest) ToProto() *Ydb_Topic.DescribeConsumerRequest

type DescribeConsumerResult added in v3.85.0 

type DescribeConsumerResult struct {
	Operation  rawydb.Operation
	Self       rawscheme.Entry
	Consumer   Consumer
	Partitions []DescribeConsumerResultPartitionInfo
}

func (*DescribeConsumerResult) FromProto added in v3.85.0 

func (res *DescribeConsumerResult) FromProto(response operation.Response) error

type DescribeConsumerResultPartitionInfo added in v3.85.0 

type DescribeConsumerResultPartitionInfo struct {
	PartitionID            int64
	Active                 bool
	ChildPartitionIDs      []int64
	ParentPartitionIDs     []int64
	PartitionStats         PartitionStats
	PartitionConsumerStats PartitionConsumerStats
}

func (*DescribeConsumerResultPartitionInfo) FromProto added in v3.85.0 

func (pi *DescribeConsumerResultPartitionInfo) FromProto(proto *Ydb_Topic.DescribeConsumerResult_PartitionInfo) error

type DescribeTopicRequest 

type DescribeTopicRequest struct {
	OperationParams rawydb.OperationParams
	Path            string
}

func (*DescribeTopicRequest) ToProto 

func (req *DescribeTopicRequest) ToProto() *Ydb_Topic.DescribeTopicRequest

type DescribeTopicResult 

type DescribeTopicResult struct {
	Operation rawydb.Operation

	Self                              rawscheme.Entry
	PartitioningSettings              PartitioningSettings
	Partitions                        []PartitionInfo
	RetentionPeriod                   time.Duration
	RetentionStorageMB                int64
	SupportedCodecs                   rawtopiccommon.SupportedCodecs
	PartitionWriteSpeedBytesPerSecond int64
	PartitionWriteBurstBytes          int64
	Attributes                        map[string]string
	Consumers                         []Consumer
	MeteringMode                      MeteringMode
}

func (*DescribeTopicResult) FromProto 

func (res *DescribeTopicResult) FromProto(response operation.Response) error

type DropTopicRequest 

type DropTopicRequest struct {
	OperationParams rawydb.OperationParams
	Path            string
}

func (*DropTopicRequest) ToProto 

func (req *DropTopicRequest) ToProto() *Ydb_Topic.DropTopicRequest

type DropTopicResult 

type DropTopicResult struct {
	Operation rawydb.Operation
}

func (*DropTopicResult) FromProto 

func (r *DropTopicResult) FromProto(proto *Ydb_Topic.DropTopicResponse) error

type MeteringMode added in v3.38.2 

type MeteringMode int

type MultipleWindowsStat added in v3.85.0 

type MultipleWindowsStat struct {
	PerMinute int64
	PerHour   int64
	PerDay    int64
}

func (*MultipleWindowsStat) MustFromProto added in v3.85.0 

func (stat *MultipleWindowsStat) MustFromProto(proto *Ydb_Topic.MultipleWindowsStat)

type PartitionConsumerStats added in v3.85.0 

type PartitionConsumerStats struct {
	LastReadOffset                 int64
	CommittedOffset                int64
	ReadSessionID                  string
	PartitionReadSessionCreateTime rawoptional.Time
	LastReadTime                   rawoptional.Time
	MaxReadTimeLag                 rawoptional.Duration
	MaxWriteTimeLag                rawoptional.Duration
	BytesRead                      MultipleWindowsStat
	ReaderName                     string
}

func (*PartitionConsumerStats) FromProto added in v3.85.0 

func (stats *PartitionConsumerStats) FromProto(proto *Ydb_Topic.DescribeConsumerResult_PartitionConsumerStats) error

type PartitionInfo added in v3.38.2 

type PartitionInfo struct {
	PartitionID        int64
	Active             bool
	ChildPartitionIDs  []int64
	ParentPartitionIDs []int64
}

type PartitionStats added in v3.85.0 

type PartitionStats struct {
	PartitionsOffset rawtopiccommon.OffsetRange
	StoreSizeBytes   int64
	LastWriteTime    rawoptional.Time
	MaxWriteTimeLag  rawoptional.Duration
	BytesWritten     MultipleWindowsStat
}

func (*PartitionStats) FromProto added in v3.85.0 

func (ps *PartitionStats) FromProto(proto *Ydb_Topic.PartitionStats) error

type PartitioningSettings 

type PartitioningSettings struct {
	MinActivePartitions int64
	PartitionCountLimit int64
}

func (*PartitioningSettings) FromProto 

func (s *PartitioningSettings) FromProto(proto *Ydb_Topic.PartitioningSettings) error

func (*PartitioningSettings) ToProto 

func (s *PartitioningSettings) ToProto() *Ydb_Topic.PartitioningSettings

type UpdateOffsetsInTransactionRequest added in v3.76.4 

type UpdateOffsetsInTransactionRequest struct {
	OperationParams rawydb.OperationParams
	Tx              rawtopiccommon.TransactionIdentity
	Topics          []UpdateOffsetsInTransactionRequest_TopicOffsets
	Consumer        string
}

func (*UpdateOffsetsInTransactionRequest) ToProto added in v3.76.4 

func (r *UpdateOffsetsInTransactionRequest) ToProto() *Ydb_Topic.UpdateOffsetsInTransactionRequest

type UpdateOffsetsInTransactionRequest_PartitionOffsets added in v3.76.4 

type UpdateOffsetsInTransactionRequest_PartitionOffsets struct {
	PartitionID      int64
	PartitionOffsets []rawtopiccommon.OffsetRange
}

type UpdateOffsetsInTransactionRequest_TopicOffsets added in v3.76.4 

type UpdateOffsetsInTransactionRequest_TopicOffsets struct {
	Path       string // Topic path
	Partitions []UpdateOffsetsInTransactionRequest_PartitionOffsets
}

Source Files

View all Source files

Directories

Path Synopsis
Code generated by MockGen.
 Code generated by MockGen.

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.