chrissewell/beelzebub
1
0
Fork 0
mirror of https://github.com/mariocandela/beelzebub.git synced 2025-07-01 18:47:26 -04:00
Code Issues Packages Projects Releases Wiki Activity

Refactoring Tracer and ProtocolManager

Browse Source
This commit is contained in:
Mario
2022-06-04 17:14:46 +02:00
parent 1aafe73505
commit ab5a4f8137
3 changed files with 11 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
parser/configurationsParser.go
View File

@ -58,7 +58,7 @@ type ReadFileBytesByFilePath func(filePath string) ([]byte, error)
type GelAllFilesNameByDirName func(dirName string) ([]string, error) type GelAllFilesNameByDirName func(dirName string) ([]string, error)
// Init Parser, return a configurationsParser and use the DI Pattern to inject the dependencies // Init Parser, return a configurationsParser and use the D.I. Pattern to inject the dependencies
func Init(configurationsCorePath, configurationsServicesDirectory string) *configurationsParser { func Init(configurationsCorePath, configurationsServicesDirectory string) *configurationsParser {
return &configurationsParser{ return &configurationsParser{
configurationsCorePath: configurationsCorePath, configurationsCorePath: configurationsCorePath,

4
protocols/protocolManager.go
View File

@ -11,7 +11,7 @@ type ServiceStrategy interface {
type ProtocolManager struct { type ProtocolManager struct {
strategy ServiceStrategy strategy ServiceStrategy
tracer *tracer.Tracer tracer tracer.Tracer
} }
func InitProtocolManager(tracerStrategy tracer.Strategy, strategy ServiceStrategy) *ProtocolManager { func InitProtocolManager(tracerStrategy tracer.Strategy, strategy ServiceStrategy) *ProtocolManager {
@ -26,5 +26,5 @@ func (pm *ProtocolManager) SetProtocolStrategy(strategy ServiceStrategy) {
} }
func (pm *ProtocolManager) InitService(beelzebubServiceConfiguration parser.BeelzebubServiceConfiguration) error { func (pm *ProtocolManager) InitService(beelzebubServiceConfiguration parser.BeelzebubServiceConfiguration) error {
return pm.strategy.Init(beelzebubServiceConfiguration, *pm.tracer) return pm.strategy.Init(beelzebubServiceConfiguration, pm.tracer)
} }

12
tracer/tracer.go
View File

@ -6,17 +6,21 @@ import (
type Strategy func(event Event) type Strategy func(event Event)
type Tracer struct { type Tracer interface {
TraceEvent(event Event)
}
type tracer struct {
strategy Strategy strategy Strategy
} }
func Init(strategy Strategy) *Tracer { func Init(strategy Strategy) *tracer {
return &Tracer{ return &tracer{
strategy: strategy, strategy: strategy,
} }
} }
func (tracer *Tracer) TraceEvent(event Event) { func (tracer *tracer) TraceEvent(event Event) {
event.DateTime = time.Now().UTC().Format(time.RFC3339) event.DateTime = time.Now().UTC().Format(time.RFC3339)
tracer.strategy(event) tracer.strategy(event)
} }