Versions in this module Expand all Collapse all v0 v0.8.2 Sep 18, 2018 v0.8.1 Aug 1, 2018 v0.8.0 Jul 18, 2018 Changes in this version + const Kubectl + const MultiFsEnv + var RunAllCephCommandsInToolbox = false + func CreateECPoolForApp(context *clusterd.Context, clusterName string, newPool CephStoragePoolDetails, ...) error + func CreateReplicatedPoolForApp(context *clusterd.Context, clusterName string, newPool CephStoragePoolDetails, ...) error + func FinalizeCephCommandArgs(command string, args []string, configDir, clusterName string) (string, []string) + func IsMultiFSEnabled() bool + func MgrDisableModule(context *clusterd.Context, clusterName, name string) error v0.7.1 Mar 9, 2018 v0.7.0 Feb 21, 2018 Changes in this version + const AdminUsername + const CephHealthErr + const CephHealthOK + const CephHealthWarn + const CephTool + const CrushTool + const ImageMinSize + const RBDTool + func AppendAdminConnectionArgs(args []string, configDir, clusterName string) []string + func AuthAdd(context *clusterd.Context, clusterName, name, keyringPath string, ...) error + func AuthDelete(context *clusterd.Context, clusterName, name string) error + func AuthGetKey(context *clusterd.Context, clusterName, name string) (string, error) + func AuthGetOrCreate(context *clusterd.Context, clusterName, name, keyringPath string, ...) error + func AuthGetOrCreateKey(context *clusterd.Context, clusterName, name string, caps []string) (string, error) + func CreateDefaultCrushMap(context *clusterd.Context, clusterName string) (string, error) + func CreateErasureCodeProfile(context *clusterd.Context, clusterName string, ...) error + func CreateFilesystem(context *clusterd.Context, clusterName, name, metadataPool string, ...) error + func CreatePool(context *clusterd.Context, clusterName string, newPool CephStoragePoolDetails) error + func CreatePoolForApp(context *clusterd.Context, clusterName string, newPool CephStoragePoolDetails, ...) error + func CreatePoolWithProfile(context *clusterd.Context, clusterName string, newPoolReq model.Pool, ...) error + func CrushRemove(context *clusterd.Context, clusterName, name string) (string, error) + func CrushReweight(context *clusterd.Context, clusterName string, id int, weight float64) (string, error) + func DeleteErasureCodeProfile(context *clusterd.Context, clusterName string, erasureCodeProfile string) error + func DeleteImage(context *clusterd.Context, clusterName, name, poolName string) error + func DeletePool(context *clusterd.Context, clusterName string, name string) error + func DisableScrubbing(context *clusterd.Context, clusterName string) (string, error) + func EnableScrubbing(context *clusterd.Context, clusterName string) (string, error) + func ExecuteCephCommand(context *clusterd.Context, clusterName string, args []string) ([]byte, error) + func ExecuteCephCommandPlain(context *clusterd.Context, clusterName string, args []string) ([]byte, error) + func ExecuteCephCommandPlainNoOutputFile(context *clusterd.Context, clusterName string, args []string) ([]byte, error) + func ExecuteRBDCommand(context *clusterd.Context, clusterName string, args []string) ([]byte, error) + func ExecuteRBDCommandNoFormat(context *clusterd.Context, clusterName string, args []string) ([]byte, error) + func ExecuteRBDCommandWithTimeout(context *clusterd.Context, clusterName string, args []string) (string, error) + func FailMDS(context *clusterd.Context, clusterName string, gid int) error + func FormatLocation(location, hostName string) ([]string, error) + func GetCrushHostName(context *clusterd.Context, clusterName string, osdID int) (string, error) + func GetErasureCodeProfileForPool(poolName string) string + func GetPoolNamesByID(context *clusterd.Context, clusterName string) (map[int]string, error) + func GetPools(context *clusterd.Context, clusterName string) ([]model.Pool, error) + func HealthToModelHealthStatus(cephHealth string) model.HealthStatus + func IsClusterClean(context *clusterd.Context, clusterName string) error + func ListErasureCodeProfiles(context *clusterd.Context, clusterName string) ([]string, error) + func MapImage(context *clusterd.Context, ...) error + func MarkFilesystemAsDown(context *clusterd.Context, clusterName string, fsName string) error + func MgrEnableModule(context *clusterd.Context, clusterName, name string, force bool) error + func OSDOut(context *clusterd.Context, clusterName string, osdID int) (string, error) + func OSDRemove(context *clusterd.Context, clusterName string, osdID int) (string, error) + func RemoveFilesystem(context *clusterd.Context, clusterName, fsName string) error + func SetCrushMap(context *clusterd.Context, clusterName, compiledMap string) (string, error) + func SetCrushTunables(context *clusterd.Context, clusterName, profile string) (string, error) + func SetPoolProperty(context *clusterd.Context, clusterName, name, propName string, propVal string) error + func StatusPlain(context *clusterd.Context, clusterName string) ([]byte, error) + func UnMapImage(context *clusterd.Context, ...) error + type CephBlockImage struct + Format int + Name string + Size uint64 + func CreateImage(context *clusterd.Context, clusterName, name, poolName string, size uint64) (*CephBlockImage, error) + func ListImages(context *clusterd.Context, clusterName, poolName string) ([]CephBlockImage, error) + type CephErasureCodeProfile struct + CodingChunkCount uint + CrushRoot string + DataChunkCount uint + FailureDomain string + Plugin string + Technique string + func GetErasureCodeProfileDetails(context *clusterd.Context, clusterName, name string) (CephErasureCodeProfile, error) + type CephFilesystem struct + DataPoolIDs []int + DataPools []string + MetadataPool string + MetadataPoolID int + Name string + func ListFilesystems(context *clusterd.Context, clusterName string) ([]CephFilesystem, error) + type CephFilesystemDetails struct + ID int + MDSMap MDSMap + func GetFilesystem(context *clusterd.Context, clusterName string, fsName string) (*CephFilesystemDetails, error) + type CephStatus struct + ElectionEpoch int + FSID string + Health HealthStatus + MgrMap MgrMap + MonMap MonMap + OsdMap struct{ ... } + PgMap PgMap + Quorum []int + QuorumNames []string + func Status(context *clusterd.Context, clusterName string) (CephStatus, error) + type CephStoragePoolDetails struct + CrushRoot string + ErasureCodeProfile string + FailureDomain string + Name string + Number int + Size uint + func GetPoolDetails(context *clusterd.Context, clusterName, name string) (CephStoragePoolDetails, error) + func ModelPoolToCephPool(modelPool model.Pool) CephStoragePoolDetails + type CephStoragePoolStats struct + Pools []struct{ ... } + func GetPoolStats(context *clusterd.Context, clusterName string) (*CephStoragePoolStats, error) + type CephStoragePoolSummary struct + Name string + Number int + func ListPoolSummaries(context *clusterd.Context, clusterName string) ([]CephStoragePoolSummary, error) + type CephUsage struct + Stats struct{ ... } + func Usage(context *clusterd.Context, clusterName string) (*CephUsage, error) + type CheckMessage struct + Severity string + Summary struct{ ... } + type CrushFindResult struct + ID int + IP string + Location struct{ ... } + func FindOSDInCrushMap(context *clusterd.Context, clusterName string, osdID int) (*CrushFindResult, error) + type CrushMap struct + Buckets []struct{ ... } + Devices []struct{ ... } + Rules []struct{ ... } + Tunables struct{} + Types []struct{ ... } + func GetCrushMap(context *clusterd.Context, clusterName string) (CrushMap, error) + type HealthStatus struct + Checks map[string]CheckMessage + Status string + type MDSInfo struct + Address string + GID int + Name string + Rank int + State string + type MDSMap struct + Damaged []int + DataPools []int + Enabled bool + Failed []int + FilesystemName string + In []int + Info map[string]MDSInfo + MaxMDS int + MetadataPool int + Root int + Stopped []int + TableServer int + Up map[string]int + type MgrMap struct + ActiveAddr string + ActiveGID int + ActiveName string + Available bool + Epoch int + Standbys []MgrStandby + type MgrStandby struct + GID int + Name string + type MonMap struct + CreatedTime string + Epoch int + FSID string + ModifiedTime string + Mons []MonMapEntry + type MonMapEntry struct + Address string + Name string + Rank int + type MonStats struct + Health struct{ ... } + Quorum []int + func GetMonStats(context *clusterd.Context, clusterName string) (*MonStats, error) + type MonStatusRequest struct + Args []string + Format string + ID int + Pool string + Prefix string + Var string + Weight float32 + type MonStatusResponse struct + MonMap struct{ ... } + Quorum []int + func GetMonStatus(context *clusterd.Context, clusterName string, debug bool) (MonStatusResponse, error) + type MonTimeSkewStatus struct + Health string + Latency json.Number + Skew json.Number + type MonTimeStatus struct + Checks struct{ ... } + Skew map[string]MonTimeSkewStatus + func GetMonTimeStatus(context *clusterd.Context, clusterName string) (*MonTimeStatus, error) + type OSDDump struct + OSDs []struct{ ... } + func GetOSDDump(context *clusterd.Context, clusterName string) (*OSDDump, error) + func (dump *OSDDump) StatusByID(id int64) (int64, int64, error) + type OSDNodeUsage struct + AvailKB json.Number + CrushWeight json.Number + Depth json.Number + ID int + KB json.Number + Name string + Pgs json.Number + Reweight json.Number + UsedKB json.Number + Utilization json.Number + Variance json.Number + type OSDPerfStats struct + PerfInfo []struct{ ... } + func GetOSDPerfStats(context *clusterd.Context, clusterName string) (*OSDPerfStats, error) + type OSDUsage struct + OSDNodes []OSDNodeUsage + Summary struct{ ... } + func GetOSDUsage(context *clusterd.Context, clusterName string) (*OSDUsage, error) + func (usage *OSDUsage) ByID(osdID int) *OSDNodeUsage + type OsdMap struct + Epoch int + Full bool + NearFull bool + NumInOsd int + NumOsd int + NumRemappedPgs int + NumUpOsd int + type PGDumpBrief struct + ActingOsdIDs []int + ActingPrimaryID int + ID string + State string + UpOsdIDs []int + UpPrimaryID int + func GetPGDumpBrief(context *clusterd.Context, clusterName string) ([]PGDumpBrief, error) + type PgMap struct + AvailableBytes uint64 + CacheEvictBps uint64 + CacheFlushBps uint64 + CachePromoteBps uint64 + DataBytes uint64 + NumPgs int + PgsByState []PgStateEntry + ReadBps uint64 + ReadOps uint64 + RecoveryBps uint64 + RecoveryKeysPerSec uint64 + RecoveryObjectsPerSec uint64 + TotalBytes uint64 + UsedBytes uint64 + Version int + WriteBps uint64 + WriteOps uint64 + type PgStateEntry struct + Count int + StateName string
Go to main page