Documentation ¶
Index ¶
- func NewGCWorker(store tikv.Storage, pdClient pd.Client) (tikv.GCHandler, error)
- func RunDistributedGCJob(ctx context.Context, s tikv.Storage, pd pd.Client, safePoint uint64, ...) error
- func RunGCJob(ctx context.Context, s tikv.Storage, safePoint uint64, identifier string, ...) error
- type GCWorker
- type MockGCWorker
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewGCWorker ¶
NewGCWorker creates a GCWorker instance.
func RunDistributedGCJob ¶
func RunDistributedGCJob(ctx context.Context, s tikv.Storage, pd pd.Client, safePoint uint64, identifier string, concurrency int) error
RunDistributedGCJob notifies TiKVs to do GC. It is exported for kv api, do not use it with GCWorker at the same time. This function may not finish immediately because it may take some time to do resolveLocks. Param concurrency specifies the concurrency of resolveLocks phase.
Types ¶
type GCWorker ¶
type GCWorker struct {
// contains filtered or unexported fields
}
GCWorker periodically triggers GC process on tikv server.
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 calls deleteRanges internally, just for test.
Click to show internal directories.
Click to hide internal directories.