mirror of
https://github.com/k3s-io/kubernetes.git
synced 2025-07-23 03:41:45 +00:00
Merge pull request #97930 from JieJhih/golint/fs
fix golint in volume fs
This commit is contained in:
commit
a64c7ed1dc
@ -183,7 +183,6 @@ pkg/volume/csi/fake
|
|||||||
pkg/volume/git_repo
|
pkg/volume/git_repo
|
||||||
pkg/volume/iscsi
|
pkg/volume/iscsi
|
||||||
pkg/volume/testing
|
pkg/volume/testing
|
||||||
pkg/volume/util/fs
|
|
||||||
pkg/volume/util/volumepathhandler
|
pkg/volume/util/volumepathhandler
|
||||||
pkg/volume/vsphere_volume
|
pkg/volume/vsphere_volume
|
||||||
plugin/pkg/admission/eventratelimit/apis/eventratelimit/v1alpha1
|
plugin/pkg/admission/eventratelimit/apis/eventratelimit/v1alpha1
|
||||||
|
@ -87,7 +87,7 @@ func (md *metricsDu) runFind(metrics *Metrics) error {
|
|||||||
// getFsInfo writes metrics.Capacity and metrics.Available from the filesystem
|
// getFsInfo writes metrics.Capacity and metrics.Available from the filesystem
|
||||||
// info
|
// info
|
||||||
func (md *metricsDu) getFsInfo(metrics *Metrics) error {
|
func (md *metricsDu) getFsInfo(metrics *Metrics) error {
|
||||||
available, capacity, _, inodes, inodesFree, _, err := fs.FsInfo(md.path)
|
available, capacity, _, inodes, inodesFree, _, err := fs.Info(md.path)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return NewFsInfoFailedError(err)
|
return NewFsInfoFailedError(err)
|
||||||
}
|
}
|
||||||
|
@ -55,7 +55,7 @@ func (md *metricsStatFS) GetMetrics() (*Metrics, error) {
|
|||||||
|
|
||||||
// getFsInfo writes metrics.Capacity, metrics.Used and metrics.Available from the filesystem info
|
// getFsInfo writes metrics.Capacity, metrics.Used and metrics.Available from the filesystem info
|
||||||
func (md *metricsStatFS) getFsInfo(metrics *Metrics) error {
|
func (md *metricsStatFS) getFsInfo(metrics *Metrics) error {
|
||||||
available, capacity, usage, inodes, inodesFree, inodesUsed, err := fs.FsInfo(md.path)
|
available, capacity, usage, inodes, inodesFree, inodesUsed, err := fs.Info(md.path)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return NewFsInfoFailedError(err)
|
return NewFsInfoFailedError(err)
|
||||||
}
|
}
|
||||||
|
@ -30,9 +30,9 @@ import (
|
|||||||
"k8s.io/kubernetes/pkg/volume/util/fsquota"
|
"k8s.io/kubernetes/pkg/volume/util/fsquota"
|
||||||
)
|
)
|
||||||
|
|
||||||
// FsInfo linux returns (available bytes, byte capacity, byte usage, total inodes, inodes free, inode usage, error)
|
// Info linux returns (available bytes, byte capacity, byte usage, total inodes, inodes free, inode usage, error)
|
||||||
// for the filesystem that path resides upon.
|
// for the filesystem that path resides upon.
|
||||||
func FsInfo(path string) (int64, int64, int64, int64, int64, int64, error) {
|
func Info(path string) (int64, int64, int64, int64, int64, int64, error) {
|
||||||
statfs := &unix.Statfs_t{}
|
statfs := &unix.Statfs_t{}
|
||||||
err := unix.Statfs(path, statfs)
|
err := unix.Statfs(path, statfs)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
@ -24,16 +24,17 @@ import (
|
|||||||
"k8s.io/apimachinery/pkg/api/resource"
|
"k8s.io/apimachinery/pkg/api/resource"
|
||||||
)
|
)
|
||||||
|
|
||||||
// FSInfo unsupported returns 0 values for available and capacity and an error.
|
// Info unsupported returns 0 values for available and capacity and an error.
|
||||||
func FsInfo(path string) (int64, int64, int64, int64, int64, int64, error) {
|
func Info(path string) (int64, int64, int64, int64, int64, int64, error) {
|
||||||
return 0, 0, 0, 0, 0, 0, fmt.Errorf("FsInfo not supported for this build.")
|
return 0, 0, 0, 0, 0, 0, fmt.Errorf("fsinfo not supported for this build")
|
||||||
}
|
}
|
||||||
|
|
||||||
// DiskUsage gets disk usage of specified path.
|
// DiskUsage gets disk usage of specified path.
|
||||||
func DiskUsage(path string) (*resource.Quantity, error) {
|
func DiskUsage(path string) (*resource.Quantity, error) {
|
||||||
return nil, fmt.Errorf("Du not supported for this build.")
|
return nil, fmt.Errorf("du not supported for this build")
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// Find will always return zero since is on unsupported platform.
|
||||||
func Find(path string) (int64, error) {
|
func Find(path string) (int64, error) {
|
||||||
return 0, fmt.Errorf("Find not supported for this build.")
|
return 0, fmt.Errorf("find not supported for this build")
|
||||||
}
|
}
|
||||||
|
@ -34,9 +34,9 @@ var (
|
|||||||
procGetDiskFreeSpaceEx = modkernel32.NewProc("GetDiskFreeSpaceExW")
|
procGetDiskFreeSpaceEx = modkernel32.NewProc("GetDiskFreeSpaceExW")
|
||||||
)
|
)
|
||||||
|
|
||||||
// FSInfo returns (available bytes, byte capacity, byte usage, total inodes, inodes free, inode usage, error)
|
// Info returns (available bytes, byte capacity, byte usage, total inodes, inodes free, inode usage, error)
|
||||||
// for the filesystem that path resides upon.
|
// for the filesystem that path resides upon.
|
||||||
func FsInfo(path string) (int64, int64, int64, int64, int64, int64, error) {
|
func Info(path string) (int64, int64, int64, int64, int64, int64, error) {
|
||||||
var freeBytesAvailable, totalNumberOfBytes, totalNumberOfFreeBytes int64
|
var freeBytesAvailable, totalNumberOfBytes, totalNumberOfFreeBytes int64
|
||||||
var err error
|
var err error
|
||||||
|
|
||||||
@ -77,7 +77,7 @@ func DiskUsage(path string) (*resource.Quantity, error) {
|
|||||||
return &used, nil
|
return &used, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
// Always return zero since inodes is not supported on Windows.
|
// Find will always return zero since inodes is not supported on Windows.
|
||||||
func Find(path string) (int64, error) {
|
func Find(path string) (int64, error) {
|
||||||
return 0, nil
|
return 0, nil
|
||||||
}
|
}
|
||||||
|
@ -27,35 +27,35 @@ import (
|
|||||||
|
|
||||||
func TestDiskUsage(t *testing.T) {
|
func TestDiskUsage(t *testing.T) {
|
||||||
|
|
||||||
dir_1, err := ioutil.TempDir("", "dir_1")
|
dir1, err := ioutil.TempDir("", "dir_1")
|
||||||
if err != nil {
|
if err != nil {
|
||||||
t.Fatalf("TestDiskUsage failed: %s", err.Error())
|
t.Fatalf("TestDiskUsage failed: %s", err.Error())
|
||||||
}
|
}
|
||||||
defer os.RemoveAll(dir_1)
|
defer os.RemoveAll(dir1)
|
||||||
|
|
||||||
tmpfile_1, err := ioutil.TempFile(dir_1, "test")
|
tmpfile1, err := ioutil.TempFile(dir1, "test")
|
||||||
if _, err = tmpfile_1.WriteString("just for testing"); err != nil {
|
if _, err = tmpfile1.WriteString("just for testing"); err != nil {
|
||||||
t.Fatalf("TestDiskUsage failed: %s", err.Error())
|
t.Fatalf("TestDiskUsage failed: %s", err.Error())
|
||||||
}
|
}
|
||||||
dir_2, err := ioutil.TempDir(dir_1, "dir_2")
|
dir2, err := ioutil.TempDir(dir1, "dir_2")
|
||||||
if err != nil {
|
if err != nil {
|
||||||
t.Fatalf("TestDiskUsage failed: %s", err.Error())
|
t.Fatalf("TestDiskUsage failed: %s", err.Error())
|
||||||
}
|
}
|
||||||
tmpfile_2, err := ioutil.TempFile(dir_2, "test")
|
tmpfile2, err := ioutil.TempFile(dir2, "test")
|
||||||
if _, err = tmpfile_2.WriteString("just for testing"); err != nil {
|
if _, err = tmpfile2.WriteString("just for testing"); err != nil {
|
||||||
t.Fatalf("TestDiskUsage failed: %s", err.Error())
|
t.Fatalf("TestDiskUsage failed: %s", err.Error())
|
||||||
}
|
}
|
||||||
|
|
||||||
dirInfo1, err := os.Lstat(dir_1)
|
dirInfo1, err := os.Lstat(dir1)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
t.Fatalf("TestDiskUsage failed: %s", err.Error())
|
t.Fatalf("TestDiskUsage failed: %s", err.Error())
|
||||||
}
|
}
|
||||||
dirInfo2, err := os.Lstat(dir_2)
|
dirInfo2, err := os.Lstat(dir2)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
t.Fatalf("TestDiskUsage failed: %s", err.Error())
|
t.Fatalf("TestDiskUsage failed: %s", err.Error())
|
||||||
}
|
}
|
||||||
file1 := dir_1 + "/" + "test"
|
file1 := dir1 + "/" + "test"
|
||||||
file2 := dir_2 + "/" + "test"
|
file2 := dir2 + "/" + "test"
|
||||||
fileInfo1, err := os.Lstat(file1)
|
fileInfo1, err := os.Lstat(file1)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
t.Fatalf("TestDiskUsage failed: %s", err.Error())
|
t.Fatalf("TestDiskUsage failed: %s", err.Error())
|
||||||
@ -66,7 +66,7 @@ func TestDiskUsage(t *testing.T) {
|
|||||||
}
|
}
|
||||||
total := dirInfo1.Size() + dirInfo2.Size() + fileInfo1.Size() + fileInfo2.Size()
|
total := dirInfo1.Size() + dirInfo2.Size() + fileInfo1.Size() + fileInfo2.Size()
|
||||||
|
|
||||||
size, err := DiskUsage(dir_1)
|
size, err := DiskUsage(dir1)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
t.Fatalf("TestDiskUsage failed: %s", err.Error())
|
t.Fatalf("TestDiskUsage failed: %s", err.Error())
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user