feat(namespace): add RemovePersistence methods to namespace admin (#1447)

Author: freeznet

pulsaradmin/pkg/admin/namespace.go

@@ -396,6 +396,12 @@ type Namespaces interface {
 	// SetPersistenceWithContext sets the persistence configuration for all the topics on a namespace
 	SetPersistenceWithContext(ctx context.Context, namespace string, persistence utils.PersistencePolicies) error
 
+	// RemovePersistence removes the persistence configuration for a namespace
+	RemovePersistence(namespace string) error
+
+	// RemovePersistenceWithContext removes the persistence configuration for a namespace
+	RemovePersistenceWithContext(ctx context.Context, namespace string) error
+
 	// GetPersistence returns the persistence configuration for a namespace.
 	// Returns nil if the persistence policy is not configured at the namespace level.
 	GetPersistence(namespace string) (*utils.PersistencePolicies, error)
@@ -1433,6 +1439,19 @@ func (n *namespaces) SetPersistenceWithContext(
 	return n.pulsar.Client.PostWithContext(ctx, endpoint, &persistence)
 }
 
+func (n *namespaces) RemovePersistence(namespace string) error {
+	return n.RemovePersistenceWithContext(context.Background(), namespace)
+}
+
+func (n *namespaces) RemovePersistenceWithContext(ctx context.Context, namespace string) error {
+	nsName, err := utils.GetNamespaceName(namespace)
+	if err != nil {
+		return err
+	}
+	endpoint := n.pulsar.endpoint(n.basePath, nsName.String(), "persistence")
+	return n.pulsar.Client.DeleteWithContext(ctx, endpoint)
+}
+
 func (n *namespaces) SetBookieAffinityGroup(namespace string, bookieAffinityGroup utils.BookieAffinityGroupData) error {
 	return n.SetBookieAffinityGroupWithContext(context.Background(), namespace, bookieAffinityGroup)
 }

pulsaradmin/pkg/admin/namespace_test.go

@@ -861,4 +861,12 @@ func TestNamespaces_Persistence(t *testing.T) {
 	assert.NotNil(t, persistence, "Expected non-nil when persistence is configured")
 	assert.Equal(t, 1, persistence.BookkeeperEnsemble)
 	assert.Equal(t, 1, persistence.BookkeeperWriteQuorum)
+
+	// Remove persistence policy - should return nil
+	err = admin.Namespaces().RemovePersistence(namespaceName)
+	assert.NoError(t, err)
+
+	persistence, err = admin.Namespaces().GetPersistence(namespaceName)
+	assert.NoError(t, err)
+	assert.Nil(t, persistence, "Expected nil after removing persistence configuration")
 }