Versions in this module Expand all Collapse all v3 v3.80.13 Sep 25, 2024 v3.80.12 Sep 24, 2024 Changes in this version + var ErrUnexpectedMessageType = errors.New("unexpected message type") + type Batch struct + Codec rawtopiccommon.Codec + MessageData []MessageData + ProducerID string + WriteSessionMeta map[string]string + WrittenAt time.Time + type ClientMessage interface + type CommitOffsetRequest struct + CommitOffsets []PartitionCommitOffset + type CommitOffsetResponse struct + PartitionsCommittedOffsets []PartitionCommittedOffset + type GrpcStream interface + CloseSend func() error + Recv func() (*Ydb_Topic.StreamReadMessage_FromServer, error) + Send func(messageNew *Ydb_Topic.StreamReadMessage_FromClient) error + type InitRequest struct + Consumer string + TopicsReadSettings []TopicReadSettings + func (r *InitRequest) GetConsumer() string + func (r *InitRequest) GetTopics() []string + type InitResponse struct + SessionID string + type MessageData struct + CreatedAt time.Time + Data []byte + MessageGroupID string + MetadataItems []rawtopiccommon.MetadataItem + Offset rawtopiccommon.Offset + SeqNo int64 + UncompressedSize int64 + type OptionalOffset struct + HasValue bool + Offset rawtopiccommon.Offset + func (offset *OptionalOffset) FromInt64(v int64) + func (offset *OptionalOffset) FromInt64Pointer(v *int64) + func (offset OptionalOffset) ToInt64() int64 + func (offset OptionalOffset) ToInt64Pointer() *int64 + type PartitionCommitOffset struct + Offsets []rawtopiccommon.OffsetRange + PartitionSessionID PartitionSessionID + type PartitionCommittedOffset struct + CommittedOffset rawtopiccommon.Offset + PartitionSessionID PartitionSessionID + type PartitionData struct + Batches []Batch + PartitionSessionID PartitionSessionID + type PartitionSession struct + PartitionID int64 + PartitionSessionID PartitionSessionID + Path string + type PartitionSessionID int64 + func (id *PartitionSessionID) FromInt64(v int64) + func (id PartitionSessionID) ToInt64() int64 + type PartitionSessionStatusRequest struct + PartitionSessionID PartitionSessionID + type PartitionSessionStatusResponse struct + PartitionOffsets rawtopiccommon.OffsetRange + PartitionSessionID PartitionSessionID + WriteTimeHighWatermark time.Time + type ReadRequest struct + BytesSize int + type ReadResponse struct + BytesSize int + PartitionData []PartitionData + func (r *ReadResponse) GetBytesSize() int + func (r *ReadResponse) GetPartitionBatchMessagesCounts() (partitionDataCount, batchCount, messagesCount int) + type ServerMessage interface + SetStatus func(status rawydb.StatusCode) + StatusData func() rawtopiccommon.ServerMessageMetadata + type StartPartitionSessionRequest struct + CommittedOffset rawtopiccommon.Offset + PartitionOffsets rawtopiccommon.OffsetRange + PartitionSession PartitionSession + type StartPartitionSessionResponse struct + CommitOffset OptionalOffset + PartitionSessionID PartitionSessionID + ReadOffset OptionalOffset + type StopPartitionSessionRequest struct + CommittedOffset rawtopiccommon.Offset + Graceful bool + PartitionSessionID PartitionSessionID + type StopPartitionSessionResponse struct + PartitionSessionID PartitionSessionID + type StreamReader struct + Stream GrpcStream + func (s StreamReader) CloseSend() error + func (s StreamReader) Recv() (ServerMessage, error) + func (s StreamReader) Send(msg ClientMessage) (err error) + type TopicReadSettings struct + MaxLag rawoptional.Duration + PartitionsID []int64 + Path string + ReadFrom rawoptional.Time + type TopicReaderStreamInterface interface + CloseSend func() error + Recv func() (ServerMessage, error) + Send func(msg ClientMessage) error + type UpdateTokenRequest struct + type UpdateTokenResponse struct
Go to main page