experiment

Documentation

Index

• func CreateExperimentProto(experiment *Experiment) *scheduler.Experiment
• type Candidate
• type Config
• type Experiment
  • func CreateExperimentFromRequest(request *scheduler.Experiment) *Experiment
  • func (e *Experiment) AreCandidatesReady() bool
  • func (e *Experiment) IsMirrorReady() bool
• type ExperimentBaselineExists
  • func (ebe *ExperimentBaselineExists) Error() string
• type ExperimentDBManager
  • func (edb *ExperimentDBManager) Stop() error
• type ExperimentDefaultNotFound
  • func (enc *ExperimentDefaultNotFound) Error() string
  • func (enc *ExperimentDefaultNotFound) Is(tgt error) bool
• type ExperimentNoCandidatesOrMirrors
  • func (enc *ExperimentNoCandidatesOrMirrors) Error() string
• type ExperimentNoDuplicates
  • func (enc *ExperimentNoDuplicates) Error() string
  • func (enc *ExperimentNoDuplicates) Is(tgt error) bool
• type ExperimentNotFound
  • func (enf *ExperimentNotFound) Error() string
  • func (enf *ExperimentNotFound) Is(tgt error) bool
• type ExperimentServer
• type ExperimentStore
  • func NewExperimentServer(logger logrus.FieldLogger, eventHub *coordinator.EventHub, ...) *ExperimentStore
  • func (es *ExperimentStore) GetExperiment(experimentName string) (*Experiment, error)
  • func (es *ExperimentStore) GetExperimentForBaselineModel(modelName string) *Experiment
  • func (es *ExperimentStore) GetExperimentForBaselinePipeline(pipelineName string) *Experiment
  • func (es *ExperimentStore) GetExperiments() ([]*Experiment, error)
  • func (es *ExperimentStore) InitialiseOrRestoreDB(path string) error
  • func (es *ExperimentStore) SetStatus(experimentName string, active bool, reason string) error
  • func (es *ExperimentStore) StartExperiment(experiment *Experiment) error
  • func (es *ExperimentStore) StopExperiment(experimentName string) error
• type KubernetesMeta
• type Mirror
• type ResourceType

Functions

func CreateExperimentProto

func CreateExperimentProto(experiment *Experiment) *scheduler.Experiment

Types

type Candidate

type Candidate struct {
	Name   string
	Weight uint32
	Ready  bool
}

type Config

type Config struct {
	StickySessions bool
}

type Experiment

type Experiment struct {
	Name              string
	Active            bool
	Deleted           bool
	Default           *string
	ResourceType      ResourceType
	Candidates        []*Candidate
	Mirror            *Mirror
	Config            *Config
	StatusDescription string
	KubernetesMeta    *KubernetesMeta
}

func CreateExperimentFromRequest

func CreateExperimentFromRequest(request *scheduler.Experiment) *Experiment

func (*Experiment) AreCandidatesReady

func (e *Experiment) AreCandidatesReady() bool

func (*Experiment) IsMirrorReady

func (e *Experiment) IsMirrorReady() bool

type ExperimentBaselineExists

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

func (*ExperimentBaselineExists) Error

func (ebe *ExperimentBaselineExists) Error() string

type ExperimentDBManager

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

func (*ExperimentDBManager) Stop

func (edb *ExperimentDBManager) Stop() error

type ExperimentDefaultNotFound

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

func (*ExperimentDefaultNotFound) Error

func (enc *ExperimentDefaultNotFound) Error() string

func (*ExperimentDefaultNotFound) Is

func (enc *ExperimentDefaultNotFound) Is(tgt error) bool

type ExperimentNoCandidatesOrMirrors

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

func (*ExperimentNoCandidatesOrMirrors) Error

func (enc *ExperimentNoCandidatesOrMirrors) Error() string

type ExperimentNoDuplicates

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

func (*ExperimentNoDuplicates) Error

func (enc *ExperimentNoDuplicates) Error() string

func (*ExperimentNoDuplicates) Is

func (enc *ExperimentNoDuplicates) Is(tgt error) bool

type ExperimentNotFound

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

func (*ExperimentNotFound) Error

func (enf *ExperimentNotFound) Error() string

func (*ExperimentNotFound) Is

func (enf *ExperimentNotFound) Is(tgt error) bool

type ExperimentServer

type ExperimentServer interface {
	StartExperiment(experiment *Experiment) error
	StopExperiment(experimentName string) error
	GetExperiment(experimentName string) (*Experiment, error)
	GetExperiments() ([]*Experiment, error)
	GetExperimentForBaselineModel(modelName string) *Experiment
	GetExperimentForBaselinePipeline(pipelineName string) *Experiment
	SetStatus(experimentName string, active bool, reason string) error
}

type ExperimentStore

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

func NewExperimentServer

func NewExperimentServer(logger logrus.FieldLogger, eventHub *coordinator.EventHub, store store.ModelStore, pipelineStore pipeline.PipelineHandler) *ExperimentStore

func (*ExperimentStore) GetExperiment

func (es *ExperimentStore) GetExperiment(experimentName string) (*Experiment, error)

func (*ExperimentStore) GetExperimentForBaselineModel

func (es *ExperimentStore) GetExperimentForBaselineModel(modelName string) *Experiment

func (*ExperimentStore) GetExperimentForBaselinePipeline

func (es *ExperimentStore) GetExperimentForBaselinePipeline(pipelineName string) *Experiment

func (*ExperimentStore) GetExperiments

func (es *ExperimentStore) GetExperiments() ([]*Experiment, error)

func (*ExperimentStore) InitialiseOrRestoreDB

func (es *ExperimentStore) InitialiseOrRestoreDB(path string) error

func (*ExperimentStore) SetStatus

func (es *ExperimentStore) SetStatus(experimentName string, active bool, reason string) error

func (*ExperimentStore) StartExperiment

func (es *ExperimentStore) StartExperiment(experiment *Experiment) error

func (*ExperimentStore) StopExperiment

func (es *ExperimentStore) StopExperiment(experimentName string) error

type KubernetesMeta

type KubernetesMeta struct {
	Namespace  string
	Generation int64
}

type Mirror

type Mirror struct {
	Name    string
	Percent uint32
	Ready   bool
}

type ResourceType

type ResourceType uint32

const (
	ModelResourceType ResourceType = iota
	PipelineResourceType
)