memory

package

v0.0.0-...-e8ccb34 Latest Latest Go to latest Published: Aug 15, 2025 License: Apache-2.0 Imports: 10 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/pingcap/tiflow

Links

Documentation ¶

Overview ¶

Package memory is an in-memory table based EventSortEngine implementation.

Index ¶

type EventIter
- func (s *EventIter) Close() error
- func (s *EventIter) Next() (event *model.PolymorphicEvent, txnFinished engine.Position, err error)
type EventSorter
- func New(_ context.Context) *EventSorter

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type EventIter ¶

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

EventIter implements sorter.EventIterator.

func (*EventIter) Close ¶

func (s *EventIter) Close() error

Close implements sorter.EventIterator.

func (*EventIter) Next ¶

func (s *EventIter) Next() (event *model.PolymorphicEvent, txnFinished engine.Position, err error)

Next implements sorter.EventIterator.

type EventSorter ¶

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

EventSorter accepts out-of-order raw kv entries and output sorted entries.

func New ¶

func New(_ context.Context) *EventSorter

New creates a new tableSorter.

func (*EventSorter) Add ¶

func (s *EventSorter) Add(span tablepb.Span, events ...*model.PolymorphicEvent)

Add implements engine.SortEngine.

func (*EventSorter) AddTable ¶

func (s *EventSorter) AddTable(span tablepb.Span, startTs model.Ts)

AddTable implements engine.SortEngine.

func (*EventSorter) CleanAllTables ¶

func (s *EventSorter) CleanAllTables(upperBound engine.Position) error

CleanAllTables implements engine.SortEngine.

func (*EventSorter) CleanByTable ¶

func (s *EventSorter) CleanByTable(span tablepb.Span, upperBound engine.Position) error

CleanByTable implements engine.SortEngine.

func (*EventSorter) Close ¶

func (s *EventSorter) Close() error

Close implements engine.SortEngine.

func (*EventSorter) FetchAllTables ¶

func (s *EventSorter) FetchAllTables(lowerBound engine.Position) engine.EventIterator

FetchAllTables implements engine.SortEngine.

func (*EventSorter) FetchByTable ¶

func (s *EventSorter) FetchByTable(span tablepb.Span, lowerBound, upperBound engine.Position) engine.EventIterator

FetchByTable implements engine.SortEngine.

func (*EventSorter) GetStatsByTable ¶

func (s *EventSorter) GetStatsByTable(span tablepb.Span) engine.TableStats

GetStatsByTable implements engine.SortEngine.

func (*EventSorter) IsTableBased ¶

func (s *EventSorter) IsTableBased() bool

IsTableBased implements engine.SortEngine.

func (*EventSorter) OnResolve ¶

func (s *EventSorter) OnResolve(action func(tablepb.Span, model.Ts))

OnResolve implements engine.SortEngine.

func (*EventSorter) RemoveTable ¶

func (s *EventSorter) RemoveTable(span tablepb.Span)

RemoveTable implements engine.SortEngine.

func (*EventSorter) SlotsAndHasher ¶

func (s *EventSorter) SlotsAndHasher() (slotCount int, hasher func(tablepb.Span, int) int)

SlotsAndHasher implements engine.SortEngine.

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL