/
ceph.go
101 lines (86 loc) · 3.75 KB
/
ceph.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
/*
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 ceph
import (
"github.com/coreos/pkg/capnslog"
"github.com/spf13/cobra"
"github.com/rook/rook/cmd/rook/rook"
"github.com/rook/rook/pkg/clusterd"
cephconfig "github.com/rook/rook/pkg/daemon/ceph/config"
osdconfig "github.com/rook/rook/pkg/operator/ceph/cluster/osd/config"
"github.com/rook/rook/pkg/util/flags"
)
// Cmd is the main command for operator and daemons.
var Cmd = &cobra.Command{
Use: "ceph",
Short: "Main command for Ceph operator and daemons.",
}
var (
cfg = &config{}
clusterInfo cephconfig.ClusterInfo
logger = capnslog.NewPackageLogger("github.com/rook/rook", "cephcmd")
)
type config struct {
devices string
directories string
metadataDevice string
dataDir string
forceFormat bool
location string
cephConfigOverride string
storeConfig osdconfig.StoreConfig
networkInfo clusterd.NetworkInfo
monEndpoints string
nodeName string
pvcBacked bool
}
func init() {
Cmd.AddCommand(operatorCmd,
agentCmd,
osdCmd,
configCmd)
}
func createContext() *clusterd.Context {
context := rook.NewContext()
context.ConfigDir = cfg.dataDir
context.ConfigFileOverride = cfg.cephConfigOverride
context.NetworkInfo = cfg.NetworkInfo()
return context
}
func addCephFlags(command *cobra.Command) {
command.Flags().StringVar(&cfg.networkInfo.PublicAddr, "public-ip", "", "public IP address for this machine")
command.Flags().StringVar(&cfg.networkInfo.ClusterAddr, "private-ip", "", "private IP address for this machine")
command.Flags().StringVar(&clusterInfo.Name, "cluster-name", "rookcluster", "ceph cluster name")
command.Flags().StringVar(&clusterInfo.FSID, "fsid", "", "the cluster uuid")
command.Flags().StringVar(&clusterInfo.MonitorSecret, "mon-secret", "", "the cephx keyring for monitors")
command.Flags().StringVar(&clusterInfo.AdminSecret, "admin-secret", "", "secret for the admin user (random if not specified)")
command.Flags().StringVar(&cfg.monEndpoints, "mon-endpoints", "", "ceph mon endpoints")
command.Flags().StringVar(&cfg.dataDir, "config-dir", "/var/lib/rook", "directory for storing configuration")
command.Flags().StringVar(&cfg.cephConfigOverride, "ceph-config-override", "", "optional path to a ceph config file that will be appended to the config files that rook generates")
// deprecated ipv4 format address
// TODO: remove these legacy flags in the future
command.Flags().StringVar(&cfg.networkInfo.PublicAddrIPv4, "public-ipv4", "", "public IPv4 address for this machine")
command.Flags().StringVar(&cfg.networkInfo.ClusterAddrIPv4, "private-ipv4", "", "private IPv4 address for this machine")
command.Flags().MarkDeprecated("public-ipv4", "Use --public-ip instead. Will be removed in a future version.")
command.Flags().MarkDeprecated("private-ipv4", "Use --private-ip instead. Will be removed in a future version.")
}
func verifyRenamedFlags(cmd *cobra.Command) error {
renamed := []flags.RenamedFlag{
{NewFlagName: "public-ip", OldFlagName: "public-ipv4"},
{NewFlagName: "private-ip", OldFlagName: "private-ipv4"},
}
return flags.VerifyRenamedFlags(cmd, renamed)
}
func (c *config) NetworkInfo() clusterd.NetworkInfo {
return c.networkInfo.Simplify()
}