rawtopiccommon

package
v3.38.3 Latest Latest
Warning

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

Go to latest
Published: Oct 3, 2022 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

View Source
const (
	CodecUNSPECIFIED Codec = iota
	CodecRaw               = Codec(Ydb_Topic.Codec_CODEC_RAW)
	CodecGzip              = Codec(Ydb_Topic.Codec_CODEC_GZIP)
	CodecLzop              = Codec(Ydb_Topic.Codec_CODEC_LZOP)
	CodecZstd              = Codec(Ydb_Topic.Codec_CODEC_ZSTD)
)
View Source
const (
	CodecCustomerFirst = 10000
	CodecCustomerEnd   = 20000 // last allowed custom codec id is 19999
)

Variables

This section is empty.

Functions

This section is empty.

Types

type Codec

type Codec int

Codec any int value, for example for custom codec

func (Codec) IsCustomerCodec

func (c Codec) IsCustomerCodec() bool

func (*Codec) MustFromProto

func (c *Codec) MustFromProto(codec Ydb_Topic.Codec)

func (Codec) ToInt32 added in v3.38.0

func (c Codec) ToInt32() int32

func (Codec) ToProto

func (c Codec) ToProto() Ydb_Topic.Codec

type ServerMessageMetadata

type ServerMessageMetadata struct {
	Status rawydb.StatusCode
	Issues rawydb.Issues
}

func (*ServerMessageMetadata) MetaFromStatusAndIssues

func (m *ServerMessageMetadata) MetaFromStatusAndIssues(p StatusAndIssues) error

func (*ServerMessageMetadata) SetStatus

func (m *ServerMessageMetadata) SetStatus(status rawydb.StatusCode)

func (*ServerMessageMetadata) StatusData

type StatusAndIssues

type StatusAndIssues interface {
	GetStatus() Ydb.StatusIds_StatusCode
	GetIssues() []*Ydb_Issue.IssueMessage
}

type SupportedCodecs

type SupportedCodecs []Codec

func (*SupportedCodecs) AllowedByCodecsList added in v3.38.0

func (c *SupportedCodecs) AllowedByCodecsList(need Codec) bool

func (*SupportedCodecs) Clone added in v3.38.0

func (c *SupportedCodecs) Clone() SupportedCodecs

func (*SupportedCodecs) Contains added in v3.38.0

func (c *SupportedCodecs) Contains(need Codec) bool

func (*SupportedCodecs) IsEqualsTo added in v3.38.0

func (c *SupportedCodecs) IsEqualsTo(other SupportedCodecs) bool

func (*SupportedCodecs) MustFromProto

func (c *SupportedCodecs) MustFromProto(proto *Ydb_Topic.SupportedCodecs)

func (*SupportedCodecs) ToProto

type UpdateTokenRequest

type UpdateTokenRequest struct {
	Token string
}

func (*UpdateTokenRequest) ToProto added in v3.38.0

type UpdateTokenResponse

type UpdateTokenResponse struct{}

func (*UpdateTokenResponse) MustFromProto added in v3.38.0

func (r *UpdateTokenResponse) MustFromProto(p *Ydb_Topic.UpdateTokenResponse)

Jump to

Keyboard shortcuts

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