osd

package
v0.4.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 3, 2017 License: Apache-2.0 Imports: 25 Imported by: 0

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.

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

View Source 
const (
	DevicesValue     = "devices"
	ForceFormatValue = "forceFormat"
)
View Source 
const (
	Filestore         = "filestore"
	Bluestore         = "bluestore"
	DefaultStore      = Filestore
	UseRemainingSpace = -1

	WalDefaultSizeMB     = 576
	DBDefaultSizeMB      = 20480
	JournalDefaultSizeMB = 5120
)

Variables

This section is empty.

Functions

func AddDesiredDevice 

func AddDesiredDevice(etcdClient etcd.KeysAPI, nodeID, uuid string, osdID int) error

add a device to the desired state

func AddDesiredDir 

func AddDesiredDir(etcdClient etcd.KeysAPI, dir, nodeID string) error

add a device to the desired state

func GetAppliedOSDs 

func GetAppliedOSDs(nodeID string, etcdClient etcd.KeysAPI) (map[int]string, error)

For all applied OSDs, gets a mapping of their osd IDs to their data device uuid

func GetCrushMap 

func GetCrushMap(adminConn client.Connection) (string, error)

calls osd getcrushmap

func PopulateCollocatedPerfSchemeEntry added in v0.4.0 

func PopulateCollocatedPerfSchemeEntry(entry *PerfSchemeEntry, device string, storeConfig StoreConfig) error

populates a partition scheme entry for an OSD where all its partitions are collocated on a single device

func PopulateDistributedPerfSchemeEntry added in v0.4.0 

func PopulateDistributedPerfSchemeEntry(entry *PerfSchemeEntry, device string, metadataInfo *MetadataDeviceInfo,
	storeConfig StoreConfig) error

populates a partition scheme entry for an OSD that will have distributed partitions: its metadata will live on a dedicated metadata device and its block data will live on a dedicated device

func RemoveDesiredDevice 

func RemoveDesiredDevice(etcdClient etcd.KeysAPI, nodeID, uuid string) error

remove a device from the desired state

func Run added in v0.3.0 

func Run(dcontext *clusterd.DaemonContext, agent *OsdAgent) error

Types

type Device 

type Device struct {
	Name   string `json:"name"`
	NodeID string `json:"nodeId"`
	Dir    bool   `json:"bool"`
}

type DeviceOsdIDEntry added in v0.3.0 

type DeviceOsdIDEntry struct {
	Data     int   // OSD ID that has data stored here
	Metadata []int // OSD IDs (multiple) that have metadata stored here
}

type DeviceOsdMapping added in v0.3.0 

type DeviceOsdMapping struct {
	Entries map[string]*DeviceOsdIDEntry // device name to OSD ID mapping entry
}

func NewDeviceOsdMapping added in v0.3.0 

func NewDeviceOsdMapping() *DeviceOsdMapping

type Leader 

type Leader struct {
}

func NewLeader 

func NewLeader() *Leader

func (*Leader) Configure 

func (l *Leader) Configure(context *clusterd.Context, nodes []string) error

Apply the desired state to the cluster. The context provides all the information needed to make changes to the service.

type MetadataDeviceInfo added in v0.4.0 

type MetadataDeviceInfo struct {
	Device     string                     `json:"device"`
	DiskUUID   string                     `json:"diskUuid"`
	Partitions []*MetadataDevicePartition `json:"partitions"`
}

represents a dedicated metadata device and all of the partitions stored on it

func NewMetadataDeviceInfo added in v0.4.0 

func NewMetadataDeviceInfo(device string) *MetadataDeviceInfo

func (*MetadataDeviceInfo) GetPartitionArgs added in v0.4.0 

func (m *MetadataDeviceInfo) GetPartitionArgs() []string

type MetadataDevicePartition added in v0.4.0 

type MetadataDevicePartition struct {
	ID            int           `json:"id"`
	OsdUUID       uuid.UUID     `json:"osdUuid"`
	Type          PartitionType `json:"type"`
	PartitionUUID string        `json:"partitionUuid"`
	SizeMB        int           `json:"sizeMB"`
	OffsetMB      int           `json:"offsetMB"`
}

representsa specific partition on a metadata device, including details about which OSD it belongs to

type OsdAgent added in v0.3.0 

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

func NewAgent 

func NewAgent(factory client.ConnectionFactory, devices string, usingDeviceFilter bool, metadataDevice, directories string, forceFormat bool,
	location string, storeConfig StoreConfig, cluster *mon.ClusterInfo) *OsdAgent

func (*OsdAgent) ConfigureLocalService added in v0.3.0 

func (a *OsdAgent) ConfigureLocalService(context *clusterd.Context) error

func (*OsdAgent) DestroyLocalService added in v0.3.0 

func (a *OsdAgent) DestroyLocalService(context *clusterd.Context) error

func (*OsdAgent) Initialize added in v0.3.0 

func (a *OsdAgent) Initialize(context *clusterd.Context) error

set the desired state in etcd

func (*OsdAgent) Name added in v0.3.0 

func (a *OsdAgent) Name() string

type PartitionType added in v0.4.0 

type PartitionType int
const (
	WalPartitionType PartitionType = iota
	DatabasePartitionType
	BlockPartitionType
	FilestoreDataPartitionType
	FilestoreJournalPartitionType
)

type PerfScheme added in v0.4.0 

type PerfScheme struct {
	Metadata *MetadataDeviceInfo `json:"metadata"`
	Entries  []*PerfSchemeEntry  `json:"entries"`
}

top level representation of an overall performance oriented partition scheme, with a dedicated metadata device and entries for all OSDs that define where their partitions live

func LoadScheme added in v0.4.0 

func LoadScheme(configDir string) (*PerfScheme, error)

Load the persistent partition info from the config directory.

func NewPerfScheme added in v0.4.0 

func NewPerfScheme() *PerfScheme

func (*PerfScheme) Save added in v0.4.0 

func (s *PerfScheme) Save(configDir string) error

Save the partition scheme to the config dir

type PerfSchemeEntry added in v0.4.0 

type PerfSchemeEntry struct {
	ID         int                                           `json:"id"`
	OsdUUID    uuid.UUID                                     `json:"osdUuid"`
	Partitions map[PartitionType]*PerfSchemePartitionDetails `json:"partitions"` // mapping of partition name to its details
	StoreType  string                                        `json:"storeType,omitempty"`
}

represents an OSD and details about all of its partitions

func NewPerfSchemeEntry added in v0.4.0 

func NewPerfSchemeEntry(storeType string) *PerfSchemeEntry

func (*PerfSchemeEntry) GetPartitionArgs added in v0.4.0 

func (e *PerfSchemeEntry) GetPartitionArgs() []string

func (*PerfSchemeEntry) IsCollocated added in v0.4.0 

func (e *PerfSchemeEntry) IsCollocated() bool

determines if the given partition scheme entry is for a collocated OSD (all partitions on 1 device)

type PerfSchemePartitionDetails added in v0.4.0 

type PerfSchemePartitionDetails struct {
	Device        string `json:"device"`
	DiskUUID      string `json:"diskUuid"`
	PartitionUUID string `json:"partitionUuid"`
	SizeMB        int    `json:"sizeMB"`
	OffsetMB      int    `json:"offsetMB"`
}

details for 1 OSD partition

type StoreConfig added in v0.4.0 

type StoreConfig struct {
	StoreType      string `json:"storeType,omitempty"`
	WalSizeMB      int    `json:"walSizeMB,omitempty"`
	DatabaseSizeMB int    `json:"databaseSizeMB,omitempty"`
	JournalSizeMB  int    `json:"journalSizeMB,omitempty"`
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.