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) ToInt32() int32
• 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) AllowedByCodecsList(need Codec) bool
• func (c *SupportedCodecs) Clone() SupportedCodecs
• func (c *SupportedCodecs) Contains(need Codec) bool
• func (c *SupportedCodecs) IsEqualsTo(other SupportedCodecs) bool
• func (c *SupportedCodecs) MustFromProto(proto *Ydb_Topic.SupportedCodecs)
• func (c *SupportedCodecs) ToProto() *Ydb_Topic.SupportedCodecs
• type UpdateTokenRequest
• func (r *UpdateTokenRequest) ToProto() *Ydb_Topic.UpdateTokenRequest
• type UpdateTokenResponse
• func (r *UpdateTokenResponse) MustFromProto(p *Ydb_Topic.UpdateTokenResponse)

Constants ¶

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

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

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 ¶

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

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

func (*SupportedCodecs) Clone ¶

func (c *SupportedCodecs) Clone() SupportedCodecs

func (*SupportedCodecs) Contains ¶

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

func (*SupportedCodecs) IsEqualsTo ¶

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

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
}

func (*UpdateTokenRequest) ToProto ¶

func (r *UpdateTokenRequest) ToProto() *Ydb_Topic.UpdateTokenRequest

type UpdateTokenResponse ¶

type UpdateTokenResponse struct{}

func (*UpdateTokenResponse) MustFromProto ¶

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

Source Files ¶

codec.go server_message_metadata.go update_token.go