rawtopiccommon

Documentation

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)