rawtopicreader

type Batch struct {
	Codec rawtopiccommon.Codec

	ProducerID       string
	WriteSessionMeta map[string]string // nil if session meta is empty
	WrittenAt        time.Time

	MessageData []MessageData
}

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

type CommitOffsetRequest struct {
	CommitOffsets []PartitionCommitOffset
	// contains filtered or unexported fields
}

type CommitOffsetResponse struct {
	rawtopiccommon.ServerMessageMetadata

	PartitionsCommittedOffsets []PartitionCommittedOffset
	// contains filtered or unexported fields
}

type EndPartitionSession struct {
	rawtopiccommon.ServerMessageMetadata

	PartitionSessionID   PartitionSessionID
	AdjacentPartitionIDs []int64
	ChildPartitionIDs    []int64
	// contains filtered or unexported fields
}

type GrpcStream interface {
	Send(messageNew *Ydb_Topic.StreamReadMessage_FromClient) error
	Recv() (*Ydb_Topic.StreamReadMessage_FromServer, error)
	CloseSend() error
}

type InitRequest struct {
	TopicsReadSettings []TopicReadSettings

	Consumer                string
	AutoPartitioningSupport bool
	// contains filtered or unexported fields
}

type InitResponse struct {
	rawtopiccommon.ServerMessageMetadata

	SessionID string
	// contains filtered or unexported fields
}

type MessageData struct {
	Offset           rawtopiccommon.Offset
	SeqNo            int64
	CreatedAt        time.Time
	Data             []byte
	UncompressedSize int64
	MessageGroupID   string
	MetadataItems    []rawtopiccommon.MetadataItem
}

type OptionalOffset struct {
	Offset   rawtopiccommon.Offset
	HasValue bool
}

type PartitionCommitOffset struct {
	PartitionSessionID PartitionSessionID
	Offsets            []rawtopiccommon.OffsetRange
}

type PartitionCommittedOffset struct {
	PartitionSessionID PartitionSessionID
	CommittedOffset    rawtopiccommon.Offset
}

type PartitionData struct {
	PartitionSessionID PartitionSessionID

	Batches []Batch
}

type PartitionSession struct {
	PartitionSessionID PartitionSessionID
	Path               string // Topic path of partition
	PartitionID        int64
}

type PartitionSessionID int64

type PartitionSessionStatusRequest struct {
	PartitionSessionID PartitionSessionID
	// contains filtered or unexported fields
}

type PartitionSessionStatusResponse struct {
	rawtopiccommon.ServerMessageMetadata

	PartitionSessionID     PartitionSessionID
	PartitionOffsets       rawtopiccommon.OffsetRange
	WriteTimeHighWatermark time.Time
	// contains filtered or unexported fields
}

type ReadRequest struct {
	BytesSize int
	// contains filtered or unexported fields
}

type ReadResponse struct {
	rawtopiccommon.ServerMessageMetadata

	BytesSize     int
	PartitionData []PartitionData
	// contains filtered or unexported fields
}

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

type StartPartitionSessionRequest struct {
	rawtopiccommon.ServerMessageMetadata

	PartitionSession PartitionSession
	CommittedOffset  rawtopiccommon.Offset
	PartitionOffsets rawtopiccommon.OffsetRange
	// contains filtered or unexported fields
}

type StartPartitionSessionResponse struct {
	PartitionSessionID PartitionSessionID
	ReadOffset         OptionalOffset
	CommitOffset       OptionalOffset
	// contains filtered or unexported fields
}

type StopPartitionSessionRequest struct {
	rawtopiccommon.ServerMessageMetadata

	PartitionSessionID PartitionSessionID
	Graceful           bool
	CommittedOffset    rawtopiccommon.Offset
	// contains filtered or unexported fields
}

type StopPartitionSessionResponse struct {
	PartitionSessionID PartitionSessionID
	// contains filtered or unexported fields
}

type StreamReader struct {
	Stream   GrpcStream
	ReaderID int64

	Tracer *trace.Topic
	// contains filtered or unexported fields
}

type TopicReadSettings struct {
	Path         string
	PartitionsID []int64

	MaxLag   rawoptional.Duration
	ReadFrom rawoptional.Time
}

type TopicReaderStreamInterface interface {
	Recv() (ServerMessage, error)
	Send(msg ClientMessage) error
	CloseSend() error
}

type UpdateTokenRequest struct {
	rawtopiccommon.UpdateTokenRequest
	// contains filtered or unexported fields
}

type UpdateTokenResponse struct {
	rawtopiccommon.UpdateTokenResponse

	rawtopiccommon.ServerMessageMetadata
	// contains filtered or unexported fields
}