v1alpha1

type ClusterStage string

type Connector struct {
	Builtin []string                `json:"builtin,omitempty"`
	Custom  []CustomConnectorSource `json:"custom,omitempty"`
}

type CustomConnectorSource struct {
	URL     string            `json:"url,omitempty"`
	Headers map[string]string `json:"headers,omitempty"`
}

type JVMOptions struct {
	// Memory defines memory options
	// +optional
	Memory []string `json:"memory"`
	// Gc defines garbage collection options
	// +optional
	Gc []string `json:"gc"`
	// GcLogging defines garbage collection logging options
	// +optional
	GcLogging []string `json:"gcLogging"`
	// Extra defines extra options
	// +optional
	Extra []string `json:"extra"`
}

type KOP struct {
	// Enabled defines whether this KOP is enabled or not.
	Enabled bool `json:"enabled,omitempty"`
	// < 0 means disabled
	// +optional
	PlainTextPort int32 `json:"plainTextPort,omitempty"`
	// < 0 means disabled
	SecuredPort int32 `json:"SecuredPort,omitempty"`
}

type Metadata struct {
	Size          int32             `json:"size,omitempty"`
	Stage         ClusterStage      `json:"stage,omitempty"`
	PulsarVersion string            `json:"pulsarVersion,omitempty"`
	BrokerConfig  map[string]string `json:"brokerConfig,omitempty"`
}

type MonitoringConfig struct {
	// Enabled defines whether this monitoring is enabled or not.
	Enabled bool `json:"enabled,omitempty"`
}

type Ports struct {
	// +kubebuilder:validation:Minimum=1
	Client int32 `json:"client,omitempty"`
	// +kubebuilder:validation:Minimum=1
	ClientTLS int32 `json:"clientTLS,omitempty"`
	// +kubebuilder:validation:Minimum=1
	Web int32 `json:"web,omitempty"`
	// +kubebuilder:validation:Minimum=1
	WebTLS int32 `json:"WebTLS,omitempty"`
}

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

	Spec   PulsarClusterSpec   `json:"spec,omitempty"`
	Status PulsarClusterStatus `json:"status,omitempty"`
}

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

type PulsarClusterSpec struct {

	// ZookeeperServers specifies the hostname/IP address and port in the format "hostname:port".
	// +kubebuilder:validation:Required
	ZookeeperServers string `json:"zookeeperServers"`
	// BookkeeperClusterUri specifies the URI of the existing BookKeeper cluster that you want to use.
	// see https://pulsar.apache.org/docs/en/reference-cli-tools/#initialize-cluster-metadata
	// +kubebuilder:validation:Required
	BookkeeperClusterUri string `json:"bookkeeperClusterUri"`
	// ConfigurationStoreServers specifies the configuration store connection string (as a comma-separated list)
	// +optional
	ConfigurationStoreServers string `json:"configurationStoreServers"`
	// PulsarVersion defines the version of broker to use
	// +optional
	PulsarVersion string `json:"pulsarVersion,omitempty"`
	// ImagePullPolicy describes a policy for if/when to pull the image
	// +optional
	ImagePullPolicy v1.PullPolicy `json:"imagePullPolicy,omitempty"`
	// +kubebuilder:validation:Minimum=0
	Size *int32 `json:"size,omitempty"`
	// KOP configures the Kafka Protocol Handler
	KOP        KOP       `json:"kop,omitempty"`
	Connectors Connector `json:"connectors,omitempty"`
	// MaxUnavailableNodes defines the maximum number of nodes that
	// can be unavailable as per kubernetes PodDisruptionBudget
	// Default is 1.
	// +optional
	MaxUnavailableNodes int32  `json:"maxUnavailableNodes"`
	Ports               *Ports `json:"ports,omitempty"`
	// BrokerConfig defines the Bookkeeper configurations to override the broker.conf
	// +optional
	BrokerConfig map[string]string `json:"brokerConfig"`
	// JVMOptions defines the JVM options for pulsar broker; this is useful for performance tuning.
	// If unspecified, a reasonable defaults will be set
	// +optional
	JVMOptions       JVMOptions                    `json:"jvmOptions"`
	InitJobResources v1.ResourceRequirements       `json:"initJobResources,omitempty"`
	Persistence      *v1.PersistentVolumeClaimSpec `json:"persistence,omitempty"`
	// PodConfig defines common configuration for the broker pods
	// +optional
	PodConfig basetype.PodConfig `json:"podConfig,omitempty"`
	// ProbeConfig defines the probing settings for the broker containers
	// +optional
	ProbeConfig *pod.Probes `json:"probeConfig,omitempty"`

	// Labels defines the labels to attach to the broker deployment
	Labels map[string]string `json:"labels,omitempty"`

	// Annotations defines the annotations to attach to the broker statefulset and services
	Annotations map[string]string `json:"annotations,omitempty"`

	// ClusterDomain defines the cluster domain for the cluster
	// It defaults to cluster.local
	ClusterDomain string `json:"clusterDomain,omitempty"`
}

type PulsarClusterStatus struct {

	// Metadata defines the metadata status of the cluster
	// +optional
	Metadata Metadata `json:"metadata,omitempty"`
}

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

	Spec   PulsarManagerSpec   `json:"spec,omitempty"`
	Status PulsarManagerStatus `json:"status,omitempty"`
}

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

type PulsarManagerSpec struct {
}

type PulsarManagerStatus struct {
}

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

	Spec   PulsarProxySpec   `json:"spec,omitempty"`
	Status PulsarProxyStatus `json:"status,omitempty"`
}

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

type PulsarProxySpec struct {
}

type PulsarProxyStatus struct {
}