upstream/kubernetes
1
0
Fork 0
mirror of https://github.com/kubernetes/kubernetes.git synced 2026-06-08 16:30:57 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions

Merge 27cd32dbcf into e136f39334

Browse source
This commit is contained in:
AMAN MISHRA 2026-05-21 17:02:55 -07:00 committed by GitHub
commit 565dac8051
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 4 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
pkg/kubelet/nodeshutdown/storage.go
View file

@ -18,6 +18,7 @@ package nodeshutdown
import (
"encoding/json"
"fmt"
"io"
"os"
"path/filepath"
@ -33,7 +34,7 @@ type localStorage struct {
Path string
}
func (l localStorage) Store(data interface{}) (err error) {
func (l localStorage) Store(data interface{}) error {
b, err := json.Marshal(data)
if err != nil {
return err
@ -41,7 +42,7 @@ func (l localStorage) Store(data interface{}) (err error) {
return atomicWrite(l.Path, b, 0644)
}
func (l localStorage) Load(data interface{}) (err error) {
func (l localStorage) Load(data interface{}) error {
b, err := os.ReadFile(l.Path)
if err != nil {
if os.IsNotExist(err) {
@ -68,7 +69,7 @@ type state struct {
func atomicWrite(filename string, data []byte, perm os.FileMode) error {
f, err := os.CreateTemp(filepath.Dir(filename), ".tmp-"+filepath.Base(filename))
if err != nil {
return err
return fmt.Errorf("failed to create temp file for atomic write %q: %w",filename, err)
}
err = os.Chmod(f.Name(), perm)
if err != nil {