Versions in this module Expand all Collapse all v0 v0.4.0 May 3, 2017 Changes in this version + const Bluestore + const DBDefaultSizeMB + const DefaultStore + const Filestore + const JournalDefaultSizeMB + const UseRemainingSpace + const WalDefaultSizeMB + func PopulateCollocatedPerfSchemeEntry(entry *PerfSchemeEntry, device string, storeConfig StoreConfig) error + func PopulateDistributedPerfSchemeEntry(entry *PerfSchemeEntry, device string, metadataInfo *MetadataDeviceInfo, ...) 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 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 v0.3.1 Mar 28, 2017 v0.3.0 Mar 3, 2017 Changes in this version + func Run(dcontext *clusterd.DaemonContext, agent *OsdAgent) error + type DeviceOsdIDEntry struct + Data int + Metadata []int + type DeviceOsdMapping struct + Entries map[string]*DeviceOsdIDEntry + func NewDeviceOsdMapping() *DeviceOsdMapping + type OsdAgent struct + 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 v0.2.2 Dec 19, 2016 v0.2.1 Dec 12, 2016 v0.2.0 Dec 8, 2016 v0.1.1 Dec 5, 2016 Changes in this version + const DevicesValue + const ForceFormatValue + func AddDesiredDevice(etcdClient etcd.KeysAPI, device, nodeID string) error + func AddDesiredDir(etcdClient etcd.KeysAPI, dir, nodeID string) error + func GetAppliedOSDs(nodeID string, etcdClient etcd.KeysAPI) (map[int]string, error) + func GetCrushMap(adminConn client.Connection) (string, error) + func NewAgent(factory client.ConnectionFactory, devices string, forceFormat bool, ...) *osdAgent + func RemoveDesiredDevice(etcdClient etcd.KeysAPI, device, nodeID string) error + type Device struct + Dir bool + Name string + NodeID string + type Leader struct + func NewLeader() *Leader + func (l *Leader) Configure(context *clusterd.Context, nodes []string) error
Go to main page