...
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 }