topictypes

package
v3.43.0-rc6 Latest Latest
Warning

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

Go to latest
Published: Mar 7, 2023 License: Apache-2.0 Imports: 4 Imported by: 5

Documentation

Index

Constants

View Source
const (
	CodecRaw  = Codec(rawtopiccommon.CodecRaw)
	CodecGzip = Codec(rawtopiccommon.CodecGzip)

	// CodecLzop not supported by default, customer need provide own codec library
	CodecLzop = Codec(rawtopiccommon.CodecLzop)

	// CodecZstd not supported by default, customer need provide own codec library
	CodecZstd = Codec(rawtopiccommon.CodecZstd)

	CodecCustomerFirst = Codec(rawtopiccommon.CodecCustomerFirst)
	CodecCustomerEnd   = Codec(rawtopiccommon.CodecCustomerEnd) // last allowed custom codec id is CodecCustomerEnd-1
)
View Source
const (
	MeteringModeUnspecified      = MeteringMode(rawtopic.MeteringModeUnspecified)
	MeteringModeReservedCapacity = MeteringMode(rawtopic.MeteringModeReservedCapacity)
	MeteringModeRequestUnits     = MeteringMode(rawtopic.MeteringModeRequestUnits)
)

Variables

This section is empty.

Functions

This section is empty.

Types

type Codec

type Codec int

Codec

Experimental

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

func (Codec) ToRaw added in v3.38.2

func (c Codec) ToRaw(r *rawtopiccommon.Codec)

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 added in v3.35.0

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 MeteringMode added in v3.38.2

type MeteringMode int

MeteringMode

Experimental

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

func (*MeteringMode) FromRaw added in v3.38.2

func (m *MeteringMode) FromRaw(raw rawtopic.MeteringMode)

FromRaw

Experimental

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

func (*MeteringMode) ToRaw added in v3.38.2

func (m *MeteringMode) ToRaw(raw *rawtopic.MeteringMode)

ToRaw

Experimental

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

type PartitionInfo added in v3.38.2

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

PartitionInfo

Experimental

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

func (*PartitionInfo) FromRaw added in v3.38.2

func (p *PartitionInfo) FromRaw(raw *rawtopic.PartitionInfo)

FromRaw

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

FromRaw

Experimental

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

func (*PartitionSettings) ToRaw

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
	Partitions                        []PartitionInfo
	RetentionPeriod                   time.Duration
	RetentionStorageMB                int64
	SupportedCodecs                   []Codec
	PartitionWriteBurstBytes          int64
	PartitionWriteSpeedBytesPerSecond int64
	Attributes                        map[string]string
	Consumers                         []Consumer
	MeteringMode                      MeteringMode
}

TopicDescription

Experimental

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

func (*TopicDescription) FromRaw

FromRaw

Experimental

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL