feat: add tart status get probe

Signed-off-by: dzmitryharchanin-tomtom <dzmitry.harchanin@tomtom.com>

Author: dzmitryharchanin-tomtom

pkg/clients/tart/client.go

@@ -20,6 +20,7 @@ import (
 	"bytes"
 	"encoding/base64"
 	"fmt"
+	"net"
 	"os"
 	"os/exec"
 	"path"
@@ -75,6 +76,22 @@ func (c *Client) GetTartVersion() (string, error) {
 	return version, nil
 }
 
+func (c *Client) GetTartVMIP(tartVMName string) (string, error) {
+	if !isValidExecutablePath(c.tartPath) {
+		return "", fmt.Errorf("invalid tart path: %s", c.tartPath)
+	}
+	// #nosec G204 - tartPath is a trusted configuration value, not user input
+	out, err := exec.Command(c.tartPath, "ip", tartVMName).CombinedOutput()
+	if err != nil {
+		return "", err
+	}
+	ip := net.ParseIP(strings.TrimRight(string(out), "\r\n"))
+	if ip == nil {
+		return "", fmt.Errorf("failed to get tart VM IP")
+	}
+	return ip.String(), nil
+}
+
 func (c *Client) BuildCMDArguments(tartVMName string, config types.RunnerConfig) []string {
 	var args []string
 

pkg/prober/probe/tart/tart.go

@@ -0,0 +1,47 @@
+/*
+ * Copyright 2025 TomTom N.V.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package tart
+
+import (
+	"fmt"
+
+	"github.com/tomtom-international/macos-actions-runner-controller/pkg/clients/tart"
+	"github.com/tomtom-international/macos-actions-runner-controller/pkg/prober/probe"
+)
+
+type tartProber struct {
+	client *tart.Client
+}
+
+type Prober interface {
+	Probe(tartVMName string) (probe.Result, string, error)
+}
+
+func New(tartClient *tart.Client) Prober {
+	return tartProber{
+		client: tartClient,
+	}
+}
+
+func (t tartProber) Probe(tartVMName string) (probe.Result, string, error) {
+	_, err := t.client.GetTartVMIP(tartVMName)
+	if err != nil {
+		return probe.Failure, fmt.Sprintf("Failed to get tart VM %s IP", tartVMName), err
+	}
+
+	return probe.Success, "tart probe success", nil
+}

pkg/prober/probe_manager.go

@@ -21,6 +21,7 @@ import (
 	"sync"
 
 	ghclient "github.com/tomtom-international/macos-actions-runner-controller/pkg/clients/github"
+	tartclient "github.com/tomtom-international/macos-actions-runner-controller/pkg/clients/tart"
 	"github.com/tomtom-international/macos-actions-runner-controller/pkg/logger"
 	"github.com/tomtom-international/macos-actions-runner-controller/pkg/prober/results"
 	pt "github.com/tomtom-international/macos-actions-runner-controller/pkg/prober/types"
@@ -39,11 +40,12 @@ type ProberManager struct {
 
 func NewManager(
 	githubClient *ghclient.Client,
+	tartClient *tartclient.Client,
 	stateManager *state.StateManager,
 	livenessManager results.Manager,
 	startupManager results.Manager) *ProberManager {
 
-	prober := newProber(githubClient)
+	prober := newProber(githubClient, tartClient)
 	return &ProberManager{
 		stateManager:    stateManager,
 		prober:          prober,

pkg/prober/prober.go

@@ -1,6 +1,6 @@
 /*
  * Copyright 2025 TomTom N.V.
- * Copyright 2015 The Kubernetes Authors.
+ * Copyright 2014 The Kubernetes Authors.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -22,10 +22,12 @@ import (
 	"time"
 
 	ghclient "github.com/tomtom-international/macos-actions-runner-controller/pkg/clients/github"
+	tartclient "github.com/tomtom-international/macos-actions-runner-controller/pkg/clients/tart"
 	"github.com/tomtom-international/macos-actions-runner-controller/pkg/logger"
 	"github.com/tomtom-international/macos-actions-runner-controller/pkg/prober/probe"
 	githubprobe "github.com/tomtom-international/macos-actions-runner-controller/pkg/prober/probe/github"
 	httpprobe "github.com/tomtom-international/macos-actions-runner-controller/pkg/prober/probe/http"
+	tartprobe "github.com/tomtom-international/macos-actions-runner-controller/pkg/prober/probe/tart"
 	pt "github.com/tomtom-international/macos-actions-runner-controller/pkg/prober/types"
 )
 
@@ -34,12 +36,14 @@ const maxProbeRetries = 3
 type prober struct {
 	github githubprobe.Prober
 	http   httpprobe.Prober
+	tart   tartprobe.Prober
 }
 
-func newProber(githubClient *ghclient.Client) *prober {
+func newProber(githubClient *ghclient.Client, tartClient *tartclient.Client) *prober {
 	return &prober{
 		github: githubprobe.New(githubClient),
 		http:   httpprobe.New(),
+		tart:   tartprobe.New(tartClient),
 	}
 }
 
@@ -90,10 +94,12 @@ func (pb *prober) runProbeWithRetries(spec *pt.Probe, target *pt.ProbeTarget, re
 func (pb *prober) runProbe(spec *pt.Probe, target *pt.ProbeTarget) (probe.Result, string, error) {
 	timeout := time.Duration(spec.TimeoutSeconds) * time.Second
 	switch {
+	case spec.TartVMStatusGet != nil:
+		logger.Debugf("Run TartVMStatusGet probe for traget: %s with ID: %s", target.Name, target.ID)
+		return pb.tart.Probe(target.TartVMName)
 	case spec.HTTPGet != nil:
-		logger.Infof("HTTPGet probe for traget: %v with ID: %v", target.Name, target.ID)
+		logger.Debugf("Run HTTPGet probe for traget: %s with ID: %s", target.Name, target.ID)
 		return pb.http.Probe(timeout)
-
 	case spec.GitHubRunnerGet != nil:
 		return pb.github.Probe(target.Name)
 	default:

pkg/prober/types/types.go

@@ -39,6 +39,8 @@ type ProbeHandler struct {
 	HTTPGet *HTTPGetAction `json:"httpGet,omitempty" yaml:"httpGet,omitempty"`
 
 	GitHubRunnerGet *GitHubRunnerGetAction `json:"githubRunnerGet,omitempty" yaml:"githubRunnerGet,omitempty"`
+
+	TartVMStatusGet *TartVMStatusGetAction `json:"tartVMStatusGet,omitempty" yaml:"tartVMStatusGet,omitempty"`
 }
 
 // URIScheme identifies the scheme used for connection to a host for Get actions
@@ -88,10 +90,14 @@ type GitHubRunnerGetAction struct {
 	RunnerName string `json:"runnerName,omitempty" yaml:"runnerName,omitempty"`
 }
 
+type TartVMStatusGetAction struct {
+}
+
 type ProbeTarget struct {
 	StartupProbe  *Probe          `json:"startupProbe,omitempty"`
 	LivenessProbe *Probe          `json:"livenessProbe,omitempty"`
 	ID            utils.UID       `json:"id"`
+	TartVMName    string          `json:"tartVMName"`
 	Name          string          `json:"name"`
 	Type          ProbeTargetType `json:"type"`
 }

pkg/tarter/tarter.go

@@ -103,7 +103,7 @@ func NewTarter(tarterConfig *config.TarterConfig,
 		versionInfo:      versionInfo,
 		githubClient:     githubClient,
 		tartClient:       tartClient,
-		proberManager:    prober.NewManager(githubClient, stateMachine, livenessManager, startupManager),
+		proberManager:    prober.NewManager(githubClient, tartClient, stateMachine, livenessManager, startupManager),
 		StateManager:     stateMachine,
 		runnerManager:    runner.NewRunnerManager(tartClient, githubClient, stateMachine, maxActiveRunners, nodeName),
 		eventBus:         eventBus,
@@ -174,6 +174,7 @@ func (t *Tarter) addProber(runner *tt.Runner) {
 	logger.Infof("Adding probe for runner %v ...", runner.ID)
 	probeTarget := &pt.ProbeTarget{
 		ID:            runner.ID,
+		TartVMName:    fmt.Sprintf("%s-%s", runner.Config.Name, string(runner.ID)),
 		Name:          runner.GhaRunnerName, // GhaRunnerName used by GitHub prober
 		Type:          pt.ProbeTargetTypeTartRunner,
 		StartupProbe:  runner.Config.StartupProbe,