diff --git a/pkg/cluster/actions.go b/pkg/cluster/actions.go
index 860b074b1..fff29bee7 100644
--- a/pkg/cluster/actions.go
+++ b/pkg/cluster/actions.go
@@ -1,18 +1,15 @@
 package cluster
 
 import (
-	"crypto/md5"
 	"fmt"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 	"k8s.io/apimachinery/pkg/types"
 	"k8s.io/client-go/pkg/api/v1"
-
-	"github.com/zalando-incubator/postgres-operator/pkg/spec"
 )
 
 var NoActions []Action = []Action{}
 
-type ActionHash = [16]byte
+type ActionHash [16]byte
 
 var orphanDependents bool = true
 
@@ -20,50 +17,39 @@ var deleteOptions *metav1.DeleteOptions = &metav1.DeleteOptions{
 	OrphanDependents: &orphanDependents,
 }
 
-type SyncSecretsData struct {
-	secrets map[string]*v1.Secret
+type CreateService struct {
+	ActionService
 }
 
-type ServiceData struct {
+type UpdateService struct {
+	ActionService
+}
+
+type DeleteService struct {
+	ActionService
+}
+
+type MetaData struct {
+	cluster   *Cluster
+	namespace string
+}
+
+type ActionService struct {
+	meta    MetaData
 	name    string
 	role    PostgresRole
 	service *v1.Service
 }
 
-type SyncVolumesData struct {
-	volumeSpec spec.Volume
-}
-
-type ActionData struct {
-	cluster   *Cluster
-	namespace string
-}
-
-type CreateService struct {
-	common  ActionData
-	service ServiceData
-}
-
-type UpdateService struct {
-	common  ActionData
-	service ServiceData
-}
-
-type DeleteService struct {
-	common  ActionData
-	service ServiceData
-}
-
 type Action interface {
 	Process() error
 	Name() string
-	Hash() ActionHash
-	GetCommon() ActionData
+	GetMeta() MetaData
 	SetCluster(*Cluster)
 }
 
 func CheckAction(action Action) error {
-	if action.GetCommon().cluster == nil {
+	if action.GetMeta().cluster == nil {
 		return fmt.Errorf("no valid cluster for %v", action)
 	}
 
@@ -79,34 +65,30 @@ func (action UpdateService) Process() error {
 	if err := CheckAction(action); err != nil {
 		return err
 	}
-	common := action.GetCommon()
-	service := action.service.service
+	meta := action.GetMeta()
+	service := action.service
 
 	if len(service.ObjectMeta.Annotations) > 0 {
 		patchData, err = servicePatchData(service.Spec, service.ObjectMeta.Annotations)
 		if err != nil {
 			msg := "could not prepare patch data with annotations for service %q: %v"
-			return fmt.Errorf(msg, action.service.name, err)
+			return fmt.Errorf(msg, action.name, err)
 		}
 	} else {
 		patchData, err = specPatch(service.Spec)
 		if err != nil {
 			msg := "could not prepare patch data for service %q: %v"
-			return fmt.Errorf(msg, action.service.name, err)
+			return fmt.Errorf(msg, action.name, err)
 		}
 	}
 
-	if updatedService, err = common.cluster.KubeClient.
-		Services(common.namespace).
-		Patch(
-			action.service.name,
-			types.MergePatchType,
-			patchData,
-			""); err != nil {
+	if updatedService, err = meta.cluster.KubeClient.
+		Services(meta.namespace).
+		Patch(action.name, types.MergePatchType, patchData, ""); err != nil {
 		return err
 	}
 
-	common.cluster.Services[action.service.role] = updatedService
+	meta.cluster.Services[action.role] = updatedService
 	return nil
 }
 
@@ -119,15 +101,15 @@ func (action CreateService) Process() error {
 	if err := CheckAction(action); err != nil {
 		return err
 	}
-	common := action.GetCommon()
+	meta := action.GetMeta()
 
-	if newService, err = common.cluster.KubeClient.
-		Services(common.namespace).
-		Create(action.service.service); err != nil {
+	if newService, err = meta.cluster.KubeClient.
+		Services(meta.namespace).
+		Create(action.service); err != nil {
 		return err
 	}
 
-	common.cluster.Services[action.service.role] = newService
+	meta.cluster.Services[action.role] = newService
 	return nil
 }
 
@@ -135,56 +117,28 @@ func (action DeleteService) Process() error {
 	if err := CheckAction(action); err != nil {
 		return err
 	}
-	common := action.GetCommon()
+	meta := action.GetMeta()
 
-	if err := common.cluster.KubeClient.
-		Services(common.namespace).
-		Delete(action.service.name, deleteOptions); err != nil {
+	if err := meta.cluster.KubeClient.
+		Services(meta.namespace).
+		Delete(action.name, deleteOptions); err != nil {
 		return err
 	}
 
-	common.cluster.Services[action.service.role] = nil
+	meta.cluster.Services[action.role] = nil
 	return nil
 }
 
-func (action UpdateService) SetCluster(client *Cluster) {
-	action.common.cluster = client
+func (action ActionService) SetCluster(client *Cluster) {
+	action.meta.cluster = client
 }
 
-func (action CreateService) SetCluster(client *Cluster) {
-	action.common.cluster = client
-}
-
-func (action DeleteService) SetCluster(client *Cluster) {
-	action.common.cluster = client
-}
-
-func (action UpdateService) GetCommon() ActionData {
-	return action.common
-}
-
-func (action CreateService) GetCommon() ActionData {
-	return action.common
-}
-
-func (action DeleteService) GetCommon() ActionData {
-	return action.common
-}
-
-func (action UpdateService) Hash() ActionHash {
-	return md5.Sum([]byte("update" + action.service.name))
-}
-
-func (action CreateService) Hash() ActionHash {
-	return md5.Sum([]byte("create" + action.service.name))
-}
-
-func (action DeleteService) Hash() ActionHash {
-	return md5.Sum([]byte("delete" + action.service.name))
+func (action ActionService) GetMeta() MetaData {
+	return action.meta
 }
 
 func (action UpdateService) Name() string {
-	return fmt.Sprintf("Update service %s", action.service.name)
+	return fmt.Sprintf("Update service %s", action.name)
 }
 
 func (action CreateService) Name() string {
@@ -192,5 +146,5 @@ func (action CreateService) Name() string {
 }
 
 func (action DeleteService) Name() string {
-	return fmt.Sprintf("Delete service %s", action.service.name)
+	return fmt.Sprintf("Delete service %s", action.name)
 }
diff --git a/pkg/cluster/resources.go b/pkg/cluster/resources.go
index 9c814f4a8..f44b40986 100644
--- a/pkg/cluster/resources.go
+++ b/pkg/cluster/resources.go
@@ -340,10 +340,10 @@ func (c *Cluster) createService(role PostgresRole) ([]Action, error) {
 	serviceSpec := c.generateService(role, &c.Spec)
 	return []Action{
 		CreateService{
-			ActionData{
-				namespace: serviceSpec.Namespace,
-			},
-			ServiceData{
+			ActionService{
+				meta: MetaData{
+					namespace: serviceSpec.Namespace,
+				},
 				service: serviceSpec,
 			},
 		},
@@ -390,20 +390,20 @@ func (c *Cluster) updateService(role PostgresRole, newService *v1.Service) ([]Ac
 
 		return []Action{
 			DeleteService{
-				ActionData{
-					namespace: serviceName.Namespace,
-				},
-				ServiceData{
+				ActionService{
+					meta: MetaData{
+						namespace: serviceName.Namespace,
+					},
 					name:    serviceName.Name,
 					role:    role,
 					service: newService,
 				},
 			},
 			CreateService{
-				ActionData{
-					namespace: serviceName.Namespace,
-				},
-				ServiceData{
+				ActionService{
+					meta: MetaData{
+						namespace: serviceName.Namespace,
+					},
 					name:    serviceName.Name,
 					role:    role,
 					service: newService,
@@ -414,10 +414,10 @@ func (c *Cluster) updateService(role PostgresRole, newService *v1.Service) ([]Ac
 
 	return []Action{
 		UpdateService{
-			ActionData{
-				namespace: serviceName.Namespace,
-			},
-			ServiceData{
+			ActionService{
+				meta: MetaData{
+					namespace: serviceName.Namespace,
+				},
 				name:    serviceName.Name,
 				service: newService,
 			},
@@ -430,10 +430,10 @@ func (c *Cluster) deleteService(role PostgresRole) ([]Action, error) {
 
 	return []Action{
 		DeleteService{
-			ActionData{
-				namespace: service.Namespace,
-			},
-			ServiceData{
+			ActionService{
+				meta: MetaData{
+					namespace: service.Namespace,
+				},
 				name: service.Name,
 			},
 		},
diff --git a/pkg/cluster/sync.go b/pkg/cluster/sync.go
index 452606b2b..243f39548 100644
--- a/pkg/cluster/sync.go
+++ b/pkg/cluster/sync.go
@@ -117,17 +117,7 @@ func (c *Cluster) syncServices() (actions []Action, err error) {
 }
 
 func (c *Cluster) applyActions(actions []Action) (err error) {
-	uniqueActions := NoActions
-	hashMap := map[ActionHash]bool{}
 	for _, action := range actions {
-		if _, present := hashMap[action.Hash()]; !present {
-			hashMap[action.Hash()] = true
-			action.SetCluster(c)
-			uniqueActions = append(uniqueActions, action)
-		}
-	}
-
-	for _, action := range uniqueActions {
 		c.logger.Infof("Applying action %s", action.Name())
 	}
 
@@ -135,7 +125,7 @@ func (c *Cluster) applyActions(actions []Action) (err error) {
 		return nil
 	}
 
-	for _, action := range uniqueActions {
+	for _, action := range actions {
 		if err := action.Process(); err != nil {
 			c.logger.Errorf("Can't apply action %s: %v", action.Name(), err)
 		}