Use atomic.Bool for runtime started detection

Author: carabasdaniel

plugins.go

@@ -87,7 +87,7 @@ func (r *Runtime) pluginsLoaded() bool {
 			continue
 		}
 
-		if (pluginName == bundlePluginName || status.State == plugins.StateNotReady) && r.Started {
+		if (pluginName == bundlePluginName || status.State == plugins.StateNotReady) && r.Started.Load() {
 			bundles, err := r.GetBundles(timeoutCxt)
 			if err == nil && len(bundles) > 0 {
 				// if bundle plugin state is not ready after a reconfiguration, forcefully update plugin state if bundles are loaded.

runtime.go

@@ -35,7 +35,7 @@ type Runtime struct {
 	Logger          *zerolog.Logger
 	Config          *Config
 	InterQueryCache cache.InterQueryCache
-	Started         bool
+	Started         atomic.Bool
 
 	pluginsManager *plugins.Manager
 	plugins        map[string]plugins.Factory
@@ -434,14 +434,14 @@ func (r *Runtime) loadPaths(paths []string) (map[string]*bundle.Bundle, error) {
 
 // Start - triggers plugin manager to start all plugins.
 func (r *Runtime) Start(ctx context.Context) error {
-	r.Started = true
+	r.Started.Store(true)
 	return r.pluginsManager.Start(ctx)
 }
 
 // Stop - triggers plugin manager to stop all plugins.
 func (r *Runtime) Stop(ctx context.Context) {
-	if r.Started {
-		r.Started = false
+	if r.Started.Load() {
+		r.Started.Store(false)
 	}
 	r.pluginsManager.Stop(ctx) // stop plugins always.
 }