Compare commits
4 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 69797a214f | |||
| 53e2d49e36 | |||
| f2ab6a94d5 | |||
| 1954182e1c |
@@ -3,8 +3,8 @@ package api
|
||||
import (
|
||||
"fmt"
|
||||
|
||||
"git.ego.cloudns.be/egommerce/api-entities/basket"
|
||||
basket "git.ego.cloudns.be/egommerce/api-entities/basket/dto"
|
||||
"git.ego.freeddns.org/egommerce/api-entities/basket"
|
||||
basket "git.ego.freeddns.org/egommerce/api-entities/basket/dto"
|
||||
"github.com/go-redis/redis/v8"
|
||||
)
|
||||
|
||||
|
||||
@@ -1,6 +1,7 @@
|
||||
package fluentd
|
||||
|
||||
import (
|
||||
"errors"
|
||||
"fmt"
|
||||
"log"
|
||||
|
||||
@@ -36,6 +37,14 @@ func (l *Logger) Log(format string, v ...any) {
|
||||
}
|
||||
}
|
||||
|
||||
func (l *Logger) Ping() error {
|
||||
if l.fluent.RequestAck {
|
||||
return nil
|
||||
}
|
||||
|
||||
return errors.New("Logger service is unavailable")
|
||||
}
|
||||
|
||||
func (l *Logger) Close() error {
|
||||
return l.fluent.Close()
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user