Please ignore

.golangci.yml

@@ -113,6 +113,7 @@ linters-settings:
       - github.com/dop251/goja_nodejs
       - github.com/fsnotify/fsnotify
       - github.com/tonistiigi/fifo
+      - github.com/leoluk/perflib_exporter/perflib
 
   gosimple:
     # Select the Go version to target. The default is '1.13'.

go.mod

@@ -321,6 +321,7 @@ replace (
 	github.com/Shopify/sarama => github.com/elastic/sarama v1.19.1-0.20220310193331-ebc2b0d8eef3
 	github.com/dop251/goja => github.com/andrewkroh/goja v0.0.0-20190128172624-dd2ac4456e20
 	github.com/dop251/goja_nodejs => github.com/dop251/goja_nodejs v0.0.0-20171011081505-adff31b136e6
+	github.com/leoluk/perflib_exporter/perflib => github.com/prometheus-community/windows_exporter/pkg/perflib v0.25.1
 	github.com/tonistiigi/fifo => github.com/containerd/fifo v0.0.0-20190816180239-bda0ff6ed73c
 )
 

internal/pkg/agent/appinit/appinit.go

@@ -0,0 +1,36 @@
+// Copyright Elasticsearch B.V. and/or licensed to Elasticsearch B.V. under one
+// or more contributor license agreements. Licensed under the Elastic License;
+// you may not use this file except in compliance with the Elastic License.
+
+package appinit
+
+import (
+	"os"
+	"sync"
+
+	"github.com/elastic/elastic-agent-libs/service"
+)
+
+var stopSvcChan = make(chan bool)
+var once sync.Once
+var stopBeat = func() {
+	close(stopSvcChan)
+}
+
+func init() {
+	if len(os.Args) > 1 && os.Args[1] == "run" {
+		once.Do(func() {
+			var wg sync.WaitGroup
+			wg.Add(1)
+			go func() {
+				wg.Done()
+				service.ProcessWindowsControlEvents(stopBeat)
+			}()
+			wg.Wait()
+		})
+	}
+}
+
+func StopSvcChan() chan bool {
+	return stopSvcChan
+}

internal/pkg/agent/cmd/otel.go

@@ -2,8 +2,6 @@
 // or more contributor license agreements. Licensed under the Elastic License;
 // you may not use this file except in compliance with the Elastic License.
 
-//go:build !windows
-
 package cmd
 
 import (

internal/pkg/agent/cmd/otel_flags.go

@@ -2,8 +2,6 @@
 // or more contributor license agreements. Licensed under the Elastic License;
 // you may not use this file except in compliance with the Elastic License.
 
-//go:build !windows
-
 package cmd
 
 import (

internal/pkg/agent/cmd/otel_flags_test.go

@@ -2,8 +2,6 @@
 // or more contributor license agreements. Licensed under the Elastic License;
 // you may not use this file except in compliance with the Elastic License.
 
-//go:build !windows
-
 package cmd
 
 import (

internal/pkg/agent/cmd/run.go

@@ -28,6 +28,7 @@ import (
 	"github.com/elastic/elastic-agent-system-metrics/report"
 	"github.com/elastic/elastic-agent/internal/pkg/agent/vault"
 
+	"github.com/elastic/elastic-agent/internal/pkg/agent/appinit"
 	"github.com/elastic/elastic-agent/internal/pkg/agent/application"
 	"github.com/elastic/elastic-agent/internal/pkg/agent/application/coordinator"
 	"github.com/elastic/elastic-agent/internal/pkg/agent/application/filelock"
@@ -117,6 +118,13 @@ func run(override cfgOverrider, testingMode bool, fleetInitTimeout time.Duration
 		service.WaitExecutionDone()
 	}()
 
+	service.BeforeRun()
+	defer service.Cleanup()
+
+	// register as a service
+	ctx, cancel := context.WithCancel(context.Background())
+	defer cancel()
+
 	if err := handleUpgrade(); err != nil {
 		return fmt.Errorf("error checking for and handling upgrade: %w", err)
 	}
@@ -129,20 +137,7 @@ func run(override cfgOverrider, testingMode bool, fleetInitTimeout time.Duration
 		_ = locker.Unlock()
 	}()
 
-	service.BeforeRun()
-	defer service.Cleanup()
-
-	// register as a service
-	stop := make(chan bool)
-	ctx, cancel := context.WithCancel(context.Background())
-	stopBeat := func() {
-		close(stop)
-	}
-
-	defer cancel()
-	go service.ProcessWindowsControlEvents(stopBeat)
-
-	return runElasticAgent(ctx, cancel, override, stop, testingMode, fleetInitTimeout, false, nil, modifiers...)
+	return runElasticAgent(ctx, cancel, override, appinit.StopSvcChan(), testingMode, fleetInitTimeout, false, nil, modifiers...)
 }
 
 func logReturn(l *logger.Logger, err error) error {

internal/pkg/agent/cmd/validate.go

@@ -2,8 +2,6 @@
 // or more contributor license agreements. Licensed under the Elastic License;
 // you may not use this file except in compliance with the Elastic License.
 
-//go:build !windows
-
 package cmd
 
 import (

internal/pkg/agent/cmd/validate_test.go

@@ -2,8 +2,6 @@
 // or more contributor license agreements. Licensed under the Elastic License;
 // you may not use this file except in compliance with the Elastic License.
 
-//go:build !windows
-
 package cmd
 
 import (

internal/pkg/otel/components.go

@@ -2,8 +2,6 @@
 // or more contributor license agreements. Licensed under the Elastic License;
 // you may not use this file except in compliance with the Elastic License.
 
-//go:build !windows
-
 package otel
 
 import (

internal/pkg/otel/config_file_provider.go

@@ -2,8 +2,6 @@
 // or more contributor license agreements. Licensed under the Elastic License;
 // you may not use this file except in compliance with the Elastic License.
 
-//go:build !windows
-
 package otel
 
 import (

internal/pkg/otel/config_file_provider_test.go

@@ -2,8 +2,6 @@
 // or more contributor license agreements. Licensed under the Elastic License;
 // you may not use this file except in compliance with the Elastic License.
 
-//go:build !windows
-
 package otel
 
 import (

internal/pkg/otel/run.go

@@ -2,8 +2,6 @@
 // or more contributor license agreements. Licensed under the Elastic License;
 // you may not use this file except in compliance with the Elastic License.
 
-//go:build !windows
-
 package otel
 
 import (

internal/pkg/otel/run_test.go

@@ -2,8 +2,6 @@
 // or more contributor license agreements. Licensed under the Elastic License;
 // you may not use this file except in compliance with the Elastic License.
 
-//go:build !windows
-
 package otel
 
 import (

internal/pkg/otel/validate.go

@@ -2,8 +2,6 @@
 // or more contributor license agreements. Licensed under the Elastic License;
 // you may not use this file except in compliance with the Elastic License.
 
-//go:build !windows
-
 package otel
 
 import (

main.go

@@ -10,6 +10,7 @@
 	"os"
 	"time"
 
+	_ "github.com/elastic/elastic-agent/internal/pkg/agent/appinit"
 	"github.com/elastic/elastic-agent/internal/pkg/agent/cmd"
 	"github.com/elastic/elastic-agent/pkg/core/process"
 )
@@ -36,7 +37,7 @@
 	}
 	defer pj.Close()
 
 	rand.Seed(time.Now().UnixNano())
 	command := cmd.NewCommand()
 	err = command.Execute()
 	if err != nil {

pkg/testing/fixture_install.go

@@ -190,7 +190,7 @@ func (f *Fixture) installNoPkgManager(ctx context.Context, installOpts *InstallO
 	installArgs = append(installArgs, installOptsArgs...)
 	out, err := f.Exec(ctx, installArgs, opts...)
 	if err != nil {
-		return out, fmt.Errorf("error running agent install command: %w", err)
+		return out, fmt.Errorf("error running agent install command: %w with output: %s", err, string(out))
 	}
 
 	f.installed = true
@@ -245,6 +245,19 @@ func (f *Fixture) installNoPkgManager(ctx context.Context, installOpts *InstallO
 			if err != nil {
 				f.t.Logf("error serializing processes: %s", err)
 			}
+
+			if runtime.GOOS == "windows" {
+				filePath := filepath.Join(dir, "build", "diagnostics", fmt.Sprintf("TEST-%s-%s-%s-EventLogs.json", sanitizedTestName, f.operatingSystem, f.architecture))
+				psCommand := `Get-EventLog -LogName Application -EntryType Error -Newest 1000`
+				out, err := exec.Command("powershell", "-NoProfile", psCommand).CombinedOutput()
+				if err != nil {
+					f.t.Logf("error executing command: %s with output %s", err, string(out))
+				} else {
+					if err := os.WriteFile(filePath, out, 0666); err != nil {
+						f.t.Logf("error wrting file %s: %s", filePath, err)
+					}
+				}
+			}
 		}
 	})
 
@@ -603,7 +616,7 @@ func (f *Fixture) uninstallNoPkgManager(ctx context.Context, uninstallOpts *Unin
 	}
 	out, err := f.Exec(ctx, uninstallArgs, opts...)
 	if err != nil {
-		return out, fmt.Errorf("error running uninstall command: %w", err)
+		return out, fmt.Errorf("error running uninstall command: %w with output: %s", err, string(out))
 	}
 	f.installed = false