objects

Documentation

Index

• type JobConfig
  • func (cfg *JobConfig) Configure(jobSpec *openapi.JobSpec, brokers []config.Broker, registry config.Registry, ...)
• type JobIdName
• type Task
  • func (tsk *Task) Configure(taskType openapi.TaskType, taskKey string, realm string, datasetUrl string, ...)

Types

type JobConfig

type JobConfig struct {
	BackEnd  string            `json:"backend"`
	Brokers  []config.Broker   `json:"brokers,omitempty"`
	Registry config.Registry   `json:"registry,omitempty"`
	Job      JobIdName         `json:"job"`
	Role     string            `json:"role"`
	Realm    string            `json:"realm"`
	Groups   map[string]string `json:"groups"`
	Channels []openapi.Channel `json:"channels"`

	MaxRunTime      int32                  `json:"maxRunTime,omitempty"`
	BaseModel       openapi.BaseModel      `json:"baseModel,omitempty"`
	Hyperparameters map[string]interface{} `json:"hyperparameters,omitempty"`
	Dependencies    []string               `json:"dependencies,omitempty"`
	DatasetUrl      string                 `json:"dataset,omitempty"`
	Optimizer       openapi.Optimizer      `json:"optimizer,omitempty"`
	Selector        openapi.Selector       `json:"selector,omitempty"`
}

func (*JobConfig) Configure

func (cfg *JobConfig) Configure(jobSpec *openapi.JobSpec, brokers []config.Broker, registry config.Registry,
	role openapi.Role, channels []openapi.Channel)

type JobIdName

type JobIdName struct {
	Id   string `json:"id"`
	Name string `json:"name"`
}

type Task

type Task struct {
	JobId     string           `json:"jobid"`
	TaskId    string           `json:"taskid"`
	Role      string           `json:"role"`
	Type      openapi.TaskType `json:"type"`
	Key       string           `json:"key"`
	ComputeId string           `json:"computeid"`

	// the following are config and code
	JobConfig  JobConfig
	ZippedCode []byte
}

func (*Task) Configure

func (tsk *Task) Configure(taskType openapi.TaskType, taskKey string, realm string, datasetUrl string, idx int)