Skip to content

Commit f6cfe2f

Browse files
committed
logger tweaks
2 parents eba8323 + 79ece62 commit f6cfe2f

5 files changed

Lines changed: 11 additions & 9 deletions

File tree

backend/pkg/logger/data/logger.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -109,8 +109,8 @@ func (sublogger *Logger) PushRecord(record abstraction.LoggerRecord) error {
109109
file, ok := sublogger.valueFileSlice[valueName]
110110
if !ok {
111111
filename := path.Join(
112-
"logger/data",
113-
fmt.Sprintf("data_%s", timestamp.Format("2006_01_02_15_04_05")),
112+
"logger", "data",
113+
loggerHandler.Timestamp.Format(loggerHandler.TimestampFormat),
114114
fmt.Sprintf("%s.csv", valueName),
115115
)
116116
err := os.MkdirAll(path.Dir(filename), os.ModePerm)

backend/pkg/logger/logger.go

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -14,6 +14,8 @@ const (
1414
HandlerName = "logger"
1515
)
1616

17+
const TimestampFormat = "01-Jan-2006_15-04-05.000"
18+
1719
// Logger is a struct that implements the abstraction.Logger interface
1820
type Logger struct {
1921
// An atomic boolean is used in order to use CompareAndSwap in the Start and Stop methods

backend/pkg/logger/order/logger.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -52,8 +52,8 @@ func (sublogger *Logger) Start() error {
5252
}
5353

5454
filename := path.Join(
55-
"logger/order",
56-
fmt.Sprintf("order_%s", logger.Timestamp.Format("2006_01_02_15_04_05")),
55+
"logger", "order",
56+
logger.Timestamp.Format(logger.TimestampFormat),
5757
"order.csv",
5858
)
5959
err := os.MkdirAll(path.Dir(filename), os.ModePerm)

backend/pkg/logger/protection/logger.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -91,8 +91,8 @@ func (sublogger *Logger) PushRecord(record abstraction.LoggerRecord) error {
9191
}
9292

9393
filename := path.Join(
94-
"logger/protections",
95-
fmt.Sprintf("protection_%s", logger.Timestamp.Format("2006_01_02_15_04_05")),
94+
"logger", "protections",
95+
logger.Timestamp.Format(logger.TimestampFormat),
9696
fmt.Sprintf("%s.csv", boardName),
9797
)
9898
err := os.MkdirAll(path.Dir(filename), os.ModePerm)

backend/pkg/logger/state/logger.go

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -68,9 +68,9 @@ func (sublogger *Logger) PushRecord(record abstraction.LoggerRecord) error {
6868
}
6969

7070
filename := path.Join(
71-
"logger/state",
72-
fmt.Sprintf("data_%s", logger.Timestamp.Format("2006_01_02_15_04_05")),
73-
fmt.Sprintf("state_%s.csv", time.Now().Format("2006_01_02_15_04_05")),
71+
"logger", "state",
72+
logger.Timestamp.Format(logger.TimestampFormat),
73+
fmt.Sprintf("%s.csv", time.Now().Format(logger.TimestampFormat)),
7474
)
7575
err := os.MkdirAll(path.Dir(filename), os.ModePerm)
7676
if err != nil {

0 commit comments

Comments
 (0)