v1alpha1

type AutoscaleConfig struct {
	// RPS is the desired requests per second to trigger upscaling.
	// +kubebuilder:validation:Minimum=1
	RPS int `json:"rps"`
	// CPU is the desired CPU utilization to trigger upscaling.
	// +kubebuilder:validation:Minimum=1
	CPU int `json:"cpu"`
	// Memory is the desired memory utilization to trigger upscaling.
	// +kubebuilder:validation:Minimum=1
	Memory int `json:"memory"`
	// Concurrency is the maximum concurrency of a Capp.
	// +kubebuilder:validation:Minimum=1
	Concurrency int `json:"concurrency"`
	// ActivationScale is the default number of replicas used when a scale-to-zero Capp scales up from idle.
	// +kubebuilder:validation:Minimum=2
	ActivationScale int `json:"activationScale"`
	// MinReplicasLimit is the global minimum scale. (maximum allowed value for minReplicas).
	// +kubebuilder:validation:Minimum=1
	MinReplicasLimit int `json:"minReplicasLimit"`
	// MaxReplicasLimit is the global maximum scale (maximum allowed value for maxReplicas).
	// +kubebuilder:validation:Minimum=1
	MaxReplicasLimit int `json:"maxReplicasLimit"`
	// MaxScaleDelay is the maximum delay in seconds before the Autoscaler scales down the Capp to zero.
	// +kubebuilder:default:=3600
	// +kubebuilder:validation:Minimum=0
	MaxScaleDelay int `json:"maxScaleDelay"`
}

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

	// CappSpec defines the desired state of Capp.
	// +optional
	Spec CappSpec `json:"spec,omitempty"`

	// CappStatus defines the observed state of Capp.
	// +optional
	Status CappStatus `json:"status,omitempty"`
}

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

	Spec   CappConfigSpec   `json:"spec,omitempty"`
	Status CappConfigStatus `json:"status,omitempty"`
}

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

type CappConfigSpec struct {
	// +kubebuilder:validation:Required
	DNSConfig DNSConfig `json:"dnsConfig"`

	// +kubebuilder:validation:Required
	AutoscaleConfig AutoscaleConfig `json:"autoscaleConfig"`

	// DefaultResources is the default resources to be assigned to Capp.
	// If other resources are specified then they override the default values.
	DefaultResources corev1.ResourceRequirements `json:"defaultResources"`

	// AllowedHostnamePatterns is a list of hostname patterns used to validate Capp hostnames.
	// If the Capp hostname matches a pattern, it is allowed to be created.
	// Defaults to an empty list (all hostnames denied) if not specified.
	// +kubebuilder:default:={}
	AllowedHostnamePatterns []HostnamePattern `json:"allowedHostnamePatterns"`

	// RevisionHistoryLimit defines how many CappRevisions will be retained
	// +kubebuilder:default:=10
	// +kubebuilder:validation:Minimum=1
	RevisionHistoryLimit int `json:"revisionHistoryLimit,omitempty"`

	// MaxKafkaConsumers is the maximum allowed KafkaSource consumers per kafka source entry.
	// +kubebuilder:default:=5
	// +kubebuilder:validation:Minimum=1
	MaxKafkaConsumers int32 `json:"maxKafkaConsumers,omitempty"`
}

type CappConfigStatus struct{}

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

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

	Spec CappRevisionSpec `json:"spec,omitempty"`
}

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

type CappRevisionSpec struct {
	// RevisionNumber represent the revision number of Capp
	RevisionNumber int `json:"revisionNumber"`

	// CappTemplate holds the manifest of a specific Capp corresponding to a particular RevisionNumber
	CappTemplate CappTemplate `json:"cappTemplate"`
}

type CappSpec struct {
	// State defines the state of capp
	// Possible values examples: "enabled", "disabled".
	// +optional
	// +kubebuilder:default:="enabled"
	// +kubebuilder:validation:Enum=enabled;disabled
	State string `json:"state,omitempty"`

	// ScaleSpec holds the Capp scaling configuration.
	ScaleSpec ScaleSpec `json:"scaleSpec"`

	// ConfigurationSpec holds the desired state of the Configuration (from the client).
	ConfigurationSpec knativev1.ConfigurationSpec `json:"configurationSpec"`

	// RouteSpec defines the route specification for the Capp.
	// +optional
	RouteSpec RouteSpec `json:"routeSpec,omitempty"`

	// LogSpec defines the configuration for shipping Capp logs.
	LogSpec LogSpec `json:"logSpec,omitempty"`

	// VolumesSpec defines the volumes specification for the Capp.
	VolumesSpec VolumesSpec `json:"volumesSpec,omitempty"`

	// EventSourcesSpec defines the event sources for the Capp.
	// +optional
	EventSourcesSpec EventSourcesSpec `json:"eventSourcesSpec,omitempty"`
}

type CappStatus struct {
	// KnativeObjectStatus represents the Status stanza of the Service resource.
	// +optional
	KnativeObjectStatus knativev1.ServiceStatus `json:"knativeObjectStatus,omitempty"`

	// RevisionInfo shows the revision information.
	// +optional
	RevisionInfo []RevisionInfo `json:"revisions,omitempty"`

	// StateStatus shows the current Capp state
	// +optional
	StateStatus StateStatus `json:"stateStatus,omitempty"`

	// LoggingStatus defines the state of the Flow and Output objects linked to the Capp.
	// +optional
	LoggingStatus LoggingStatus `json:"loggingStatus,omitempty"`

	// RouteStatus shows the state of the DomainMapping object linked to the Capp.
	// +optional
	RouteStatus RouteStatus `json:"routeStatus,omitempty"`

	// VolumesStatus shows the state of the Volumes objects linked to the Capp.
	// +optional
	VolumesStatus VolumesStatus `json:"volumesStatus,omitempty"`

	// EventingStatus shows the state of event sources linked to the Capp.
	// +optional
	EventingStatus EventingStatus `json:"eventingStatus,omitempty"`

	// Conditions contain details about the current state of the Capp.
	// +optional
	Conditions []metav1.Condition `json:"conditions,omitempty"`
}

type CappTemplate struct {
	// Spec is the related Capp spec
	Spec CappSpec `json:"cappSpec,omitempty"`

	// Labels is a map of string keys and values which are the actual labels of the related Capp
	// +optional
	Labels map[string]string `json:"labels,omitempty"`

	// Annotations is a map of string keys and values which are the actual annotations of the related Capp
	// +optional
	Annotations map[string]string `json:"annotations,omitempty"`
}

type DNSConfig struct {
	// Zone defines the DNS zone for Capp Hostnames.
	// +kubebuilder:validation:MinLength=1
	// +kubebuilder:validation:XValidation:rule="self.endsWith('.')",message="zone must end with '.'"
	Zone string `json:"zone"`
	// CNAME defines the CNAME record that will be used for Capp Hostnames.
	// +kubebuilder:validation:MinLength=1
	CNAME string `json:"cname"`
	// Provider defines the DNS provider.
	// +kubebuilder:validation:MinLength=1
	Provider string `json:"provider"`
	// IssuerRef identifies the cert-manager issuer used to issue certificates.
	IssuerRef IssuerRef `json:"issuerRef"`
}

type DNSRecordObjectStatus struct {
	// CNAMERecordObjectStatus is the status of the underlying ARecordSet object
	// +optional
	CNAMERecordObjectStatus dnsrecordv1alpha1.CNAMERecordStatus `json:"cnameRecordObjectStatus,omitempty"`
}

type EventSourceStatus struct {
	// Name is the K8s name of the underlying source resource.
	// +optional
	Name string `json:"name,omitempty"`

	// Condition holds the readiness condition for the underlying source resource.
	Condition kapis.Condition `json:"condition"`
}

type EventSourcesSpec struct {
	// Sources is the list of event sources connected to the Capp's Knative Service.
	// +optional
	Sources []SourceConfiguration `json:"sources,omitempty"`
}

type EventingStatus struct {
	// EventSources lists the status of each owned event source resource.
	// +optional
	EventSources []EventSourceStatus `json:"eventSources,omitempty"`
}

type HostnamePattern struct {
	// Match is a regex used to match Capp hostnames.
	// +kubebuilder:validation:MinLength=1
	Match string `json:"match"`
	// Explanation is a human-readable description shown in webhook error messages.
	// +kubebuilder:validation:MaxLength=100
	// +optional
	Explanation string `json:"explanation,omitempty"`
}

type IssuerRef struct {
	// Name is the name of the certificate issuer.
	// +kubebuilder:validation:MinLength=1
	Name string `json:"name"`
	// Kind is the kind of the certificate issuer (e.g. ClusterIssuer).
	// +kubebuilder:validation:MinLength=1
	Kind string `json:"kind"`
	// Group is the API group of the certificate issuer (e.g. cert-manager.io).
	// +kubebuilder:validation:MinLength=1
	Group string `json:"group"`
}

type KafkaSourceConfiguration struct {
	// BootstrapServers is the list of Kafka broker addresses.
	// +kubebuilder:validation:Required
	// +kubebuilder:validation:MinItems=1
	BootstrapServers []string `json:"bootstrapServers"`

	// Topics is the list of Kafka topics to consume.
	// +kubebuilder:validation:Required
	// +kubebuilder:validation:MinItems=1
	Topics []string `json:"topics"`

	// ConsumerGroup is the Kafka consumer group ID.
	// Optional; when unset the operator assigns a dedicated group for this source.
	// +optional
	ConsumerGroup string `json:"consumerGroup,omitempty"`

	// Consumers is the number of parallel KafkaSource consumers for this source.
	// +kubebuilder:validation:Minimum=1
	// +optional
	Consumers *int32 `json:"consumers,omitempty"`

	// SecretRef references a Secret in the Capp namespace with credentials for the Kafka cluster.
	// +kubebuilder:validation:Required
	SecretRef corev1.LocalObjectReference `json:"secretRef"`
}

type LogSpec struct {
	// Type defines where to send the Capp logs
	// +kubebuilder:validation:Enum=elastic;elastic-datastream
	// +optional
	Type LogType `json:"type,omitempty"`

	// Host defines Elasticsearch or Splunk host.
	// Should include full URL with protocol and port (e.g. https://elasticsearch:9200/_bulk).
	// +optional
	Host string `json:"host,omitempty"`

	// Index defines the index name to write events to.
	// Ignored if type is set to "elastic-datastream".
	// +optional
	Index string `json:"index,omitempty"`

	// User defines a User for authentication.
	// +optional
	User string `json:"user,omitempty"`

	// PasswordSecret defines the name of the secret
	// containing the password for authentication.
	// +optional
	PasswordSecret string `json:"passwordSecret,omitempty"`
}

type LogType string

type LoggingStatus struct {
	// SyslogNGFlow represents the Status of the SyslogNGFlow used by the Capp.
	// +optional
	SyslogNGFlow loggingv1beta1.SyslogNGFlowStatus `json:"syslogngflow,omitempty"`

	// SyslogNGOutput represents the Status of the SyslogNGOutput used by the Capp.
	// +optional
	SyslogNGOutput loggingv1beta1.SyslogNGOutputStatus `json:"syslogngoutput,omitempty"`

	// Conditions contain details about the current state of the SyslogNGFlow and SyslogNGOutput used by the Capp.
	// +optional
	Conditions []metav1.Condition `json:"conditions,omitempty"`
}

type NFSVolume struct {
	// Server is the hostname or IP address of the NFS server.
	// +kubebuilder:validation:MinLength=1
	Server string `json:"server"`

	// Path is the exported path on the NFS server.
	// +kubebuilder:validation:MinLength=1
	// +kubebuilder:validation:XValidation:rule="self.startsWith('/')",message="path must start with '/'"
	Path string `json:"path"`

	// Name is the name of the volume.
	// +kubebuilder:validation:MinLength=1
	// +kubebuilder:validation:MaxLength=63
	// +kubebuilder:validation:Pattern=`^[a-z0-9]([-a-z0-9]*[a-z0-9])?$`
	Name string `json:"name"`

	// Capacity is the capacity of the volume.
	Capacity corev1.ResourceList `json:"capacity"`
}

type NFSVolumeStatus struct {
	// VolumeName is the name of the volume.
	VolumeName string `json:"volumeName,omitempty"`

	// NFSPVCStatus is the status of the underlying NfsPvc object.
	NFSPVCStatus nfspvcv1alpha1.NfsPvcStatus `json:"nfsPvcStatus,omitempty"`
}

type PingSourceConfiguration struct {

	// Schedule is the cron expression that defines the schedule for the PingSource.
	// +kubebuilder:default:="* * * * *"
	Schedule string `json:"schedule"`
	// Data is the payload that the PingSource will send when it triggers.
	// Must be valid JSON.
	// +optional
	Data string `json:"data,omitempty"`
}

type RevisionInfo struct {
	// RevisionStatus communicates the observed state of the Revision (from the controller).
	// +optional
	RevisionStatus knativev1.RevisionStatus `json:"revisionsStatus,omitempty"`

	// RevisionName is the name of the revision.
	// +optional
	RevisionName string `json:"name,omitempty"`
}

type RouteSpec struct {
	// Hostname is the custom DNS name for the Capp route.
	// Required when tlsEnabled is true.
	// +optional
	Hostname string `json:"hostname,omitempty"`

	// TlsEnabled enables HTTPS and automatic certificate management for hostname.
	// +optional
	TlsEnabled bool `json:"tlsEnabled,omitempty"`

	// TrafficTarget holds a single entry of the routing table for the Capp route.
	// +optional
	TrafficTarget knativev1.TrafficTarget `json:"trafficTarget,omitempty"`

	// RouteTimeoutSeconds is the maximum duration in seconds
	// that the request instance is allowed to respond to a request.
	// +optional
	RouteTimeoutSeconds *int64 `json:"routeTimeoutSeconds,omitempty"`
}

type RouteStatus struct {
	// DomainMappingObjectStatus is the status of the underlying DomainMapping object
	// +optional
	DomainMappingObjectStatus knativev1beta1.DomainMappingStatus `json:"domainMappingObjectStatus,omitempty"`

	// ARecordSetObjectStatus is the status of the underlying ARecordSet object
	// +optional
	DNSRecordObjectStatus DNSRecordObjectStatus `json:"dnsRecordObjectStatus,omitempty"`

	// CertificateObjectStatus is the status of the underlying Certificate object
	// +optional
	CertificateObjectStatus cmapi.CertificateStatus `json:"certificateObjectStatus,omitempty"`
}

type ScaleSpec struct {
	// Metric defines which metric type is watched by the Autoscaler.
	// Possible values examples: "concurrency", "rps", "cpu", "memory".
	// +kubebuilder:default:="concurrency"
	// +kubebuilder:validation:Enum=cpu;memory;rps;concurrency
	Metric string `json:"metric,omitempty"`

	// MinReplicas is the minimum number of replicas for the Capp.
	// +kubebuilder:validation:Minimum=0
	// +optional
	MinReplicas *int32 `json:"minReplicas,omitempty"`

	// MaxReplicas is the maximum number of replicas for the Capp.
	// +kubebuilder:validation:Minimum=1
	// +optional
	MaxReplicas *int32 `json:"maxReplicas,omitempty"`

	// ScaleDelaySeconds is the delay in seconds before the Autoscaler scales down the Capp to zero.
	// +kubebuilder:validation:Minimum=0
	// +optional
	ScaleDelaySeconds *int32 `json:"scaleDelaySeconds,omitempty"`
}

type SourceConfiguration struct {
	// Name is a unique logical identifier for this source within the Capp.
	// +kubebuilder:validation:Required
	// +kubebuilder:validation:MinLength=1
	Name string `json:"name"`

	// URI is a relative path appended to the resolved Capp Knative Service address (e.g. "/path").
	// +kubebuilder:validation:Optional
	// +kubebuilder:validation:XValidation:rule="self.startsWith('/')",message="uri must be a relative path"
	URI *kapis.URL `json:"uri,omitempty"`

	// Configuration for a PingSource.
	// +optional
	PingSourceConfiguration *PingSourceConfiguration `json:"pingSourceConfiguration,omitempty"`

	// Configuration for a KafkaSource.
	// +optional
	KafkaSourceConfiguration *KafkaSourceConfiguration `json:"kafkaSourceConfiguration,omitempty"`
}

type StateStatus struct {
	// State is actual enabled state of the capp
	// +optional
	State string `json:"state,omitempty"`

	// LastChange is the last time the state of capp changed
	// +optional
	LastChange metav1.Time `json:"lastChange,omitempty"`
}

type VolumesSpec struct {
	// NFSVolumes is a list of NFS volumes to be mounted.
	NFSVolumes []NFSVolume `json:"nfsVolumes,omitempty"`
}

type VolumesStatus struct {
	// NFSVolumeStatus is the status of the underlying NFSVolume objects.
	NFSVolumesStatus []NFSVolumeStatus `json:"nfsVolumesStatus,omitempty"`
}