Documentation
¶
Index ¶
- type Client
- func (c *Client) CmdSafety(ctx context.Context, req *CmdSafetyRequest) (*CmdSafetyResponse, error)
- func (c *Client) Config(ctx context.Context, req *ConfigRequest) (*ConfigResponse, error)
- func (c *Client) Configdb(ctx context.Context, req *ConfigdbRequest) (*ConfigdbResponse, error)
- func (c *Client) Crush(ctx context.Context, req *CrushRequest) (*CrushResponse, error)
- func (c *Client) Index(ctx context.Context, req *IndexRequest) (*IndexResponse, error)
- func (c *Client) Init(ctx context.Context, req *InitRequest) (*InitResponse, error)
- func (c *Client) Log(ctx context.Context, req *LogRequest) (*LogResponse, error)
- func (c *Client) Restart(ctx context.Context, req *RestartRequest) (*RestartResponse, error)
- func (c *Client) Rules(ctx context.Context, req *RulesRequest) (*RulesResponse, error)
- func (c *Client) Start(ctx context.Context, req *StartRequest) (*StartResponse, error)
- func (c *Client) Status(ctx context.Context, req *StatusRequest) (*StatusResponse, error)
- func (c *Client) Stop(ctx context.Context, req *StopRequest) (*StopResponse, error)
- type CmdSafetyRequest
- type CmdSafetyResponse
- type ConfigRequest
- type ConfigResponse
- type ConfigdbRequest
- type ConfigdbResponse
- type CrushRequest
- type CrushResponse
- type HTTPClient
- type IndexRequest
- type IndexResponse
- type InitRequest
- type InitResponse
- type LogRequest
- type LogResponse
- type RestartRequest
- type RestartResponse
- type RulesRequest
- type RulesResponse
- type StartRequest
- type StartResponse
- type StatusRequest
- type StatusResponse
- type StopRequest
- type StopResponse
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Client ¶
type Client struct {
// contains filtered or unexported fields
}
func New ¶
func New(c HTTPClient) *Client
func (*Client) CmdSafety ¶
func (c *Client) CmdSafety(ctx context.Context, req *CmdSafetyRequest) (*CmdSafetyResponse, error)
CmdSafety Heuristical check if it is safe to perform an action.
func (*Client) Config ¶
func (c *Client) Config(ctx context.Context, req *ConfigRequest) (*ConfigResponse, error)
Config Get Ceph configuration.
func (*Client) Configdb ¶
func (c *Client) Configdb(ctx context.Context, req *ConfigdbRequest) (*ConfigdbResponse, error)
Configdb Get Ceph configuration database.
func (*Client) Crush ¶
func (c *Client) Crush(ctx context.Context, req *CrushRequest) (*CrushResponse, error)
Crush Get OSD crush map
func (*Client) Index ¶
func (c *Client) Index(ctx context.Context, req *IndexRequest) (*IndexResponse, error)
Index Directory index.
func (*Client) Init ¶
func (c *Client) Init(ctx context.Context, req *InitRequest) (*InitResponse, error)
Init Create initial ceph default configuration and setup symlinks.
func (*Client) Log ¶
func (c *Client) Log(ctx context.Context, req *LogRequest) (*LogResponse, error)
Log Read ceph log
func (*Client) Restart ¶
func (c *Client) Restart(ctx context.Context, req *RestartRequest) (*RestartResponse, error)
Restart Restart ceph services.
func (*Client) Rules ¶
func (c *Client) Rules(ctx context.Context, req *RulesRequest) (*RulesResponse, error)
Rules List ceph rules.
func (*Client) Start ¶
func (c *Client) Start(ctx context.Context, req *StartRequest) (*StartResponse, error)
Start Start ceph services.
func (*Client) Status ¶
func (c *Client) Status(ctx context.Context, req *StatusRequest) (*StatusResponse, error)
Status Get ceph status.
func (*Client) Stop ¶
func (c *Client) Stop(ctx context.Context, req *StopRequest) (*StopResponse, error)
Stop Stop ceph services.
type CmdSafetyRequest ¶
type CmdSafetyResponse ¶
type ConfigRequest ¶
type ConfigRequest struct {
Node string `url:"node",json:"node"` // The cluster node name.
}
type ConfigResponse ¶
type ConfigResponse string
type ConfigdbRequest ¶
type ConfigdbRequest struct {
Node string `url:"node",json:"node"` // The cluster node name.
}
type ConfigdbResponse ¶
type ConfigdbResponse []*struct { CanUpdateAtRuntime bool `url:"can_update_at_runtime",json:"can_update_at_runtime"` Level string `url:"level",json:"level"` Mask string `url:"mask",json:"mask"` Name string `url:"name",json:"name"` Section string `url:"section",json:"section"` Value string `url:"value",json:"value"` }
type CrushRequest ¶
type CrushRequest struct {
Node string `url:"node",json:"node"` // The cluster node name.
}
type CrushResponse ¶
type CrushResponse string
type HTTPClient ¶
type IndexRequest ¶
type IndexRequest struct {
Node string `url:"node",json:"node"` // The cluster node name.
}
type IndexResponse ¶
type IndexResponse []*map[string]interface{}
type InitRequest ¶
type InitRequest struct { Node string `url:"node",json:"node"` // The cluster node name. // The following parameters are optional ClusterNetwork *string `url:"cluster-network,omitempty",json:"cluster-network,omitempty"` // Declare a separate cluster network, OSDs will routeheartbeat, object replication and recovery traffic over it DisableCephx *bool `url:"disable_cephx,omitempty",json:"disable_cephx,omitempty"` // Disable cephx authentication.WARNING: cephx is a security feature protecting against man-in-the-middle attacks. Only consider disabling cephx if your network is private! MinSize *int `url:"min_size,omitempty",json:"min_size,omitempty"` // Minimum number of available replicas per object to allow I/O Network *string `url:"network,omitempty",json:"network,omitempty"` // Use specific network for all ceph related traffic PgBits *int `url:"pg_bits,omitempty",json:"pg_bits,omitempty"` // Placement group bits, used to specify the default number of placement groups.NOTE: 'osd pool default pg num' does not work for default pools. Size *int `url:"size,omitempty",json:"size,omitempty"` // Targeted number of replicas per object }
type InitResponse ¶
type InitResponse map[string]interface{}
type LogRequest ¶
type LogResponse ¶
type RestartRequest ¶
type RestartResponse ¶
type RestartResponse string
type RulesRequest ¶
type RulesRequest struct {
Node string `url:"node",json:"node"` // The cluster node name.
}
type RulesResponse ¶
type RulesResponse []*map[string]interface{}
type StartRequest ¶
type StartResponse ¶
type StartResponse string
type StatusRequest ¶
type StatusRequest struct {
Node string `url:"node",json:"node"` // The cluster node name.
}
type StatusResponse ¶
type StatusResponse map[string]interface{}
type StopRequest ¶
type StopResponse ¶
type StopResponse string
Click to show internal directories.
Click to hide internal directories.