package rawtopiccommon

import "github.com/ydb-platform/ydb-go-sdk/v3/internal/grpcwrapper/rawtopic/rawtopiccommon"

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{}

Source Files ¶

codec.go server_message_metadata.go update_token.go