mgr

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.

Index

• Constants
• func CreateKeyring(context *clusterd.Context, clusterName, name string) (string, error)
• func EnableCephMgr(etcdClient etcd.KeysAPI) error
• func NewAgent() *agent
• func RemoveObjectStore(etcdClient etcd.KeysAPI) error
• func Run(context *clusterd.Context, config *Config) error
• type Config
• type Leader
  • func NewLeader() *Leader
  • func (r *Leader) Configure(context *clusterd.Context) error

Constants

const (
	MgrKey = "cephmgr"
)

Functions

func CreateKeyring

func CreateKeyring(context *clusterd.Context, clusterName, name string) (string, error)

create a keyring for the mds client with a limited set of privileges

func EnableCephMgr

func EnableCephMgr(etcdClient etcd.KeysAPI) error

Configure a single instance of the cephmgr in the cluster.

func NewAgent

func NewAgent() *agent

func RemoveObjectStore

func RemoveObjectStore(etcdClient etcd.KeysAPI) error

Remove the single instance of the cephmgr from the cluster.

func Run

func Run(context *clusterd.Context, config *Config) error

Types

type Config

type Config struct {
	InProc      bool
	ClusterInfo *mon.ClusterInfo
	Name        string
	Keyring     string
}

type Leader

type Leader struct {
}

func NewLeader

func NewLeader() *Leader

func (*Leader) Configure

func (r *Leader) Configure(context *clusterd.Context) error

Apply the desired state to the cluster. The context provides all the information needed to make changes to the service. Initialize CephMGR. Must be idempotent.