memory

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 sorter.Position, err error)
• type EventSorter
  • func New(_ context.Context) *EventSorter
  • func (s *EventSorter) Add(span tablepb.Span, events ...*model.PolymorphicEvent)
  • func (s *EventSorter) AddTable(span tablepb.Span, startTs model.Ts)
  • func (s *EventSorter) CleanAllTables(upperBound sorter.Position) error
  • func (s *EventSorter) CleanByTable(span tablepb.Span, upperBound sorter.Position) error
  • func (s *EventSorter) Close() error
  • func (s *EventSorter) FetchAllTables(lowerBound sorter.Position) sorter.EventIterator
  • func (s *EventSorter) FetchByTable(span tablepb.Span, lowerBound, upperBound sorter.Position) sorter.EventIterator
  • func (s *EventSorter) GetStatsByTable(span tablepb.Span) sorter.TableStats
  • func (s *EventSorter) IsTableBased() bool
  • func (s *EventSorter) OnResolve(action func(tablepb.Span, model.Ts))
  • func (s *EventSorter) RemoveTable(span tablepb.Span)
  • func (s *EventSorter) SlotsAndHasher() (slotCount int, hasher func(tablepb.Span, int) int)

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 sorter.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 sorter.SortEngine.

func (*EventSorter) AddTable

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

AddTable implements sorter.SortEngine.

func (*EventSorter) CleanAllTables

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

CleanAllTables implements sorter.SortEngine.

func (*EventSorter) CleanByTable

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

CleanByTable implements sorter.SortEngine.

func (*EventSorter) Close

func (s *EventSorter) Close() error

Close implements sorter.SortEngine.

func (*EventSorter) FetchAllTables

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

FetchAllTables implements sorter.SortEngine.

func (*EventSorter) FetchByTable

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

FetchByTable implements sorter.SortEngine.

func (*EventSorter) GetStatsByTable

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

GetStatsByTable implements sorter.SortEngine.

func (*EventSorter) IsTableBased

func (s *EventSorter) IsTableBased() bool

IsTableBased implements sorter.SortEngine.

func (*EventSorter) OnResolve

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

OnResolve implements sorter.SortEngine.

func (*EventSorter) RemoveTable

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

RemoveTable implements sorter.SortEngine.

func (*EventSorter) SlotsAndHasher

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

SlotsAndHasher implements sorter.SortEngine.