Documentation
¶
Index ¶
Constants ¶
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 )
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.
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 ¶
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
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 ¶
func (d *TopicDescription) FromRaw(raw *rawtopic.DescribeTopicResult)
FromRaw
Experimental ¶
Notice: This API is EXPERIMENTAL and may be changed or removed in a later release.
Source Files