Versions in this module Expand all Collapse all v0 v0.6.2 Dec 12, 2017 v0.6.1 Dec 4, 2017 v0.6.0 Nov 8, 2017 Changes in this version + type Monitor struct + func NewMonitor(context *clusterd.Context, agent *OsdAgent) *Monitor + func (m *Monitor) Run() type PerfScheme + func (s *PerfScheme) SaveScheme(kv kvstore.KeyValueStore, storeName string) error type PerfSchemeEntry + FSCreated bool v0.5.1 Aug 15, 2017 v0.5.0 Aug 8, 2017 Changes in this version + const Bluestore + const DBDefaultSizeMB + const DefaultStore + const DevicesValue + const Filestore + const ForceFormatValue + const JournalDefaultSizeMB + const UseRemainingSpace + const WalDefaultSizeMB + func AddDesiredDevice(etcdClient etcd.KeysAPI, nodeID, uuid string, osdID int) error + func AddDesiredDir(etcdClient etcd.KeysAPI, dir, nodeID string) error + func GetAppliedOSDs(nodeID string, etcdClient etcd.KeysAPI) (map[int]string, error) + func PopulateCollocatedPerfSchemeEntry(entry *PerfSchemeEntry, device string, storeConfig StoreConfig) error + func PopulateDistributedPerfSchemeEntry(entry *PerfSchemeEntry, device string, metadataInfo *MetadataDeviceInfo, ...) error + func RemoveDesiredDevice(etcdClient etcd.KeysAPI, nodeID, uuid string) error + func Run(context *clusterd.Context, agent *OsdAgent) error + type Device struct + Dir bool + Name string + NodeID string + type DeviceOsdIDEntry struct + Data int + Metadata []int + type DeviceOsdMapping struct + Entries map[string]*DeviceOsdIDEntry + func NewDeviceOsdMapping() *DeviceOsdMapping + type Leader struct + func NewLeader() *Leader + func (l *Leader) Configure(context *clusterd.Context, nodes []string) error + type MetadataDeviceInfo struct + Device string + DiskUUID string + Partitions []*MetadataDevicePartition + func NewMetadataDeviceInfo(device string) *MetadataDeviceInfo + func (m *MetadataDeviceInfo) GetPartitionArgs() []string + type MetadataDevicePartition struct + ID int + OffsetMB int + OsdUUID uuid.UUID + PartitionUUID string + SizeMB int + Type PartitionType + type OsdAgent struct + func NewAgent(devices string, usingDeviceFilter bool, metadataDevice, directories string, ...) *OsdAgent + func (a *OsdAgent) ConfigureLocalService(context *clusterd.Context) error + func (a *OsdAgent) DestroyLocalService(context *clusterd.Context) error + func (a *OsdAgent) Initialize(context *clusterd.Context) error + func (a *OsdAgent) Name() string + type PartitionType int + const BlockPartitionType + const DatabasePartitionType + const FilestoreDataPartitionType + const FilestoreJournalPartitionType + const WalPartitionType + type PerfScheme struct + Entries []*PerfSchemeEntry + Metadata *MetadataDeviceInfo + func LoadScheme(configDir string) (*PerfScheme, error) + func NewPerfScheme() *PerfScheme + func (s *PerfScheme) Save(configDir string) error + type PerfSchemeEntry struct + ID int + OsdUUID uuid.UUID + Partitions map[PartitionType]*PerfSchemePartitionDetails + StoreType string + func NewPerfSchemeEntry(storeType string) *PerfSchemeEntry + func (e *PerfSchemeEntry) GetPartitionArgs() []string + func (e *PerfSchemeEntry) IsCollocated() bool + type PerfSchemePartitionDetails struct + Device string + DiskUUID string + OffsetMB int + PartitionUUID string + SizeMB int + type StoreConfig struct + DatabaseSizeMB int + JournalSizeMB int + StoreType string + WalSizeMB int