mon

Documentation

Overview

Copyright 2016 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.

Copyright 2016 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.

Copyright 2016 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.

Copyright 2016 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.

Copyright 2016 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.

Copyright 2016 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.

Index

• Constants
• func ConnectToCluster(context *clusterd.Context, factory client.ConnectionFactory, ...) (client.Connection, error)
• func ConnectToClusterAsAdmin(context *clusterd.Context, factory client.ConnectionFactory, ...) (client.Connection, error)
• func CreateDefaultCephConfig(cluster *ClusterInfo, runDir string, logLevel capnslog.LogLevel, ...) *cephConfig
• func CreateKeyring(conn client.Connection, username, keyringPath string, access []string, ...) error
• func GenerateConfigFile(context *clusterd.Context, cluster *ClusterInfo, ...) (string, error)
• func GenerateConnectionConfigFile(context *clusterd.Context, cluster *ClusterInfo, ...) (string, error)
• func GenerateTempConfigFiles(context *clusterd.Context, cluster *ClusterInfo) (string, string, string, error)
• func GetClusterName(etcdClient etcd.KeysAPI) (string, error)
• func GetConfFilePath(root, clusterName string) string
• func GetDesiredMonitors(etcdClient etcd.KeysAPI) (map[string]*CephMonitorConfig, error)
• func NewAgent(factory client.ConnectionFactory) clusterd.ServiceAgent
• type CephMonitorConfig
• type ClusterInfo
  • func CreateClusterInfo(factory client.ConnectionFactory, adminSecret string) (*ClusterInfo, error)
  • func LoadClusterInfo(etcdClient etcd.KeysAPI) (*ClusterInfo, error)
• type ConnectionFactory
  • func NewConnectionFactory() ConnectionFactory
• type GlobalConfig
• type Leader
  • func NewLeader() *Leader
  • func (m *Leader) Configure(context *clusterd.Context, factory client.ConnectionFactory, ...) error

Constants

const (
	CephKey = "/rook/services/ceph"
)

const (
	UnhealthyHeartbeatAgeSeconds = 10
)

Functions

func ConnectToCluster

func ConnectToCluster(context *clusterd.Context, factory client.ConnectionFactory, cluster *ClusterInfo,
	basePath, user, keyringPath string) (client.Connection, error)

opens a connection to the cluster that can be used for management operations

func ConnectToClusterAsAdmin

func ConnectToClusterAsAdmin(context *clusterd.Context, factory client.ConnectionFactory, cluster *ClusterInfo) (client.Connection, error)

func CreateDefaultCephConfig

func CreateDefaultCephConfig(cluster *ClusterInfo, runDir string, logLevel capnslog.LogLevel, bluestore bool) *cephConfig

func CreateKeyring

func CreateKeyring(conn client.Connection, username, keyringPath string, access []string, generateKeyring func(string) string) error

create a keyring for access to the cluster, with the desired set of privileges

func GenerateConfigFile

func GenerateConfigFile(context *clusterd.Context, cluster *ClusterInfo, pathRoot, user, keyringPath string,
	bluestore bool, userConfig *cephConfig, clientSettings map[string]string) (string, error)

generates and writes the monitor config file to disk

func GenerateConnectionConfigFile

func GenerateConnectionConfigFile(context *clusterd.Context, cluster *ClusterInfo, pathRoot, user, keyringPath string) (string, error)

generates and writes the monitor config file to disk

func GenerateTempConfigFiles

func GenerateTempConfigFiles(context *clusterd.Context, cluster *ClusterInfo) (string, string, string, error)

func GetClusterName

func GetClusterName(etcdClient etcd.KeysAPI) (string, error)

func GetConfFilePath

func GetConfFilePath(root, clusterName string) string

get the path of a given monitor's config file

func GetDesiredMonitors

func GetDesiredMonitors(etcdClient etcd.KeysAPI) (map[string]*CephMonitorConfig, error)

func NewAgent

func NewAgent(factory client.ConnectionFactory) clusterd.ServiceAgent

Types

type CephMonitorConfig

type CephMonitorConfig struct {
	Name     string `json:"name"`
	Endpoint string `json:"endpoint"`
}

type ClusterInfo

type ClusterInfo struct {
	FSID          string
	MonitorSecret string
	AdminSecret   string
	Name          string
	Monitors      map[string]*CephMonitorConfig
}

func CreateClusterInfo

func CreateClusterInfo(factory client.ConnectionFactory, adminSecret string) (*ClusterInfo, error)

create new cluster info (FSID, shared keys)

func LoadClusterInfo

func LoadClusterInfo(etcdClient etcd.KeysAPI) (*ClusterInfo, error)

attempt to load any previously created and saved cluster info

type ConnectionFactory

type ConnectionFactory interface {
	ConnectAsAdmin(context *clusterd.Context, cephFactory client.ConnectionFactory) (client.Connection, error)
}

func NewConnectionFactory

func NewConnectionFactory() ConnectionFactory

type GlobalConfig

type GlobalConfig struct {
	EnableExperimental       string `ini:"enable experimental unrecoverable data corrupting features"`
	FSID                     string `ini:"fsid,omitempty"`
	RunDir                   string `ini:"run dir,omitempty"`
	MonMembers               string `ini:"mon initial members,omitempty"`
	LogFile                  string `ini:"log file,omitempty"`
	MonClusterLogFile        string `ini:"mon cluster log file,omitempty"`
	MonKeyValueDb            string `ini:"mon keyvaluedb"`
	DebugLogDefaultLevel     int    `ini:"debug default"`
	DebugLogRadosLevel       int    `ini:"debug rados"`
	DebugLogMonLevel         int    `ini:"debug mon"`
	DebugLogOSDLevel         int    `ini:"debug osd"`
	DebugLogBluestoreLevel   int    `ini:"debug bluestore"`
	DebugLogFilestoreLevel   int    `ini:"debug filestore"`
	DebugLogJournalLevel     int    `ini:"debug journal"`
	DebugLogLevelDBLevel     int    `ini:"debug leveldb"`
	FileStoreOmapBackend     string `ini:"filestore_omap_backend"`
	OsdPgBits                int    `ini:"osd pg bits,omitempty"`
	OsdPgpBits               int    `ini:"osd pgp bits,omitempty"`
	OsdPoolDefaultSize       int    `ini:"osd pool default size,omitempty"`
	OsdPoolDefaultMinSize    int    `ini:"osd pool default min size,omitempty"`
	OsdPoolDefaultPgNum      int    `ini:"osd pool default pg num,omitempty"`
	OsdPoolDefaultPgpNum     int    `ini:"osd pool default pgp num,omitempty"`
	OsdMaxObjectNameLen      int    `ini:"osd max object name len,omitempty"`
	OsdMaxObjectNamespaceLen int    `ini:"osd max object namespace len,omitempty"`
	OsdObjectStore           string `ini:"osd objectstore"`
	RbdDefaultFeatures       int    `ini:"rbd_default_features,omitempty"`
	CrushtoolPath            string `ini:"crushtool"`
}

type Leader

type Leader struct {
	// contains filtered or unexported fields
}

func NewLeader

func NewLeader() *Leader

func (*Leader) Configure

func (m *Leader) Configure(context *clusterd.Context, factory client.ConnectionFactory, adminSecret string) error

Apply the desired state to the cluster. The context provides all the information needed to make changes to the service. Create the ceph monitors Must be idempotent