Versions in this module Expand all Collapse all v0 v0.15.5 Nov 25, 2024 v0.15.4 Nov 11, 2024 Changes in this version + type QueueStatsRow struct + ActualShare float64 + AdjustedFairShare float64 + AllocatedCPU int + AllocatedGPU int + AllocatedMemory int + CpuShare float64 + FairShare float64 + GpuShare float64 + MemoryShare float64 + NumEvicted int + NumPreempted int + NumScheduled int + Pool string + Queue string + Ts int64 + type QueueStatsWriter struct + func NewQueueStatsWriter(path string) (*QueueStatsWriter, error) + func (j *QueueStatsWriter) Close(ctx *armadacontext.Context) + func (j *QueueStatsWriter) Update(time time.Time, result *scheduling.SchedulerResult) error v0.15.3 Oct 22, 2024 v0.15.2 Oct 22, 2024 v0.15.1 Oct 21, 2024 v0.15.0 Oct 17, 2024 Changes in this version + type FairShareRow struct + ActualShare float64 + AdjustedFairShare float64 + FairShare float64 + Pool string + Queue string + Ts int64 + type FairShareWriter struct + func NewFairShareWriter(path string) (*FairShareWriter, error) + func (j *FairShareWriter) Close(ctx *armadacontext.Context) + func (j *FairShareWriter) Update(result *scheduling.SchedulerResult) error + type JobRunRow struct + Cpu float64 + EphemeralStorage float64 + ExitCode int + FinishedTime int64 + Gpu float64 + JobId string + JobSet string + Memory float64 + PriorityClass string + Queue string + RunId string + ScheduledTime int64 + State string + SubmittedTime int64 + type JobWriter struct + func NewJobWriter(path string) (*JobWriter, error) + func (j *JobWriter) Close(ctx *armadacontext.Context) + func (j *JobWriter) Update(st *model.StateTransition) error + type NullSink struct + func (s NullSink) Close(ctx *armadacontext.Context) + func (s NullSink) OnCycleEnd(_ *scheduling.SchedulerResult) error + func (s NullSink) OnNewStateTransitions(_ []*model.StateTransition) error + type ParquetSink struct + func NewParquetSink(outputDir string) (*ParquetSink, error) + func (s *ParquetSink) Close(ctx *armadacontext.Context) + func (s *ParquetSink) OnCycleEnd(result *scheduling.SchedulerResult) error + func (s *ParquetSink) OnNewStateTransitions(transitions []*model.StateTransition) error + type Sink interface + Close func(ctx *armadacontext.Context) + OnCycleEnd func(result *scheduling.SchedulerResult) error + OnNewStateTransitions func(transitions []*model.StateTransition) error
Go to main page