simulator

Jan 22, 2024

Changes in this version

type Simulator

+ func (s *Simulator) Now() time.Time

+ func (s *Simulator) Since(t time.Time) time.Duration

Dec 20, 2023

Changes in this version

+ func RepeatEvents(n int, seq *armadaevents.EventSequence) *armadaevents.EventSequence

Nov 21, 2023

Changes in this version

+ type FlattenedArmadaEvent struct

+ Cpu float64

+ EphemeralStorage float64

+ EventType int

+ ExitCode int

+ Gpu float64

+ JobId string

+ JobSet string

+ Memory float64

+ NumRuns int

+ PreviousEventType int

+ PriorityClass string

+ Queue string

+ RunIndex int

+ SecondsSinceLastEvent float64

+ Time int64

type Simulator

+ func (s *Simulator) StateTransitions() <-chan StateTransition

+ type StateTransition struct

+ EventSequence *armadaevents.EventSequence

+ Jobs []*jobdb.Job

+ type Writer struct

+ func NewWriter(writer io.Writer, c <-chan StateTransition) (*Writer, error)

+ func (w *Writer) Run(ctx *armadacontext.Context) (err error)

Nov 13, 2023

Changes in this version

type MetricsVector

+ TimeOfMostRecentEvent time.Duration

+ TimeOfMostRecentJobLeasedEvent time.Duration

+ TimeOfMostRecentJobPreemptedEvent time.Duration

+ TimeOfMostRecentJobSubmittedEvent time.Duration

Oct 30, 2023

Changes in this version

+ func EventSequenceSummary(eventSequence *armadaevents.EventSequence) string

+ func EventSequencesSummary(eventSequences []*armadaevents.EventSequence) string

+ func EventSummary(event *armadaevents.EventSequence_Event) string

+ func GetBasicSchedulingConfig() configuration.SchedulingConfig

+ func JobRunLeased() *armadaevents.EventSequence_Event

+ func JobRunPreempted() *armadaevents.EventSequence_Event

+ func JobSucceeded() *armadaevents.EventSequence_Event

+ func SchedulingConfigsByFilePathFromPattern(pattern string) (map[string]configuration.SchedulingConfig, error)

+ func Simulate(ctx *armadacontext.Context, ...) error

+ func SubmitJob() *armadaevents.EventSequence_Event

+ type Cluster struct

+ Name string

+ NodeTemplates []*NodeTemplate

+ func Executor32Cpu(numNodes int64) *Cluster

+ func ExecutorGpu(numNodes int64) *Cluster

+ func WithNodeTemplatesExecutor(executor *Cluster, nodeTemplates ...*NodeTemplate) *Cluster

+ func (*Cluster) Descriptor() ([]byte, []int)

+ func (*Cluster) ProtoMessage()

+ func (m *Cluster) GetName() string

+ func (m *Cluster) GetNodeTemplates() []*NodeTemplate

+ func (m *Cluster) Marshal() (dAtA []byte, err error)

+ func (m *Cluster) MarshalTo(dAtA []byte) (int, error)

+ func (m *Cluster) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Cluster) Reset()

+ func (m *Cluster) Size() (n int)

+ func (m *Cluster) String() string

+ func (m *Cluster) Unmarshal(dAtA []byte) error

+ func (m *Cluster) XXX_DiscardUnknown()

+ func (m *Cluster) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Cluster) XXX_Merge(src proto.Message)

+ func (m *Cluster) XXX_Size() int

+ func (m *Cluster) XXX_Unmarshal(b []byte) error

+ type ClusterGroup struct

+ Clusters []*Cluster

+ func ExecutorGroup32Cpu(numExecutors, numNodesPerExecutor int64) *ClusterGroup

+ func ExecutorGroupGpu(numExecutors, numNodesPerExecutor int64) *ClusterGroup

+ func WithExecutorsExecutorGroup(executorGroup *ClusterGroup, executors ...*Cluster) *ClusterGroup

+ func (*ClusterGroup) Descriptor() ([]byte, []int)

+ func (*ClusterGroup) ProtoMessage()

+ func (m *ClusterGroup) GetClusters() []*Cluster

+ func (m *ClusterGroup) Marshal() (dAtA []byte, err error)

+ func (m *ClusterGroup) MarshalTo(dAtA []byte) (int, error)

+ func (m *ClusterGroup) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ClusterGroup) Reset()

+ func (m *ClusterGroup) Size() (n int)

+ func (m *ClusterGroup) String() string

+ func (m *ClusterGroup) Unmarshal(dAtA []byte) error

+ func (m *ClusterGroup) XXX_DiscardUnknown()

+ func (m *ClusterGroup) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ClusterGroup) XXX_Merge(src proto.Message)

+ func (m *ClusterGroup) XXX_Size() int

+ func (m *ClusterGroup) XXX_Unmarshal(b []byte) error

+ type ClusterSpec struct

+ Name string

+ PendingDelayDistribution ShiftedExponential

+ Pools []*Pool

+ WorkflowManagerDelayDistribution ShiftedExponential

+ func ClusterSpecFromFilePath(filePath string) (*ClusterSpec, error)

+ func ClusterSpecsFromFilePaths(filePaths []string) ([]*ClusterSpec, error)

+ func ClusterSpecsFromPattern(pattern string) ([]*ClusterSpec, error)

+ func GetTwoPoolTwoNodeCluster() *ClusterSpec

+ func (*ClusterSpec) Descriptor() ([]byte, []int)

+ func (*ClusterSpec) ProtoMessage()

+ func (cs *ClusterSpec) TotalResources() schedulerobjects.ResourceList

+ func (m *ClusterSpec) GetName() string

+ func (m *ClusterSpec) GetPendingDelayDistribution() ShiftedExponential

+ func (m *ClusterSpec) GetPools() []*Pool

+ func (m *ClusterSpec) GetWorkflowManagerDelayDistribution() ShiftedExponential

+ func (m *ClusterSpec) Marshal() (dAtA []byte, err error)

+ func (m *ClusterSpec) MarshalTo(dAtA []byte) (int, error)

+ func (m *ClusterSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ClusterSpec) Reset()

+ func (m *ClusterSpec) Size() (n int)

+ func (m *ClusterSpec) String() string

+ func (m *ClusterSpec) Unmarshal(dAtA []byte) error

+ func (m *ClusterSpec) XXX_DiscardUnknown()

+ func (m *ClusterSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ClusterSpec) XXX_Merge(src proto.Message)

+ func (m *ClusterSpec) XXX_Size() int

+ func (m *ClusterSpec) XXX_Unmarshal(b []byte) error

type JobTemplate

+ EarliestSubmitTime time.Duration

+ EarliestSubmitTimeFromDependencyCompletion time.Duration

+ RuntimeDistribution ShiftedExponential

+ func JobTemplate1Cpu(n int64, jobSet, priorityClassName string, id string) *JobTemplate

+ func JobTemplate32Cpu(n int64, jobSet, priorityClassName string) *JobTemplate

+ func WithDependenciesJobTemplate(jobTemplate *JobTemplate, dependencyIds ...string) *JobTemplate

+ func WithIdJobTemplate(jobTemplate *JobTemplate, id string) *JobTemplate

+ func WithMinSubmitTimeJobTemplate(jobTemplate *JobTemplate, minSubmitTime time.Duration) *JobTemplate

+ func (m *JobTemplate) GetEarliestSubmitTime() time.Duration

+ func (m *JobTemplate) GetEarliestSubmitTimeFromDependencyCompletion() time.Duration

+ func (m *JobTemplate) GetRuntimeDistribution() ShiftedExponential

+ type MetricsCollector struct

+ LogSummaryInterval int

+ MetricsByQueue map[string]MetricsVector

+ OverallMetrics MetricsVector

+ func NewMetricsCollector(c <-chan *armadaevents.EventSequence) *MetricsCollector

+ func (mc *MetricsCollector) Run(ctx *armadacontext.Context) error

+ func (mc *MetricsCollector) String() string

+ type MetricsVector struct

+ NumEvents int

+ NumJobSucceededEvents int

+ NumLeasedEvents int

+ NumPreemptedEvents int

+ NumSubmitEvents int

+ TimeOfMostRecentJobSucceededEvent time.Duration

+ func (m MetricsVector) String() string

type NodeTemplate

+ func NodeTemplate32Cpu(n int64) *NodeTemplate

+ func NodeTemplateGpu(n int64) *NodeTemplate

type Pool

+ ClusterGroups []*ClusterGroup

+ func Pool32Cpu(name string, ...) *Pool

+ func PoolGpu(name string, ...) *Pool

+ func WithExecutorGroupsPool(pool *Pool, executorGroups ...*ClusterGroup) *Pool

+ func (m *Pool) GetClusterGroups() []*ClusterGroup

type Queue

+ func WithJobTemplatesQueue(queue *Queue, jobTemplate ...*JobTemplate) *Queue

+ type ShiftedExponential struct

+ Minimum time.Duration

+ TailMean time.Duration

+ func (*ShiftedExponential) Descriptor() ([]byte, []int)

+ func (*ShiftedExponential) ProtoMessage()

+ func (m *ShiftedExponential) GetMinimum() time.Duration

+ func (m *ShiftedExponential) GetTailMean() time.Duration

+ func (m *ShiftedExponential) Marshal() (dAtA []byte, err error)

+ func (m *ShiftedExponential) MarshalTo(dAtA []byte) (int, error)

+ func (m *ShiftedExponential) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ShiftedExponential) Reset()

+ func (m *ShiftedExponential) Size() (n int)

+ func (m *ShiftedExponential) String() string

+ func (m *ShiftedExponential) Unmarshal(dAtA []byte) error

+ func (m *ShiftedExponential) XXX_DiscardUnknown()

+ func (m *ShiftedExponential) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ShiftedExponential) XXX_Merge(src proto.Message)

+ func (m *ShiftedExponential) XXX_Size() int

+ func (m *ShiftedExponential) XXX_Unmarshal(b []byte) error

type Simulator

+ ClusterSpec *ClusterSpec

+ SuppressSchedulerLogs bool

+ WorkloadSpec *WorkloadSpec

+ func (s *Simulator) Output() <-chan *armadaevents.EventSequence

+ type WorkloadSpec struct

+ Name string

+ Queues []*Queue

+ RandomSeed int64

+ func GetOneQueue10JobWorkload() *WorkloadSpec

+ func WorkloadSpecFromFilePath(filePath string) (*WorkloadSpec, error)

+ func WorkloadSpecsFromFilePaths(filePaths []string) ([]*WorkloadSpec, error)

+ func WorkloadsFromPattern(pattern string) ([]*WorkloadSpec, error)

+ func (*WorkloadSpec) Descriptor() ([]byte, []int)

+ func (*WorkloadSpec) ProtoMessage()

+ func (m *WorkloadSpec) GetName() string

+ func (m *WorkloadSpec) GetQueues() []*Queue

+ func (m *WorkloadSpec) GetRandomSeed() int64

+ func (m *WorkloadSpec) Marshal() (dAtA []byte, err error)

+ func (m *WorkloadSpec) MarshalTo(dAtA []byte) (int, error)

+ func (m *WorkloadSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *WorkloadSpec) Reset()

+ func (m *WorkloadSpec) Size() (n int)

+ func (m *WorkloadSpec) String() string

+ func (m *WorkloadSpec) Unmarshal(dAtA []byte) error

+ func (m *WorkloadSpec) XXX_DiscardUnknown()

+ func (m *WorkloadSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *WorkloadSpec) XXX_Merge(src proto.Message)

+ func (m *WorkloadSpec) XXX_Size() int

+ func (m *WorkloadSpec) XXX_Unmarshal(b []byte) error

Aug 31, 2023

Changes in this version

+ var ErrIntOverflowSimulator = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthSimulator = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrUnexpectedEndOfGroupSimulator = fmt.Errorf("proto: unexpected end of group")

+ func SchedulingConfigFromFilePath(filePath string) (configuration.SchedulingConfig, error)

+ func SchedulingConfigsFromFilePaths(filePaths []string) ([]configuration.SchedulingConfig, error)

+ func SchedulingConfigsFromPattern(pattern string) ([]configuration.SchedulingConfig, error)

+ type Event struct

+ type EventLog []Event

+ func (el *EventLog) Pop() any

+ func (el *EventLog) Push(x any)

+ func (el EventLog) Len() int

+ func (el EventLog) Less(i, j int) bool

+ func (el EventLog) Swap(i, j int)

+ type Executor struct

+ Name string

+ NodeTemplates []*NodeTemplate

+ func (*Executor) Descriptor() ([]byte, []int)

+ func (*Executor) ProtoMessage()

+ func (m *Executor) GetName() string

+ func (m *Executor) GetNodeTemplates() []*NodeTemplate

+ func (m *Executor) Marshal() (dAtA []byte, err error)

+ func (m *Executor) MarshalTo(dAtA []byte) (int, error)

+ func (m *Executor) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Executor) Reset()

+ func (m *Executor) Size() (n int)

+ func (m *Executor) String() string

+ func (m *Executor) Unmarshal(dAtA []byte) error

+ func (m *Executor) XXX_DiscardUnknown()

+ func (m *Executor) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Executor) XXX_Merge(src proto.Message)

+ func (m *Executor) XXX_Size() int

+ func (m *Executor) XXX_Unmarshal(b []byte) error

+ type ExecutorGroup struct

+ Executors []*Executor

+ func (*ExecutorGroup) Descriptor() ([]byte, []int)

+ func (*ExecutorGroup) ProtoMessage()

+ func (m *ExecutorGroup) GetExecutors() []*Executor

+ func (m *ExecutorGroup) Marshal() (dAtA []byte, err error)

+ func (m *ExecutorGroup) MarshalTo(dAtA []byte) (int, error)

+ func (m *ExecutorGroup) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ExecutorGroup) Reset()

+ func (m *ExecutorGroup) Size() (n int)

+ func (m *ExecutorGroup) String() string

+ func (m *ExecutorGroup) Unmarshal(dAtA []byte) error

+ func (m *ExecutorGroup) XXX_DiscardUnknown()

+ func (m *ExecutorGroup) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ExecutorGroup) XXX_Merge(src proto.Message)

+ func (m *ExecutorGroup) XXX_Size() int

+ func (m *ExecutorGroup) XXX_Unmarshal(b []byte) error

+ type JobTemplate struct

+ Dependencies []string

+ Id string

+ JobSet string

+ MinSubmitTime time.Time

+ Number int64

+ NumberSuccessful int64

+ PriorityClassName string

+ Queue string

+ QueuePriority uint32

+ Requirements schedulerobjects.PodRequirements

+ RuntimeMean int64

+ RuntimeVariance int64

+ func (*JobTemplate) Descriptor() ([]byte, []int)

+ func (*JobTemplate) ProtoMessage()

+ func (m *JobTemplate) GetDependencies() []string

+ func (m *JobTemplate) GetId() string

+ func (m *JobTemplate) GetJobSet() string

+ func (m *JobTemplate) GetMinSubmitTime() time.Time

+ func (m *JobTemplate) GetNumber() int64

+ func (m *JobTemplate) GetNumberSuccessful() int64

+ func (m *JobTemplate) GetPriorityClassName() string

+ func (m *JobTemplate) GetQueue() string

+ func (m *JobTemplate) GetQueuePriority() uint32

+ func (m *JobTemplate) GetRequirements() schedulerobjects.PodRequirements

+ func (m *JobTemplate) GetRuntimeMean() int64

+ func (m *JobTemplate) GetRuntimeVariance() int64

+ func (m *JobTemplate) Marshal() (dAtA []byte, err error)

+ func (m *JobTemplate) MarshalTo(dAtA []byte) (int, error)

+ func (m *JobTemplate) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *JobTemplate) Reset()

+ func (m *JobTemplate) Size() (n int)

+ func (m *JobTemplate) String() string

+ func (m *JobTemplate) Unmarshal(dAtA []byte) error

+ func (m *JobTemplate) XXX_DiscardUnknown()

+ func (m *JobTemplate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *JobTemplate) XXX_Merge(src proto.Message)

+ func (m *JobTemplate) XXX_Size() int

+ func (m *JobTemplate) XXX_Unmarshal(b []byte) error

+ type NodeTemplate struct

+ Labels map[string]string

+ Number int64

+ Taints []v1.Taint

+ TotalResources schedulerobjects.ResourceList

+ func (*NodeTemplate) Descriptor() ([]byte, []int)

+ func (*NodeTemplate) ProtoMessage()

+ func (m *NodeTemplate) GetLabels() map[string]string

+ func (m *NodeTemplate) GetNumber() int64

+ func (m *NodeTemplate) GetTaints() []v1.Taint

+ func (m *NodeTemplate) GetTotalResources() schedulerobjects.ResourceList

+ func (m *NodeTemplate) Marshal() (dAtA []byte, err error)

+ func (m *NodeTemplate) MarshalTo(dAtA []byte) (int, error)

+ func (m *NodeTemplate) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *NodeTemplate) Reset()

+ func (m *NodeTemplate) Size() (n int)

+ func (m *NodeTemplate) String() string

+ func (m *NodeTemplate) Unmarshal(dAtA []byte) error

+ func (m *NodeTemplate) XXX_DiscardUnknown()

+ func (m *NodeTemplate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *NodeTemplate) XXX_Merge(src proto.Message)

+ func (m *NodeTemplate) XXX_Size() int

+ func (m *NodeTemplate) XXX_Unmarshal(b []byte) error

+ type Pool struct

+ ExecutorGroups []*ExecutorGroup

+ Name string

+ func (*Pool) Descriptor() ([]byte, []int)

+ func (*Pool) ProtoMessage()

+ func (m *Pool) GetExecutorGroups() []*ExecutorGroup

+ func (m *Pool) GetName() string

+ func (m *Pool) Marshal() (dAtA []byte, err error)

+ func (m *Pool) MarshalTo(dAtA []byte) (int, error)

+ func (m *Pool) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Pool) Reset()

+ func (m *Pool) Size() (n int)

+ func (m *Pool) String() string

+ func (m *Pool) Unmarshal(dAtA []byte) error

+ func (m *Pool) XXX_DiscardUnknown()

+ func (m *Pool) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Pool) XXX_Merge(src proto.Message)

+ func (m *Pool) XXX_Size() int

+ func (m *Pool) XXX_Unmarshal(b []byte) error

+ type Queue struct

+ JobTemplates []*JobTemplate

+ Name string

+ Weight float64

+ func (*Queue) Descriptor() ([]byte, []int)

+ func (*Queue) ProtoMessage()

+ func (m *Queue) GetJobTemplates() []*JobTemplate

+ func (m *Queue) GetName() string

+ func (m *Queue) GetWeight() float64

+ func (m *Queue) Marshal() (dAtA []byte, err error)

+ func (m *Queue) MarshalTo(dAtA []byte) (int, error)

+ func (m *Queue) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Queue) Reset()

+ func (m *Queue) Size() (n int)

+ func (m *Queue) String() string

+ func (m *Queue) Unmarshal(dAtA []byte) error

+ func (m *Queue) XXX_DiscardUnknown()

+ func (m *Queue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Queue) XXX_Merge(src proto.Message)

+ func (m *Queue) XXX_Size() int

+ func (m *Queue) XXX_Unmarshal(b []byte) error

+ type Simulator struct

+ func NewSimulator(testCase *TestCase, schedulingConfig configuration.SchedulingConfig) (*Simulator, error)

+ func (s *Simulator) C() <-chan *armadaevents.EventSequence

+ func (s *Simulator) Run() error

+ type TestCase struct

+ Name string

+ Pools []*Pool

+ Queues []Queue

+ RandomSeed int64

+ func TestCaseFromBytes(yamlBytes []byte) (*TestCase, error)

+ func TestCaseFromFilePath(filePath string) (*TestCase, error)

+ func TestCasesFromFilePaths(filePaths []string) ([]*TestCase, error)

+ func TestCasesFromPattern(pattern string) ([]*TestCase, error)

+ func (*TestCase) Descriptor() ([]byte, []int)

+ func (*TestCase) ProtoMessage()

+ func (m *TestCase) GetName() string

+ func (m *TestCase) GetPools() []*Pool

+ func (m *TestCase) GetQueues() []Queue

+ func (m *TestCase) GetRandomSeed() int64

+ func (m *TestCase) Marshal() (dAtA []byte, err error)

+ func (m *TestCase) MarshalTo(dAtA []byte) (int, error)

+ func (m *TestCase) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *TestCase) Reset()

+ func (m *TestCase) Size() (n int)

+ func (m *TestCase) String() string

+ func (m *TestCase) Unmarshal(dAtA []byte) error

+ func (m *TestCase) XXX_DiscardUnknown()

+ func (m *TestCase) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TestCase) XXX_Merge(src proto.Message)

+ func (m *TestCase) XXX_Size() int

+ func (m *TestCase) XXX_Unmarshal(b []byte) error