a
/
seaweedfs-operator
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

adjust logs

This commit is contained in:
Chris Lu 2020-10-17 14:07:06 -07:00
parent 95164dc830
commit 4df48f08de
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
controllers/controller_filer.go
View File

@ -70,11 +70,11 @@ func (r *SeaweedReconciler) ensureFilerStatefulSet(seaweedCR *seaweedv1.Seaweed)
} }
func (r *SeaweedReconciler) ensureFilerHeadlessService(seaweedCR *seaweedv1.Seaweed) (bool, ctrl.Result, error) { func (r *SeaweedReconciler) ensureFilerHeadlessService(seaweedCR *seaweedv1.Seaweed) (bool, ctrl.Result, error) {
return r.ensureService(seaweedCR, "-filer-headless", r.createFilerHeadlessService) return r.ensureService(seaweedCR, "filer-headless", r.createFilerHeadlessService)
} }
func (r *SeaweedReconciler) ensureFilerNodePortService(seaweedCR *seaweedv1.Seaweed) (bool, ctrl.Result, error) { func (r *SeaweedReconciler) ensureFilerNodePortService(seaweedCR *seaweedv1.Seaweed) (bool, ctrl.Result, error) {
return r.ensureService(seaweedCR, "-filer", r.createFilerNodePortService) return r.ensureService(seaweedCR, "filer", r.createFilerNodePortService)
} }
func labelsForFiler(name string) map[string]string { func labelsForFiler(name string) map[string]string {
@ -88,7 +88,7 @@ func (r *SeaweedReconciler) ensureService(seaweedCR *seaweedv1.Seaweed, nameSuff
log := r.Log.WithValues("sw", seaweedCR.Name, "service", nameSuffix) log := r.Log.WithValues("sw", seaweedCR.Name, "service", nameSuffix)
aService := &corev1.Service{} aService := &corev1.Service{}
err := r.Get(ctx, types.NamespacedName{Name: seaweedCR.Name + nameSuffix, Namespace: seaweedCR.Namespace}, aService) err := r.Get(ctx, types.NamespacedName{Name: seaweedCR.Name + "-" + nameSuffix, Namespace: seaweedCR.Namespace}, aService)
if err != nil && errors.IsNotFound(err) { if err != nil && errors.IsNotFound(err) {
// Define a new deployment // Define a new deployment
dep := serviceFunc(seaweedCR) dep := serviceFunc(seaweedCR)