spdf/elektron
Archived
1
0
Fork 0
Code Issues 4 Pull requests 1 Projects Releases Packages Wiki Activity

WIP : Elektron Logging library #16

Merged
balandi1 merged 50 commits from master into master 2019-12-10 01:15:34 +00:00
Conversation 113 Commits 50 Files changed 61 +3 -3
1 changed files with 3 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files
Showing only changes of commit f084eddd68 - Show all commits

6
schedulers/base.go
View file

@ -316,8 +316,8 @@ func (s *BaseScheduler) LogSlaveLost(slaveID *mesos.SlaveID) {
func (s *BaseScheduler) LogExecutorLost(executorID *mesos.ExecutorID, slaveID *mesos.SlaveID) { func (s *BaseScheduler) LogExecutorLost(executorID *mesos.ExecutorID, slaveID *mesos.SlaveID) {
elekLog.WithFields(log.Fields{ elekLog.WithFields(log.Fields{
"ExecutorID": executorID, "ExecutorID": *executorID.Value,
"SlaveID": slaveID, "SlaveID": *slaveID.Value,
}).Log(CONSOLE, log.ErrorLevel, "EXECUTOR LOST") }).Log(CONSOLE, log.ErrorLevel, "EXECUTOR LOST")
} }
@ -337,7 +337,7 @@ func (s *BaseScheduler) LogElectronError(err error) {
func (s *BaseScheduler) LogFrameworkRegistered(frameworkID *mesos.FrameworkID, func (s *BaseScheduler) LogFrameworkRegistered(frameworkID *mesos.FrameworkID,
masterInfo *mesos.MasterInfo) { masterInfo *mesos.MasterInfo) {
elekLog.WithFields(log.Fields{ elekLog.WithFields(log.Fields{
"frameworkID": frameworkID, "frameworkID": *frameworkID.Value,
"master": fmt.Sprintf("%v", masterInfo), "master": fmt.Sprintf("%v", masterInfo),
}).Log(CONSOLE, log.InfoLevel, "FRAMEWORK REGISTERED!") }).Log(CONSOLE, log.InfoLevel, "FRAMEWORK REGISTERED!")
} }