elio/datawriter
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Datewriter um Eliofile geupdated

Browse Source
This commit is contained in:
Marco Kittel 2025-06-25 23:23:38 +02:00
parent e8ce057f49
commit 0ec9c4501a
3 changed files with 11 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
go.mod
View File

@ -6,3 +6,5 @@ require (
gittea.marcokittel.de/elio/eliotools/logger v0.0.0-20250624203334-69cf94bf1eef
gittea.marcokittel.de/elio/eliotools/tools v0.0.0-20250622182838-d7bc6feff972
)
require gittea.marcokittel.de/elio/eliotools/eliofile v0.0.0-20250625211821-d801fbca0baf // indirect

4
go.sum
View File

@ -1,3 +1,7 @@
gittea.marcokittel.de/elio/eliotools/eliofile v0.0.0-20250625210735-e36a0cd13fe6 h1:lM7K/jCZINyCHQpRJR7hMvXRq6mlZlZChn2aBrRpeJE=
gittea.marcokittel.de/elio/eliotools/eliofile v0.0.0-20250625210735-e36a0cd13fe6/go.mod h1:RQlmQsRhpitThSuGT7vl5XwTh1duVGHCmJ0caI+xIoE=
gittea.marcokittel.de/elio/eliotools/eliofile v0.0.0-20250625211821-d801fbca0baf h1:LfjRyNZYKkWpdziHim2MygdvzTkHRusystBifCO0yuo=
gittea.marcokittel.de/elio/eliotools/eliofile v0.0.0-20250625211821-d801fbca0baf/go.mod h1:RQlmQsRhpitThSuGT7vl5XwTh1duVGHCmJ0caI+xIoE=
gittea.marcokittel.de/elio/eliotools/logger v0.0.0-20250622173330-32b4c009427c h1:oDEBlixjzptDRNutBddsgcNqls/+dDgfgzWvGGSnQwY=
gittea.marcokittel.de/elio/eliotools/logger v0.0.0-20250622173330-32b4c009427c/go.mod h1:WDmnG6o72HhGTSkgwj2kXYcRL2MaNFNsKNBeTh6NIzo=
gittea.marcokittel.de/elio/eliotools/logger v0.0.0-20250624203334-69cf94bf1eef h1:EzFzLINpiq712X2/t8ZMTLoWuqA6sRmpH3J0VpFi2Cg=

7
internal/dataservice/dataservice.go
View File

@ -7,12 +7,14 @@ import (
"gittea.marcokittel.de/elio/eliotools/datawriter/internal/dbwriter"
"gittea.marcokittel.de/elio/eliotools/datawriter/internal/event"
"gittea.marcokittel.de/elio/eliotools/eliofile"
"gittea.marcokittel.de/elio/eliotools/logger"
)
type DataService struct {
listener []event.EventListener
log logger.Logger
ef eliofile.ElioDateiFoo
}
func (d *DataService) ListenerCount() int {
@ -28,13 +30,14 @@ func (d *DataService) Run(ctx context.Context, wg *sync.WaitGroup) {
default:
//Hier nach neuen Dateien suchen
for _, l := range d.listener {
d.ef.ScanCsv()
err := l.HandleData(ctx, dbwriter.MyStruct{A: "dkl", B: 3})
if err != nil {
//todo
}
}
d.log.Info("DataService Run")
time.Sleep(time.Second * 2)
time.Sleep(time.Second * 10)
}
}
}
@ -44,6 +47,6 @@ func (d *DataService) AddListener(ev event.EventListener) {
}
func NewDataService() *DataService {
ds := DataService{listener: make([]event.EventListener, 0), log: logger.NewMarcoLogger()}
ds := DataService{listener: make([]event.EventListener, 0), log: logger.NewMarcoLogger(), ef: *eliofile.NewElioDateiFoo(".")}
return &ds
}