forked from rook/rook
/
sync.go
115 lines (99 loc) · 3.09 KB
/
sync.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
/*
Copyright 2018 The Rook Authors. All rights reserved.
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
*/
package controller
import (
cassandrav1alpha1 "github.com/rook/rook/pkg/apis/cassandra.rook.io/v1alpha1"
"github.com/rook/rook/pkg/operator/cassandra/controller/util"
corev1 "k8s.io/api/core/v1"
)
const (
// SuccessSynced is used as part of the Event 'reason' when a Cluster is
// synced.
SuccessSynced = "Synced"
// ErrSyncFailed is used as part of the Event 'reason' when a
// Cluster fails to sync due to a resource of the same name already
// existing.
ErrSyncFailed = "ErrSyncFailed"
MessageRackCreated = "Rack %s created"
MessageRackScaledUp = "Rack %s scaled up to %d members"
MessageRackScaleDownInProgress = "Rack %s scaling down to %d members"
MessageRackScaledDown = "Rack %s scaled down to %d members"
// Messages to display when experiencing an error.
MessageHeadlessServiceSyncFailed = "Failed to sync Headless Service for cluster"
MessageMemberServicesSyncFailed = "Failed to sync MemberServices for cluster"
MessageUpdateStatusFailed = "Failed to update status for cluster"
MessageCleanupFailed = "Failed to clean up cluster resources"
MessageClusterSyncFailed = "Failed to sync cluster"
)
// Sync attempts to sync the given Cassandra Cluster.
// NOTE: the Cluster Object is a DeepCopy. Modify at will.
func (cc *ClusterController) Sync(c *cassandrav1alpha1.Cluster) error {
// Before syncing, ensure that all StatefulSets are up-to-date
stale, err := util.StatefulSetStatusesStale(c, cc.statefulSetLister)
if err != nil {
return err
}
if stale {
return nil
}
// Cleanup Cluster resources
if err := cc.cleanup(c); err != nil {
cc.recorder.Event(
c,
corev1.EventTypeWarning,
ErrSyncFailed,
MessageCleanupFailed,
)
}
// Sync Headless Service for Cluster
if err := cc.syncClusterHeadlessService(c); err != nil {
cc.recorder.Event(
c,
corev1.EventTypeWarning,
ErrSyncFailed,
MessageHeadlessServiceSyncFailed,
)
return err
}
// Sync Cluster Member Services
if err := cc.syncMemberServices(c); err != nil {
cc.recorder.Event(
c,
corev1.EventTypeWarning,
ErrSyncFailed,
MessageMemberServicesSyncFailed,
)
return err
}
// Update Status
if err := cc.updateStatus(c); err != nil {
cc.recorder.Event(
c,
corev1.EventTypeWarning,
ErrSyncFailed,
MessageUpdateStatusFailed,
)
return err
}
// Sync Cluster
if err := cc.syncCluster(c); err != nil {
cc.recorder.Event(
c,
corev1.EventTypeWarning,
ErrSyncFailed,
MessageClusterSyncFailed,
)
return err
}
return nil
}