market

Documentation

Index

• func Optimize(jobFile *cedana.JobFile) []cedana.Instance
• func OptimizeOrchestrator() []cedana.Instance
• type LocalProvider
  • func GenLocalClient() *LocalProvider
  • func (l *LocalProvider) CreateInstance(Candidate *cedana.Instance) (*cedana.Instance, error)
  • func (l *LocalProvider) DescribeInstance(Instances []*cedana.Instance, filter string) error
  • func (l *LocalProvider) DestroyInstance(i cedana.Instance) error
  • func (l *LocalProvider) GetInstanceStatus(i cedana.Instance) (*cedana.ProviderEvent, error)
  • func (l *LocalProvider) Name() string
• type MockProvider
  • func (m *MockProvider) CreateInstance(Candidate *cedana.Instance) (*cedana.Instance, error)
  • func (m *MockProvider) DescribeInstance(Instances []*cedana.Instance, filter string) error
  • func (m *MockProvider) DestroyInstance(i cedana.Instance) error
  • func (m *MockProvider) GetInstanceStatus(i cedana.Instance) (*cedana.ProviderEvent, error)
  • func (m *MockProvider) Name() string
• type Optimizer
  • func Build(jobFile *cedana.JobFile) *Optimizer
  • func (o *Optimizer) CedanaBasicPriceOptimizer() *Optimizer
  • func (o *Optimizer) FilterAWSCapacity() *Optimizer
  • func (o *Optimizer) FilterByRegions(maxInstancesToConsider int) *Optimizer
  • func (o *Optimizer) FilterForGPUs() *Optimizer
  • func (o *Optimizer) FilterUsingConfig() *Optimizer
  • func (o *Optimizer) FilterUsingConfigOrch() *Optimizer
  • func (o *Optimizer) FilterUsingMaxPrice() *Optimizer
  • func (o *Optimizer) LoadCatalogsFromR2()

Functions

func Optimize

func Optimize(jobFile *cedana.JobFile) []cedana.Instance

Every optimization function should be adding instances to o.output at every stage.

func OptimizeOrchestrator

func OptimizeOrchestrator() []cedana.Instance

Types

type LocalProvider

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

func GenLocalClient

func GenLocalClient() *LocalProvider

func (*LocalProvider) CreateInstance

func (l *LocalProvider) CreateInstance(Candidate *cedana.Instance) (*cedana.Instance, error)

func (*LocalProvider) DescribeInstance

func (l *LocalProvider) DescribeInstance(Instances []*cedana.Instance, filter string) error

func (*LocalProvider) DestroyInstance

func (l *LocalProvider) DestroyInstance(i cedana.Instance) error

func (*LocalProvider) GetInstanceStatus

func (l *LocalProvider) GetInstanceStatus(i cedana.Instance) (*cedana.ProviderEvent, error)

func (*LocalProvider) Name

func (l *LocalProvider) Name() string

type MockProvider

type MockProvider struct {
	MockTermination bool // helps fiddle with the termination logic
}

func (*MockProvider) CreateInstance

func (m *MockProvider) CreateInstance(Candidate *cedana.Instance) (*cedana.Instance, error)

func (*MockProvider) DescribeInstance

func (m *MockProvider) DescribeInstance(Instances []*cedana.Instance, filter string) error

func (*MockProvider) DestroyInstance

func (m *MockProvider) DestroyInstance(i cedana.Instance) error

func (*MockProvider) GetInstanceStatus

func (m *MockProvider) GetInstanceStatus(i cedana.Instance) (*cedana.ProviderEvent, error)

func (*MockProvider) Name

func (m *MockProvider) Name() string

type Optimizer

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

func Build

func Build(jobFile *cedana.JobFile) *Optimizer

func (*Optimizer) CedanaBasicPriceOptimizer

func (o *Optimizer) CedanaBasicPriceOptimizer() *Optimizer

func (*Optimizer) FilterAWSCapacity

func (o *Optimizer) FilterAWSCapacity() *Optimizer

func (*Optimizer) FilterByRegions

func (o *Optimizer) FilterByRegions(maxInstancesToConsider int) *Optimizer

func (*Optimizer) FilterForGPUs

func (o *Optimizer) FilterForGPUs() *Optimizer

Only call if GPU is asked for, as this will return empty otherwise

func (*Optimizer) FilterUsingConfig

func (o *Optimizer) FilterUsingConfig() *Optimizer

func (*Optimizer) FilterUsingConfigOrch

func (o *Optimizer) FilterUsingConfigOrch() *Optimizer

func (*Optimizer) FilterUsingMaxPrice

func (o *Optimizer) FilterUsingMaxPrice() *Optimizer

func (*Optimizer) LoadCatalogsFromR2

func (o *Optimizer) LoadCatalogsFromR2()