rawtopicwriter

Documentation

Overview

nolint

nolint

Index

• type ClientMessage
• type GrpcStream
• type InitRequest
• type InitResult
• type MessageData
• type MessageWriteStatus
• type Partitioning
• type PartitioningType
• type ServerMessage
• type StreamWriter
  • func (w *StreamWriter) Recv() (ServerMessage, error)
  • func (w *StreamWriter) Send(msg ClientMessage) error
• type WriteAck
• type WriteRequest
• type WriteResult
• type WriteStatistics
• type WriteStatusSkipReason
• type WriteStatusType

Types

type ClientMessage

type ClientMessage interface {
	// contains filtered or unexported methods
}

type GrpcStream

type GrpcStream interface {
	Send(messageNew *Ydb_PersQueue_V1.StreamingWriteClientMessage) error
	Recv() (*Ydb_PersQueue_V1.StreamingWriteServerMessage, error)
	CloseSend() error
}

type InitRequest

type InitRequest struct {
	Path             string
	ProducerID       string
	WriteSessionMeta map[string]string

	Partitioning Partitioning

	GetLastSeqNo bool
	// contains filtered or unexported fields
}

type InitResult

type InitResult struct {
	rawtopiccommon.ServerMessageMetadata

	LastSeqNo       int64
	SessionID       string
	PartitionID     int64
	SupportedCodecs rawtopiccommon.SupportedCodecs
	// contains filtered or unexported fields
}

type MessageData

type MessageData struct {
	SeqNo            int64
	CreatedAt        time.Time
	UncompressedSize int64
	Partitioning     Partitioning
	Data             []byte
}

type MessageWriteStatus

type MessageWriteStatus struct {
	Type          WriteStatusType
	WrittenOffset int64
	SkippedReason WriteStatusSkipReason
}

MessageWriteStatus is struct because it included in per-message structure and places on hot-path for write messages structure will work and compile-optimization better then interface

type Partitioning

type Partitioning struct {
	Type           PartitioningType
	MessageGroupID string
	PartitionID    int64
}

Partitioning is struct because it included in per-message structure and places on hot-path for write messages structure will work and compile-optimization better then interface

type PartitioningType

type PartitioningType int

const (
	PartitioningUndefined PartitioningType = iota
	PartitioningMessageGroupID
	PartitioningPartitionID
)

type ServerMessage

type ServerMessage interface {
	StatusData() rawtopiccommon.ServerMessageMetadata
	SetStatus(status rawydb.StatusCode)
	// contains filtered or unexported methods
}

type StreamWriter

type StreamWriter struct {
	Stream GrpcStream
}

func (*StreamWriter) Recv

func (w *StreamWriter) Recv() (ServerMessage, error)

func (*StreamWriter) Send

func (w *StreamWriter) Send(msg ClientMessage) error

type WriteAck

type WriteAck struct {
	SeqNo              int64
	MessageWriteStatus MessageWriteStatus
}

type WriteRequest

type WriteRequest struct {
	Messages []MessageData
	Codec    rawtopiccommon.Codec
	// contains filtered or unexported fields
}

type WriteResult

type WriteResult struct {
	rawtopiccommon.ServerMessageMetadata

	Acks            []WriteAck
	PartitionID     int64
	WriteStatistics WriteStatistics
	// contains filtered or unexported fields
}

type WriteStatistics

type WriteStatistics struct {
	PersistingTime     time.Duration
	MinQueueWaitTime   time.Duration
	MaxQueueWaitTime   time.Duration
	TopicQuotaWaitTime time.Duration
}

type WriteStatusSkipReason

type WriteStatusSkipReason int

const (
	WriteStatusSkipReasonUnspecified    WriteStatusSkipReason = 0
	WriteStatusSkipReasonAlreadyWritten WriteStatusSkipReason = 1
)

type WriteStatusType

type WriteStatusType int

const (
	WriteStatusTypeUnknown WriteStatusType = iota
	WriteStatusTypeWritten
	WriteStatusTypeSkipped
)