osd

package
v0.0.0-...-1ea1cc7 Latest Latest
Warning

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

Go to latest
Published: May 15, 2019 License: Apache-2.0 Imports: 26 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CopyBinariesForDaemon

func CopyBinariesForDaemon(target string) error

CopyBinariesForDaemon copies the "tini" and "rook" binaries to a shared volume at the target path. This is necessary for the filestore on a device scenario when rook needs to mount a directory in the same container as the ceph process so it can be unmounted upon exit.

func Provision

func Provision(context *clusterd.Context, agent *OsdAgent) error

func RunFilestoreOnDevice

func RunFilestoreOnDevice(context *clusterd.Context, mountSourcePath, mountPath string, cephArgs []string) error

func StartOSD

func StartOSD(context *clusterd.Context, osdType, osdID, osdUUID string, cephArgs []string) error

StartOSD starts an OSD on a device that was provisioned by ceph-volume

func WriteConfigFile

func WriteConfigFile(context *clusterd.Context, cluster *cephconfig.ClusterInfo, kv *k8sutil.ConfigMapKVStore, osdID int, device bool, storeConfig config.StoreConfig, nodeName, location string) error

Types

type DesiredDevice

type DesiredDevice struct {
	Name          string
	OSDsPerDevice int
	IsFilter      bool
}

DesiredDevice keeps track of the desired settings for a device

type Device

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

type DeviceOsdIDEntry

type DeviceOsdIDEntry struct {
	Data                  int           // OSD ID that has data stored here
	Metadata              []int         // OSD IDs (multiple) that have metadata stored here
	Config                DesiredDevice // Device specific config options
	LegacyPartitionsFound bool          // Whether legacy rook partitions were found
}

type DeviceOsdMapping

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

func (*DeviceOsdMapping) String

func (m *DeviceOsdMapping) String() string

type OsdAgent

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

func NewAgent

func NewAgent(context *clusterd.Context, devices []DesiredDevice, metadataDevice, directories string, forceFormat bool,
	location string, storeConfig config.StoreConfig, cluster *cephconfig.ClusterInfo, nodeName string, kv *k8sutil.ConfigMapKVStore) *OsdAgent

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL