Remove labels from HeartbeatRequest and worker struct

Author: sebastianrath

agent/models.go

@@ -75,7 +75,6 @@ type StatusReport struct {
 // HeartbeatRequest is sent periodically with agent metrics.
 type HeartbeatRequest struct {
 	UUID          string  `json:"uuid,omitempty"`
-	Labels        string  `json:"labels,omitempty"`
 	CPUPercent    float64 `json:"cpu_percent"`
 	MemPercent    float64 `json:"mem_percent"`
 	MemUsedBytes  int64   `json:"mem_used_bytes"`

agent/worker.go

@@ -24,7 +24,6 @@ type Worker struct {
 	client       *Client
 	docker       DockerConfig
 	vcsOpts      vcs.Options
-	labels       string
 	pollInterval time.Duration
 	uuid         string
 	slotCleanup  func()
@@ -34,14 +33,13 @@ type Worker struct {
 	lastCounters *RawCounters
 }
 
-func NewWorker(client *Client, docker DockerConfig, vcsOpts vcs.Options, labels string) *Worker {
+func NewWorker(client *Client, docker DockerConfig, vcsOpts vcs.Options) *Worker {
 	uuid, cleanup := acquireAgentSlot()
 	client.SetUUID(uuid)
 	return &Worker{
 		client:       client,
 		docker:       docker,
 		vcsOpts:      vcsOpts,
-		labels:       labels,
 		pollInterval: 1 * time.Second,
 		uuid:         uuid,
 		slotCleanup:  cleanup,
@@ -630,13 +628,13 @@ func (w *Worker) buildHeartbeatRequest() HeartbeatRequest {
 	snap, err := Snapshot()
 	if err != nil {
 		w.log.WithError(err).Warn("metrics snapshot error")
-		return HeartbeatRequest{UUID: w.uuid, Labels: w.labels}
+		return HeartbeatRequest{UUID: w.uuid}
 	}
 
 	w.metricsMu.Lock()
 	defer w.metricsMu.Unlock()
 
-	req := HeartbeatRequest{UUID: w.uuid, Labels: w.labels}
+	req := HeartbeatRequest{UUID: w.uuid}
 	if w.lastCounters != nil {
 		// CPU percent
 		if snap.CPUInstant {

cmd/cmd_agent.go

@@ -16,7 +16,6 @@ import (
 var (
 	flagAgentServer             string
 	flagAgentToken              string
-	flagAgentLabels             string
 	flagAgentDockerDisabled     bool
 	flagAgentDockerDefaultImage string
 	flagAgentP4Client           string
@@ -36,7 +35,6 @@ func init() {
 	if os.Getenv("ACT_AGENT_TOKEN") == "" {
 		cmdAgent.MarkFlagRequired("token")
 	}
-	cmdAgent.Flags().StringVar(&flagAgentLabels, "labels", envOr("ACT_AGENT_LABELS", ""), "Comma-separated labels for job matching (env: ACT_AGENT_LABELS)")
 	cmdAgent.Flags().BoolVar(&flagAgentDockerDisabled, "docker-disabled", envOrBool("ACT_AGENT_DOCKER_DISABLED", false), "Disable Docker execution, always run natively")
 	cmdAgent.Flags().StringVar(&flagAgentDockerDefaultImage, "docker-default-image", envOr("ACT_AGENT_DOCKER_DEFAULT_IMAGE", ""), "Force this Docker image for all scripts")
 	cmdAgent.Flags().StringVar(&flagAgentP4Client, "p4-client", envOr("ACT_AGENT_P4CLIENT", ""), "Reuse an existing Perforce workspace instead of creating a temporary one (env: ACT_AGENT_P4CLIENT)")
@@ -70,7 +68,7 @@ func cmdAgentRun(cmd *cobra.Command, args []string) {
 			DefaultImage: flagAgentDockerDefaultImage,
 		}, vcs.Options{
 			P4Client: flagAgentP4Client,
-		}, flagAgentLabels)
+		})
 
 		log.WithField("server", serverURL).Info("connecting")
 		err := w.Run(ctx)