✨ redis cached: batch size option

api/v1alpha1/limitador_types.go

@@ -224,6 +224,10 @@ type RedisCachedOptions struct {
 	// +optional
 	// ResponseTimeout defines the timeout for Redis commands in milliseconds [default: 350]
 	ResponseTimeout *int `json:"response-timeout,omitempty"`
+
+	// +optional
+	// BatchSize defines the size of entries to flush in as single flush [default: 100]
+	BatchSize *int `json:"batch-size,omitempty"`
 }
 
 type RedisCached struct {

bundle/manifests/limitador-operator.clusterserviceversion.yaml

@@ -37,7 +37,7 @@ metadata:
     capabilities: Basic Install
     categories: Integration & Delivery
     containerImage: quay.io/kuadrant/limitador-operator:latest
-    createdAt: "2024-05-03T10:11:12Z"
+    createdAt: "2024-05-16T14:52:42Z"
     operators.operatorframework.io/builder: operator-sdk-v1.32.0
     operators.operatorframework.io/project_layout: go.kubebuilder.io/v3
     repository: https://github.com/Kuadrant/limitador-operator

bundle/manifests/limitador.kuadrant.io_limitadors.yaml

@@ -1055,6 +1055,10 @@ spec:
                         x-kubernetes-map-type: atomic
                       options:
                         properties:
+                          batch-size:
+                            description: 'BatchSize defines the size of entries to
+                              flush in as single flush [default: 100]'
+                            type: integer
                           flush-period:
                             description: 'FlushPeriod for counters in milliseconds
                               [default: 1000]'

config/crd/bases/limitador.kuadrant.io_limitadors.yaml

@@ -1056,6 +1056,10 @@ spec:
                         x-kubernetes-map-type: atomic
                       options:
                         properties:
+                          batch-size:
+                            description: 'BatchSize defines the size of entries to
+                              flush in as single flush [default: 100]'
+                            type: integer
                           flush-period:
                             description: 'FlushPeriod for counters in milliseconds
                               [default: 1000]'

controllers/limitador_controller_test.go

@@ -603,6 +603,7 @@ var _ = Describe("Limitador controller", func() {
 				FlushPeriod:     ptr.To(3),
 				MaxCached:       ptr.To(4),
 				ResponseTimeout: ptr.To(5),
+				BatchSize:       ptr.To(6),
 			}
 
 			Expect(k8sClient.Create(ctx, limitadorObj)).Should(Succeed())
@@ -633,6 +634,7 @@ var _ = Describe("Limitador controller", func() {
 					"--flush-period", "3",
 					"--max-cached", "4",
 					"--response-timeout", "5",
+					"--batch-size", "6",
 				),
 			)
 		}, specTimeOut)

doc/storage.md

@@ -108,12 +108,12 @@ Additionally, caching options can be specified in the `spec.storage.redis-cached
 
 ### Options
 
-| Option         | Description                                                           |
-|----------------|-----------------------------------------------------------------------|
-| `ttl`          | TTL for cached counters in milliseconds [default: 5000]               |
-| `ratio`        | Ratio to apply to the TTL from Redis on cached counters [default: 10] |
-| `flush-period` | Flushing period for counters in milliseconds [default: 1000]          |
-| `max-cached`   | Maximum amount of counters cached [default: 10000]                    |
+| Option               | Description                                                           |
+|----------------------|-----------------------------------------------------------------------|
+| `batch-size`         | Size of entries to flush in as single flush [default: 100]            |
+| `flush-period`       | Flushing period for counters in milliseconds [default: 1000]          |
+| `max-cached`         | Maximum amount of counters cached [default: 10000]                    |
+| `response-timeout`   | Timeout for Redis commands in milliseconds [default: 350]             |
 
 For example:
 
@@ -128,7 +128,7 @@ spec:
       configSecretRef: # The secret reference storing the URL for Redis
         name: redisconfig
       options: # Every option is optional
-        ttl: 1000
+        batch-size: 50
         max-cached: 5000
 ```
 

pkg/limitador/redis_cache_storage_options.go

@@ -30,6 +30,9 @@ func RedisCachedDeploymentOptions(ctx context.Context, cl client.Client, defSecr
 		if redisCachedObj.Options.ResponseTimeout != nil {
 			command = append(command, "--response-timeout", strconv.Itoa(*redisCachedObj.Options.ResponseTimeout))
 		}
+		if redisCachedObj.Options.BatchSize != nil {
+			command = append(command, "--batch-size", strconv.Itoa(*redisCachedObj.Options.BatchSize))
+		}
 	}
 
 	return DeploymentStorageOptions{

pkg/limitador/redis_cache_storage_options_test.go

@@ -108,6 +108,7 @@ func TestRedisCachedDeploymentOptions(t *testing.T) {
 				FlushPeriod:     ptr.To(3),
 				MaxCached:       ptr.To(4),
 				ResponseTimeout: ptr.To(5),
+				BatchSize:       ptr.To(6),
 			},
 		}
 		options, err := RedisCachedDeploymentOptions(ctx, cl, namespace, redisObj)
@@ -120,6 +121,7 @@ func TestRedisCachedDeploymentOptions(t *testing.T) {
 					"--flush-period", "3",
 					"--max-cached", "4",
 					"--response-timeout", "5",
+					"--batch-size", "6",
 				},
 			},
 		)