mirrors/ctrl
1
0
Fork 0
mirror of https://github.com/postmannen/ctrl.git synced 2025-03-31 01:24:31 +00:00
Code Activity

added own error layout for relayed messages

Browse source
This commit is contained in:
postmannen 2022-01-20 07:19:49 +01:00
parent a75c0d933a
commit 43bd929b2c
1 changed files with 9 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

14
errorkernel.go
View file

@ -76,12 +76,18 @@ func (e *errorKernel) start(newMessagesCh chan<- []subjectAndMessage) error {
switch errEvent.errorType {
case errTypeSendToCentralErrorLogger:
fmt.Printf(" * case errTypeSend\n")
// Just log the error by creating a message and send it
// to the errorCentral log server.
go func() {
// Add time stamp
er := fmt.Sprintf("%v, node: %v, %v\n", time.Now().Format("Mon Jan _2 15:04:05 2006"), errEvent.process.node, errEvent.err)
var er string
// Decide what extra information to add to the error message.
switch {
case errEvent.message.RelayFromNode != "":
er = fmt.Sprintf("%v, node: %v, relayFromNode: %v, %v\n", time.Now().Format("Mon Jan _2 15:04:05 2006"), errEvent.process.node, errEvent.message.RelayFromNode, errEvent.err)
default:
er = fmt.Sprintf("%v, node: %v, %v\n", time.Now().Format("Mon Jan _2 15:04:05 2006"), errEvent.process.node, errEvent.err)
}
sam := subjectAndMessage{
Subject: newSubject(REQErrorLog, "errorCentral"),
@ -108,8 +114,6 @@ func (e *errorKernel) start(newMessagesCh chan<- []subjectAndMessage) error {
// process who sent the error should block and wait for receiving
// an errActionContinue message.
fmt.Printf(" * case errTypeWithAction\n")
go func() {
log.Printf("TESTING, we received and error from the process, but we're telling the process back to continue\n")