Documentation ¶
Index ¶
- Variables
- func GetPgStatusBasedCount(status string, clusterId uuid.UUID, pgMap map[string]interface{}) (uint64, error)
- func New() backend.Backend
- type CephApi
- func (c CephApi) AddMon(clusterName string, mons []backend.Mon, ctxt string) (bool, error)
- func (c CephApi) AddOSD(clusterName string, osd backend.OSD, ctxt string) (map[string][]string, error)
- func (c CephApi) AddOsdToCrush(mon string, clusterName string, osdName string, weight float64, host string, ...) (bool, error)
- func (c CephApi) CreateCluster(clusterName string, fsid uuid.UUID, mons []backend.Mon, ctxt string) (bool, error)
- func (c CephApi) CreateCrushNode(mon string, clusterId uuid.UUID, node backend.CrushNodeRequest, ctxt string) (int, error)
- func (c CephApi) CreateCrushRule(mon string, clusterId uuid.UUID, rule backend.CrushRuleRequest, ctxt string) (int, error)
- func (c CephApi) CreateECPool(name string, mon string, clusterName string, pgnum uint, replicas int, ...) (bool, error)
- func (c CephApi) CreatePool(name string, mon string, clusterName string, pgnum uint, replicas int, ...) (bool, error)
- func (c CephApi) EmitRbdEvents(node string, cluster string, ctxt string) error
- func (c CephApi) ExecCmd(mon string, clusterId uuid.UUID, cmd string, ctxt string) (bool, string, error)
- func (c CephApi) GetCluster(mon string, ctxt string) (backend.CephCluster, error)
- func (c CephApi) GetClusterConfig(mon string, clusterId uuid.UUID, ctxt string) (map[string]string, error)
- func (c CephApi) GetClusterNetworks(mon string, clusterId uuid.UUID, ctxt string) (skyringmodels.ClusterNetworks, error)
- func (c CephApi) GetClusterNodes(mon string, clusterId uuid.UUID, ctxt string) ([]backend.CephClusterNode, error)
- func (c CephApi) GetClusterStats(mon string, clusterName string, ctxt string) (backend.ClusterUtilization, error)
- func (c CephApi) GetClusterStatus(mon string, clusterId uuid.UUID, clusterName string, ctxt string) (status string, err error)
- func (c CephApi) GetCrushNode(mon string, clusterId uuid.UUID, crushNodeId int, ctxt string) (backend.CrushNode, error)
- func (c CephApi) GetCrushNodes(mon string, clusterId uuid.UUID, ctxt string) ([]backend.CrushNode, error)
- func (c CephApi) GetCrushRule(mon string, clusterId uuid.UUID, crushRuleId int, ctxt string) (map[string]interface{}, error)
- func (c CephApi) GetCrushRules(mon string, clusterId uuid.UUID, ctxt string) ([]map[string]interface{}, error)
- func (c CephApi) GetJournalDeviceDetails(node string, journalPath string, ctxt string) (backend.DeviceDetail, error)
- func (c CephApi) GetMonStatus(mon string, clusterId uuid.UUID, node string, ctxt string) (backend.MonNodeStatus, error)
- func (c CephApi) GetMonitors(mon string, clusterId uuid.UUID, ctxt string) ([]string, error)
- func (c CephApi) GetOSD(mon string, clusterId uuid.UUID, osdId string, ctxt string) (backend.CephOSD, error)
- func (c CephApi) GetOSDDetails(mon string, clusterName string, ctxt string) (osds []backend.OSDDetails, err error)
- func (c CephApi) GetOSDs(mon string, clusterId uuid.UUID, ctxt string) ([]backend.CephOSD, error)
- func (c CephApi) GetObjectCount(mon string, clusterName string, ctxt string) (map[string]int64, error)
- func (c CephApi) GetPGCount(mon string, clusterId uuid.UUID, ctxt string) (map[string]uint64, error)
- func (c CephApi) GetPGSummary(mon string, clusterId uuid.UUID, ctxt string) (backend.PgSummary, error)
- func (c CephApi) GetPartDeviceDetails(node string, partPath string, ctxt string) (backend.DeviceDetail, error)
- func (c CephApi) GetPool(mon string, clusterId uuid.UUID, pool_id int, ctxt string) (backend.CephPool, error)
- func (c CephApi) GetPools(mon string, clusterId uuid.UUID, ctxt string) ([]backend.CephPool, error)
- func (c CephApi) GetRBDStats(mon string, poolName string, clusterName string, ctxt string) ([]backend.RBDStats, error)
- func (c CephApi) GetServiceCount(hostname string, ctxt string) (service_details map[string]int, err error)
- func (c CephApi) ListPoolNames(mon string, clusterName string, ctxt string) ([]string, error)
- func (c *CephApi) LoadRoutes()
- func (c CephApi) ParticipatesInCluster(node string, ctxt string) bool
- func (c CephApi) PatchCrushNode(mon string, clusterId uuid.UUID, crushNodeId int, ...) (bool, error)
- func (c CephApi) PatchCrushRule(mon string, clusterId uuid.UUID, crushRuleId int, ...) (bool, error)
- func (c CephApi) RemovePool(mon string, clusterId uuid.UUID, clusterName string, pool string, poolId int, ...) (bool, error)
- func (c CephApi) StartCalamari(node string, ctxt string) error
- func (c CephApi) StartMon(nodes []string, ctxt string) (bool, error)
- func (c CephApi) StopCalamari(node string, ctxt string) error
- func (c CephApi) UpdateOSD(mon string, clusterId uuid.UUID, osdId string, params map[string]interface{}, ...) (bool, error)
- func (c CephApi) UpdatePool(mon string, clusterId uuid.UUID, poolId int, pool map[string]interface{}, ...) (bool, error)
- type CephApiRoute
Constants ¶
This section is empty.
Variables ¶
View Source
var (
CEPH_API_ROUTES = make(map[string]CephApiRoute)
)
View Source
var ErrTimedOut = errors.New("Timed out")
Functions ¶
func GetPgStatusBasedCount ¶
Types ¶
type CephApi ¶
type CephApi struct { }
func (CephApi) AddOsdToCrush ¶ added in v0.0.34
func (CephApi) CreateCluster ¶
func (CephApi) CreateCrushNode ¶
func (CephApi) CreateCrushRule ¶
func (CephApi) CreateECPool ¶
func (CephApi) CreatePool ¶
func (CephApi) EmitRbdEvents ¶ added in v0.0.27
func (CephApi) GetCluster ¶
func (CephApi) GetClusterConfig ¶
func (CephApi) GetClusterNetworks ¶
func (c CephApi) GetClusterNetworks(mon string, clusterId uuid.UUID, ctxt string) (skyringmodels.ClusterNetworks, error)
func (CephApi) GetClusterNodes ¶
func (CephApi) GetClusterStats ¶
func (CephApi) GetClusterStatus ¶
func (CephApi) GetCrushNode ¶ added in v0.0.22
func (CephApi) GetCrushNodes ¶
func (CephApi) GetCrushRule ¶ added in v0.0.27
func (CephApi) GetCrushRules ¶
func (CephApi) GetJournalDeviceDetails ¶ added in v0.0.41
func (CephApi) GetMonStatus ¶
func (CephApi) GetMonitors ¶
func (CephApi) GetOSDDetails ¶
func (CephApi) GetObjectCount ¶
func (CephApi) GetPGCount ¶
func (CephApi) GetPGSummary ¶
func (CephApi) GetPartDeviceDetails ¶
func (CephApi) GetRBDStats ¶
func (CephApi) GetServiceCount ¶
func (CephApi) ListPoolNames ¶
func (*CephApi) LoadRoutes ¶
func (c *CephApi) LoadRoutes()
func (CephApi) ParticipatesInCluster ¶
func (CephApi) PatchCrushNode ¶
func (CephApi) PatchCrushRule ¶ added in v0.0.27
func (CephApi) RemovePool ¶
func (CephApi) StopCalamari ¶ added in v0.0.21
Click to show internal directories.
Click to hide internal directories.