v1beta2

type VpArtifact struct {
	Kind string `json:"kind"`

	JarURI string `json:"jarUri"`
	// +optional
	MainArgs string `json:"mainArgs,omitempty"`
	// +optional
	EntryClass string `json:"entryClass,omitempty"`
	// +optional
	FlinkVersion string `json:"flinkVersion,omitempty"`
	// +optional
	FlinkImageRegistry string `json:"flinkImageRegistry,omitempty"`
	// +optional
	FlinkImageRepository string `json:"flinkImageRepository,omitempty"`
	// +optional
	FlinkImageTag string `json:"flinkImageTag,omitempty"`
}

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

	Spec VpDeploymentObjectSpec `json:"spec"`
	// +optional
	Status *VpDeploymentStatus `json:"status,omitempty"`
}

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

type VpDeploymentObjectSpec struct {

	// VP
	Metadata VpMetadata       `json:"metadata"`
	Spec     VpDeploymentSpec `json:"spec"`

	// DeploymentTargetName is an extension on the VP API
	// Must provide a spec.deploymentTargetId if not set
	// +optional
	DeploymentTargetName string `json:"deploymentTargetName,omitempty"`
}

type VpDeploymentRestoreStrategy struct {
	// +optional
	Kind string `json:"kind,omitempty"`
	// +optional
	AllowNonRestoredState bool `json:"allowNonRestoredState,omitempty"`
}

type VpDeploymentRunningCondition struct {
	Type               string      `json:"type"`
	Status             string      `json:"status"`
	Message            string      `json:"message"`
	Reason             string      `json:"reason"`
	LastTransitionTime metav1.Time `json:"lastTransitionTime,omitempty"`
	LastUpdateTime     metav1.Time `json:"lastUpdateTime,omitempty"`
}

type VpDeploymentRunningStatus struct {
	// +optional
	Conditions []VpDeploymentRunningCondition `json:"conditions,omitempty"`
	JobID      string                         `json:"jobId"`
	// +optional
	TransitionTime metav1.Time `json:"transitionTime,omitempty"`
}

type VpDeploymentSpec struct {
	State VpDeploymentState `json:"state"`

	UpgradeStrategy *VpDeploymentUpgradeStrategy `json:"upgradeStrategy"`
	// +optional
	RestoreStrategy *VpDeploymentRestoreStrategy `json:"restoreStrategy,omitempty"`
	// +optional
	DeploymentTargetID string `json:"deploymentTargetId,omitempty"`
	// +optional
	MaxSavepointCreationAttempts *int32 `json:"maxSavepointCreationAttempts,omitempty"`
	// +optional
	MaxJobCreationAttempts *int32 `json:"maxJobCreationAttempts,omitempty"`

	Template *VpDeploymentTemplate `json:"template"`
}

type VpDeploymentState string

type VpDeploymentStatus struct {

	// +optional
	State VpDeploymentState `json:"state,omitempty"`

	// see: https://docs.ververica.com/user_guide/deployments/index.html#running
	// +optional
	Running *VpDeploymentRunningStatus `json:"running,omitempty"`
}

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

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

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

type VpDeploymentTargetObjectSpec struct {

	// +optional
	Metadata VpMetadata `json:"metadata,omitempty"`
	// +optional
	Spec VpDeploymentTargetSpec `json:"spec,omitempty"`
}

type VpDeploymentTargetSpec struct {
	Kubernetes VpKubernetesTarget `json:"kubernetes"`
}

type VpDeploymentTemplate struct {
	// +optional
	Metadata *VpDeploymentTemplateMetadata `json:"metadata,omitempty"`

	Spec *VpDeploymentTemplateSpec `json:"spec"`
}

type VpDeploymentTemplateMetadata struct {
	// +optional
	Annotations map[string]string `json:"annotations,omitempty"`
}

type VpDeploymentTemplateSpec struct {
	Artifact *VpArtifact `json:"artifact"`
	// +optional
	// +kubebuilder:validation:Minimum=1
	Parallelism *int32 `json:"parallelism,omitempty"`
	// +optional
	// +kubebuilder:validation:Minimum=1
	NumberOfTaskManagers *int32 `json:"numberOfTaskManagers,omitempty"`
	// +optional
	Resources map[string]VpResourceSpec `json:"resources,omitempty"`
	// +optional
	FlinkConfiguration map[string]string `json:"flinkConfiguration,omitempty"`
	// +optional
	Logging *VpLogging `json:"logging,omitempty"`
	// +optional
	Kubernetes *VpKubernetesOptions `json:"kubernetes,omitempty"`
}

type VpDeploymentUpgradeStrategy struct {
	// +optional
	Kind string `json:"kind,omitempty"`
}

type VpKubernetesOptions struct {
	Pods *VpPodSpec `json:"pods,omitempty"`
}

type VpKubernetesTarget struct {
	// +optional
	Namespace string `json:"namespace,omitempty"`
}

type VpLogging struct {
	// +optional
	Log4jLoggers map[string]string `json:"log4jLoggers,omitempty"`
}

type VpMetadata struct {
	// +optional
	Namespace string `json:"namespace,omitempty"`
	// +optional
	Labels map[string]string `json:"labels,omitempty"`
	// +optional
	Annotations map[string]string `json:"annotations,omitempty"`
}

type VpPodSpec struct {
	// +optional
	Annotations map[string]string `json:"annotations,omitempty"`
	// List of environment variables to set in the container.
	// Cannot be updated.
	// +optional
	// +patchMergeKey=name
	// +patchStrategy=merge
	EnvVars []core.EnvVar `json:"envVars,omitempty" patchStrategy:"merge" patchMergeKey:"name"`

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

	// +optional
	VolumeMounts []VpVolumeAndMount `json:"volumeMounts,omitempty"`

	// NodeSelector is a selector which must be true for the pod to fit on a node.
	// Selector which must match a node's labels for the pod to be scheduled on that node.
	// More info: https://kubernetes.io/docs/concepts/configuration/assign-pod-node/
	// +optional
	NodeSelector map[string]string `json:"nodeSelector,omitempty" protobuf:"bytes,7,rep,name=nodeSelector"`
	// SecurityContext holds pod-level security attributes and common container settings.
	// Optional: Defaults to empty.  See type description for default values of each field.
	// +optional
	SecurityContext *core.PodSecurityContext `json:"securityContext,omitempty" protobuf:"bytes,14,opt,name=securityContext"`
	// 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.
	// If specified, these secrets will be passed to individual puller implementations for them to use. For example,
	// in the case of docker, only DockerConfig type secrets are honored.
	// More info: https://kubernetes.io/docs/concepts/containers/images#specifying-imagepullsecrets-on-a-pod
	// +optional
	// +patchMergeKey=name
	// +patchStrategy=merge
	ImagePullSecrets []core.LocalObjectReference `json:"imagePullSecrets,omitempty" patchStrategy:"merge" patchMergeKey:"name" protobuf:"bytes,15,rep,name=imagePullSecrets"`
	// If specified, the pod's scheduling constraints
	// +optional
	Affinity *core.Affinity `json:"affinity,omitempty" protobuf:"bytes,18,opt,name=affinity"`
	// If specified, the pod's tolerations.
	// +optional
	Tolerations []core.Toleration `json:"tolerations,omitempty" protobuf:"bytes,22,opt,name=tolerations"`
}

type VpResourceSpec struct {
	// +optional
	CPU resource.Quantity `json:"cpu,omitempty"`
	// +optional
	// +kubebuilder:validation:minLength=2
	Memory *string `json:"memory,omitempty"`
}

type VpVolumeAndMount struct {
	Name        string            `json:"name"`
	Volume      *core.Volume      `json:"volume"`
	VolumeMount *core.VolumeMount `json:"volumeMount"`
}