feat: support offloadThreshold policy on Namespace

Signed-off-by: ericsyh <[email protected]>
streamnative · Sep 2, 2024 · da3be8f · da3be8f
1 parent 83ea5ac
commit da3be8f
Show file tree

Hide file tree

Showing 6 changed files with 126 additions and 2 deletions.
diff --git a/api/v1alpha1/pulsarnamespace_types.go b/api/v1alpha1/pulsarnamespace_types.go
@@ -99,6 +99,16 @@ type PulsarNamespaceSpec struct {
 	// +optional
 	BacklogQuotaType *string `json:"backlogQuotaType,omitempty"`
 
+	// OffloadThresholdTime specifies the time limit for message offloading.
+	// Messages older than this limit will be offloaded to the tiered storage.
+	// +optional
+	OffloadThresholdTime *utils.Duration `json:"offloadThresholdTime,omitempty"`
+
+	// OffloadThresholdSize specifies the size limit for message offloading.
+	// When the limit is reached, older messages will be offloaded to the tiered storage.
+	// +optional
+	OffloadThresholdSize *resource.Quantity `json:"offloadThresholdSize,omitempty"`
+
 	// GeoReplicationRefs is a list of references to PulsarGeoReplication resources,
 	// used to configure geo-replication for this namespace.
 	// This is **ONLY** used when you are using PulsarGeoReplication for setting up geo-replication

diff --git a/api/v1alpha1/zz_generated.deepcopy.go b/api/v1alpha1/zz_generated.deepcopy.go