mds

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.

Index

• Constants
• func CreateKeyring(conn client.Connection, id string) (string, error)
• func NewAgent(factory client.ConnectionFactory) *mdsAgent
• func RemoveFileSystem(context *clusterd.Context, fsr model.FilesystemRequest) error
• func Run(context *clusterd.DaemonContext, config *Config) error
• type Config
• type FileSystem
  • func NewFS(context *clusterd.Context, factory client.ConnectionFactory, id, pool string) *FileSystem
  • func (f *FileSystem) AddToDesiredState() error
  • func (f *FileSystem) CreateFilesystem(cluster *mon.ClusterInfo) error
  • func (f *FileSystem) DeleteFromDesiredState() error
• type Leader
  • func NewLeader() *Leader
  • func (r *Leader) Configure(context *clusterd.Context, factory client.ConnectionFactory) error

Constants

const (
	FileSystemKey = "fs"
)

const (
	MDSKey = "mds"
)

Functions

func CreateKeyring

func CreateKeyring(conn client.Connection, id string) (string, error)

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

func NewAgent

func NewAgent(factory client.ConnectionFactory) *mdsAgent

func RemoveFileSystem

func RemoveFileSystem(context *clusterd.Context, fsr model.FilesystemRequest) error

Remove the given file system instance in the cluster. Multiple file systems are supported.

func Run

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

Types

type Config

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

type FileSystem

type FileSystem struct {
	ID   string `json:"id"`
	Pool string `json:"pool"`
	// contains filtered or unexported fields
}

A castle file system (an instance of CephFS)

func NewFS

func NewFS(context *clusterd.Context, factory client.ConnectionFactory, id, pool string) *FileSystem

Create a new file service struct

func (*FileSystem) AddToDesiredState

func (f *FileSystem) AddToDesiredState() error

Add the file system to the desired state.

func (*FileSystem) CreateFilesystem

func (f *FileSystem) CreateFilesystem(cluster *mon.ClusterInfo) error

func (*FileSystem) DeleteFromDesiredState

func (f *FileSystem) DeleteFromDesiredState() error

Remove the file system from the desired state.

type Leader

type Leader struct {
}

func NewLeader

func NewLeader() *Leader

func (*Leader) Configure

func (r *Leader) Configure(context *clusterd.Context, factory client.ConnectionFactory) error

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