v1alpha1

type CloudType struct {
	// Image specifies the container image for cloud deployment
	Image string `json:"image"`
}

type ConfigItem struct {
	// DisplayName is the human-readable name of the config item
	// +kubebuilder:validation:Optional
	DisplayName string `json:"displayName,omitempty"`
	// Description provides additional information about the config item
	// +kubebuilder:validation:Optional
	Description string `json:"description,omitempty"`
	// Type specifies the data type of the config item
	// +kubebuilder:validation:Optional
	Type string `json:"type,omitempty"`
	// Required indicates whether this config item is mandatory
	// +kubebuilder:validation:Optional
	Required bool `json:"required,omitempty"`
}

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

	Spec   FunctionSpec   `json:"spec,omitempty"`
	Status FunctionStatus `json:"status,omitempty"`
}

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

type FunctionSpec struct {
	// Display name of the function
	// +kubebuilder:validation:Optional
	DisplayName string `json:"displayName,omitempty"`
	// Description of the function
	// +kubebuilder:validation:Optional
	Description string `json:"description,omitempty"`
	// Package reference
	// +kubebuilder:validation:Required
	PackageRef PackageRef `json:"packageRef"`
	// Module name
	// +kubebuilder:validation:Required
	Module string `json:"module"`
	// Number of replicas for the function deployment
	// +kubebuilder:validation:Optional
	// +kubebuilder:default=1
	Replicas *int32 `json:"replicas,omitempty"`
	// +kubebuilder:validation:Optional
	SubscriptionName string `json:"subscriptionName,omitempty"`
	// List of sources
	// +kubebuilder:validation:Optional
	Sources []SourceSpec `json:"sources,omitempty"`
	// Request source
	// +kubebuilder:validation:Optional
	RequestSource *SourceSpec `json:"requestSource,omitempty"`
	// Sink specifies the sink configuration
	// +kubebuilder:validation:Optional
	Sink *SinkSpec `json:"sink,omitempty"`
	// Configurations as key-value pairs
	// +kubebuilder:validation:Optional
	Config map[string]v1.JSON `json:"config,omitempty"`
}

type FunctionStatus struct {
	// Number of available pods (ready for at least minReadySeconds)
	AvailableReplicas int32 `json:"availableReplicas,omitempty"`
	// Total number of ready pods
	ReadyReplicas int32 `json:"readyReplicas,omitempty"`
	// Total number of non-terminated pods targeted by this deployment
	Replicas int32 `json:"replicas,omitempty"`
	// Total number of updated pods
	UpdatedReplicas int32 `json:"updatedReplicas,omitempty"`
	// Most recent generation observed for this Function
	ObservedGeneration int64 `json:"observedGeneration,omitempty"`
}

type FunctionType struct {
	// Cloud contains cloud function package configuration
	// +kubebuilder:validation:Optional
	Cloud *CloudType `json:"cloud,omitempty"`
}

type Module struct {
	// DisplayName is the human-readable name of the module
	// +kubebuilder:validation:Optional
	DisplayName string `json:"displayName,omitempty"`
	// Description provides additional information about the module
	// +kubebuilder:validation:Optional
	Description string `json:"description,omitempty"`
	// SourceSchema defines the input schema for the module
	// +kubebuilder:validation:Optional
	SourceSchema string `json:"sourceSchema,omitempty"`
	// SinkSchema defines the output schema for the module
	// +kubebuilder:validation:Optional
	SinkSchema string `json:"sinkSchema,omitempty"`
	// Config is a list of configuration items for the module
	// +kubebuilder:validation:Optional
	Config map[string]ConfigItem `json:"config,omitempty"`
}

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

	Spec   PackageSpec   `json:"spec,omitempty"`
	Status PackageStatus `json:"status,omitempty"`
}

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

type PackageRef struct {
	// Name of the Package resource
	// +kubebuilder:validation:Required
	Name string `json:"name"`
	// Namespace of the Package resource
	// +kubebuilder:validation:Optional
	Namespace string `json:"namespace,omitempty"`
}

type PackageSpec struct {
	// DisplayName is the human-readable name of the package
	// +kubebuilder:validation:Optional
	DisplayName string `json:"displayName,omitempty"`
	// Logo is the URL or base64 encoded image for the package logo
	// +kubebuilder:validation:Optional
	Logo string `json:"logo,omitempty"`
	// Description provides additional information about the package
	// +kubebuilder:validation:Optional
	Description string `json:"description,omitempty"`
	// FunctionType contains function type configuration
	FunctionType FunctionType `json:"functionType"`
	// Modules is a map of module names to their configurations
	Modules map[string]Module `json:"modules"`
}

type PackageStatus struct {
}

type PulsarSinkSpec struct {
	// Topic name
	// +kubebuilder:validation:Required
	Topic string `json:"topic"`
}

type PulsarSourceSpec struct {
	// Topic name
	// +kubebuilder:validation:Required
	Topic string `json:"topic"`
}

type SinkSpec struct {
	// Pulsar sink specification
	// +kubebuilder:validation:Optional
	Pulsar *PulsarSinkSpec `json:"pulsar,omitempty"`
}

type SourceSpec struct {
	// Pulsar source specification
	// +kubebuilder:validation:Optional
	Pulsar *PulsarSourceSpec `json:"pulsar,omitempty"`
}