From f0e395935b862bcb89a89ea4737257d221aae915 Mon Sep 17 00:00:00 2001
From: yfsn666 <lwy2306@163.com>
Date: Wed, 19 Aug 2026 23:13:48 +0800
Subject: [PATCH] [INLONG-12201][SDK] Update metrics when no available worker
 in Dataproxy Go SDK

---
 .../dataproxy-sdk-golang/dataproxy/client.go                    | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/inlong-sdk/dataproxy-sdk-twins/dataproxy-sdk-golang/dataproxy/client.go b/inlong-sdk/dataproxy-sdk-twins/dataproxy-sdk-golang/dataproxy/client.go
index f06b249a6b..5c3dff2f0a 100755
--- a/inlong-sdk/dataproxy-sdk-twins/dataproxy-sdk-golang/dataproxy/client.go
+++ b/inlong-sdk/dataproxy-sdk-twins/dataproxy-sdk-golang/dataproxy/client.go
@@ -230,6 +230,7 @@ func (c *client) Send(ctx context.Context, msg Message) error {
 
 	worker, err := c.getWorker()
 	if err != nil {
+		c.metrics.incMessage(workerBusy.getStrCode())
 		return ErrNoAvailableWorker
 	}
 	return worker.send(ctx, msg)
@@ -249,6 +250,7 @@ func (c *client) SendAsync(ctx context.Context, msg Message, cb Callback) {
 		if cb != nil {
 			cb(msg, ErrNoAvailableWorker)
 		}
+		c.metrics.incMessage(workerBusy.getStrCode())
 		return
 	}