rawtopiccommon

Documentation

Index

• Constants
• type Codec
  • func (c Codec) IsCustomerCodec() bool
  • func (c *Codec) MustFromProto(codec Ydb_Topic.Codec)
  • func (c Codec) ToProto() Ydb_Topic.Codec
• type ServerMessageMetadata
  • func (m *ServerMessageMetadata) MetaFromStatusAndIssues(p StatusAndIssues) error
  • func (m *ServerMessageMetadata) SetStatus(status rawydb.StatusCode)
  • func (m *ServerMessageMetadata) StatusData() ServerMessageMetadata
• type StatusAndIssues
• type SupportedCodecs
  • func (c *SupportedCodecs) MustFromProto(proto *Ydb_Topic.SupportedCodecs)
  • func (c SupportedCodecs) ToProto() *Ydb_Topic.SupportedCodecs
• type UpdateTokenRequest
• type UpdateTokenResponse

Constants

const (
	CodecUNSPECIFIED Codec = iota
	CodecRaw               = Codec(Ydb_PersQueue_V1.Codec_CODEC_RAW)
	CodecGzip              = Codec(Ydb_PersQueue_V1.Codec_CODEC_GZIP)
	CodecLzop              = Codec(Ydb_PersQueue_V1.Codec_CODEC_LZOP)
	CodecZstd              = Codec(Ydb_PersQueue_V1.Codec_CODEC_ZSTD)
)

const (
	CodecCustomerFirst = 10000
	CodecCustomerEnd   = 20000 // last allowed custom codec id is 19999
)

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) 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

func (m *ServerMessageMetadata) StatusData() ServerMessageMetadata

type StatusAndIssues

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

type SupportedCodecs

type SupportedCodecs []Codec

func (*SupportedCodecs) MustFromProto

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

func (SupportedCodecs) ToProto

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

type UpdateTokenRequest

type UpdateTokenRequest struct {
	Token string
}

type UpdateTokenResponse

type UpdateTokenResponse struct{}