optimus

type Clock func() time.Time

type Config struct {
	PrivateKey   privateKey `yaml:"ethereum" json:"-"`
	Logging      logging.Config
	Workers      []auth.Addr
	Benchmarks   benchmarks.Config `yaml:"benchmarks"`
	Marketplace  marketplaceConfig
	Optimization optimizationConfig
}

type Consumer interface {
	LowerBound() []float64
	DeviceType() sonm.DeviceType
	DeviceBenchmark(id int) (*sonm.Benchmark, bool)
	SplittingAlgorithm() sonm.SplittingAlgorithm
	Result(criteria float64) interface{}
}

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

type MarketOrder = sonm.DWHOrder

type Model interface {
	Train(trainingSet [][]float64, expectation []float64) (TrainedModel, error)
}

type ModelConfig struct {
	Alpha          float64 `yaml:"alpha" default:"1e-3"`
	Regularization float64 `yaml:"regularization" default:"6.0"`
	MaxIterations  int     `yaml:"max_iterations" default:"1000"`
}

type Normalizer interface {
	Normalize(x float64) float64
	NormalizeBatch(x []float64)
	Denormalize(x float64) float64
}

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

type OrderClassifier interface {
	Classify(orders []*MarketOrder) ([]WeightedOrder, error)
}

type OrderScanner interface {
	All(ctx context.Context) ([]*MarketOrder, error)
}

type TrainedModel interface {
	Predict(vec []float64) (float64, error)
}

type Watcher interface {
	OnRun()
	OnShutdown()
	Execute(ctx context.Context)
}

type WeightedOrder struct {
	Order    *MarketOrder
	Distance float64
	Weight   float64
}