...
Package compactor
Overview ▹
Index ▹
type Compactable ¶
type Compactable interface {
Compact(ctx context.Context, r *pb.CompactionRequest) (*pb.CompactionResponse, error)
}
type Periodic ¶
Periodic compacts the log by purging revisions older than the configured retention time. Compaction happens hourly.
type Periodic struct {
// contains filtered or unexported fields
}
func NewPeriodic ¶
func NewPeriodic(h int, rg RevGetter, c Compactable) *Periodic
func (*Periodic) Pause ¶
func (t *Periodic) Pause()
func (*Periodic) Resume ¶
func (t *Periodic) Resume()
func (*Periodic) Run ¶
func (t *Periodic) Run()
func (*Periodic) Stop ¶
func (t *Periodic) Stop()
type RevGetter ¶
type RevGetter interface {
Rev() int64
}
ActiveGo 1.8