feat: align topic level latest apis for policies

api/v1alpha1/pulsarnamespace_types.go

@@ -161,7 +161,7 @@ type PulsarNamespaceSpec struct {
 	// This setting controls how schema evolution is handled for topics within this namespace.
 	// +optional
 	// +kubebuilder:validation:Enum=UNDEFINED;ALWAYS_INCOMPATIBLE;ALWAYS_COMPATIBLE;BACKWARD;FORWARD;FULL;BACKWARD_TRANSITIVE;FORWARD_TRANSITIVE;FULL_TRANSITIVE
-	SchemaCompatibilityStrategy *adminutils.SchemaCompatibilityStrategy `json:"schemaCompatibilityStrategy,omitempty"`
+	SchemaCompatibilityStrategy *SchemaCompatibilityStrategy `json:"schemaCompatibilityStrategy,omitempty"`
 
 	// SchemaValidationEnforced controls whether schema validation is enforced for this namespace.
 	// When enabled, producers must provide a schema when publishing messages.

api/v1alpha1/pulsartopic_types.go

@@ -161,6 +161,65 @@ type PulsarTopicSpec struct {
 	// This controls how inactive topics are automatically cleaned up.
 	// +optional
 	InactiveTopicPolicies *InactiveTopicPolicies `json:"inactiveTopicPolicies,omitempty"`
+
+	// SubscribeRate defines the subscription rate limiting policy for the topic.
+	// This controls the rate at which new subscriptions can be created.
+	// +optional
+	SubscribeRate *SubscribeRate `json:"subscribeRate,omitempty"`
+
+	// MaxMessageSize specifies the maximum size of messages that can be published to the topic.
+	// Messages larger than this size will be rejected.
+	// +optional
+	MaxMessageSize *int32 `json:"maxMessageSize,omitempty"`
+
+	// MaxConsumersPerSubscription sets the maximum number of consumers allowed per subscription.
+	// +optional
+	MaxConsumersPerSubscription *int32 `json:"maxConsumersPerSubscription,omitempty"`
+
+	// MaxSubscriptionsPerTopic sets the maximum number of subscriptions allowed on the topic.
+	// +optional
+	MaxSubscriptionsPerTopic *int32 `json:"maxSubscriptionsPerTopic,omitempty"`
+
+	// SchemaValidationEnforced determines whether schema validation is enforced for the topic.
+	// When enabled, only messages that conform to the topic's schema will be accepted.
+	// +optional
+	SchemaValidationEnforced *bool `json:"schemaValidationEnforced,omitempty"`
+
+	// SubscriptionDispatchRate defines the message dispatch rate limiting policy for subscriptions.
+	// This controls the rate at which messages are delivered to consumers per subscription.
+	// +optional
+	SubscriptionDispatchRate *DispatchRate `json:"subscriptionDispatchRate,omitempty"`
+
+	// ReplicatorDispatchRate defines the message dispatch rate limiting policy for replicators.
+	// This controls the rate at which messages are replicated to other clusters.
+	// +optional
+	ReplicatorDispatchRate *DispatchRate `json:"replicatorDispatchRate,omitempty"`
+
+	// DeduplicationSnapshotInterval specifies the interval for taking deduplication snapshots.
+	// This affects the deduplication performance and storage overhead.
+	// +optional
+	DeduplicationSnapshotInterval *int32 `json:"deduplicationSnapshotInterval,omitempty"`
+
+	// OffloadPolicies defines the offload policies for the topic.
+	// This controls how data is offloaded to external storage systems.
+	// +optional
+	OffloadPolicies *OffloadPolicies `json:"offloadPolicies,omitempty"`
+
+	// AutoSubscriptionCreation defines the auto subscription creation override for the topic.
+	// This controls whether subscriptions can be created automatically.
+	// +optional
+	AutoSubscriptionCreation *AutoSubscriptionCreationOverride `json:"autoSubscriptionCreation,omitempty"`
+
+	// SchemaCompatibilityStrategy defines the schema compatibility strategy for the topic.
+	// This controls how schema evolution is handled.
+	// +optional
+	// +kubebuilder:validation:Enum=UNDEFINED;ALWAYS_INCOMPATIBLE;ALWAYS_COMPATIBLE;BACKWARD;FORWARD;FULL;BACKWARD_TRANSITIVE;FORWARD_TRANSITIVE;FULL_TRANSITIVE
+	SchemaCompatibilityStrategy *SchemaCompatibilityStrategy `json:"schemaCompatibilityStrategy,omitempty"`
+
+	// Properties is a map of user-defined properties associated with the topic.
+	// These can be used to store additional metadata about the topic.
+	// +optional
+	Properties map[string]string `json:"properties,omitempty"`
 }
 
 // DelayedDeliveryData defines the delayed delivery policy for a topic
@@ -194,6 +253,38 @@ type SchemaInfo struct {
 	Properties map[string]string `json:"properties,omitempty"`
 }
 
+// OffloadPolicies defines the offload policies for a topic.
+// This is a local type definition that mirrors the external library's OffloadPolicies
+// to ensure proper Kubernetes deep copy generation.
+type OffloadPolicies struct {
+	ManagedLedgerOffloadDriver                        string            `json:"managedLedgerOffloadDriver,omitempty"`
+	ManagedLedgerOffloadMaxThreads                    int               `json:"managedLedgerOffloadMaxThreads,omitempty"`
+	ManagedLedgerOffloadThresholdInBytes              int64             `json:"managedLedgerOffloadThresholdInBytes,omitempty"`
+	ManagedLedgerOffloadDeletionLagInMillis           int64             `json:"managedLedgerOffloadDeletionLagInMillis,omitempty"`
+	ManagedLedgerOffloadAutoTriggerSizeThresholdBytes int64             `json:"managedLedgerOffloadAutoTriggerSizeThresholdBytes,omitempty"`
+	S3ManagedLedgerOffloadBucket                      string            `json:"s3ManagedLedgerOffloadBucket,omitempty"`
+	S3ManagedLedgerOffloadRegion                      string            `json:"s3ManagedLedgerOffloadRegion,omitempty"`
+	S3ManagedLedgerOffloadServiceEndpoint             string            `json:"s3ManagedLedgerOffloadServiceEndpoint,omitempty"`
+	S3ManagedLedgerOffloadCredentialID                string            `json:"s3ManagedLedgerOffloadCredentialId,omitempty"`
+	S3ManagedLedgerOffloadCredentialSecret            string            `json:"s3ManagedLedgerOffloadCredentialSecret,omitempty"`
+	S3ManagedLedgerOffloadRole                        string            `json:"s3ManagedLedgerOffloadRole,omitempty"`
+	S3ManagedLedgerOffloadRoleSessionName             string            `json:"s3ManagedLedgerOffloadRoleSessionName,omitempty"`
+	OffloadersDirectory                               string            `json:"offloadersDirectory,omitempty"`
+	ManagedLedgerOffloadDriverMetadata                map[string]string `json:"managedLedgerOffloadDriverMetadata,omitempty"`
+}
+
+// AutoSubscriptionCreationOverride defines the auto subscription creation override for a topic.
+// This is a local type definition that mirrors the external library's AutoSubscriptionCreationOverride
+// to ensure proper Kubernetes deep copy generation.
+type AutoSubscriptionCreationOverride struct {
+	AllowAutoSubscriptionCreation bool `json:"allowAutoSubscriptionCreation,omitempty"`
+}
+
+// SchemaCompatibilityStrategy defines the schema compatibility strategy for a topic.
+// This is a local type definition that mirrors the external library's SchemaCompatibilityStrategy
+// to ensure proper Kubernetes deep copy generation.
+type SchemaCompatibilityStrategy string
+
 // PulsarTopicStatus defines the observed state of PulsarTopic
 type PulsarTopicStatus struct {
 	// INSERT ADDITIONAL STATUS FIELD - define observed state of cluster