iterator

Documentation

Index

• Constants
• Variables
• type BinlogIterator
  • func NewInsertBinlogIterator(v [][]byte, pkFieldID typeutil.UniqueID, pkType schemapb.DataType, ...) (*BinlogIterator, error)
  • func (i *BinlogIterator) Dispose()
  • func (i *BinlogIterator) HasNext() bool
  • func (i *BinlogIterator) Next() (*LabeledRowData, error)
  • func (i *BinlogIterator) WaitForDisposed()
• type DeltalogIterator
  • func NewDeltalogIterator(v [][]byte, label *Label) *DeltalogIterator
  • func (d *DeltalogIterator) Dispose()
  • func (d *DeltalogIterator) HasNext() bool
  • func (d *DeltalogIterator) Next() (*LabeledRowData, error)
  • func (d *DeltalogIterator) WaitForDisposed()
• type DeltalogRow
  • func (r *DeltalogRow) GetPk() storage.PrimaryKey
  • func (r *DeltalogRow) GetTimestamp() uint64
• type InsertRow
  • func (r *InsertRow) GetPk() storage.PrimaryKey
  • func (r *InsertRow) GetTimestamp() uint64
• type Iterator
• type Label
• type LabeledRowData
  • func NewLabeledRowData(data Row, label *Label) *LabeledRowData
  • func (l *LabeledRowData) GetLabel() *Label
  • func (l *LabeledRowData) GetPk() storage.PrimaryKey
  • func (l *LabeledRowData) GetSegmentID() typeutil.UniqueID
  • func (l *LabeledRowData) GetTimestamp() uint64
• type Row

Constants

const InvalidID int64 = -1

Variables

var (
	// ErrNoMoreRecord is the error that the iterator does not have next record.
	ErrNoMoreRecord = errors.New("no more record")
	// ErrDisposed is the error that the iterator is disposed.
	ErrDisposed = errors.New("iterator is disposed")
)

Types

type BinlogIterator

type BinlogIterator struct {
	// contains filtered or unexported fields
}

func NewInsertBinlogIterator

func NewInsertBinlogIterator(v [][]byte, pkFieldID typeutil.UniqueID, pkType schemapb.DataType, label *Label) (*BinlogIterator, error)

NewInsertBinlogIterator creates a new iterator

func (*BinlogIterator) Dispose

func (i *BinlogIterator) Dispose()

Dispose disposes the iterator

func (*BinlogIterator) HasNext

func (i *BinlogIterator) HasNext() bool

HasNext returns true if the iterator have unread record

func (*BinlogIterator) Next

func (i *BinlogIterator) Next() (*LabeledRowData, error)

func (*BinlogIterator) WaitForDisposed

func (i *BinlogIterator) WaitForDisposed()

Disposed wait forever for the iterator to dispose

type DeltalogIterator

type DeltalogIterator struct {
	// contains filtered or unexported fields
}

func NewDeltalogIterator

func NewDeltalogIterator(v [][]byte, label *Label) *DeltalogIterator

func (*DeltalogIterator) Dispose

func (d *DeltalogIterator) Dispose()

func (*DeltalogIterator) HasNext

func (d *DeltalogIterator) HasNext() bool

func (*DeltalogIterator) Next

func (d *DeltalogIterator) Next() (*LabeledRowData, error)

func (*DeltalogIterator) WaitForDisposed

func (d *DeltalogIterator) WaitForDisposed()

type DeltalogRow

type DeltalogRow struct {
	Pk        storage.PrimaryKey
	Timestamp typeutil.Timestamp
}

func (*DeltalogRow) GetPk

func (r *DeltalogRow) GetPk() storage.PrimaryKey

func (*DeltalogRow) GetTimestamp

func (r *DeltalogRow) GetTimestamp() uint64

type InsertRow

type InsertRow struct {
	ID        int64
	Pk        storage.PrimaryKey
	Timestamp typeutil.Timestamp
	Value     map[storage.FieldID]interface{}
}

func (*InsertRow) GetPk

func (r *InsertRow) GetPk() storage.PrimaryKey

func (*InsertRow) GetTimestamp

func (r *InsertRow) GetTimestamp() uint64

type Iterator

type Iterator interface {
	HasNext() bool
	Next() (*LabeledRowData, error)
	Dispose()
	WaitForDisposed() // wait until the iterator is disposed
}

type Label

type Label struct {
	// contains filtered or unexported fields
}

type LabeledRowData

type LabeledRowData struct {
	// contains filtered or unexported fields
}

func NewLabeledRowData

func NewLabeledRowData(data Row, label *Label) *LabeledRowData

func (*LabeledRowData) GetLabel

func (l *LabeledRowData) GetLabel() *Label

func (*LabeledRowData) GetPk

func (l *LabeledRowData) GetPk() storage.PrimaryKey

func (*LabeledRowData) GetSegmentID

func (l *LabeledRowData) GetSegmentID() typeutil.UniqueID

func (*LabeledRowData) GetTimestamp

func (l *LabeledRowData) GetTimestamp() uint64

type Row

type Row interface {
	GetPk() storage.PrimaryKey
	GetTimestamp() uint64
}