gcworker

Documentation

Index

• func NewGCWorker(store tikv.Storage) (tikv.GCHandler, error)
• type GCWorker
  • func (w *GCWorker) Close()
  • func (w *GCWorker) Start()
• type MockGCWorker
  • func NewMockGCWorker(store tikv.Storage) (*MockGCWorker, error)
  • func (w *MockGCWorker) DeleteRanges(ctx context.Context, safePoint uint64) error

Functions

func NewGCWorker

func NewGCWorker(store tikv.Storage) (tikv.GCHandler, error)

NewGCWorker creates a GCWorker instance.

Types

type GCWorker

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

GCWorker periodically triggers GC process on tikv server.

func (*GCWorker) Close

func (w *GCWorker) Close()

Close stops background goroutines.

func (*GCWorker) Start

func (w *GCWorker) Start()

Start starts the worker.

type MockGCWorker

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

MockGCWorker is for test.

func NewMockGCWorker

func NewMockGCWorker(store tikv.Storage) (*MockGCWorker, error)

NewMockGCWorker creates a MockGCWorker instance ONLY for test.

func (*MockGCWorker) DeleteRanges

func (w *MockGCWorker) DeleteRanges(ctx context.Context, safePoint uint64) error

DeleteRanges call deleteRanges internally, just for test.