mirrors/ceph-csi
1
0
Fork 0
mirror of https://github.com/ceph/ceph-csi.git synced 2025-06-14 02:43:36 +00:00
Code Issues Packages Projects Releases Wiki Activity

Remove unwanted else block and add comments about some exported functions

Browse Source 
and variables.

Signed-off-by: Humble Chirammal <hchiramm@redhat.com>
This commit is contained in:
Humble Chirammal
2019-01-16 14:25:36 +05:30
parent 2f1317ff1d
commit 2f0595ab71
4 changed files with 31 additions and 29 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
pkg/cephfs/cephuser.go
View File

@ -96,7 +96,7 @@ func createCephUser(volOptions *volumeOptions, adminCr *credentials, volId volum
"osd", caps.Osd,
}
if err := execCommandJson(&ents, "ceph", args[:]...); err != nil {
if err := execCommandJSON(&ents, "ceph", args[:]...); err != nil {
return nil, fmt.Errorf("error creating ceph user: %v", err)
}

5
pkg/cephfs/driver.go
View File

@ -26,8 +26,10 @@ import (
)
const (
// PluginFolder is the kubelet plugin directory for cephfs plugin
PluginFolder = "/var/lib/kubelet/plugins/csi-cephfsplugin"
Version = "0.3.0"
// Version of the cephfs csi driver
Version = "0.3.0"
)
type cephfsDriver struct {
@ -46,6 +48,7 @@ var (
DefaultVolumeMounter string
)
// NewCephFSDriver provides a remote csi cephfs driver object.
func NewCephFSDriver() *cephfsDriver {
return &cephfsDriver{}
}

2
pkg/cephfs/util.go
View File

@ -53,7 +53,7 @@ func execCommandAndValidate(program string, args ...string) error {
return nil
}
func execCommandJson(v interface{}, program string, args ...string) error {
func execCommandJSON(v interface{}, program string, args ...string) error {
out, err := execCommand(program, args...)
if err != nil {