unit

Mar 23, 2023

Changes in this version

type Scheduler

+ func (s *Scheduler) GetAvgCatchUpSlotDuration() int64

+ func (s *Scheduler) GetAvgUnitLife() int64

+ func (s *Scheduler) GetAvgWorkSlotDuration() int64

+ func (s *Scheduler) GetMaxSlotPace() int64

type SchedulerConfig

+ StatCycleDuration time.Duration

Mar 13, 2023

Changes in this version

type Scheduler

+ func (s *Scheduler) GetAvgSlotPace() int64

+ func (s *Scheduler) GetMaxLeveledSlotPace() int64

+ func (s *Scheduler) ResetAvgSlotPace()

+ func (s *Scheduler) ResetMaxLeveledSlotPace()

type SchedulerConfig

+ SlotChangeRatePerStreak float64

+ WorkSlotPercentage float64

Dec 20, 2022

Changes in this version

+ type Scheduler struct

+ func NewScheduler(config *SchedulerConfig) *Scheduler

+ func (s *Scheduler) DebugUnit(u *Unit, unitSource string)

+ func (s *Scheduler) GetClearanceUpTo() int64

+ func (s *Scheduler) GetCurrentUnitID() int64

+ func (s *Scheduler) GetEpoch() int32

+ func (s *Scheduler) GetFinished() int64

+ func (s *Scheduler) GetFinishedInEpoch() int64

+ func (s *Scheduler) GetHighPrioUnitsInEpoch() int64

+ func (s *Scheduler) GetPausedUnitsInEpoch() int64

+ func (s *Scheduler) GetSlotPace() int64

+ func (s *Scheduler) NewUnit() *Unit

+ func (s *Scheduler) SlotScheduler(ctx context.Context) error

+ func (s *Scheduler) StartDebugLog()

+ func (s *Scheduler) State() *SchedulerState

+ func (s *Scheduler) Stop()

+ type SchedulerConfig struct

+ AdjustFractionPerStreak int64

+ EpochDuration time.Duration

+ HighPriorityMaxReserveFraction int64

+ MinSlotPace int64

+ SlotDuration time.Duration

+ type SchedulerState struct

+ ClearanceUpTo int64

+ CurrentUnitID int64

+ Epoch int32

+ Finished int64

+ FinishedInEpoch int64

+ HighPrioUnitsInEpoch int64

+ PausedUnitsInEpoch int64

+ SlotPace int64

+ type Unit struct

+ func (u *Unit) Finish()

+ func (u *Unit) IsHighPriority() bool

+ func (u *Unit) MakeHighPriority()

+ func (u *Unit) Pause()

+ func (u *Unit) ReUse()

+ func (u *Unit) RemovePriority()

+ func (u *Unit) WaitForSlot()

+ type UnitDebugData struct

+ type UnitDebugger struct