github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-29 14:37:00 +00:00
Code Issues Projects Releases Wiki Activity

Merge pull request #113649 from andrewsykim/apiserver-identity-hash

Browse Source 
apiserver identity : use SHA256 hash in lease names
This commit is contained in:
Kubernetes Prow Robot 2022-11-07 11:20:49 -08:00 committed by GitHub
commit 3d5725d9c0
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 9 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
staging/src/k8s.io/apiserver/pkg/server/config.go
View File

@ -18,8 +18,9 @@ package server
import ( import (
"context" "context"
"crypto/sha256"
"encoding/base32"
"fmt" "fmt"
"hash/fnv"
"net" "net"
"net/http" "net/http"
"os" "os"
@ -335,9 +336,8 @@ func NewConfig(codecs serializer.CodecFactory) *Config {
klog.Fatalf("error getting hostname for apiserver identity: %v", err) klog.Fatalf("error getting hostname for apiserver identity: %v", err)
} }
h := fnv.New32a() hash := sha256.Sum256([]byte(hostname))
h.Write([]byte(hostname)) id = "kube-apiserver-" + strings.ToLower(base32.StdEncoding.WithPadding(base32.NoPadding).EncodeToString(hash[:16]))
id = "kube-apiserver-" + fmt.Sprint(h.Sum32())
} }
lifecycleSignals := newLifecycleSignals() lifecycleSignals := newLifecycleSignals()

9
test/integration/controlplane/apiserver_identity_test.go
View File

@ -18,9 +18,11 @@ package controlplane
import ( import (
"context" "context"
"crypto/sha256"
"encoding/base32"
"fmt" "fmt"
"hash/fnv"
"os" "os"
"strings"
"testing" "testing"
"time" "time"
@ -44,9 +46,8 @@ const (
) )
func expectedAPIServerIdentity(hostname string) string { func expectedAPIServerIdentity(hostname string) string {
h := fnv.New32a() hash := sha256.Sum256([]byte(hostname))
h.Write([]byte(hostname)) return "kube-apiserver-" + strings.ToLower(base32.StdEncoding.WithPadding(base32.NoPadding).EncodeToString(hash[:16]))
return "kube-apiserver-" + fmt.Sprint(h.Sum32())
} }
func TestCreateLeaseOnStart(t *testing.T) { func TestCreateLeaseOnStart(t *testing.T) {