Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func InitLogger ¶
InitLogger ... initializes new logger with trainingID and userID
func KillDeployedJob ¶
func KillDeployedJob(trainingID string, userID string, jobName string, logr *logger.LocLoggingEntry) error
KillDeployedJob ... Contact the LCM and kill training job
Types ¶
type JobMonitor ¶
type JobMonitor struct {
UseNativeDistribution bool
TrainingID string
UserID string
JobName string
NumLearners int
EtcdClient coord.Coordinator
// contains filtered or unexported fields
}
JobMonitor ...
func NewJobMonitor ¶
func NewJobMonitor(trainingID string, userID string, numLearners int, jobName string, useNativeDistribution bool, statsdClient *statsd.Statsd, logr *logger.LocLoggingEntry) (*JobMonitor, error)
NewJobMonitor ...
func (*JobMonitor) ManageDistributedJob ¶
func (jm *JobMonitor) ManageDistributedJob(logr *logger.LocLoggingEntry)
ManageDistributedJob ...manages a DLaaS training job
Source Files
Click to show internal directories.
Click to hide internal directories.