From 8f2ecbc5e59ee0beddae1d9eac71d1e13d15792b Mon Sep 17 00:00:00 2001 From: Marco Kittel Date: Thu, 26 Jun 2025 07:05:47 +0200 Subject: [PATCH] Datawriter: Added HandleFunc --- go.mod | 2 +- go.sum | 8 ++++---- internal/dataservice/dataservice.go | 7 +++++-- 3 files changed, 10 insertions(+), 7 deletions(-) diff --git a/go.mod b/go.mod index f23e302..5450e8d 100644 --- a/go.mod +++ b/go.mod @@ -7,4 +7,4 @@ require ( gittea.marcokittel.de/elio/eliotools/tools v0.0.0-20250622182838-d7bc6feff972 ) -require gittea.marcokittel.de/elio/eliotools/eliofile v0.0.0-20250625211821-d801fbca0baf // indirect +require gittea.marcokittel.de/elio/eliotools/eliofile v0.0.0-20250626045721-6475655ba7b0 diff --git a/go.sum b/go.sum index cfae0ba..0273cd8 100644 --- a/go.sum +++ b/go.sum @@ -1,9 +1,9 @@ -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/eliofile v0.0.0-20250626043708-9b699695e66f h1:BHYs9jasxprRiOlAtHXVoam0fVtuMbIUVx8j0DQ5sMA= +gittea.marcokittel.de/elio/eliotools/eliofile v0.0.0-20250626043708-9b699695e66f/go.mod h1:RQlmQsRhpitThSuGT7vl5XwTh1duVGHCmJ0caI+xIoE= +gittea.marcokittel.de/elio/eliotools/eliofile v0.0.0-20250626045721-6475655ba7b0 h1:888K6jaDIbZpFPGv0weZMQXywtsDmUx/pD4mZWyFDEA= +gittea.marcokittel.de/elio/eliotools/eliofile v0.0.0-20250626045721-6475655ba7b0/go.mod h1:RQlmQsRhpitThSuGT7vl5XwTh1duVGHCmJ0caI+xIoE= gittea.marcokittel.de/elio/eliotools/logger v0.0.0-20250624203334-69cf94bf1eef h1:EzFzLINpiq712X2/t8ZMTLoWuqA6sRmpH3J0VpFi2Cg= gittea.marcokittel.de/elio/eliotools/logger v0.0.0-20250624203334-69cf94bf1eef/go.mod h1:WDmnG6o72HhGTSkgwj2kXYcRL2MaNFNsKNBeTh6NIzo= gittea.marcokittel.de/elio/eliotools/tools v0.0.0-20250622182838-d7bc6feff972 h1:ADdr3tbG0Zd5lYirqcMGWd7LSiVkwdOoknVOCfGFkYI= diff --git a/internal/dataservice/dataservice.go b/internal/dataservice/dataservice.go index 4c75d17..878875b 100644 --- a/internal/dataservice/dataservice.go +++ b/internal/dataservice/dataservice.go @@ -2,6 +2,7 @@ package dataservice import ( "context" + "fmt" "sync" "time" @@ -37,7 +38,7 @@ func (d *DataService) Run(ctx context.Context, wg *sync.WaitGroup) { } } d.log.Info("DataService Run") - time.Sleep(time.Second * 10) + time.Sleep(time.Second * 3) } } } @@ -47,6 +48,8 @@ func (d *DataService) AddListener(ev event.EventListener) { } func NewDataService() *DataService { - ds := DataService{listener: make([]event.EventListener, 0), log: logger.NewMarcoLogger(), ef: *eliofile.NewElioDateiFoo(".")} + ds := DataService{listener: make([]event.EventListener, 0), log: logger.NewMarcoLogger(), ef: *eliofile.NewElioDateiFoo(".", func(filename string) { + fmt.Printf("Achtung hier wird das CSV Vearbeitet: %s\n\n", filename) + })} return &ds }