gc_scan

Documentation

Index

• Constants
• type GcScan
  • func NewGcScan(ctx context.Context, store *storage.YigFsStorage, gcCfg helper.GcConfig, ...) (gcScan *GcScan, err error)
  • func (gs *GcScan) Run()
  • func (gs *GcScan) Stop()
• type GcSegment
  • func (g *GcSegment) GetCost(ctx context.Context, seg *types.GcSegmentInfo) (cost float64)
  • func (g *GcSegment) GetMaxAndMinAge(segs []int64)
• type Heap
  • func NewHeap(maxSize int) *Heap
  • func (h *Heap) GetTopHeapValue() float64
  • func (h *Heap) Pop() (seg *types.GcSegmentInfo)
  • func (h *Heap) Push(seg *types.GcSegmentInfo)

Constants

const (
	MAX_CONST float64 = 10000
)

Types

type GcScan

type GcScan struct {
	Unit   string
	Period int
	Store  *storage.YigFsStorage
	// contains filtered or unexported fields
}

func NewGcScan

func NewGcScan(ctx context.Context, store *storage.YigFsStorage, gcCfg helper.GcConfig, msgBus helper.MsgBusConfig, leadeMgr *tools.LeaderMgr, wg *sync.WaitGroup, gcExecuting, gcCompleted int) (gcScan *GcScan, err error)

func (*GcScan) Run

func (gs *GcScan) Run()

func (*GcScan) Stop

func (gs *GcScan) Stop()

type GcSegment

type GcSegment struct {
}

func (*GcSegment) GetCost

func (g *GcSegment) GetCost(ctx context.Context, seg *types.GcSegmentInfo) (cost float64)

func (*GcSegment) GetMaxAndMinAge

func (g *GcSegment) GetMaxAndMinAge(segs []int64)

type Heap

type Heap struct {
	Size  int
	Elems []*types.GcSegmentInfo
}

func NewHeap

func NewHeap(maxSize int) *Heap

func (*Heap) GetTopHeapValue

func (h *Heap) GetTopHeapValue() float64

func (*Heap) Pop

func (h *Heap) Pop() (seg *types.GcSegmentInfo)

func (*Heap) Push

func (h *Heap) Push(seg *types.GcSegmentInfo)