scheduler

package

v0.0.0-...-a92cdc1 Latest Latest Go to latest Published: Apr 7, 2022 License: GPL-3.0 Imports: 9 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/gdsim/gdsim

Links

Open Source Insights

Documentation ¶

Index ¶

type Adaptive2Scheduler
- func NewAdaptive2(t topology.Topology, ratio float64) *Adaptive2Scheduler
- func (scheduler *Adaptive2Scheduler) Add(j *job.Job)
- func (scheduler Adaptive2Scheduler) Pending() int
- func (scheduler *Adaptive2Scheduler) Results() map[string]*job.Job
- func (scheduler *Adaptive2Scheduler) Schedule(now uint64) []event.Event
type AdaptiveScheduler
- func NewAdaptive(t topology.Topology, ratio float64) *AdaptiveScheduler
- func (scheduler *AdaptiveScheduler) Add(j *job.Job)
- func (scheduler AdaptiveScheduler) Pending() int
- func (scheduler *AdaptiveScheduler) Results() map[string]*job.Job
- func (scheduler *AdaptiveScheduler) Schedule(now uint64) []event.Event
type GlobalSRPTScheduler
- func NewGRPTS(t topology.Topology) *GlobalSRPTScheduler
- func (scheduler *GlobalSRPTScheduler) Add(j *job.Job)
- func (scheduler GlobalSRPTScheduler) Pending() int
- func (scheduler GlobalSRPTScheduler) Results() map[string]*job.Job
- func (scheduler *GlobalSRPTScheduler) Schedule(now uint64) []event.Event
type MakespanScheduler
- func NewGeoDis(t topology.Topology) *MakespanScheduler
- func NewMakespanScheduler(t topology.Topology, ...) *MakespanScheduler
- func NewSwag(t topology.Topology) *MakespanScheduler
- func (scheduler *MakespanScheduler) Add(j *job.Job)
- func (scheduler MakespanScheduler) Pending() int
- func (scheduler MakespanScheduler) Results() map[string]*job.Job
- func (scheduler *MakespanScheduler) Schedule(now uint64) []event.Event
- func (scheduler *MakespanScheduler) Update(now uint64) (totalMakespan uint64)
type Ratio1Scheduler
- func NewRatio1(t topology.Topology, ratio float64) *Ratio1Scheduler
- func (scheduler *Ratio1Scheduler) Add(j *job.Job)
- func (scheduler Ratio1Scheduler) Pending() int
- func (scheduler *Ratio1Scheduler) Results() map[string]*job.Job
- func (scheduler *Ratio1Scheduler) Schedule(now uint64) []event.Event
type Ratio2Scheduler
- func NewRatio2(t topology.Topology, ratio float64) *Ratio2Scheduler
- func (scheduler *Ratio2Scheduler) Add(j *job.Job)
- func (scheduler Ratio2Scheduler) Pending() int
- func (scheduler *Ratio2Scheduler) Results() map[string]*job.Job
- func (scheduler *Ratio2Scheduler) Schedule(now uint64) []event.Event
type Ratio3Scheduler
- func NewRatio3(t topology.Topology, ratio float64) *Ratio3Scheduler
- func (scheduler *Ratio3Scheduler) Add(j *job.Job)
- func (scheduler Ratio3Scheduler) Pending() int
- func (scheduler *Ratio3Scheduler) Results() map[string]*job.Job
- func (scheduler *Ratio3Scheduler) Schedule(now uint64) []event.Event
type Scheduler

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Adaptive2Scheduler ¶

type Adaptive2Scheduler struct {
	// contains filtered or unexported fields
}

func NewAdaptive2 ¶

func NewAdaptive2(t topology.Topology, ratio float64) *Adaptive2Scheduler

func (*Adaptive2Scheduler) Add ¶

func (scheduler *Adaptive2Scheduler) Add(j *job.Job)

func (Adaptive2Scheduler) Pending ¶

func (scheduler Adaptive2Scheduler) Pending() int

func (*Adaptive2Scheduler) Results ¶

func (scheduler *Adaptive2Scheduler) Results() map[string]*job.Job

func (*Adaptive2Scheduler) Schedule ¶

func (scheduler *Adaptive2Scheduler) Schedule(now uint64) []event.Event

type AdaptiveScheduler ¶

type AdaptiveScheduler struct {
	// contains filtered or unexported fields
}

func NewAdaptive ¶

func NewAdaptive(t topology.Topology, ratio float64) *AdaptiveScheduler

func (*AdaptiveScheduler) Add ¶

func (scheduler *AdaptiveScheduler) Add(j *job.Job)

func (AdaptiveScheduler) Pending ¶

func (scheduler AdaptiveScheduler) Pending() int

func (*AdaptiveScheduler) Results ¶

func (scheduler *AdaptiveScheduler) Results() map[string]*job.Job

func (*AdaptiveScheduler) Schedule ¶

func (scheduler *AdaptiveScheduler) Schedule(now uint64) []event.Event

type GlobalSRPTScheduler ¶

type GlobalSRPTScheduler struct {
	// contains filtered or unexported fields
}

func NewGRPTS ¶

func NewGRPTS(t topology.Topology) *GlobalSRPTScheduler

func (*GlobalSRPTScheduler) Add ¶

func (scheduler *GlobalSRPTScheduler) Add(j *job.Job)

func (GlobalSRPTScheduler) Pending ¶

func (scheduler GlobalSRPTScheduler) Pending() int

func (GlobalSRPTScheduler) Results ¶

func (scheduler GlobalSRPTScheduler) Results() map[string]*job.Job

func (*GlobalSRPTScheduler) Schedule ¶

func (scheduler *GlobalSRPTScheduler) Schedule(now uint64) []event.Event

type MakespanScheduler ¶

type MakespanScheduler struct {
	// contains filtered or unexported fields
}

func NewGeoDis ¶

func NewGeoDis(t topology.Topology) *MakespanScheduler

func NewMakespanScheduler ¶

func NewMakespanScheduler(t topology.Topology, bestDcs func(file.File, topology.Topology, int) []transferCenter) *MakespanScheduler

func NewSwag ¶

func NewSwag(t topology.Topology) *MakespanScheduler

func (*MakespanScheduler) Add ¶

func (scheduler *MakespanScheduler) Add(j *job.Job)

func (MakespanScheduler) Pending ¶

func (scheduler MakespanScheduler) Pending() int

func (MakespanScheduler) Results ¶

func (scheduler MakespanScheduler) Results() map[string]*job.Job

func (*MakespanScheduler) Schedule ¶

func (scheduler *MakespanScheduler) Schedule(now uint64) []event.Event

func (*MakespanScheduler) Update ¶

func (scheduler *MakespanScheduler) Update(now uint64) (totalMakespan uint64)

type Ratio1Scheduler ¶

type Ratio1Scheduler struct {
	// contains filtered or unexported fields
}

func NewRatio1 ¶

func NewRatio1(t topology.Topology, ratio float64) *Ratio1Scheduler

func (*Ratio1Scheduler) Add ¶

func (scheduler *Ratio1Scheduler) Add(j *job.Job)

func (Ratio1Scheduler) Pending ¶

func (scheduler Ratio1Scheduler) Pending() int

func (*Ratio1Scheduler) Results ¶

func (scheduler *Ratio1Scheduler) Results() map[string]*job.Job

func (*Ratio1Scheduler) Schedule ¶

func (scheduler *Ratio1Scheduler) Schedule(now uint64) []event.Event

type Ratio2Scheduler ¶

type Ratio2Scheduler struct {
	// contains filtered or unexported fields
}

func NewRatio2 ¶

func NewRatio2(t topology.Topology, ratio float64) *Ratio2Scheduler

func (*Ratio2Scheduler) Add ¶

func (scheduler *Ratio2Scheduler) Add(j *job.Job)

func (Ratio2Scheduler) Pending ¶

func (scheduler Ratio2Scheduler) Pending() int

func (*Ratio2Scheduler) Results ¶

func (scheduler *Ratio2Scheduler) Results() map[string]*job.Job

func (*Ratio2Scheduler) Schedule ¶

func (scheduler *Ratio2Scheduler) Schedule(now uint64) []event.Event

type Ratio3Scheduler ¶

type Ratio3Scheduler struct {
	// contains filtered or unexported fields
}

func NewRatio3 ¶

func NewRatio3(t topology.Topology, ratio float64) *Ratio3Scheduler

func (*Ratio3Scheduler) Add ¶

func (scheduler *Ratio3Scheduler) Add(j *job.Job)

func (Ratio3Scheduler) Pending ¶

func (scheduler Ratio3Scheduler) Pending() int

func (*Ratio3Scheduler) Results ¶

func (scheduler *Ratio3Scheduler) Results() map[string]*job.Job

func (*Ratio3Scheduler) Schedule ¶

func (scheduler *Ratio3Scheduler) Schedule(now uint64) []event.Event

type Scheduler ¶

type Scheduler interface {
	//Pop() *job.Task
	Add(t *job.Job)
	Schedule(now uint64) []event.Event
	Results() map[string]*job.Job
	Pending() int
}

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
event

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL