mirror of
https://github.com/k3s-io/kubernetes.git
synced 2025-08-01 07:47:56 +00:00
test coverage
We want to ensure that backoff and rate limit configuration is opt-in
This commit is contained in:
parent
3f3aa279b9
commit
af5ce2fcc5
@ -604,6 +604,20 @@ func TestNewCloudFromJSON(t *testing.T) {
|
|||||||
validateConfig(t, config)
|
validateConfig(t, config)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// Test Backoff and Rate Limit defaults (json)
|
||||||
|
func TestCloudDefaultConfigFromJSON(t *testing.T) {
|
||||||
|
config := `{}`
|
||||||
|
|
||||||
|
validateEmptyConfig(t, config)
|
||||||
|
}
|
||||||
|
|
||||||
|
// Test Backoff and Rate Limit defaults (yaml)
|
||||||
|
func TestCloudDefaultConfigFromYAML(t *testing.T) {
|
||||||
|
config := ``
|
||||||
|
|
||||||
|
validateEmptyConfig(t, config)
|
||||||
|
}
|
||||||
|
|
||||||
// Test Configuration deserialization (yaml)
|
// Test Configuration deserialization (yaml)
|
||||||
func TestNewCloudFromYAML(t *testing.T) {
|
func TestNewCloudFromYAML(t *testing.T) {
|
||||||
config := `
|
config := `
|
||||||
@ -631,16 +645,7 @@ cloudProviderRateLimitBucket: 5
|
|||||||
}
|
}
|
||||||
|
|
||||||
func validateConfig(t *testing.T, config string) {
|
func validateConfig(t *testing.T, config string) {
|
||||||
configReader := strings.NewReader(config)
|
azureCloud := getCloudFromConfig(t, config)
|
||||||
cloud, err := NewCloud(configReader)
|
|
||||||
if err != nil {
|
|
||||||
t.Error(err)
|
|
||||||
}
|
|
||||||
|
|
||||||
azureCloud, ok := cloud.(*Cloud)
|
|
||||||
if !ok {
|
|
||||||
t.Error("NewCloud returned incorrect type")
|
|
||||||
}
|
|
||||||
|
|
||||||
if azureCloud.TenantID != "--tenant-id--" {
|
if azureCloud.TenantID != "--tenant-id--" {
|
||||||
t.Errorf("got incorrect value for TenantID")
|
t.Errorf("got incorrect value for TenantID")
|
||||||
@ -701,6 +706,34 @@ func validateConfig(t *testing.T, config string) {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func getCloudFromConfig(t *testing.T, config string) *Cloud {
|
||||||
|
configReader := strings.NewReader(config)
|
||||||
|
cloud, err := NewCloud(configReader)
|
||||||
|
if err != nil {
|
||||||
|
t.Error(err)
|
||||||
|
}
|
||||||
|
azureCloud, ok := cloud.(*Cloud)
|
||||||
|
if !ok {
|
||||||
|
t.Error("NewCloud returned incorrect type")
|
||||||
|
}
|
||||||
|
return azureCloud
|
||||||
|
}
|
||||||
|
|
||||||
|
// TODO include checks for other appropriate default config parameters
|
||||||
|
func validateEmptyConfig(t *testing.T, config string) {
|
||||||
|
azureCloud := getCloudFromConfig(t, config)
|
||||||
|
|
||||||
|
// backoff should be disabled by default if not explicitly enabled in config
|
||||||
|
if azureCloud.CloudProviderBackoff != false {
|
||||||
|
t.Errorf("got incorrect value for CloudProviderBackoff")
|
||||||
|
}
|
||||||
|
|
||||||
|
// rate limits should be disabled by default if not explicitly enabled in config
|
||||||
|
if azureCloud.CloudProviderRateLimit != false {
|
||||||
|
t.Errorf("got incorrect value for CloudProviderRateLimit")
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
func TestDecodeInstanceInfo(t *testing.T) {
|
func TestDecodeInstanceInfo(t *testing.T) {
|
||||||
response := `{"ID":"_azdev","UD":"0","FD":"99"}`
|
response := `{"ID":"_azdev","UD":"0","FD":"99"}`
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user