diff --git a/pkg/core/core.go b/pkg/core/core.go index 06cb815..b02fc93 100644 --- a/pkg/core/core.go +++ b/pkg/core/core.go @@ -33,7 +33,7 @@ type Core struct { context context.Context cancel context.CancelFunc taskIDCounter atomic.Uint64 - waitgroup sync.WaitGroup + waitGroup sync.WaitGroup shutdown atomic.Bool } diff --git a/pkg/core/runtime.go b/pkg/core/runtime.go index 89c296e..627c52d 100644 --- a/pkg/core/runtime.go +++ b/pkg/core/runtime.go @@ -60,7 +60,7 @@ func (c *Core) ServiceShutdown(ctx context.Context) Result { // Drain background tasks before stopping services. done := make(chan struct{}) go func() { - c.waitgroup.Wait() + c.waitGroup.Wait() close(done) }() select { diff --git a/pkg/core/task.go b/pkg/core/task.go index ed4859c..8e67ba7 100644 --- a/pkg/core/task.go +++ b/pkg/core/task.go @@ -28,7 +28,7 @@ func (c *Core) PerformAsync(t Task) Result { tid.SetTaskIdentifier(taskID) } c.ACTION(ActionTaskStarted{TaskIdentifier: taskID, Task: t}) - c.waitgroup.Go(func() { + c.waitGroup.Go(func() { defer func() { if rec := recover(); rec != nil { err := E("core.PerformAsync", Sprint("panic: ", rec), nil)