server

Documentation

Index

• Constants
• func DeleteServerExperiment(exp *redskyv1beta1.Experiment) bool
• func FailExperiment(exp *redskyv1beta1.Experiment, reason string, err error) bool
• func FromCluster(in *redskyv1beta1.Experiment) (redskyapi.ExperimentName, *redskyapi.Experiment, *redskyapi.TrialAssignments, ...)
• func FromClusterTrial(t *redskyv1beta1.Trial) *redskyapi.TrialValues
• func IsServerSyncEnabled(exp *redskyv1beta1.Experiment) bool
• func StopExperiment(exp *redskyv1beta1.Experiment, err error) bool
• func ToCluster(exp *redskyv1beta1.Experiment, ee *redskyapi.Experiment)
• func ToClusterTrial(t *redskyv1beta1.Trial, suggestion *redskyapi.TrialAssignments)

Constants

const (
	// Finalizer is used to ensure synchronization with the server
	Finalizer = "serverFinalizer.redskyops.dev"
)

Functions

func DeleteServerExperiment

func DeleteServerExperiment(exp *redskyv1beta1.Experiment) bool

DeleteServerExperiment checks to see if the supplied experiment should be deleted from the server upon completion. Normally, we do not actually want to delete the experiment from the server in order to preserve the data, for example, in a multi-cluster experiment we would require that the experiment still exist for all the other clusters. We also want to ensure results are visible in the UI after the experiment ends in the cluster (deleting the server experiments means it won't be available to the UI anymore. We also would not want a `reset` (which deletes the CRD) to wipe out all the data on the server.

func FailExperiment

func FailExperiment(exp *redskyv1beta1.Experiment, reason string, err error) bool

FailExperiment records a recognized error as an experiment failure.

func FromCluster

func FromCluster(in *redskyv1beta1.Experiment) (redskyapi.ExperimentName, *redskyapi.Experiment, *redskyapi.TrialAssignments, error)

FromCluster converts cluster state to API state

func FromClusterTrial

func FromClusterTrial(t *redskyv1beta1.Trial) *redskyapi.TrialValues

FromClusterTrial converts cluster state to API state

func IsServerSyncEnabled

func IsServerSyncEnabled(exp *redskyv1beta1.Experiment) bool

IsServerSyncEnabled checks to see if server synchronization is enabled.

func StopExperiment

func StopExperiment(exp *redskyv1beta1.Experiment, err error) bool

StopExperiment updates the experiment in the event that it should be paused or halted

func ToCluster

func ToCluster(exp *redskyv1beta1.Experiment, ee *redskyapi.Experiment)

ToCluster converts API state to cluster state

func ToClusterTrial

func ToClusterTrial(t *redskyv1beta1.Trial, suggestion *redskyapi.TrialAssignments)

ToClusterTrial converts API state to cluster state