Skip to content

Commit 32e1c03

Browse files
feiskyerfeiskyer
committed
Add logs for rate limit values
1 parent 52435c0 commit 32e1c03

File tree

1 file changed

+78
-0
lines changed

1 file changed

+78
-0
lines changed

‎staging/src/k8s.io/legacy-cloud-providers/azure/azure_client.go‎

Lines changed: 78 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -184,6 +184,12 @@ func newAzVirtualMachinesClient(config *azClientConfig) *azVirtualMachinesClient
184184
}
185185
configureUserAgent(&virtualMachinesClient.Client)
186186

187+
klog.V(2).Infof("Azure VirtualMachinesClient (read ops) using rate limit config: QPS=%g, bucket=%d",
188+
config.rateLimitConfig.CloudProviderRateLimitQPS,
189+
config.rateLimitConfig.CloudProviderRateLimitBucket)
190+
klog.V(2).Infof("Azure VirtualMachinesClient (write ops) using rate limit config: QPS=%g, bucket=%d",
191+
config.rateLimitConfig.CloudProviderRateLimitQPSWrite,
192+
config.rateLimitConfig.CloudProviderRateLimitBucketWrite)
187193
rateLimiterReader, rateLimiterWriter := NewRateLimiter(config.rateLimitConfig)
188194
return &azVirtualMachinesClient{
189195
rateLimiterReader: rateLimiterReader,
@@ -307,6 +313,12 @@ func newAzInterfacesClient(config *azClientConfig) *azInterfacesClient {
307313
}
308314
configureUserAgent(&interfacesClient.Client)
309315

316+
klog.V(2).Infof("Azure InterfacesClient (read ops) using rate limit config: QPS=%g, bucket=%d",
317+
config.rateLimitConfig.CloudProviderRateLimitQPS,
318+
config.rateLimitConfig.CloudProviderRateLimitBucket)
319+
klog.V(2).Infof("Azure InterfacesClient (write ops) using rate limit config: QPS=%g, bucket=%d",
320+
config.rateLimitConfig.CloudProviderRateLimitQPSWrite,
321+
config.rateLimitConfig.CloudProviderRateLimitBucketWrite)
310322
rateLimiterReader, rateLimiterWriter := NewRateLimiter(config.rateLimitConfig)
311323
return &azInterfacesClient{
312324
rateLimiterReader: rateLimiterReader,
@@ -392,6 +404,12 @@ func newAzLoadBalancersClient(config *azClientConfig) *azLoadBalancersClient {
392404
}
393405
configureUserAgent(&loadBalancerClient.Client)
394406

407+
klog.V(2).Infof("Azure LoadBalancersClient (read ops) using rate limit config: QPS=%g, bucket=%d",
408+
config.rateLimitConfig.CloudProviderRateLimitQPS,
409+
config.rateLimitConfig.CloudProviderRateLimitBucket)
410+
klog.V(2).Infof("Azure LoadBalancersClient (write ops) using rate limit config: QPS=%g, bucket=%d",
411+
config.rateLimitConfig.CloudProviderRateLimitQPSWrite,
412+
config.rateLimitConfig.CloudProviderRateLimitBucketWrite)
395413
rateLimiterReader, rateLimiterWriter := NewRateLimiter(config.rateLimitConfig)
396414
return &azLoadBalancersClient{
397415
rateLimiterReader: rateLimiterReader,
@@ -545,6 +563,12 @@ func newAzPublicIPAddressesClient(config *azClientConfig) *azPublicIPAddressesCl
545563
}
546564
configureUserAgent(&publicIPAddressClient.Client)
547565

566+
klog.V(2).Infof("Azure PublicIPAddressesClient (read ops) using rate limit config: QPS=%g, bucket=%d",
567+
config.rateLimitConfig.CloudProviderRateLimitQPS,
568+
config.rateLimitConfig.CloudProviderRateLimitBucket)
569+
klog.V(2).Infof("Azure PublicIPAddressesClient (write ops) using rate limit config: QPS=%g, bucket=%d",
570+
config.rateLimitConfig.CloudProviderRateLimitQPSWrite,
571+
config.rateLimitConfig.CloudProviderRateLimitBucketWrite)
548572
rateLimiterReader, rateLimiterWriter := NewRateLimiter(config.rateLimitConfig)
549573
return &azPublicIPAddressesClient{
550574
rateLimiterReader: rateLimiterReader,
@@ -683,6 +707,12 @@ func newAzSubnetsClient(config *azClientConfig) *azSubnetsClient {
683707
}
684708
configureUserAgent(&subnetsClient.Client)
685709

710+
klog.V(2).Infof("Azure SubnetsClient (read ops) using rate limit config: QPS=%g, bucket=%d",
711+
config.rateLimitConfig.CloudProviderRateLimitQPS,
712+
config.rateLimitConfig.CloudProviderRateLimitBucket)
713+
klog.V(2).Infof("Azure SubnetsClient (write ops) using rate limit config: QPS=%g, bucket=%d",
714+
config.rateLimitConfig.CloudProviderRateLimitQPSWrite,
715+
config.rateLimitConfig.CloudProviderRateLimitBucketWrite)
686716
rateLimiterReader, rateLimiterWriter := NewRateLimiter(config.rateLimitConfig)
687717
return &azSubnetsClient{
688718
client: subnetsClient,
@@ -803,6 +833,12 @@ func newAzSecurityGroupsClient(config *azClientConfig) *azSecurityGroupsClient {
803833
}
804834
configureUserAgent(&securityGroupsClient.Client)
805835

836+
klog.V(2).Infof("Azure SecurityGroupsClient (read ops) using rate limit config: QPS=%g, bucket=%d",
837+
config.rateLimitConfig.CloudProviderRateLimitQPS,
838+
config.rateLimitConfig.CloudProviderRateLimitBucket)
839+
klog.V(2).Infof("Azure SecurityGroupsClient (write ops) using rate limit config: QPS=%g, bucket=%d",
840+
config.rateLimitConfig.CloudProviderRateLimitQPSWrite,
841+
config.rateLimitConfig.CloudProviderRateLimitBucketWrite)
806842
rateLimiterReader, rateLimiterWriter := NewRateLimiter(config.rateLimitConfig)
807843
return &azSecurityGroupsClient{
808844
client: securityGroupsClient,
@@ -955,6 +991,12 @@ func newAzVirtualMachineScaleSetsClient(config *azClientConfig) *azVirtualMachin
955991
}
956992
configureUserAgent(&virtualMachineScaleSetsClient.Client)
957993

994+
klog.V(2).Infof("Azure VirtualMachineScaleSetsClient (read ops) using rate limit config: QPS=%g, bucket=%d",
995+
config.rateLimitConfig.CloudProviderRateLimitQPS,
996+
config.rateLimitConfig.CloudProviderRateLimitBucket)
997+
klog.V(2).Infof("Azure VirtualMachineScaleSetsClient (write ops) using rate limit config: QPS=%g, bucket=%d",
998+
config.rateLimitConfig.CloudProviderRateLimitQPSWrite,
999+
config.rateLimitConfig.CloudProviderRateLimitBucketWrite)
9581000
rateLimiterReader, rateLimiterWriter := NewRateLimiter(config.rateLimitConfig)
9591001
return &azVirtualMachineScaleSetsClient{
9601002
client: virtualMachineScaleSetsClient,
@@ -1053,6 +1095,12 @@ func newAzVirtualMachineScaleSetVMsClient(config *azClientConfig) *azVirtualMach
10531095
}
10541096
configureUserAgent(&virtualMachineScaleSetVMsClient.Client)
10551097

1098+
klog.V(2).Infof("Azure VirtualMachineScaleSetVMsClient (read ops) using rate limit config: QPS=%g, bucket=%d",
1099+
config.rateLimitConfig.CloudProviderRateLimitQPS,
1100+
config.rateLimitConfig.CloudProviderRateLimitBucket)
1101+
klog.V(2).Infof("Azure VirtualMachineScaleSetVMsClient (write ops) using rate limit config: QPS=%g, bucket=%d",
1102+
config.rateLimitConfig.CloudProviderRateLimitQPSWrite,
1103+
config.rateLimitConfig.CloudProviderRateLimitBucketWrite)
10561104
rateLimiterReader, rateLimiterWriter := NewRateLimiter(config.rateLimitConfig)
10571105
return &azVirtualMachineScaleSetVMsClient{
10581106
client: virtualMachineScaleSetVMsClient,
@@ -1150,6 +1198,12 @@ func newAzRoutesClient(config *azClientConfig) *azRoutesClient {
11501198
}
11511199
configureUserAgent(&routesClient.Client)
11521200

1201+
klog.V(2).Infof("Azure RoutesClient (read ops) using rate limit config: QPS=%g, bucket=%d",
1202+
config.rateLimitConfig.CloudProviderRateLimitQPS,
1203+
config.rateLimitConfig.CloudProviderRateLimitBucket)
1204+
klog.V(2).Infof("Azure RoutesClient (write ops) using rate limit config: QPS=%g, bucket=%d",
1205+
config.rateLimitConfig.CloudProviderRateLimitQPSWrite,
1206+
config.rateLimitConfig.CloudProviderRateLimitBucketWrite)
11531207
rateLimiterReader, rateLimiterWriter := NewRateLimiter(config.rateLimitConfig)
11541208
return &azRoutesClient{
11551209
client: routesClient,
@@ -1257,6 +1311,12 @@ func newAzRouteTablesClient(config *azClientConfig) *azRouteTablesClient {
12571311
}
12581312
configureUserAgent(&routeTablesClient.Client)
12591313

1314+
klog.V(2).Infof("Azure RouteTablesClient (read ops) using rate limit config: QPS=%g, bucket=%d",
1315+
config.rateLimitConfig.CloudProviderRateLimitQPS,
1316+
config.rateLimitConfig.CloudProviderRateLimitBucket)
1317+
klog.V(2).Infof("Azure RouteTablesClient (write ops) using rate limit config: QPS=%g, bucket=%d",
1318+
config.rateLimitConfig.CloudProviderRateLimitQPSWrite,
1319+
config.rateLimitConfig.CloudProviderRateLimitBucketWrite)
12601320
rateLimiterReader, rateLimiterWriter := NewRateLimiter(config.rateLimitConfig)
12611321
return &azRouteTablesClient{
12621322
client: routeTablesClient,
@@ -1355,6 +1415,12 @@ func newAzStorageAccountClient(config *azClientConfig) *azStorageAccountClient {
13551415
}
13561416
configureUserAgent(&storageAccountClient.Client)
13571417

1418+
klog.V(2).Infof("Azure StorageAccountClient (read ops) using rate limit config: QPS=%g, bucket=%d",
1419+
config.rateLimitConfig.CloudProviderRateLimitQPS,
1420+
config.rateLimitConfig.CloudProviderRateLimitBucket)
1421+
klog.V(2).Infof("Azure StorageAccountClient (write ops) using rate limit config: QPS=%g, bucket=%d",
1422+
config.rateLimitConfig.CloudProviderRateLimitQPSWrite,
1423+
config.rateLimitConfig.CloudProviderRateLimitBucketWrite)
13581424
rateLimiterReader, rateLimiterWriter := NewRateLimiter(config.rateLimitConfig)
13591425
return &azStorageAccountClient{
13601426
client: storageAccountClient,
@@ -1476,6 +1542,12 @@ func newAzDisksClient(config *azClientConfig) *azDisksClient {
14761542
}
14771543
configureUserAgent(&disksClient.Client)
14781544

1545+
klog.V(2).Infof("Azure DisksClient (read ops) using rate limit config: QPS=%g, bucket=%d",
1546+
config.rateLimitConfig.CloudProviderRateLimitQPS,
1547+
config.rateLimitConfig.CloudProviderRateLimitBucket)
1548+
klog.V(2).Infof("Azure DisksClient (write ops) using rate limit config: QPS=%g, bucket=%d",
1549+
config.rateLimitConfig.CloudProviderRateLimitQPSWrite,
1550+
config.rateLimitConfig.CloudProviderRateLimitBucketWrite)
14791551
rateLimiterReader, rateLimiterWriter := NewRateLimiter(config.rateLimitConfig)
14801552
return &azDisksClient{
14811553
client: disksClient,
@@ -1578,6 +1650,12 @@ func newAzVirtualMachineSizesClient(config *azClientConfig) *azVirtualMachineSiz
15781650
}
15791651
configureUserAgent(&VirtualMachineSizesClient.Client)
15801652

1653+
klog.V(2).Infof("Azure VirtualMachineSizesClient (read ops) using rate limit config: QPS=%g, bucket=%d",
1654+
config.rateLimitConfig.CloudProviderRateLimitQPS,
1655+
config.rateLimitConfig.CloudProviderRateLimitBucket)
1656+
klog.V(2).Infof("Azure VirtualMachineSizesClient (write ops) using rate limit config: QPS=%g, bucket=%d",
1657+
config.rateLimitConfig.CloudProviderRateLimitQPSWrite,
1658+
config.rateLimitConfig.CloudProviderRateLimitBucketWrite)
15811659
rateLimiterReader, rateLimiterWriter := NewRateLimiter(config.rateLimitConfig)
15821660
return &azVirtualMachineSizesClient{
15831661
rateLimiterReader: rateLimiterReader,

0 commit comments

Comments
 (0)