dataprocess

type DataProcessInfo struct {
	TargetDataset string `json:"targetDataset,omitempty"`

	ServiceAccountName string `json:"serviceAccountName,omitempty"`

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

	Annotations map[string]string `json:"annotations,omitempty"`

	JobProcessor *JobProcessor `json:"jobProcessor,omitempty"`

	ScriptProcessor *ScriptProcessor `json:"scriptProcessor,omitempty"`
}

type DataProcessValue struct {
	Name string `json:"name"`

	Owner *common.OwnerReference `json:"owner,omitempty"`

	DataProcessInfo DataProcessInfo `json:"dataProcess"`
}

type JobProcessor struct {
	PodSpec *corev1.PodSpec `json:"podSpec,omitempty"`
}

type JobProcessorImpl struct {
	*datav1alpha1.JobProcessor
}

type Processor interface {
	ValidateDatasetMountPath(datasetMountPath string) (pass bool, conflictVolName string, conflictContainerName string)

	TransformDataProcessValues(value *DataProcessValue, datasetVolumes []corev1.Volume, datasetVolumeMounts []corev1.VolumeMount)
}

type ScriptProcessor struct {
	Image string `json:"image,omitempty"`

	ImagePullPolicy corev1.PullPolicy `json:"imagePullPolicy,omitempty"`

	RestartPolicy corev1.RestartPolicy `json:"restartPolicy,omitempty"`

	Command []string `json:"command,omitempty"`

	Source string `json:"source,omitempty"`

	Envs []corev1.EnvVar `json:"envs,omitempty"`

	Volumes []corev1.Volume `json:"volumes,omitempty"`

	VolumeMounts []corev1.VolumeMount `json:"volumeMounts,omitempty"`

	Resources corev1.ResourceRequirements `json:"resources,omitempty"`

	Affinity *corev1.Affinity `json:"affinity,omitempty"`
}

type ScriptProcessorImpl struct {
	*datav1alpha1.ScriptProcessor
}