fix: r

Signed-off-by: Ashing Zheng <[email protected]>

Author: ronething

internal/provider/adc/adc.go

@@ -115,7 +115,7 @@ func New(updater status.Updater, readier readiness.ReadinessManager, opts ...Opt
 	o := Options{}
 	o.ApplyOptions(opts)
 
-	executor := NewHTTPADCExecutor("http://127.0.0.1:3000")
+	executor := NewHTTPADCExecutor("http://127.0.0.1:3000", o.SyncTimeout)
 	log.Infow("using HTTP ADC Executor", zap.String("server_url", "http://127.0.0.1:3000"))
 
 	return &adcClient{

internal/provider/adc/executor.go

@@ -227,10 +227,10 @@ type HTTPADCExecutor struct {
 }
 
 // NewHTTPADCExecutor creates a new HTTPADCExecutor with the specified ADC Server URL
-func NewHTTPADCExecutor(serverURL string) *HTTPADCExecutor {
+func NewHTTPADCExecutor(serverURL string, timeout time.Duration) *HTTPADCExecutor {
 	return &HTTPADCExecutor{
 		httpClient: &http.Client{
-			Timeout: 30 * time.Second,
+			Timeout: timeout,
 		},
 		serverURL: serverURL,
 	}
@@ -272,7 +272,7 @@ func (e *HTTPADCExecutor) runHTTPSync(ctx context.Context, mode string, config a
 
 // runHTTPSyncForSingleServer performs HTTP sync to a single ADC Server
 func (e *HTTPADCExecutor) runHTTPSyncForSingleServer(ctx context.Context, serverAddr, mode string, config adcConfig, args []string) error {
-	ctx, cancel := context.WithTimeout(ctx, 15*time.Second)
+	ctx, cancel := context.WithTimeout(ctx, e.httpClient.Timeout)
 	defer cancel()
 
 	// Parse args to extract labels, types, and file path