factory

Documentation

Index

• type SortEngineFactory
  • func NewForPebble(dir string, memQuotaInBytes uint64, cfg *config.DBConfig) *SortEngineFactory
  • func (f *SortEngineFactory) Close() (err error)
  • func (f *SortEngineFactory) Create(ID model.ChangeFeedID) (e sorter.SortEngine, err error)
  • func (f *SortEngineFactory) Drop(ID model.ChangeFeedID) error

Types

type SortEngineFactory

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

SortEngineFactory is a manager to create or drop SortEngine.

func NewForPebble

func NewForPebble(dir string, memQuotaInBytes uint64, cfg *config.DBConfig) *SortEngineFactory

NewForPebble will create a SortEngineFactory for the pebble implementation.

func (*SortEngineFactory) Close

func (f *SortEngineFactory) Close() (err error)

Close will close all created engines and release all resources.

func (*SortEngineFactory) Create

func (f *SortEngineFactory) Create(ID model.ChangeFeedID) (e sorter.SortEngine, err error)

Create creates a SortEngine. If an engine with same ID already exists, it will be returned directly.

func (*SortEngineFactory) Drop

func (f *SortEngineFactory) Drop(ID model.ChangeFeedID) error

Drop cleans the given event sort engine.