/
labels.go
76 lines (66 loc) · 2.75 KB
/
labels.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
/*
Copyright 2020 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 osd
import (
"fmt"
"strconv"
"strings"
"github.com/rook/rook/pkg/operator/ceph/controller"
)
const (
// CephDeviceSetLabelKey is the Rook device set label key
CephDeviceSetLabelKey = "ceph.rook.io/DeviceSet"
// CephSetIndexLabelKey is the Rook label key index
CephSetIndexLabelKey = "ceph.rook.io/setIndex"
// CephDeviceSetPVCIDLabelKey is the Rook PVC ID label key
CephDeviceSetPVCIDLabelKey = "ceph.rook.io/DeviceSetPVCId"
// OSDOverPVCLabelKey is the Rook PVC label key
OSDOverPVCLabelKey = "ceph.rook.io/pvc"
// TopologyLocationLabel is the crush location label added to OSD deployments
TopologyLocationLabel = "topology-location-%s"
)
func makeStorageClassDeviceSetPVCLabel(storageClassDeviceSetName, pvcStorageClassDeviceSetPVCId string, setIndex int) map[string]string {
return map[string]string{
CephDeviceSetLabelKey: storageClassDeviceSetName,
CephSetIndexLabelKey: fmt.Sprintf("%d", setIndex),
CephDeviceSetPVCIDLabelKey: pvcStorageClassDeviceSetPVCId,
}
}
func (c *Cluster) getOSDLabels(osd OSDInfo, failureDomainValue string, portable bool) map[string]string {
stringID := fmt.Sprintf("%d", osd.ID)
labels := controller.CephDaemonAppLabels(AppName, c.clusterInfo.Namespace, "osd", stringID, true)
labels[OsdIdLabelKey] = stringID
labels[FailureDomainKey] = failureDomainValue
labels[portableKey] = strconv.FormatBool(portable)
labels["app.kubernetes.io/name"] = AppName
labels["app.kubernetes.io/instance"] = c.clusterInfo.Namespace + "_osd-" + stringID
labels["app.kubernetes.io/component"] = "ceph-osd"
labels["app.kubernetes.io/part-of"] = "cephclusters.ceph.rook.io_" + c.clusterInfo.Namespace
labels["app.kubernetes.io/managed-by"] = "rook-ceph-operator"
labels["app.kubernetes.io/created-by"] = "rook-ceph-operator"
for k, v := range getOSDTopologyLocationLabels(osd.Location) {
labels[k] = v
}
return labels
}
func getOSDTopologyLocationLabels(topologyLocation string) map[string]string {
labels := map[string]string{}
locations := strings.Split(topologyLocation, " ")
for _, location := range locations {
loc := strings.Split(location, "=")
if len(loc) == 2 {
labels[fmt.Sprintf(TopologyLocationLabel, loc[0])] = loc[1]
}
}
return labels
}