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 MetadataItem
• type Offset
• func NewOffset(v int64) Offset
• func (offset *Offset) FromInt64(v int64)
• func (offset Offset) ToInt64() int64
• type OffsetRange
• func (r *OffsetRange) FromProto(p *Ydb_Topic.OffsetsRange) error
• func (r *OffsetRange) ToProto() *Ydb_Topic.OffsetsRange
• 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 TransactionIdentity
• func (t TransactionIdentity) ToProto() *Ydb_Topic.TransactionIdentity
• 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 int32

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 MetadataItem ¶

type MetadataItem struct {
	Key   string
	Value []byte
}

type Offset ¶

type Offset int64

func NewOffset ¶

func NewOffset(v int64) Offset

func (*Offset) FromInt64 ¶

func (offset *Offset) FromInt64(v int64)

func (Offset) ToInt64 ¶

func (offset Offset) ToInt64() int64

type OffsetRange ¶

type OffsetRange struct {
	Start Offset
	End   Offset
}

func (*OffsetRange) FromProto ¶

func (r *OffsetRange) FromProto(p *Ydb_Topic.OffsetsRange) error

func (*OffsetRange) ToProto ¶

func (r *OffsetRange) ToProto() *Ydb_Topic.OffsetsRange

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 TransactionIdentity ¶

type TransactionIdentity struct {
	ID      string
	Session string
}

func (TransactionIdentity) ToProto ¶

func (t TransactionIdentity) ToProto() *Ydb_Topic.TransactionIdentity

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 message_metadata.go offset.go rangeoffset.go server_message_metadata.go transaction.go update_token.go