Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func InitMetrics ¶
func InitMetrics(registry *prometheus.Registry)
InitMetrics registers all metrics in this file
func ResetGlobalPoolWithoutCleanup ¶
func ResetGlobalPoolWithoutCleanup()
ResetGlobalPoolWithoutCleanup reset the pool without cleaning up files. Note that it is used in tests only.
func RunWorkerPool ¶
RunWorkerPool runs the worker pool used by the heapSorters It **must** be running for Unified Sorter to work.
Types ¶
type Sorter ¶
type Sorter struct {
// contains filtered or unexported fields
}
Sorter provides both sorting in memory and in file. Memory pressure is used to determine which one to use.
func NewUnifiedSorter ¶
func NewUnifiedSorter( dir string, changeFeedID model.ChangeFeedID, keyspanName string, keyspanID model.KeySpanID, captureAddr string, ) (*Sorter, error)
NewUnifiedSorter creates a new Sorter
func (*Sorter) AddEntry ¶
func (s *Sorter) AddEntry(ctx context.Context, entry *model.PolymorphicEvent)
AddEntry implements the EventSorter interface
func (*Sorter) Output ¶
func (s *Sorter) Output() <-chan *model.PolymorphicEvent
Output implements the EventSorter interface
func (*Sorter) TryAddEntry ¶
TryAddEntry implements the EventSorter interface
Source Files
Click to show internal directories.
Click to hide internal directories.