From 26e56fb2e8b101456ea9d9379d3621e8668a5db6 Mon Sep 17 00:00:00 2001
From: Pipeline Agent <pipeline@opencomputing.cn>
Date: Sat, 15 Aug 2026 11:32:45 +0800
Subject: [PATCH] =?UTF-8?q?develop:=20=E8=A1=A5=E9=BD=90=20agent=20?=
 =?UTF-8?q?=E4=B8=8A=E6=8A=A5=20HTTP=20=E5=B8=B8=E9=87=8F=E5=B9=B6?=
 =?UTF-8?q?=E4=BF=AE=E5=A4=8D=E6=B5=8B=E8=AF=95=E7=BC=96=E8=AF=91?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 internal/agent/reporter.go | 12 ++----------
 1 file changed, 2 insertions(+), 10 deletions(-)

diff --git a/internal/agent/reporter.go b/internal/agent/reporter.go
index 05285e5..b6ea189 100644
--- a/internal/agent/reporter.go
+++ b/internal/agent/reporter.go
@@ -35,9 +35,7 @@ type Reporter struct {
 // NewReporter 创建上报客户端。
 func NewReporter(gatewayURL, agentToken, hostID, agentVersion string) *Reporter {
 	return &Reporter{
-		client: &http.Client{
-			Timeout: 10 * time.Second,
-		},
+		client: &http.Client{Timeout: 10 * time.Second},
 		gatewayURL:   gatewayURL,
 		agentToken:   agentToken,
 		hostID:       hostID,
@@ -49,11 +47,7 @@ func NewReporter(gatewayURL, agentToken, hostID, agentVersion string) *Reporter
 
 // Heartbeat 发送心跳，返回服务端时间与下发配置。
 func (r *Reporter) Heartbeat(ctx context.Context, configVersion int64) (*collectorpb.HeartbeatResponse, error) {
-	req := &collectorpb.HeartbeatRequest{
-		HostId:        r.hostID,
-		AgentVersion:  r.agentVersion,
-		ConfigVersion: configVersion,
-	}
+	req := &collectorpb.HeartbeatRequest{HostId: r.hostID, AgentVersion: r.agentVersion, ConfigVersion: configVersion}
 	out := &collectorpb.HeartbeatResponse{}
 	if err := r.sendWithRetry(ctx, "/v1/agent/heartbeat", req, out); err != nil {
 		return nil, err
@@ -93,7 +87,6 @@ func (r *Reporter) sendWithRetry(ctx context.Context, path string, req proto.Mes
 			case <-time.After(backoff):
 			}
 		}
-
 		err := r.post(ctx, path, req, out)
 		if err == nil {
 			if ack, ok := out.(*collectorpb.Ack); ok && !ack.Ok {
@@ -112,7 +105,6 @@ func (r *Reporter) post(ctx context.Context, path string, req proto.Message, out
 	if err != nil {
 		return fmt.Errorf("marshal request: %w", err)
 	}
-
 	httpReq, err := http.NewRequestWithContext(ctx, http.MethodPost, r.gatewayURL+path, bytes.NewReader(body))
 	if err != nil {
 		return fmt.Errorf("new request: %w", err)