Address review comments

Signed-off-by: senthil <cendhu@gmail.com>

Author: cendhu

utils/connection/retry.go

@@ -105,6 +105,7 @@ func (p *RetryProfile) NewBackoff() *backoff.ExponentialBackOff {
 //
 //	(1) UNAVAILABLE	The service is currently unavailable (e.g., transient network issue, server down).
 //	(2) DEADLINE_EXCEEDED	Operation took too long (deadline passed).
+//	(3) RESOURCE_EXHAUSTED	Some resource (e.g., quota) has been exhausted; the operation cannot proceed.
 func (p *RetryProfile) MakeGrpcRetryPolicyJSON() string {
 	// We initialize a backoff object to fetch the default values.
 	b := p.NewBackoff()
@@ -129,6 +130,7 @@ func (p *RetryProfile) MakeGrpcRetryPolicyJSON() string {
 				"retryableStatusCodes": []string{
 					"UNAVAILABLE",
 					"DEADLINE_EXCEEDED",
+					"RESOURCE_EXHAUSTED",
 				},
 			},
 		}},

utils/connection/retry_test.go

@@ -139,7 +139,7 @@ func TestGrpcRetryJSON(t *testing.T) {
 		  "backoffMultiplier": 1.5,
 		  "initialBackoff": "0.5s",
 		  "maxBackoff": "10s",
-		  "retryableStatusCodes": ["UNAVAILABLE", "DEADLINE_EXCEEDED"]
+		  "retryableStatusCodes": ["UNAVAILABLE", "DEADLINE_EXCEEDED", "RESOURCE_EXHAUSTED",]
 		}
 	  }]
 	}`

utils/connection/server_util.go

@@ -46,8 +46,7 @@ func NewLocalHostServer() *ServerConfig {
 
 // GrpcServer instantiate a [grpc.Server].
 func (c *ServerConfig) GrpcServer() *grpc.Server {
-	opts := append([]grpc.ServerOption{}, grpc.MaxRecvMsgSize(maxMsgSize))
-	opts = append(opts, grpc.MaxSendMsgSize(maxMsgSize))
+	opts := []grpc.ServerOption{grpc.MaxRecvMsgSize(maxMsgSize), grpc.MaxSendMsgSize(maxMsgSize)}
 	if c.Creds != nil {
 		cert, err := tls.LoadX509KeyPair(c.Creds.CertPath, c.Creds.KeyPath)
 		utils.Must(err)