jobmonitor

Documentation

Index

• func InitLogger(trainingID string, userID string) *log.Entry
• func KillDeployedJob(trainingID string, userID string, jobName string, logr *logger.LocLoggingEntry) error
• type JobMonitor
  • func NewJobMonitor(trainingID string, userID string, numLearners int, jobName string, ...) (*JobMonitor, error)
  • func (jm *JobMonitor) ManageDistributedJob(logr *logger.LocLoggingEntry)

Functions

func InitLogger

func InitLogger(trainingID string, userID string) *log.Entry

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