in pkg/controller/controller/dledger_controller.go [356:380]
func getVolumes(controller *rocketmqv1alpha1.Controller) []corev1.Volume {
switch controller.Spec.StorageMode {
case cons.StorageModeStorageClass:
return nil
case cons.StorageModeEmptyDir:
volumes := []corev1.Volume{{
Name: controller.Spec.VolumeClaimTemplates[0].Name,
VolumeSource: corev1.VolumeSource{
EmptyDir: &corev1.EmptyDirVolumeSource{}},
}}
return volumes
case cons.StorageModeHostPath:
fallthrough
default:
volumes := []corev1.Volume{{
Name: controller.Spec.VolumeClaimTemplates[0].Name,
VolumeSource: corev1.VolumeSource{
HostPath: &corev1.HostPathVolumeSource{
Path: controller.Spec.HostPath,
}},
}}
return volumes
}
}