v1alpha1

type Artifact struct {
	// +optional
	JarURI string `json:"jarUri,omitempty"`

	// +kubebuilder:validation:Enum=JAR;PYTHON;sqlscript
	// +kubebuilder:validation:Required
	Kind string `json:"kind,omitempty"`

	// +optional
	PythonArtifactURI string `json:"pythonArtifactUri,omitempty"`

	// +optional
	SQLScript string `json:"sqlScript,omitempty"`

	// +optional
	AdditionalDependencies []string `json:"additionalDependencies,omitempty"`

	// +optional
	AdditionalPythonArchives []string `json:"additionalPythonArchives,omitempty"`

	// +optional
	AdditionalPythonLibraries []string `json:"additionalPythonLibraries,omitempty"`

	// +optional
	// +kubebuilder:validation:Enum=PYTHON;SQLSCRIPT;JAR;UNKNOWN
	ArtifactKind string `json:"artifactKind,omitempty"`

	// +optional
	EntryClass string `json:"entryClass,omitempty"`

	// +optional
	EntryModule string `json:"entryModule,omitempty"`

	// +optional
	FlinkImageRegistry string `json:"flinkImageRegistry,omitempty"`

	// +optional
	FlinkImageRepository string `json:"flinkImageRepository,omitempty"`

	// +optional
	FlinkImageTag string `json:"flinkImageTag,omitempty"`

	// +optional
	FlinkVersion string `json:"flinkVersion,omitempty"`

	// +optional
	MainArgs string `json:"mainArgs,omitempty"`

	// +optional
	URI string `json:"uri,omitempty"`

	// +optional
	ArtifactImage string `json:"artifactImage,omitempty"`
}

type AuthConfig struct {
	// CredentialsRef is the reference to the service account credentials secret
	// +required
	CredentialsRef corev1.LocalObjectReference `json:"credentialsRef"`
}

type AutoFailoverPolicyType string

type BatchSourceConfig struct {
	// +optional
	DiscoveryTriggererClassName string `json:"discoveryTriggererClassName,omitempty" yaml:"discoveryTriggererClassName"`

	// +optional
	DiscoveryTriggererConfig *apiextensionsv1.JSON `json:"discoveryTriggererConfig,omitempty" yaml:"discoveryTriggererConfig"`
}

type BookieAffinityGroupData struct {
	BookkeeperAffinityGroupPrimary string `json:"bookkeeperAffinityGroupPrimary"`

	// +optional
	BookkeeperAffinityGroupSecondary string `json:"bookkeeperAffinityGroupSecondary,omitempty"`
}

type ClusterInfo struct {
	// Name is the pulsar cluster name
	Name string `json:"name,omitempty"`
	// ConnectionRef is the connection reference that can connect to the pulsar cluster
	ConnectionRef corev1.LocalObjectReference `json:"connectionRef"`
}

type CommunityDeploymentMetadata struct {
	// Annotations to add to the deployment
	// +optional
	Annotations map[string]string `json:"annotations,omitempty"`

	// Labels to add to the deployment
	// +optional
	Labels map[string]string `json:"labels,omitempty"`
}

type CommunityDeploymentSpec struct {
	// Image defines the Flink image
	// +required
	Image string `json:"image"`

	// FlinkConfiguration defines the Flink configuration
	// +optional
	FlinkConfiguration map[string]string `json:"flinkConfiguration,omitempty"`

	// JobManagerPodTemplate defines the job manager pod template
	// +optional
	JobManagerPodTemplate *PodTemplate `json:"jobManagerPodTemplate,omitempty"`

	// TaskManagerPodTemplate defines the task manager pod template
	// +optional
	TaskManagerPodTemplate *PodTemplate `json:"taskManagerPodTemplate,omitempty"`

	// JarURI defines the URI of the JAR file
	// +required
	JarURI string `json:"jarUri"`

	// EntryClass defines the entry class of the JAR
	// +optional
	EntryClass string `json:"entryClass,omitempty"`

	// MainArgs defines the main arguments
	// +optional
	MainArgs string `json:"mainArgs,omitempty"`
}

type CommunityDeploymentTemplate struct {
	// Metadata defines the metadata for the deployment
	// +optional
	Metadata CommunityDeploymentMetadata `json:"metadata,omitempty"`

	// Spec defines the deployment specification
	// +required
	Spec CommunityDeploymentSpec `json:"spec"`
}

type ComputeFlinkDeployment struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   ComputeFlinkDeploymentSpec   `json:"spec,omitempty"`
	Status ComputeFlinkDeploymentStatus `json:"status,omitempty"`
}

type ComputeFlinkDeploymentList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []ComputeFlinkDeployment `json:"items"`
}

type ComputeFlinkDeploymentSpec struct {
	// APIServerRef is the reference to the StreamNativeCloudConnection.
	// If not specified, the APIServerRef from the referenced ComputeWorkspace will be used.
	// +optional
	APIServerRef corev1.LocalObjectReference `json:"apiServerRef,omitempty"`

	// WorkspaceName is the reference to the workspace, and is required
	// +kubebuilder:validation:Required
	// +required
	WorkspaceName string `json:"workspaceName"`

	// Labels to add to the deployment
	// +optional
	Labels map[string]string `json:"labels,omitempty"`

	// Annotations to add to the deployment
	// +optional
	Annotations map[string]string `json:"annotations,omitempty"`

	// Template is the VVP deployment template
	// +optional
	Template *VvpDeploymentTemplate `json:"template,omitempty"`

	// CommunityTemplate is the community deployment template
	// +optional
	CommunityTemplate *CommunityDeploymentTemplate `json:"communityTemplate,omitempty"`

	// DefaultPulsarCluster is the default pulsar cluster to use
	// +optional
	DefaultPulsarCluster *string `json:"defaultPulsarCluster,omitempty"`

	// Configuration is the list of configurations to deploy with the Flink deployment.
	// +optional
	Configuration *Configuration `json:"configuration,omitempty"`

	// ImagePullSecrets is the list of image pull secrets to use for the deployment.
	// +optional
	ImagePullSecrets []corev1.LocalObjectReference `json:"imagePullSecrets,omitempty"`
}

type ComputeFlinkDeploymentStatus struct {
	// Conditions represent the latest available observations of an object's state
	// +optional
	Conditions []metav1.Condition `json:"conditions,omitempty"`

	// ObservedGeneration is the last observed generation.
	// +optional
	ObservedGeneration int64 `json:"observedGeneration,omitempty"`

	// DeploymentStatus represents the status from the API server
	// +optional
	DeploymentStatus *runtime.RawExtension `json:"deploymentStatus,omitempty"`
}

type ComputeWorkspace struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   ComputeWorkspaceSpec   `json:"spec,omitempty"`
	Status ComputeWorkspaceStatus `json:"status,omitempty"`
}

type ComputeWorkspaceList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []ComputeWorkspace `json:"items"`
}

type ComputeWorkspaceSpec struct {
	// APIServerRef is the reference to the StreamNativeCloudConnection
	// +required
	APIServerRef corev1.LocalObjectReference `json:"apiServerRef"`

	// PulsarClusterNames is the list of Pulsar clusters that the workspace will have access to.
	// +optional
	PulsarClusterNames []string `json:"pulsarClusterNames,omitempty"`

	// PoolRef is the reference to the pool that the workspace will be access to.
	// +optional
	PoolRef *PoolRef `json:"poolRef"`

	// UseExternalAccess is the flag to indicate whether the workspace will use external access.
	// +optional
	UseExternalAccess *bool `json:"useExternalAccess,omitempty"`

	// FlinkBlobStorage is the configuration for the Flink blob storage.
	// +optional
	FlinkBlobStorage *FlinkBlobStorage `json:"flinkBlobStorage,omitempty"`
}

type ComputeWorkspaceStatus struct {
	// Conditions represent the latest available observations of an object's state
	// +optional
	Conditions []metav1.Condition `json:"conditions,omitempty"`

	// ObservedGeneration is the last observed generation.
	// +optional
	ObservedGeneration int64 `json:"observedGeneration,omitempty"`

	// WorkspaceID is the ID of the workspace in the API server
	// +optional
	WorkspaceID string `json:"workspaceId,omitempty"`
}

type Configuration struct {
	// Envs is the list of environment variables to set in the Flink deployment.
	// +optional
	Envs []EnvVar `json:"envs,omitempty" protobuf:"bytes,1,opt,name=envs"`

	// Secrets is the list of secrets referenced to deploy with the Flink deployment.
	// +optional
	Secrets []SecretReference `json:"secrets,omitempty" protobuf:"bytes,2,opt,name=secrets"`
}

type ConsumerConfig struct {
	// +optional
	SchemaType string `json:"schemaType,omitempty" yaml:"schemaType"`

	// +optional
	SerdeClassName string `json:"serdeClassName,omitempty" yaml:"serdeClassName"`

	// +optional
	RegexPattern bool `json:"regexPattern,omitempty" yaml:"regexPattern"`

	// +optional
	ReceiverQueueSize int `json:"receiverQueueSize,omitempty" yaml:"receiverQueueSize"`

	// +optional
	SchemaProperties map[string]string `json:"schemaProperties,omitempty" yaml:"schemaProperties"`

	// +optional
	ConsumerProperties map[string]string `json:"consumerProperties,omitempty" yaml:"consumerProperties"`

	// +optional
	CryptoConfig *CryptoConfig `json:"cryptoConfig,omitempty" yaml:"cryptoConfig"`

	// +optional
	PoolMessages bool `json:"poolMessages,omitempty" yaml:"poolMessages"`
}

type Container struct {
	// Name of the container specified as a DNS_LABEL.
	// +optional
	Name string `json:"name,omitempty"`

	// Docker image name.
	// +optional
	Image string `json:"image,omitempty"`

	// Entrypoint array. Not executed within a shell.
	// +optional
	Command []string `json:"command,omitempty"`

	// Arguments to the entrypoint.
	// +optional
	Args []string `json:"args,omitempty"`

	// Container's working directory.
	// +optional
	WorkingDir string `json:"workingDir,omitempty"`

	// List of environment variables to set in the container.
	// +optional
	Env []corev1.EnvVar `json:"env,omitempty"`

	// List of sources to populate environment variables in the container.
	// +optional
	EnvFrom []corev1.EnvFromSource `json:"envFrom,omitempty"`

	// Compute Resources required by this container.
	// +optional
	Resources corev1.ResourceRequirements `json:"resources,omitempty"`

	// Pod volumes to mount into the container's filesystem.
	// +optional
	VolumeMounts []corev1.VolumeMount `json:"volumeMounts,omitempty"`

	// Image pull policy.
	// +optional
	ImagePullPolicy corev1.PullPolicy `json:"imagePullPolicy,omitempty"`

	// Security context at container level
	// +optional
	SecurityContext *corev1.SecurityContext `json:"securityContext,omitempty"`
}

type CryptoConfig struct {

	// +optional
	CryptoKeyReaderClassName string `json:"cryptoKeyReaderClassName,omitempty" yaml:"cryptoKeyReaderClassName"`

	// +optional
	CryptoKeyReaderConfig map[string]string `json:"cryptoKeyReaderConfig,omitempty" yaml:"cryptoKeyReaderConfig"`

	// +optional
	EncryptionKeys []string `json:"encryptionKeys,omitempty" yaml:"encryptionKeys"`

	// +optional
	ProducerCryptoFailureAction string `json:"producerCryptoFailureAction,omitempty" yaml:"producerCryptoFailureAction"`

	// +optional
	ConsumerCryptoFailureAction string `json:"consumerCryptoFailureAction,omitempty" yaml:"consumerCryptoFailureAction"`
}

type EnvVar struct {
	// Name of the environment variable.
	Name string `json:"name" protobuf:"bytes,1,opt,name=name"`

	// Value of the environment variable.
	Value string `json:"value" protobuf:"bytes,2,opt,name=value"`
}

type FlinkBlobStorage struct {
	// Bucket is required if you want to use cloud storage.
	// +required
	Bucket string `json:"bucket"`

	// Path is the sub path in the bucket.
	// Leave it empty if you want to use the whole bucket.
	// +optional
	Path string `json:"path,omitempty"`
}

type FunctionSecretKeyRef struct {
	Path string `json:"path"`
	Key  string `json:"key"`
}

type KubernetesSecretReference struct {
	Namespace string `json:"namespace" protobuf:"bytes,1,opt,name=namespace"`
	Name      string `json:"name" protobuf:"bytes,2,opt,name=name"`
}

type KubernetesSpec struct {
	// JobManagerPodTemplate defines the job manager pod template
	// +optional
	JobManagerPodTemplate *PodTemplate `json:"jobManagerPodTemplate,omitempty"`

	// TaskManagerPodTemplate defines the task manager pod template
	// +optional
	TaskManagerPodTemplate *PodTemplate `json:"taskManagerPodTemplate,omitempty"`

	// Labels defines the labels to add to all resources
	// +optional
	Labels map[string]string `json:"labels,omitempty"`
}

type LogConfig struct {
	// ServiceURL is the URL of the logging service
	// +required
	ServiceURL string `json:"serviceUrl"`
}

type Logging struct {
	// +optional
	Log4j2ConfigurationTemplate string `json:"log4j2ConfigurationTemplate,omitempty"`

	// +optional
	Log4jLoggers map[string]string `json:"log4jLoggers,omitempty"`

	// +optional
	LoggingProfile string `json:"loggingProfile,omitempty"`
}

type ObjectMeta struct {
	// Name of the resource
	// +optional
	Name string `json:"name,omitempty"`

	// Namespace of the resource
	// +optional
	Namespace string `json:"namespace,omitempty"`

	// Labels of the resource
	// +optional
	Labels map[string]string `json:"labels,omitempty"`

	// Annotations of the resource
	// +optional
	Annotations map[string]string `json:"annotations,omitempty"`
}

type PackageContentRef struct {

	// +optional
	URL string `json:"url,omitempty"`
}

type PodTemplate struct {
	// Standard object's metadata.
	// +optional
	ObjectMeta ObjectMeta `json:"metadata,omitempty"`

	// Specification of the desired behavior of the pod.
	// +optional
	Spec PodTemplateSpec `json:"spec,omitempty"`
}

type PodTemplateSpec struct {
	// List of volumes that can be mounted by containers belonging to the pod.
	// +optional
	Volumes []Volume `json:"volumes,omitempty"`

	// List of initialization containers belonging to the pod.
	// +optional
	InitContainers []Container `json:"initContainers,omitempty"`

	// List of containers belonging to the pod.
	// +optional
	Containers []Container `json:"containers,omitempty"`

	// ServiceAccountName is the name of the ServiceAccount to use to run this pod.
	// +optional
	ServiceAccountName string `json:"serviceAccountName,omitempty"`

	// NodeSelector is a selector which must be true for the pod to fit on a node.
	// +optional
	NodeSelector map[string]string `json:"nodeSelector,omitempty"`

	// SecurityContext holds pod-level security attributes and common container settings.
	// +optional
	SecurityContext *corev1.PodSecurityContext `json:"securityContext,omitempty"`

	// ImagePullSecrets is an optional list of references to secrets in the same namespace to use for pulling any of the images used by this PodSpec.
	// +optional
	ImagePullSecrets []corev1.LocalObjectReference `json:"imagePullSecrets,omitempty"`

	// If specified, the pod's scheduling constraints
	// +optional
	Affinity *corev1.Affinity `json:"affinity,omitempty"`

	// If specified, the pod's tolerations.
	// +optional
	Tolerations []corev1.Toleration `json:"tolerations,omitempty"`
}

type PoolMemberReference struct {
	Namespace string `json:"namespace" protobuf:"bytes,1,opt,name=namespace"`
	Name      string `json:"name" protobuf:"bytes,2,opt,name=name"`
}

type PoolRef struct {
	// Namespace is the namespace of the pool
	// +optional
	Namespace string `json:"namespace,omitempty"`

	// Name is the name of the pool
	// +required
	Name string `json:"name"`
}

type ProducerConfig struct {
	// +optional
	MaxPendingMessages int `json:"maxPendingMessages,omitempty" yaml:"maxPendingMessages"`

	// +optional
	MaxPendingMessagesAcrossPartitions int `json:"maxPendingMessagesAcrossPartitions,omitempty" yaml:"maxPendingMessagesAcrossPartitions"`

	// +optional
	UseThreadLocalProducers bool `json:"useThreadLocalProducers,omitempty" yaml:"useThreadLocalProducers"`

	// +optional
	CryptoConfig *CryptoConfig `json:"cryptoConfig,omitempty" yaml:"cryptoConfig"`

	// +optional
	BatchBuilder string `json:"batchBuilder,omitempty" yaml:"batchBuilder"`

	// +optional
	CompressionType string `json:"compressionType,omitempty" yaml:"compressionType"`
}

type PulsarAuthentication struct {
	// Token specifies the configuration for token-based authentication.
	// This can be either a direct token value or a reference to a secret containing the token.
	// If using a secret, the token should be stored under the specified key in the secret.
	// +optional
	Token *ValueOrSecretRef `json:"token,omitempty"`

	// OAuth2 specifies the configuration for OAuth2-based authentication.
	// This includes all necessary parameters for setting up OAuth2 authentication with Pulsar.
	// For detailed information on the OAuth2 fields, refer to the PulsarAuthenticationOAuth2 struct.
	// +optional
	OAuth2 *PulsarAuthenticationOAuth2 `json:"oauth2,omitempty"`
}

type PulsarAuthenticationOAuth2 struct {
	// IssuerEndpoint is the URL of the OAuth2 authorization server.
	// This is typically the base URL of your identity provider's OAuth2 service.
	IssuerEndpoint string `json:"issuerEndpoint"`

	// ClientID is the OAuth2 client identifier issued to the client during the registration process.
	ClientID string `json:"clientID"`

	// Audience is the intended recipient of the token. In Pulsar's context, this is usually
	// the URL of your Pulsar cluster or a specific identifier for your Pulsar service.
	Audience string `json:"audience"`

	// Key is either the client secret or the path to a JSON credentials file.
	// For confidential clients, this would be the client secret.
	// For public clients using JWT authentication, this would be the path to the JSON credentials file.
	Key *ValueOrSecretRef `json:"key"`

	// Scope is an optional field to request specific permissions from the OAuth2 server.
	// If not specified, the default scope defined by the OAuth2 server will be used.
	Scope string `json:"scope,omitempty"`
}

type PulsarConnection struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   PulsarConnectionSpec   `json:"spec,omitempty"`
	Status PulsarConnectionStatus `json:"status,omitempty"`
}

type PulsarConnectionList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []PulsarConnection `json:"items"`
}

type PulsarConnectionSpec struct {

	// AdminServiceURL is the HTTP(S) URL for the Pulsar cluster's admin service.
	// This URL is used for administrative operations.
	// +optional
	// +kubebuilder:validation:Pattern="^https?://.+$"
	AdminServiceURL string `json:"adminServiceURL"`

	// Authentication defines the authentication configuration for connecting to the Pulsar cluster.
	// It supports both token-based and OAuth2-based authentication methods.
	// +optional
	Authentication *PulsarAuthentication `json:"authentication,omitempty"`

	// BrokerServiceURL is the non-TLS URL for connecting to Pulsar brokers.
	// Use this for non-secure connections to the Pulsar cluster.
	// +optional
	// +kubebuilder:validation:Pattern="^pulsar?://.+$"
	BrokerServiceURL string `json:"brokerServiceURL,omitempty"`

	// BrokerServiceSecureURL is the TLS-enabled URL for secure connections to Pulsar brokers.
	// Use this for encrypted communications with the Pulsar cluster.
	// +optional
	// +kubebuilder:validation:Pattern="^pulsar\\+ssl://.+$"
	BrokerServiceSecureURL string `json:"brokerServiceSecureURL,omitempty"`

	// AdminServiceSecureURL is the HTTPS URL for secure connections to the Pulsar admin service.
	// Use this for encrypted administrative operations.
	// +optional
	// +kubebuilder:validation:Pattern="^https://.+$"
	AdminServiceSecureURL string `json:"adminServiceSecureURL,omitempty"`

	// BrokerClientTrustCertsFilePath is the file path to the trusted TLS certificate
	// for outgoing connections to Pulsar brokers. This is used for TLS verification.
	// +optional
	BrokerClientTrustCertsFilePath string `json:"brokerClientTrustCertsFilePath,omitempty"`

	// ClusterName specifies the name of the local Pulsar cluster.
	// When setting up Geo-Replication between Pulsar instances, this should be enabled to identify the cluster.
	// +optional
	ClusterName string `json:"clusterName,omitempty"`
}

type PulsarConnectionStatus struct {

	// ObservedGeneration is the most recent generation observed for this resource.
	// It corresponds to the metadata generation, which is updated on mutation by the API Server.
	// This field is used to track whether the controller has processed the latest changes.
	// +optional
	ObservedGeneration int64 `json:"observedGeneration,omitempty"`

	// SecretKeyHash is the hash of the secret reference used for authentication.
	// This is used to detect changes in the secret without exposing sensitive information.
	// The controller should update this hash when the secret changes.
	// +optional
	SecretKeyHash string `json:"secretKeyHash,omitempty"`

	// Conditions represent the latest available observations of the connection's current state.
	// It follows the Kubernetes conventions for condition types and status.
	// The "Ready" condition type is typically used to indicate the overall status.
	// +patchMergeKey=type
	// +patchStrategy=merge
	// +listType=map
	// +listMapKey=type
	// +optional
	Conditions []metav1.Condition `json:"conditions,omitempty" patchStrategy:"merge" patchMergeKey:"type"`
}

type PulsarFunction struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   PulsarFunctionSpec   `json:"spec,omitempty"`
	Status PulsarFunctionStatus `json:"status,omitempty"`
}

type PulsarFunctionList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []PulsarFunction `json:"items"`
}

type PulsarFunctionSpec struct {

	// TimeoutMs is the function timeout in milliseconds
	// +optional
	TimeoutMs *int64 `json:"timeoutMs,omitempty"`

	// TopicsPattern is the topics pattern that the function subscribes to
	// +optional
	TopicsPattern *string `json:"topicsPattern,omitempty"`

	// CleanupSubscription is the flag to indicate whether the subscription should be cleaned up when the function is deleted
	// +optional
	CleanupSubscription bool `json:"cleanupSubscription"`

	// RetainOrdering is the flag to indicate whether the function should retain ordering
	// +optional
	RetainOrdering bool `json:"retainOrdering"`

	// RetainKeyOrdering is the flag to indicate whether the function should retain key ordering
	// +optional
	RetainKeyOrdering bool `json:"retainKeyOrdering"`

	// BatchBuilder is the batch builder that the function uses
	// +optional
	BatchBuilder *string `json:"batchBuilder,omitempty"`

	// ForwardSourceMessageProperty is the flag to indicate whether the function should forward source message properties
	// +optional
	ForwardSourceMessageProperty bool `json:"forwardSourceMessageProperty"`

	// AutoAck is the flag to indicate whether the function should auto ack
	// +optional
	AutoAck bool `json:"autoAck"`

	// Parallelism is the parallelism of the function
	// +optional
	Parallelism int `json:"parallelism,omitempty"`

	// MaxMessageRetries is the max message retries of the function
	// +optional
	MaxMessageRetries *int `json:"maxMessageRetries,omitempty"`

	// Output is the output of the function
	// +optional
	Output string `json:"output,omitempty"`

	// ProducerConfig is the producer config of the function
	// +optional
	ProducerConfig *ProducerConfig `json:"producerConfig,omitempty"`

	// CustomSchemaOutputs is the custom schema outputs of the function
	// +optional
	CustomSchemaOutputs map[string]string `json:"customSchemaOutputs,omitempty"`

	// OutputSerdeClassName is the output serde class name of the function
	// +optional
	OutputSerdeClassName string `json:"outputSerdeClassName,omitempty"`

	// LogTopic is the log topic of the function
	// +optional
	LogTopic string `json:"logTopic,omitempty"`

	// ProcessingGuarantees is the processing guarantees of the function
	// +optional
	ProcessingGuarantees string `json:"processingGuarantees,omitempty"`

	// OutputSchemaType is the output schema type of the function
	// +optional
	OutputSchemaType string `json:"outputSchemaType,omitempty"`

	// OutputTypeClassName is the output type class name of the function
	// +optional
	OutputTypeClassName string `json:"outputTypeClassName,omitempty"`

	// DeadLetterTopic is the dead letter topic of the function
	// +optional
	DeadLetterTopic string `json:"deadLetterTopic,omitempty"`

	// SubName is the sub name of the function
	// +optional
	SubName string `json:"subName,omitempty"`

	// Jar is the jar of the function
	// +optional
	Jar *PackageContentRef `json:"jar,omitempty"`

	// Py is the py of the function
	// +optional
	Py *PackageContentRef `json:"py,omitempty"`

	// Go is the go of the function
	// +optional
	Go *PackageContentRef `json:"go,omitempty"`

	// RuntimeFlags is the runtime flags of the function
	// +optional
	RuntimeFlags string `json:"runtimeFlags,omitempty"`

	// Tenant is the tenant of the function
	// +optional
	Tenant string `json:"tenant,omitempty"`

	// Namespace is the namespace of the function
	// +optional
	Namespace string `json:"namespace,omitempty"`

	// Name is the name of the function
	// +optional
	Name string `json:"name,omitempty"`

	// ClassName is the class name of the function
	// +optional
	ClassName string `json:"className,omitempty"`

	// Resources is the resources of the function
	// +optional
	Resources *Resources `json:"resources,omitempty"`

	// WindowConfig is the window config of the function
	// +optional
	WindowConfig *WindowConfig `json:"windowConfig,omitempty"`

	// Inputs is the inputs of the function
	// +optional
	Inputs []string `json:"inputs,omitempty"`

	// UserConfig is the user config of the function
	// +optional
	UserConfig *apiextensionsv1.JSON `json:"userConfig,omitempty"`

	// CustomSerdeInputs is the custom serde inputs of the function
	// +optional
	CustomSerdeInputs map[string]string `json:"customSerdeInputs,omitempty"`

	// CustomSchemaInputs is the custom schema inputs of the function
	// +optional
	CustomSchemaInputs map[string]string `json:"customSchemaInputs,omitempty"`

	// InputSpecs is the input specs of the function
	// +optional
	InputSpecs map[string]ConsumerConfig `json:"inputSpecs,omitempty"`

	// InputTypeClassName is the input type class name of the function
	// +optional
	InputTypeClassName string `json:"inputTypeClassName,omitempty"`

	// CustomRuntimeOptions is the custom runtime options of the function
	// +optional
	CustomRuntimeOptions *apiextensionsv1.JSON `json:"customRuntimeOptions,omitempty"`

	// Secrets is the secrets of the function
	// +optional
	Secrets map[string]FunctionSecretKeyRef `json:"secrets,omitempty"`

	// MaxPendingAsyncRequests is the max pending async requests of the function
	// +optional
	MaxPendingAsyncRequests int `json:"maxPendingAsyncRequests,omitempty"`

	// ExposePulsarAdminClientEnabled is the flag to indicate whether the function should expose pulsar admin client
	// +optional
	ExposePulsarAdminClientEnabled bool `json:"exposePulsarAdminClientEnabled"`

	// SkipToLatest is the flag to indicate whether the function should skip to latest
	// +optional
	SkipToLatest bool `json:"skipToLatest"`

	// SubscriptionPosition is the subscription position of the function
	// +optional
	SubscriptionPosition string `json:"subscriptionPosition,omitempty"`

	// ConnectionRef is the reference to the PulsarConnection resource
	ConnectionRef corev1.LocalObjectReference `json:"connectionRef"`

	// +kubebuilder:validation:Enum=CleanUpAfterDeletion;KeepAfterDeletion
	// +optional
	LifecyclePolicy PulsarResourceLifeCyclePolicy `json:"lifecyclePolicy,omitempty"`
}

type PulsarFunctionStatus struct {

	// ObservedGeneration is the most recent generation observed for this resource.
	// It corresponds to the metadata generation, which is updated on mutation by the API Server.
	// +optional
	ObservedGeneration int64 `json:"observedGeneration,omitempty"`

	// Represents the observations of a connection's current state.
	// +patchMergeKey=type
	// +patchStrategy=merge
	// +listType=map
	// +listMapKey=type
	// +optional
	Conditions []metav1.Condition `json:"conditions,omitempty" patchStrategy:"merge" patchMergeKey:"type"`
}

type PulsarGeoReplication struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   PulsarGeoReplicationSpec   `json:"spec,omitempty"`
	Status PulsarGeoReplicationStatus `json:"status,omitempty"`
}

type PulsarGeoReplicationList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []PulsarGeoReplication `json:"items"`
}

type PulsarGeoReplicationSpec struct {

	// ConnectionRef is the reference to the source PulsarConnection
	ConnectionRef corev1.LocalObjectReference `json:"connectionRef"`

	// DestinationConnectionRef is the connection reference to the remote cluster
	DestinationConnectionRef corev1.LocalObjectReference `json:"destinationConnectionRef"`

	// +kubebuilder:validation:Enum=CleanUpAfterDeletion;KeepAfterDeletion
	// +optional
	LifecyclePolicy PulsarResourceLifeCyclePolicy `json:"lifecyclePolicy,omitempty"`
}

type PulsarGeoReplicationStatus struct {

	// ObservedGeneration is the most recent generation observed for this resource.
	// It corresponds to the metadata generation, which is updated on mutation by the API Server.
	// +optional
	ObservedGeneration int64 `json:"observedGeneration,omitempty"`

	// Conditions Represents the observations of a connection's current state.
	// +patchMergeKey=type
	// +patchStrategy=merge
	// +listType=map
	// +listMapKey=type
	// +optional
	Conditions []metav1.Condition `json:"conditions,omitempty" patchStrategy:"merge" patchMergeKey:"type"`
}

type PulsarNSIsolationPolicy struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   PulsarNSIsolationPolicySpec   `json:"spec,omitempty"`
	Status PulsarNSIsolationPolicyStatus `json:"status,omitempty"`
}

type PulsarNSIsolationPolicyList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []PulsarNSIsolationPolicy `json:"items"`
}

type PulsarNSIsolationPolicySpec struct {

	// Name is the policy name
	// +kubebuilder:validation:Required
	Name string `json:"name"`

	// Cluster is the name of the Pulsar Cluster
	// +kubebuilder:validation:Required
	Cluster string `json:"cluster"`

	// ConnectionRef is the reference to the PulsarConnection resource
	// used to connect to the Pulsar cluster for this ns-isolation-policy.
	ConnectionRef corev1.LocalObjectReference `json:"connectionRef"`

	// Namespaces namespaces-regex list
	// +kubebuilder:validation:Required
	Namespaces []string `json:"namespaces"`

	// Primary primary-broker-regex list
	// +kubebuilder:validation:Required
	Primary []string `json:"primary"`

	// Secondary secondary-broker-regex list, optional
	// +optional
	Secondary []string `json:"secondary,omitempty"`

	// AutoFailoverPolicyType auto failover policy type name, only support min_available now
	// +kubebuilder:validation:Required
	// +kubebuilder:validation:Enum=min_available
	AutoFailoverPolicyType AutoFailoverPolicyType `json:"autoFailoverPolicyType"`

	// AutoFailoverPolicyParams auto failover policy parameters
	// +kubebuilder:validation:Required
	AutoFailoverPolicyParams map[string]string `json:"autoFailoverPolicyParams"`
}

type PulsarNSIsolationPolicyStatus struct {

	// ObservedGeneration is the most recent generation observed for this resource.
	// It corresponds to the metadata generation, which is updated on mutation by the API Server.
	// This field is used to track whether the controller has processed the latest changes.
	// +optional
	ObservedGeneration int64 `json:"observedGeneration,omitempty"`

	// Conditions represent the latest available observations of the ns-isolation-policy's current state.
	// It follows the Kubernetes conventions for condition types and status.
	// The "Ready" condition type is typically used to indicate the overall status of the ns-isolation-policy.
	// +patchMergeKey=type
	// +patchStrategy=merge
	// +listType=map
	// +listMapKey=type
	// +optional
	Conditions []metav1.Condition `json:"conditions,omitempty" patchStrategy:"merge" patchMergeKey:"type"`
}

type PulsarNamespace struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   PulsarNamespaceSpec   `json:"spec,omitempty"`
	Status PulsarNamespaceStatus `json:"status,omitempty"`
}

type PulsarNamespaceList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []PulsarNamespace `json:"items"`
}

type PulsarNamespaceSpec struct {

	// Name is the fully qualified namespace name in the format "tenant/namespace".
	Name string `json:"name"`

	// Bundles specifies the number of bundles to split the namespace into.
	// This affects how the namespace is distributed across the cluster.
	Bundles *int32 `json:"bundles,omitempty"`

	// ConnectionRef is the reference to the PulsarConnection resource
	// used to connect to the Pulsar cluster for this namespace.
	ConnectionRef corev1.LocalObjectReference `json:"connectionRef"`

	// LifecyclePolicy determines whether to keep or delete the Pulsar namespace
	// when the Kubernetes resource is deleted.
	// +kubebuilder:validation:Enum=CleanUpAfterDeletion;KeepAfterDeletion
	// +optional
	LifecyclePolicy PulsarResourceLifeCyclePolicy `json:"lifecyclePolicy,omitempty"`

	// MaxProducersPerTopic sets the maximum number of producers allowed on a single topic in the namespace.
	// +optional
	MaxProducersPerTopic *int32 `json:"maxProducersPerTopic,omitempty"`

	// MaxConsumersPerTopic sets the maximum number of consumers allowed on a single topic in the namespace.
	// +optional
	MaxConsumersPerTopic *int32 `json:"maxConsumersPerTopic,omitempty"`

	// MaxConsumersPerSubscription sets the maximum number of consumers allowed on a single subscription in the namespace.
	// +optional
	MaxConsumersPerSubscription *int32 `json:"maxConsumersPerSubscription,omitempty"`

	// MessageTTL specifies the Time to Live (TTL) for messages in the namespace.
	// Messages older than this TTL will be automatically marked as consumed.
	// +optional
	MessageTTL *utils.Duration `json:"messageTTL,omitempty"`

	// RetentionTime specifies the minimum time to retain messages in the namespace.
	// Should be set in conjunction with RetentionSize for effective retention policy.
	// Retention Quota must exceed configured backlog quota for namespace
	// +optional
	RetentionTime *utils.Duration `json:"retentionTime,omitempty"`

	// RetentionSize specifies the maximum size of backlog retained in the namespace.
	// Should be set in conjunction with RetentionTime for effective retention policy.
	// +optional
	RetentionSize *resource.Quantity `json:"retentionSize,omitempty"`

	// BacklogQuotaLimitTime specifies the time limit for message backlog.
	// Messages older than this limit will be removed or handled according to the retention policy.
	// +optional
	BacklogQuotaLimitTime *utils.Duration `json:"backlogQuotaLimitTime,omitempty"`

	// BacklogQuotaLimitSize specifies the size limit for message backlog.
	// When the limit is reached, older messages will be removed or handled according to the retention policy.
	// +optional
	BacklogQuotaLimitSize *resource.Quantity `json:"backlogQuotaLimitSize,omitempty"`

	// BacklogQuotaRetentionPolicy specifies the retention policy for messages when backlog quota is exceeded.
	// Valid values are "producer_request_hold", "producer_exception", or "consumer_backlog_eviction".
	// +optional
	BacklogQuotaRetentionPolicy *string `json:"backlogQuotaRetentionPolicy,omitempty"`

	// BacklogQuotaType controls how the backlog quota is enforced.
	// "destination_storage" limits backlog by size (in bytes), while "message_age" limits by time.
	// +kubebuilder:validation:Enum=destination_storage;message_age
	// +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
	// between two Pulsar instances.
	// Please use `ReplicationClusters` instead if you are replicating clusters within the same Pulsar instance.
	// +optional
	GeoReplicationRefs []*corev1.LocalObjectReference `json:"geoReplicationRefs,omitempty"`

	// ReplicationClusters is the list of clusters to which the namespace is replicated
	// This is **ONLY** used if you are replicating clusters within the same Pulsar instance.
	// Please use `GeoReplicationRefs` instead if you are setting up geo-replication
	// between two Pulsar instances.
	// +optional
	ReplicationClusters []string `json:"replicationClusters,omitempty"`

	// Deduplication controls whether to enable message deduplication for the namespace.
	// +optional
	Deduplication *bool `json:"deduplication,omitempty"`

	// BookieAffinityGroup is the name of the namespace isolation policy to apply to the namespace.
	BookieAffinityGroup *BookieAffinityGroupData `json:"bookieAffinityGroup,omitempty"`
}

type PulsarNamespaceStatus struct {

	// ObservedGeneration is the most recent generation observed for this resource.
	// It corresponds to the metadata generation, which is updated on mutation by the API Server.
	// This field is used to track whether the controller has processed the latest changes.
	// +optional
	ObservedGeneration int64 `json:"observedGeneration,omitempty"`

	// Conditions represent the latest available observations of the namespace's current state.
	// It follows the Kubernetes conventions for condition types and status.
	// The "Ready" condition type is typically used to indicate the overall status of the namespace.
	// +patchMergeKey=type
	// +patchStrategy=merge
	// +listType=map
	// +listMapKey=type
	// +optional
	Conditions []metav1.Condition `json:"conditions,omitempty" patchStrategy:"merge" patchMergeKey:"type"`

	// GeoReplicationEnabled indicates whether geo-replication between two Pulsar instances (via PulsarGeoReplication)
	// is enabled for the namespace
	// +optional
	GeoReplicationEnabled bool `json:"geoReplicationEnabled,omitempty"`
}

type PulsarPackage struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   PulsarPackageSpec   `json:"spec,omitempty"`
	Status PulsarPackageStatus `json:"status,omitempty"`
}

type PulsarPackageList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []PulsarPackage `json:"items"`
}

type PulsarPackageSpec struct {

	// PackageURL is the Pulsar Package URL, in format of type://tenant/namespace/package@version
	// +kubebuilder:validation:Required
	PackageURL string `json:"packageURL"`

	// FileURL is the download-able URL of the package from http or https protocol
	// Support cloud storage providers: AWS S3 (s3://), Google Cloud Storage (gs://), Azure Blob Storage (azblob://)
	// +kubebuilder:validation:Required
	FileURL string `json:"fileURL"`

	// ConnectionRef is the reference to the PulsarConnection resource
	ConnectionRef corev1.LocalObjectReference `json:"connectionRef"`

	// +optional
	Description string `json:"description,omitempty"`

	// +optional
	Contact string `json:"contact,omitempty"`

	// +optional
	Properties map[string]string `json:"properties,omitempty"`

	// +kubebuilder:validation:Enum=CleanUpAfterDeletion;KeepAfterDeletion
	// +optional
	LifecyclePolicy PulsarResourceLifeCyclePolicy `json:"lifecyclePolicy,omitempty"`

	// SyncPolicy represents the sync policy of the package, including Always, IfNotPresent, Never
	// Defaults to Always if @latest tag is used in the package URL, or IfNotPresent otherwise
	// +kubebuilder:validation:Enum=Always;IfNotPresent;Never
	// +optional
	SyncPolicy PulsarPackageSyncPolicy `json:"syncPolicy,omitempty"`
}

type PulsarPackageStatus struct {

	// ObservedGeneration is the most recent generation observed for this resource.
	// It corresponds to the metadata generation, which is updated on mutation by the API Server.
	// +optional
	ObservedGeneration int64 `json:"observedGeneration,omitempty"`

	// Represents the observations of a connection's current state.
	// +patchMergeKey=type
	// +patchStrategy=merge
	// +listType=map
	// +listMapKey=type
	// +optional
	Conditions []metav1.Condition `json:"conditions,omitempty" patchStrategy:"merge" patchMergeKey:"type"`
}

type PulsarPackageSyncPolicy string

type PulsarPermission struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   PulsarPermissionSpec   `json:"spec,omitempty"`
	Status PulsarPermissionStatus `json:"status,omitempty"`
}

type PulsarPermissionList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []PulsarPermission `json:"items"`
}

type PulsarPermissionSpec struct {

	// ConnectionRef is the reference to the PulsarConnection resource
	// used to connect to the Pulsar cluster for this permission.
	ConnectionRef corev1.LocalObjectReference `json:"connectionRef"`

	// ResourceName is the name of the target resource (namespace or topic)
	// to which the permissions will be granted.
	ResourceName string `json:"resourceName"`

	// ResourceType indicates whether the permission is for a namespace or a topic.
	// +kubebuilder:validation:Enum=namespace;topic
	ResoureType PulsarResourceType `json:"resourceType"`

	// Roles is a list of role names that will be granted the specified permissions
	// for the target resource.
	Roles []string `json:"roles"`

	// Actions is a list of permissions to grant.
	// Valid options include "produce", "consume", and "functions".
	// +optional
	Actions []string `json:"actions,omitempty"`

	// LifecyclePolicy determines how to handle the Pulsar permissions
	// when the PulsarPermission resource is deleted.
	// +optional
	LifecyclePolicy PulsarResourceLifeCyclePolicy `json:"lifecyclePolicy,omitempty"`
}

type PulsarPermissionStatus struct {

	// ObservedGeneration is the most recent generation observed for this resource.
	// It corresponds to the metadata generation, which is updated on mutation by the API Server.
	// This field is used to track whether the controller has processed the latest changes.
	// +optional
	ObservedGeneration int64 `json:"observedGeneration,omitempty"`

	// Conditions represent the latest available observations of the PulsarPermission's current state.
	// It follows the Kubernetes conventions for condition types and status.
	// The "Ready" condition type is typically used to indicate the overall status of the permission configuration.
	// +patchMergeKey=type
	// +patchStrategy=merge
	// +listType=map
	// +listMapKey=type
	// +optional
	Conditions []metav1.Condition `json:"conditions,omitempty" patchStrategy:"merge" patchMergeKey:"type"`
}

type PulsarResourceLifeCyclePolicy string

type PulsarResourceType string

type PulsarSink struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   PulsarSinkSpec   `json:"spec,omitempty"`
	Status PulsarSinkStatus `json:"status,omitempty"`
}

type PulsarSinkList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []PulsarSink `json:"items"`
}

type PulsarSinkSpec struct {

	// TopicsPattern is the pattern of topics to consume from Pulsar
	// +optional
	TopicsPattern *string `json:"topicsPattern,omitempty"`

	// Resources is the resource requirements for the PulsarSink
	// +optional
	Resources *Resources `json:"resources,omitempty"`

	// TimeoutMs is the timeout in milliseconds for the PulsarSink
	// +optional
	TimeoutMs *int64 `json:"timeoutMs,omitempty"`

	// CleanupSubscription is the flag to enable or disable the cleanup of subscription
	// +optional
	CleanupSubscription bool `json:"cleanupSubscription,omitempty"`

	// RetainOrdering is the flag to enable or disable the retain ordering
	// +optional
	RetainOrdering bool `json:"retainOrdering,omitempty"`

	// RetainKeyOrdering is the flag to enable or disable the retain key ordering
	// +optional
	RetainKeyOrdering bool `json:"retainKeyOrdering,omitempty"`

	// AutoAck is the flag to enable or disable the auto ack
	// +optional
	AutoAck bool `json:"autoAck,omitempty"`

	// Parallelism is the parallelism of the PulsarSink
	// +optional
	Parallelism int `json:"parallelism,omitempty"`

	// Tenant is the tenant of the PulsarSink
	// +optional
	Tenant string `json:"tenant,omitempty"`

	// Namespace is the namespace of the PulsarSink
	// +optional
	Namespace string `json:"namespace,omitempty"`

	// Name is the name of the PulsarSink
	// +optional
	Name string `json:"name,omitempty"`

	// ClassName is the class name of the PulsarSink
	// +optional
	ClassName string `json:"className,omitempty"`

	// SinkType is the type of the PulsarSink
	// +optional
	SinkType string `json:"sinkType,omitempty"`

	// Archive is the archive of the PulsarSink
	// +optional
	Archive *PackageContentRef `json:"archive,omitempty"`

	// ProcessingGuarantees is the processing guarantees of the PulsarSink
	// +optional
	ProcessingGuarantees string `json:"processingGuarantees,omitempty"`

	// SourceSubscriptionName is the source subscription name of the PulsarSink
	// +optional
	SourceSubscriptionName string `json:"sourceSubscriptionName,omitempty"`

	// SourceSubscriptionPosition is the source subscription position of the PulsarSink
	// +optional
	SourceSubscriptionPosition string `json:"sourceSubscriptionPosition,omitempty"`

	// RuntimeFlags is the runtime flags of the PulsarSink
	// +optional
	RuntimeFlags string `json:"runtimeFlags,omitempty"`

	// Inputs is the list of inputs of the PulsarSink
	// +optional
	Inputs []string `json:"inputs,omitempty"`

	// TopicToSerdeClassName is the map of topic to serde class name of the PulsarSink
	// +optional
	TopicToSerdeClassName map[string]string `json:"topicToSerdeClassName,omitempty"`

	// TopicToSchemaType is the map of topic to schema type of the PulsarSink
	// +optional
	TopicToSchemaType map[string]string `json:"topicToSchemaType,omitempty"`

	// InputSpecs is the map of input specs of the PulsarSink
	// +optional
	InputSpecs map[string]ConsumerConfig `json:"inputSpecs,omitempty"`

	// Configs is the map of configs of the PulsarSink
	// +optional
	Configs *apiextensionsv1.JSON `json:"configs,omitempty"`

	// TopicToSchemaProperties is the map of topic to schema properties of the PulsarSink
	// +optional
	TopicToSchemaProperties map[string]string `json:"topicToSchemaProperties,omitempty"`

	// CustomRuntimeOptions is the custom runtime options of the PulsarSink
	// +optional
	CustomRuntimeOptions *apiextensionsv1.JSON `json:"customRuntimeOptions,omitempty"`

	// Secrets is the map of secrets of the PulsarSink
	// +optional
	Secrets map[string]FunctionSecretKeyRef `json:"secrets,omitempty"`

	// MaxMessageRetries is the max message retries of the PulsarSink
	// +optional
	MaxMessageRetries int `json:"maxMessageRetries,omitempty"`

	// DeadLetterTopic is the dead letter topic of the PulsarSink
	// +optional
	DeadLetterTopic string `json:"deadLetterTopic,omitempty"`

	// NegativeAckRedeliveryDelayMs is the negative ack redelivery delay in milliseconds of the PulsarSink
	// +optional
	NegativeAckRedeliveryDelayMs int64 `json:"negativeAckRedeliveryDelayMs,omitempty"`

	// TransformFunction is the transform function of the PulsarSink
	// +optional
	TransformFunction string `json:"transformFunction,omitempty"`

	// TransformFunctionClassName is the transform function class name of the PulsarSink
	// +optional
	TransformFunctionClassName string `json:"transformFunctionClassName,omitempty"`

	// TransformFunctionConfig is the transform function config of the PulsarSink
	// +optional
	TransformFunctionConfig string `json:"transformFunctionConfig,omitempty"`

	// ConnectionRef is the reference to the PulsarConnection resource
	ConnectionRef corev1.LocalObjectReference `json:"connectionRef"`

	// +kubebuilder:validation:Enum=CleanUpAfterDeletion;KeepAfterDeletion
	// +optional
	LifecyclePolicy PulsarResourceLifeCyclePolicy `json:"lifecyclePolicy,omitempty"`
}

type PulsarSinkStatus struct {

	// ObservedGeneration is the most recent generation observed for this resource.
	// It corresponds to the metadata generation, which is updated on mutation by the API Server.
	// +optional
	ObservedGeneration int64 `json:"observedGeneration,omitempty"`

	// Represents the observations of a connection's current state.
	// +patchMergeKey=type
	// +patchStrategy=merge
	// +listType=map
	// +listMapKey=type
	// +optional
	Conditions []metav1.Condition `json:"conditions,omitempty" patchStrategy:"merge" patchMergeKey:"type"`
}

type PulsarSource struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   PulsarSourceSpec   `json:"spec,omitempty"`
	Status PulsarSourceStatus `json:"status,omitempty"`
}

type PulsarSourceList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []PulsarSource `json:"items"`
}

type PulsarSourceSpec struct {

	// Tenant is the tenant of the PulsarSource
	// +optional
	Tenant string `json:"tenant,omitempty"`

	// Namespace is the namespace of the PulsarSource
	// +optional
	Namespace string `json:"namespace,omitempty"`

	// Name is the name of the PulsarSource
	// +optional
	Name string `json:"name,omitempty"`

	// ClassName is the class name of the
	// +optional
	ClassName string `json:"className,omitempty"`

	// ProducerConfig is the producer config of the PulsarSource
	// +optional
	ProducerConfig *ProducerConfig `json:"producerConfig,omitempty"`

	// TopicName is the topic name of the PulsarSource
	// +optional
	TopicName string `json:"topicName,omitempty"`

	// SerdeClassName is the serde class name of the PulsarSource
	// +optional
	SerdeClassName string `json:"serdeClassName,omitempty"`

	// SchemaType is the schema type of the PulsarSource
	// +optional
	SchemaType string `json:"schemaType,omitempty"`

	// Configs is the map of configs of the PulsarSource
	// +optional
	Configs *apiextensionsv1.JSON `json:"configs,omitempty"`

	// Secrets is the map of secrets of the PulsarSource
	// +optional
	Secrets map[string]FunctionSecretKeyRef `json:"secrets,omitempty"`

	// Parallelism is the parallelism of the PulsarSource
	// +optional
	Parallelism int `json:"parallelism,omitempty"`

	// ProcessingGuarantees is the processing guarantees of the PulsarSource
	// +optional
	ProcessingGuarantees string `json:"processingGuarantees,omitempty"`

	// Resources is the resources of the PulsarSource
	// +optional
	Resources *Resources `json:"resources,omitempty"`

	// Archive is the archive of the PulsarSource
	// +optional
	Archive *PackageContentRef `json:"archive,omitempty"`

	// RuntimeFlags is the runtime flags of the PulsarSource
	// +optional
	RuntimeFlags string `json:"runtimeFlags,omitempty"`

	// CustomRuntimeOptions is the custom runtime options of the PulsarSource
	// +optional
	CustomRuntimeOptions *apiextensionsv1.JSON `json:"customRuntimeOptions,omitempty"`

	// BatchSourceConfig is the batch source config of the PulsarSource
	// +optional
	BatchSourceConfig *BatchSourceConfig `json:"batchSourceConfig,omitempty"`

	// BatchBuilder is the batch builder of the PulsarSource
	// +optional
	BatchBuilder string `json:"batchBuilder,omitempty"`

	// ConnectionRef is the reference to the PulsarConnection resource
	ConnectionRef corev1.LocalObjectReference `json:"connectionRef"`

	// +kubebuilder:validation:Enum=CleanUpAfterDeletion;KeepAfterDeletion
	// +optional
	LifecyclePolicy PulsarResourceLifeCyclePolicy `json:"lifecyclePolicy,omitempty"`
}

type PulsarSourceStatus struct {

	// ObservedGeneration is the most recent generation observed for this resource.
	// It corresponds to the metadata generation, which is updated on mutation by the API Server.
	// +optional
	ObservedGeneration int64 `json:"observedGeneration,omitempty"`

	// Represents the observations of a connection's current state.
	// +patchMergeKey=type
	// +patchStrategy=merge
	// +listType=map
	// +listMapKey=type
	// +optional
	Conditions []metav1.Condition `json:"conditions,omitempty" patchStrategy:"merge" patchMergeKey:"type"`
}

type PulsarTenant struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   PulsarTenantSpec   `json:"spec,omitempty"`
	Status PulsarTenantStatus `json:"status,omitempty"`
}

type PulsarTenantList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []PulsarTenant `json:"items"`
}

type PulsarTenantSpec struct {

	// Name is the tenant name.
	// This field is required and must be unique within the Pulsar cluster.
	Name string `json:"name"`

	// ConnectionRef is the reference to the PulsarConnection resource
	// used to connect to the Pulsar cluster for this tenant.
	ConnectionRef corev1.LocalObjectReference `json:"connectionRef"`

	// AdminRoles is a list of roles that have administrative privileges for this tenant.
	// These roles can perform actions like creating namespaces, topics, and managing permissions.
	// +optional
	AdminRoles []string `json:"adminRoles,omitempty"`

	// AllowedClusters is a list of clusters that this tenant is allowed to access.
	// This field is optional and can be used to restrict the clusters a tenant can connect to.
	// Please use `GeoReplicationRefs` instead if you are setting up geo-replication
	// between multiple Pulsar instances.
	// +optional
	AllowedClusters []string `json:"allowedClusters,omitempty"`

	// LifecyclePolicy determines whether to keep or delete the Pulsar tenant
	// when the Kubernetes resource is deleted.
	// +kubebuilder:validation:Enum=CleanUpAfterDeletion;KeepAfterDeletion
	// +optional
	LifecyclePolicy PulsarResourceLifeCyclePolicy `json:"lifecyclePolicy,omitempty"`

	// GeoReplicationRefs is a list of references to PulsarGeoReplication resources,
	// used to configure geo-replication for this tenant across multiple Pulsar instances.
	// This is **ONLY** used when you are using PulsarGeoReplication for setting up geo-replication
	// between multiple Pulsar instances.
	// Please use `AllowedClusters` instead if you are allowing a tenant to be available within
	// specific clusters in a same Pulsar instance.
	// +optional
	GeoReplicationRefs []*corev1.LocalObjectReference `json:"geoReplicationRefs,omitempty"`
}

type PulsarTenantStatus struct {

	// ObservedGeneration is the most recent generation observed for this resource.
	// It corresponds to the metadata generation, which is updated on mutation by the API Server.
	// This field is used to track whether the controller has processed the latest changes.
	// +optional
	ObservedGeneration int64 `json:"observedGeneration,omitempty"`

	// Conditions represent the latest available observations of the PulsarTenant's current state.
	// It follows the Kubernetes conventions for condition types and status.
	// The "Ready" condition type is typically used to indicate the overall status of the tenant.
	// Other condition types may be used to provide more detailed status information.
	// +patchMergeKey=type
	// +patchStrategy=merge
	// +listType=map
	// +listMapKey=type
	// +optional
	Conditions []metav1.Condition `json:"conditions,omitempty" patchStrategy:"merge" patchMergeKey:"type"`
}

type PulsarTopic struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   PulsarTopicSpec   `json:"spec,omitempty"`
	Status PulsarTopicStatus `json:"status,omitempty"`
}

type PulsarTopicList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []PulsarTopic `json:"items"`
}

type PulsarTopicSpec struct {

	// Name is the topic name
	Name string `json:"name"`

	// Persistent determines if the topic is persistent (true) or non-persistent (false).
	// Defaults to true if not specified.
	// +kubebuilder:default=true
	// +optional
	Persistent *bool `json:"persistent,omitempty"`

	// Partitions specifies the number of partitions for a partitioned topic.
	// Set to 0 for a non-partitioned topic.
	// +kubebuilder:default=0
	// +optional
	Partitions *int32 `json:"partitions,omitempty"`

	// ConnectionRef is the reference to the PulsarConnection resource
	// used to connect to the Pulsar cluster for this topic.
	ConnectionRef corev1.LocalObjectReference `json:"connectionRef"`

	// LifecyclePolicy determines whether to keep or delete the Pulsar topic
	// when the Kubernetes resource is deleted.
	// +kubebuilder:validation:Enum=CleanUpAfterDeletion;KeepAfterDeletion
	// +optional
	LifecyclePolicy PulsarResourceLifeCyclePolicy `json:"lifecyclePolicy,omitempty"`

	// MaxProducers sets the maximum number of producers allowed on the topic.
	// +optional
	MaxProducers *int32 `json:"maxProducers,omitempty"`

	// MaxConsumers sets the maximum number of consumers allowed on the topic.
	// +optional
	MaxConsumers *int32 `json:"maxConsumers,omitempty"`

	// MessageTTL specifies the Time to Live (TTL) for messages on the topic.
	// Messages older than this TTL will be automatically marked as deleted.
	// +optional
	MessageTTL *utils.Duration `json:"messageTTL,omitempty"`

	// MaxUnAckedMessagesPerConsumer sets the maximum number of unacknowledged
	// messages allowed for a consumer before it's blocked from receiving more messages.
	// +optional
	MaxUnAckedMessagesPerConsumer *int32 `json:"maxUnAckedMessagesPerConsumer,omitempty"`

	// MaxUnAckedMessagesPerSubscription sets the maximum number of unacknowledged
	// messages allowed for a subscription before it's blocked from receiving more messages.
	// +optional
	MaxUnAckedMessagesPerSubscription *int32 `json:"maxUnAckedMessagesPerSubscription,omitempty"`

	// RetentionTime specifies the minimum time to retain messages on the topic.
	// Should be set in conjunction with RetentionSize for effective retention policy.
	// Retention Quota must exceed configured backlog quota for topic
	// +optional
	RetentionTime *utils.Duration `json:"retentionTime,omitempty"`

	// RetentionSize specifies the maximum size of backlog retained on the topic.
	// Should be set in conjunction with RetentionTime for effective retention policy.
	// Retention Quota must exceed configured backlog quota for topic
	// +optional
	RetentionSize *resource.Quantity `json:"retentionSize,omitempty"`

	// BacklogQuotaLimitTime specifies the time limit for message backlog.
	// Messages older than this limit will be removed or handled according to the retention policy.
	// +optional
	BacklogQuotaLimitTime *utils.Duration `json:"backlogQuotaLimitTime,omitempty"`

	// BacklogQuotaLimitSize specifies the size limit for message backlog.
	// When the limit is reached, older messages will be removed or handled according to the retention policy.
	// +optional
	BacklogQuotaLimitSize *resource.Quantity `json:"backlogQuotaLimitSize,omitempty"`

	// BacklogQuotaRetentionPolicy specifies the retention policy for messages when backlog quota is exceeded.
	// Valid values are "producer_request_hold", "producer_exception", or "consumer_backlog_eviction".
	// +optional
	BacklogQuotaRetentionPolicy *string `json:"backlogQuotaRetentionPolicy,omitempty"`

	// SchemaInfo defines the schema for the topic, if any.
	// +optional
	SchemaInfo *SchemaInfo `json:"schemaInfo,omitempty"`

	// GeoReplicationRefs is a list of references to PulsarGeoReplication resources,
	// used to configure geo-replication for this topic across multiple Pulsar instances.
	// This is **ONLY** used when you are using PulsarGeoReplication for setting up geo-replication
	// between two Pulsar instances.
	// +optional
	GeoReplicationRefs []*corev1.LocalObjectReference `json:"geoReplicationRefs,omitempty"`

	// ReplicationClusters is the list of clusters to which the topic is replicated
	// This is **ONLY** used if you are replicating clusters within the same Pulsar instance.
	// Please use `GeoReplicationRefs` instead if you are setting up geo-replication
	// between two Pulsar instances.
	// +optional
	ReplicationClusters []string `json:"replicationClusters,omitempty"`

	// Deduplication controls whether to enable message deduplication for the topic.
	// +optional
	Deduplication *bool `json:"deduplication,omitempty"`
}

type PulsarTopicStatus struct {

	// ObservedGeneration is the most recent generation observed for this resource.
	// It corresponds to the metadata generation, which is updated on mutation by the API Server.
	// This field is used to track whether the controller has processed the latest changes.
	// +optional
	ObservedGeneration int64 `json:"observedGeneration,omitempty"`

	// Conditions represent the latest available observations of the PulsarTopic's current state.
	// It follows the Kubernetes conventions for condition types and status.
	// The "Ready" condition type indicates the overall status of the topic.
	// The "PolicyReady" condition type indicates whether the topic policies have been successfully applied.
	// +patchMergeKey=type
	// +patchStrategy=merge
	// +listType=map
	// +listMapKey=type
	// +optional
	Conditions []metav1.Condition `json:"conditions,omitempty" patchStrategy:"merge" patchMergeKey:"type"`

	// GeoReplicationEnabled indicates whether geo-replication is enabled for this topic.
	// This is set to true when GeoReplicationRefs are configured in the spec and successfully applied.
	// +optional
	GeoReplicationEnabled bool `json:"geoReplicationEnabled,omitempty"`
}

type ResourceSpec struct {
	// CPU represents the minimum amount of CPU required.
	// +kubebuilder:validation:Required
	CPU string `json:"cpu"`

	// Memory represents the minimum amount of memory required.
	// +kubebuilder:validation:Required
	Memory string `json:"memory"`
}

type Resources struct {
	// +optional
	CPU string `json:"cpu,omitempty"`

	// +optional
	Disk int64 `json:"disk,omitempty"`

	// +optional
	RAM int64 `json:"ram,omitempty"`
}

type SchemaInfo struct {
	// Type determines how to interpret the schema data.
	// Valid values include: "AVRO", "JSON", "PROTOBUF", "PROTOBUF_NATIVE", "KEY_VALUE", "BYTES", or "NONE".
	// For KEY_VALUE schemas, use the format "KEY_VALUE(KeyType,ValueType)" where KeyType and ValueType
	// are one of the other schema types.
	Type string `json:"type,omitempty"`

	// Schema contains the actual schema definition.
	// For AVRO and JSON schemas, this should be a JSON string of the schema definition.
	// For PROTOBUF schemas, this should be the protobuf definition string.
	// For BYTES or NONE schemas, this field can be empty.
	Schema string `json:"schema,omitempty"`

	// Properties is a map of user-defined properties associated with the schema.
	// These can be used to store additional metadata about the schema.
	Properties map[string]string `json:"properties,omitempty"`
}

type Secret struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   SecretSpec   `json:"spec,omitempty"`
	Status SecretStatus `json:"status,omitempty"`
}

type SecretKeyRef struct {
	Name string `json:"name"`
	Key  string `json:"key"`
}

type SecretList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []Secret `json:"items"`
}

type SecretReference struct {
	// Name of the ENV variable.
	Name string `json:"name" protobuf:"bytes,1,opt,name=name"`

	// ValueFrom references a secret in the same namespace.
	ValueFrom *corev1.SecretKeySelector `json:"valueFrom,omitempty" protobuf:"bytes,2,opt,name=valueFrom"`
}

type SecretSpec struct {
	// APIServerRef is the reference to the StreamNativeCloudConnection
	// +required
	APIServerRef corev1.LocalObjectReference `json:"apiServerRef"`

	// InstanceName is the name of the instance this secret is for (e.g. pulsar-instance)
	// +optional
	InstanceName string `json:"instanceName"`

	// Location is the location of the secret.
	// +optional
	Location string `json:"location"`

	// the value should be base64 encoded
	// +optional
	Data map[string]string `json:"data,omitempty"`

	// SecretRef is the reference to the kubernetes secret
	// When SecretRef is set, it will be used to fetch the secret data.
	// Data will be ignored.
	// +optional
	SecretRef *KubernetesSecretReference `json:"secretRef,omitempty"`

	// PoolMemberName is the pool member to deploy the secret.
	// +optional
	PoolMemberName *string `json:"poolMemberName,omitempty"`

	// Toleration is the toleration for the secret.
	// +optional
	// +listType=atomic
	Tolerations []Toleration `json:"tolerations,omitempty"`

	// Type Used to facilitate programmatic handling of secret data.
	// +optional
	Type *corev1.SecretType `json:"type,omitempty"`
}

type SecretStatus struct {
	// Conditions represent the latest available observations of an object's state
	// +optional
	Conditions []metav1.Condition `json:"conditions,omitempty"`

	// ObservedGeneration is the last observed generation.
	// +optional
	ObservedGeneration int64 `json:"observedGeneration,omitempty"`
}

type ServiceAccountCredentials struct {
	// Type is the type of the credentials, must be "sn_service_account"
	Type string `json:"type"`

	// ClientID is the OAuth2 client ID
	ClientID string `json:"client_id"`

	// ClientSecret is the OAuth2 client secret
	ClientSecret string `json:"client_secret"`

	// ClientEmail is the email address of the service account
	ClientEmail string `json:"client_email"`

	// IssuerURL is the OpenID Connect issuer URL
	IssuerURL string `json:"issuer_url"`
}

type StreamNativeCloudConnection struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   StreamNativeCloudConnectionSpec   `json:"spec,omitempty"`
	Status StreamNativeCloudConnectionStatus `json:"status,omitempty"`
}

type StreamNativeCloudConnectionList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []StreamNativeCloudConnection `json:"items"`
}

type StreamNativeCloudConnectionSpec struct {
	// Server is the URL of the API server
	// +required
	Server string `json:"server"`

	// Auth defines the authentication configuration
	// +required
	Auth AuthConfig `json:"auth"`

	// Logs defines the logging service configuration
	// +optional
	Logs LogConfig `json:"logs,omitempty"`

	// Organization is the organization to use in the API server
	// If not specified, the operator will use the connection name as the organization
	// +optional
	Organization string `json:"organization,omitempty"`
}

type StreamNativeCloudConnectionStatus struct {
	// Conditions represent the latest available observations of an object's state
	// +optional
	Conditions []metav1.Condition `json:"conditions,omitempty"`

	// ObservedGeneration is the last observed generation.
	// +optional
	ObservedGeneration int64 `json:"observedGeneration,omitempty"`

	// LastConnectedTime is the last time we successfully connected to the API server
	// +optional
	LastConnectedTime *metav1.Time `json:"lastConnectedTime,omitempty"`
}

type TaintEffect string

type Toleration struct {
	// Key is the taint key that the toleration applies to. Empty means match all taint keys.
	// If the key is empty, operator must be Exists; this combination means to match all values and all keys.
	// +optional
	Key string `json:"key,omitempty" protobuf:"bytes,1,opt,name=key"`
	// Operator represents a key's relationship to the value.
	// Valid operators are Exists and Equal. Defaults to Equal.
	// Exists is equivalent to wildcard for value, so that a workload can
	// tolerate all taints of a particular category.
	// +optional
	Operator TolerationOperator `json:"operator,omitempty" protobuf:"bytes,2,opt,name=operator,casttype=TolerationOperator"`
	// Value is the taint value the toleration matches to.
	// If the operator is Exists, the value should be empty, otherwise just a regular string.
	// +optional
	Value string `json:"value,omitempty" protobuf:"bytes,3,opt,name=value"`
	// Effect indicates the taint effect to match. Empty means match all taint effects.
	// When specified, allowed values are NoSchedule and PreferNoSchedule.
	// +optional
	Effect TaintEffect `json:"effect,omitempty" protobuf:"bytes,4,opt,name=effect,casttype=TaintEffect"`
}

type TolerationOperator string

type UserMetadata struct {
	// Name of the deployment
	// +optional
	Name string `json:"name,omitempty"`

	// Namespace of the deployment
	// +optional
	Namespace string `json:"namespace,omitempty"`

	// Labels of the deployment
	// +optional
	Labels map[string]string `json:"labels,omitempty"`

	// Annotations of the deployment
	// +optional
	Annotations map[string]string `json:"annotations,omitempty"`

	// DisplayName of the deployment
	// +optional
	DisplayName string `json:"displayName,omitempty"`
}

type ValueOrSecretRef struct {
	// +optional
	Value *string `json:"value,omitempty"`

	// +optional
	SecretRef *SecretKeyRef `json:"secretRef,omitempty"`
}

type Volume struct {
	// Volume's name.
	// +required
	Name string `json:"name"`

	// VolumeSource represents the location and type of the mounted volume.
	// +required
	VolumeSource `json:",inline"`
}

type VolumeSource struct {
	// ConfigMap represents a configMap that should populate this volume
	// +optional
	ConfigMap *corev1.ConfigMapVolumeSource `json:"configMap,omitempty"`

	// Secret represents a secret that should populate this volume.
	// +optional
	Secret *corev1.SecretVolumeSource `json:"secret,omitempty"`
}

type VvpDeploymentDetails struct {
	// DeploymentTargetName defines the target name for the deployment
	// +optional
	DeploymentTargetName *string `json:"deploymentTargetName,omitempty"`

	// JobFailureExpirationTime defines the expiration time for job failures
	// +optional
	JobFailureExpirationTime *string `json:"jobFailureExpirationTime,omitempty"`

	// MaxJobCreationAttempts defines the maximum number of job creation attempts
	// +kubebuilder:validation:Minimum=1
	// +optional
	MaxJobCreationAttempts *int32 `json:"maxJobCreationAttempts,omitempty"`

	// MaxSavepointCreationAttempts defines the maximum number of savepoint creation attempts
	// +kubebuilder:validation:Minimum=1
	// +optional
	MaxSavepointCreationAttempts *int32 `json:"maxSavepointCreationAttempts,omitempty"`

	// RestoreStrategy defines the restore strategy for the deployment
	// +optional
	RestoreStrategy *VvpRestoreStrategy `json:"restoreStrategy,omitempty"`

	// SessionClusterName defines the name of the session cluster
	// +optional
	SessionClusterName *string `json:"sessionClusterName,omitempty"`

	// State of the deployment
	// +kubebuilder:validation:Enum=RUNNING;SUSPENDED;CANCELLED
	// +optional
	State string `json:"state,omitempty"`

	// Template defines the deployment template
	// +required
	Template VvpDeploymentDetailsTemplate `json:"template"`
}

type VvpDeploymentDetailsTemplate struct {
	// Metadata of the deployment
	// +optional
	Metadata VvpDeploymentDetailsTemplateMetadata `json:"metadata,omitempty"`

	// Spec defines the deployment specification
	// +required
	Spec VvpDeploymentDetailsTemplateSpec `json:"spec"`
}

type VvpDeploymentDetailsTemplateMetadata struct {
	// Annotations to add to the deployment
	// +optional
	Annotations map[string]string `json:"annotations,omitempty"`
}

type VvpDeploymentDetailsTemplateSpec struct {
	// Artifact defines the deployment artifact
	// +required
	Artifact *Artifact `json:"artifact"`

	// FlinkConfiguration defines the Flink configuration
	// +optional
	FlinkConfiguration map[string]string `json:"flinkConfiguration,omitempty"`

	// +optional
	Kubernetes *VvpDeploymentDetailsTemplateSpecKubernetesSpec `json:"kubernetes,omitempty"`

	// +optional
	LatestCheckpointFetchInterval *int32 `json:"latestCheckpointFetchInterval,omitempty"`

	// +optional
	Logging *Logging `json:"logging,omitempty"`

	// +optional
	NumberOfTaskManagers *int32 `json:"numberOfTaskManagers,omitempty"`

	// +optional
	Parallelism *int32 `json:"parallelism,omitempty"`

	// +optional
	Resources *VvpDeploymentKubernetesResources `json:"resources,omitempty"`
}

type VvpDeploymentDetailsTemplateSpecKubernetesSpec struct {
	// +optional
	Labels map[string]string `json:"labels,omitempty"`
}

type VvpDeploymentKubernetesResources struct {
	// +optional
	Jobmanager *ResourceSpec `json:"jobmanager,omitempty"`

	// +optional
	Taskmanager *ResourceSpec `json:"taskmanager,omitempty"`
}

type VvpDeploymentStatus struct {
	// CustomResourceState defines the state of the custom resource
	// +optional
	CustomResourceState string `json:"customResourceState,omitempty"`

	// DeploymentID defines the ID of the deployment
	// +optional
	DeploymentID string `json:"deploymentId,omitempty"`

	// StatusState defines the state of the status
	// +optional
	StatusState string `json:"statusState,omitempty"`

	// DeploymentNamespace defines the namespace of the deployment
	// +optional
	DeploymentNamespace string `json:"deploymentNamespace,omitempty"`
}

type VvpDeploymentTemplate struct {
	// SyncingMode defines how the deployment should be synced
	// +optional
	SyncingMode string `json:"syncingMode,omitempty"`

	// Deployment defines the deployment configuration
	// +required
	Deployment VvpDeploymentTemplateSpec `json:"deployment"`
}

type VvpDeploymentTemplateSpec struct {
	// UserMetadata defines the metadata for the deployment
	// +required
	UserMetadata UserMetadata `json:"userMetadata"`

	// Spec defines the deployment specification
	// +required
	Spec VvpDeploymentDetails `json:"spec"`
}

type VvpRestoreStrategy struct {
	AllowNonRestoredState bool   `json:"allowNonRestoredState,omitempty"`
	Kind                  string `json:"kind,omitempty"`
}

type WindowConfig struct {
	// +optional
	WindowLengthCount *int `json:"windowLengthCount,omitempty" yaml:"windowLengthCount"`

	// +optional
	WindowLengthDurationMs *int64 `json:"windowLengthDurationMs,omitempty" yaml:"windowLengthDurationMs"`

	// +optional
	SlidingIntervalCount *int `json:"slidingIntervalCount,omitempty" yaml:"slidingIntervalCount"`

	// +optional
	SlidingIntervalDurationMs *int64 `json:"slidingIntervalDurationMs,omitempty" yaml:"slidingIntervalDurationMs"`

	// +optional
	LateDataTopic *string `json:"lateDataTopic,omitempty" yaml:"lateDataTopic"`

	// +optional
	MaxLagMs *int64 `json:"maxLagMs,omitempty" yaml:"maxLagMs"`

	// +optional
	WatermarkEmitIntervalMs *int64 `json:"watermarkEmitIntervalMs,omitempty" yaml:"watermarkEmitIntervalMs"`

	// +optional
	TimestampExtractorClassName *string `json:"timestampExtractorClassName,omitempty" yaml:"timestampExtractorClassName"`

	// +optional
	ActualWindowFunctionClassName *string `json:"actualWindowFunctionClassName,omitempty" yaml:"actualWindowFunctionClassName"`

	// +optional
	ProcessingGuarantees *string `json:"processingGuarantees,omitempty" yaml:"processingGuarantees"`
}