package topictypes

import "github.com/ydb-platform/ydb-go-sdk/v3/topic/topictypes"

Index ¶

• Constants
• type Codec
• type Consumer
• func (c *Consumer) FromRaw(raw *rawtopic.Consumer)
• func (c *Consumer) ToRaw(raw *rawtopic.Consumer)
• type PartitionSettings
• func (s *PartitionSettings) FromRaw(raw *rawtopic.PartitioningSettings)
• func (s *PartitionSettings) ToRaw(raw *rawtopic.PartitioningSettings)
• type TopicDescription
• func (d *TopicDescription) FromRaw(raw *rawtopic.DescribeTopicResult)
• func (d *TopicDescription) ToRaw(raw *rawtopic.DescribeTopicResult)

Constants ¶

const (
	CodecRaw  = Codec(rawtopiccommon.CodecRaw)
	CodecGzip = Codec(rawtopiccommon.CodecGzip)
	CodecLzop = Codec(rawtopiccommon.CodecLzop)
	CodecZstd = Codec(rawtopiccommon.CodecZstd)

	CodecCustomerFirst = Codec(rawtopiccommon.CodecCustomerFirst)
	CodecCustomerEnd   = Codec(rawtopiccommon.CodecCustomerEnd) // last allowed custom codec id is CodecCustomerEnd-1
)

Types ¶

type Codec ¶

type Codec int

Codec

Experimental

Notice: This API is EXPERIMENTAL and may be changed or removed in a later release.

type Consumer ¶

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

Consumer

Experimental

Notice: This API is EXPERIMENTAL and may be changed or removed in a later release.

func (*Consumer) FromRaw ¶

func (c *Consumer) FromRaw(raw *rawtopic.Consumer)

FromRaw

Experimental

Notice: This API is EXPERIMENTAL and may be changed or removed in a later release.

func (*Consumer) ToRaw ¶

func (c *Consumer) ToRaw(raw *rawtopic.Consumer)

ToRaw

Experimental

Notice: This API is EXPERIMENTAL and may be changed or removed in a later release.

type PartitionSettings ¶

type PartitionSettings struct {
	MinActivePartitions int64
	PartitionCountLimit int64
}

PartitionSettings

Experimental

Notice: This API is EXPERIMENTAL and may be changed or removed in a later release.

func (*PartitionSettings) FromRaw ¶

func (s *PartitionSettings) FromRaw(raw *rawtopic.PartitioningSettings)

FromRaw

Experimental

Notice: This API is EXPERIMENTAL and may be changed or removed in a later release.

func (*PartitionSettings) ToRaw ¶

func (s *PartitionSettings) ToRaw(raw *rawtopic.PartitioningSettings)

ToRaw

Experimental

Notice: This API is EXPERIMENTAL and may be changed or removed in a later release.

type TopicDescription ¶

type TopicDescription struct {
	Path                              string
	PartitionSettings                 PartitionSettings
	Consumers                         []Consumer
	SupportedCodecs                   []Codec
	RetentionPeriod                   time.Duration
	PartitionWriteBurstBytes          int64
	PartitionWriteSpeedBytesPerSecond int64
	Attributes                        map[string]string
}

TopicDescription

Experimental

Notice: This API is EXPERIMENTAL and may be changed or removed in a later release.

func (*TopicDescription) FromRaw ¶

func (d *TopicDescription) FromRaw(raw *rawtopic.DescribeTopicResult)

FromRaw

Experimental

Notice: This API is EXPERIMENTAL and may be changed or removed in a later release.

func (*TopicDescription) ToRaw ¶

func (d *TopicDescription) ToRaw(raw *rawtopic.DescribeTopicResult)

ToRaw

Experimental

Notice: This API is EXPERIMENTAL and may be changed or removed in a later release.

Source Files ¶

topictypes.go