Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var (
// KeySlotOffset tags metrics with the slot offset.
KeySlotOffset, _ = tag.NewKey("slot_offset")
)
View Source
var SlotMgrMeasures = struct { SlotsAvailable *stats.Int64Measure SlotsAcquired *stats.Int64Measure SlotsReleased *stats.Int64Measure SlotErrors *stats.Int64Measure }{ SlotsAvailable: stats.Int64(pre+"slots_available", "Number of available slots.", stats.UnitDimensionless), SlotsAcquired: stats.Int64(pre+"slots_acquired", "Total number of slots acquired.", stats.UnitDimensionless), SlotsReleased: stats.Int64(pre+"slots_released", "Total number of slots released.", stats.UnitDimensionless), SlotErrors: stats.Int64(pre+"slot_errors", "Total number of slot errors (e.g., failed to put).", stats.UnitDimensionless), }
SlotMgrMeasures groups the high-level slotmgr metrics.
View Source
var SlotMgrSlotMeasures = struct { SlotInUse *stats.Int64Measure SlotSectorCount *stats.Int64Measure }{ SlotInUse: stats.Int64(pre+"slot_in_use", "Slot actively in use (batch sealing). 1=in use, 0=not in use", stats.UnitDimensionless), SlotSectorCount: stats.Int64(pre+"slot_sector_count", "Number of sectors in the slot", stats.UnitDimensionless), }
SlotMgrSlotMeasures groups per-slot metrics.
View Source
var WatchInterval = 5 * time.Minute
Functions ¶
This section is empty.
Types ¶
type SlotMgr ¶
type SlotMgr struct {
// contains filtered or unexported fields
}
func NewSlotMgr ¶
NewSlotMgr creates the SlotMgr and initializes local references from the DB.
func (*SlotMgr) AbortSlot ¶ added in v1.24.4
AbortSlot marks a slot which was used for work as immediately free
func (*SlotMgr) MarkWorkDone ¶ added in v1.24.4
MarkWorkDone marks a slot as no longer being actively used for batch sealing This is when sectors start waiting for finalization (After C1 outputs were produced)
Click to show internal directories.
Click to hide internal directories.