cephapi

package
v0.0.43 Latest Latest
Warning

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

Go to latest
Published: Sep 29, 2016 License: Apache-2.0 Imports: 19 Imported by: 0

Documentation

Index

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

func GetPgStatusBasedCount(status string, clusterId uuid.UUID, pgMap map[string]interface{}) (uint64, error)

func New

func New() backend.Backend

Types

type CephApi

type CephApi struct {
}

func (CephApi) AddMon

func (c CephApi) AddMon(clusterName string, mons []backend.Mon, ctxt string) (bool, error)

func (CephApi) AddOSD

func (c CephApi) AddOSD(clusterName string, osd backend.OSD, ctxt string) (map[string][]string, error)

func (CephApi) AddOsdToCrush added in v0.0.34

func (c CephApi) AddOsdToCrush(mon string, clusterName string, osdName string, weight float64, host string, ctxt string) (bool, error)

func (CephApi) CreateCluster

func (c CephApi) CreateCluster(clusterName string, fsid uuid.UUID, mons []backend.Mon, ctxt string) (bool, error)

func (CephApi) CreateCrushNode

func (c CephApi) CreateCrushNode(mon string, clusterId uuid.UUID, node backend.CrushNodeRequest, ctxt string) (int, error)

func (CephApi) CreateCrushRule

func (c CephApi) CreateCrushRule(mon string, clusterId uuid.UUID, rule backend.CrushRuleRequest, ctxt string) (int, error)

func (CephApi) CreateECPool

func (c CephApi) CreateECPool(
	name string,
	mon string,
	clusterName string,
	pgnum uint,
	replicas int,
	quotaMaxObjects int,
	quotaMaxBytes uint64,
	ecProfile string,
	ruleset map[string]interface{},
	sProfile string,
	ctxt string) (bool, error)

func (CephApi) CreatePool

func (c CephApi) CreatePool(name string, mon string, clusterName string, pgnum uint, replicas int, quotaMaxObjects int, quotaMaxBytes uint64, ruleset int, ctxt string) (bool, error)

func (CephApi) EmitRbdEvents added in v0.0.27

func (c CephApi) EmitRbdEvents(node string, cluster string, ctxt string) error

func (CephApi) ExecCmd

func (c CephApi) ExecCmd(mon string, clusterId uuid.UUID, cmd string, ctxt string) (bool, string, error)

func (CephApi) GetCluster

func (c CephApi) GetCluster(mon string, ctxt string) (backend.CephCluster, error)

func (CephApi) GetClusterConfig

func (c CephApi) GetClusterConfig(mon string, clusterId uuid.UUID, ctxt string) (map[string]string, error)

func (CephApi) GetClusterNetworks

func (c CephApi) GetClusterNetworks(mon string, clusterId uuid.UUID, ctxt string) (skyringmodels.ClusterNetworks, error)

func (CephApi) GetClusterNodes

func (c CephApi) GetClusterNodes(mon string, clusterId uuid.UUID, ctxt string) ([]backend.CephClusterNode, error)

func (CephApi) GetClusterStats

func (c CephApi) GetClusterStats(mon string, clusterName string, ctxt string) (backend.ClusterUtilization, error)

func (CephApi) GetClusterStatus

func (c CephApi) GetClusterStatus(mon string, clusterId uuid.UUID, clusterName string, ctxt string) (status string, err error)

func (CephApi) GetCrushNode added in v0.0.22

func (c CephApi) GetCrushNode(mon string, clusterId uuid.UUID, crushNodeId int, ctxt string) (backend.CrushNode, error)

func (CephApi) GetCrushNodes

func (c CephApi) GetCrushNodes(mon string, clusterId uuid.UUID, ctxt string) ([]backend.CrushNode, error)

func (CephApi) GetCrushRule added in v0.0.27

func (c CephApi) GetCrushRule(mon string, clusterId uuid.UUID, crushRuleId int, ctxt string) (map[string]interface{}, error)

func (CephApi) GetCrushRules

func (c CephApi) GetCrushRules(mon string, clusterId uuid.UUID, ctxt string) ([]map[string]interface{}, error)

func (CephApi) GetJournalDeviceDetails added in v0.0.41

func (c CephApi) GetJournalDeviceDetails(node string, journalPath string, ctxt string) (backend.DeviceDetail, error)

func (CephApi) GetMonStatus

func (c CephApi) GetMonStatus(mon string, clusterId uuid.UUID, node string, ctxt string) (backend.MonNodeStatus, error)

func (CephApi) GetMonitors

func (c CephApi) GetMonitors(mon string, clusterId uuid.UUID, ctxt string) ([]string, error)

func (CephApi) GetOSD

func (c CephApi) GetOSD(mon string, clusterId uuid.UUID, osdId string, ctxt string) (backend.CephOSD, error)

func (CephApi) GetOSDDetails

func (c CephApi) GetOSDDetails(mon string, clusterName string, ctxt string) (osds []backend.OSDDetails, err error)

func (CephApi) GetOSDs

func (c CephApi) GetOSDs(mon string, clusterId uuid.UUID, ctxt string) ([]backend.CephOSD, error)

func (CephApi) GetObjectCount

func (c CephApi) GetObjectCount(mon string, clusterName string, ctxt string) (map[string]int64, error)

func (CephApi) GetPGCount

func (c CephApi) GetPGCount(mon string, clusterId uuid.UUID, ctxt string) (map[string]uint64, error)

func (CephApi) GetPGSummary

func (c CephApi) GetPGSummary(mon string, clusterId uuid.UUID, ctxt string) (backend.PgSummary, error)

func (CephApi) GetPartDeviceDetails

func (c CephApi) GetPartDeviceDetails(node string, partPath string, ctxt string) (backend.DeviceDetail, error)

func (CephApi) GetPool

func (c CephApi) GetPool(mon string, clusterId uuid.UUID, pool_id int, ctxt string) (backend.CephPool, error)

func (CephApi) GetPools

func (c CephApi) GetPools(mon string, clusterId uuid.UUID, ctxt string) ([]backend.CephPool, error)

func (CephApi) GetRBDStats

func (c CephApi) GetRBDStats(mon string, poolName string, clusterName string, ctxt string) ([]backend.RBDStats, error)

func (CephApi) GetServiceCount

func (c CephApi) GetServiceCount(hostname string, ctxt string) (service_details map[string]int, err error)

func (CephApi) ListPoolNames

func (c CephApi) ListPoolNames(mon string, clusterName string, ctxt string) ([]string, error)

func (*CephApi) LoadRoutes

func (c *CephApi) LoadRoutes()

func (CephApi) ParticipatesInCluster

func (c CephApi) ParticipatesInCluster(node string, ctxt string) bool

func (CephApi) PatchCrushNode

func (c CephApi) PatchCrushNode(mon string, clusterId uuid.UUID, crushNodeId int, params map[string]interface{}, ctxt string) (bool, error)

func (CephApi) PatchCrushRule added in v0.0.27

func (c CephApi) PatchCrushRule(mon string, clusterId uuid.UUID, crushRuleId int, params map[string]interface{}, ctxt string) (bool, error)

func (CephApi) RemovePool

func (c CephApi) RemovePool(mon string, clusterId uuid.UUID, clusterName string, pool string, poolId int, ctxt string) (bool, error)

func (CephApi) StartCalamari

func (c CephApi) StartCalamari(node string, ctxt string) error

func (CephApi) StartMon

func (c CephApi) StartMon(nodes []string, ctxt string) (bool, error)

func (CephApi) StopCalamari added in v0.0.21

func (c CephApi) StopCalamari(node string, ctxt string) error

func (CephApi) UpdateOSD

func (c CephApi) UpdateOSD(mon string, clusterId uuid.UUID, osdId string, params map[string]interface{}, ctxt string) (bool, error)

func (CephApi) UpdatePool

func (c CephApi) UpdatePool(mon string, clusterId uuid.UUID, poolId int, pool map[string]interface{}, ctxt string) (bool, error)

type CephApiRoute

type CephApiRoute struct {
	Name    string
	Pattern string
	Method  string
	Version int
}

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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