in pkg/controller/broker/broker_controller.go [571:596]
func getVolumes(broker *rocketmqv1alpha1.Broker) []corev1.Volume {
switch broker.Spec.StorageMode {
case cons.StorageModeStorageClass:
return broker.Spec.Volumes
case cons.StorageModeEmptyDir:
volumes := broker.Spec.Volumes
volumes = append(volumes, corev1.Volume{
Name: broker.Spec.VolumeClaimTemplates[0].Name,
VolumeSource: corev1.VolumeSource{
EmptyDir: &corev1.EmptyDirVolumeSource{}},
})
return volumes
case cons.StorageModeHostPath:
fallthrough
default:
volumes := broker.Spec.Volumes
volumes = append(volumes, corev1.Volume{
Name: broker.Spec.VolumeClaimTemplates[0].Name,
VolumeSource: corev1.VolumeSource{
HostPath: &corev1.HostPathVolumeSource{
Path: broker.Spec.HostPath,
}},
})
return volumes
}
}