utils

var (
	ExitFunc                 = os.Exit              // Function for exiting the application
	WaitForKubernetesAPIFunc = WaitForKubernetesAPI // Function for mocking
	RetryInterval            = 2 * time.Second      // Default values for retry logic, can be overridden externally

	// GCP Metadata Server URL
	MetadataServerBaseURL = "http://metadata.google.internal/computeMetadata/v1/instance/service-accounts/default/identity"

	// ListenAndServeWrapper wraps the http.ListenAndServe function for testing
	ListenAndServeWrapper = func(addr string, handler http.Handler) error {
		server := &http.Server{
			Addr:    addr,
			Handler: handler,
		}

		listener, err := net.Listen("tcp", addr)
		if err != nil {
			logging.Logger().Errorw(
				"Port already in use or cannot bind",
				"address", addr,
				"error", err,
			)
			return err
		}

		logging.Logger().Infow(
			"Server started successfully",
			"address", addr,
		)
		return server.Serve(listener)
	}
)