Signed-off-by: Dmitrii Stepanov <d.stepanov@yadro.com>

@@ -125,6 +126,14 @@ func (x *Config) GC() *gcconfig.Config {
 	)
 }
 
+// Limits returns "limits" subsection as a gcconfig.Config.

@@ -139,7 +139,10 @@
       "skip_session_token_issuer_verification": true
     },
     "get": {
-      "priority": ["$attribute:ClusterName", "$attribute:UN-LOCODE"]

@@ -303,1 +304,4 @@
 
+### `limits` subsection
+
+### `limits` subsection

@@ -0,0 +57,4 @@
+		return &semaphore{limit: int64(config.MaxRunningOps)}, nil
+	}
+	return scheduling.NewMClock(
+		uint64(config.MaxRunningOps), uint64(config.MaxWaitingOps),

@@ -372,0 +381,4 @@
+		return err
+	}
+	if newConfig.limiter != nil {
+		newConfig.limiter.Close()

@@ -0,0 +40,4 @@
+	}
+	readScheduler, err := createScheduler(c.Read())
+	if err != nil {
+		return nil, fmt.Errorf("failed to create read scheduler: %w", err)

@@ -0,0 +78,4 @@
+			return fmt.Errorf("invalid limit_ops for tag %s: must be positive value", t.String())
+		}
+		if float64Value(v.Reserved) < 0 || math.IsNaN(float64Value(v.Reserved)) {
+			return fmt.Errorf("invalid limit_ops for tag %s: must be positive value", t.String())

@@ -0,0 +71,4 @@
+	MaxRunningOps int64
+	// IdleTimeout returns the value of "idle_timeout" config parameter.
+	//
+	// Returns DefaultIdleTimeout if the value is not a valid duration.

@@ -0,0 +2,4 @@
+
+import "strings"
+
+func Cond(cond bool, details ...string) {

@@ -0,0 +2,4 @@
+
+import "strings"
+
+func Cond(cond bool, details ...string) {

@@ -0,0 +27,4 @@
+	default:
+	}
+
+	v := s.count.Add(1)

@@ -195,0 +175,4 @@
+
+type rebuildLimiter struct {
+	concurrencyLimiter common.ConcurrencyLimiter
+	rateLimiter        qos.Limiter