Documentation ¶
Index ¶
- func DecodeWorkerArgstr(s string) (*workerArgs, error)
- func MakeDbSession(host string) (*dbSession, error)
- func MakeExperiment(config *ExperimentConfig) *experiment
- func MakeWorkerArgstr(job *experimentJob) string
- func RunReaders(db *dbSession, jobId JobId, jobChannels *OutputChannels, ...)
- type DeploymentConfig
- type ExperimentConfig
- type ExperimentId
- type JobConfig
- type JobHostAssignment
- type JobId
- type JobOutputConfig
- type JobParamConfig
- type OutputChannels
- type OutputReader
- type ParamInstantiation
- type ReaderSource
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func DecodeWorkerArgstr ¶
func MakeDbSession ¶
func MakeExperiment ¶
func MakeExperiment(config *ExperimentConfig) *experiment
func MakeWorkerArgstr ¶
func MakeWorkerArgstr(job *experimentJob) string
func RunReaders ¶
func RunReaders(db *dbSession, jobId JobId, jobChannels *OutputChannels, readerConfigs []*JobOutputConfig)
Types ¶
type DeploymentConfig ¶
type ExperimentConfig ¶
type ExperimentConfig struct { Name string Deployment *DeploymentConfig Jobs *JobConfig }
type ExperimentId ¶
type JobConfig ¶
type JobConfig struct { CommandTemplate string `yaml:"command_template"` Params []*JobParamConfig Outputs []*JobOutputConfig }
type JobHostAssignment ¶
type JobHostAssignment [][]*experimentJob
func AssignJobsToHosts ¶
func AssignJobsToHosts( jobs []*experimentJob, deployment *DeploymentConfig) JobHostAssignment
type JobOutputConfig ¶
type JobParamConfig ¶
type OutputChannels ¶
func MakeOutputChannels ¶
func MakeOutputChannels() *OutputChannels
type OutputReader ¶
type ParamInstantiation ¶
func InstantiateParams ¶
func InstantiateParams(paramSpecs []*JobParamConfig) []ParamInstantiation
Takes parameter specifications (names and possible values) and produces a list of instantiations of those parameters
Click to show internal directories.
Click to hide internal directories.