Skip to content

Commit fe5869d

Browse files
fix(hydrator): increase max msg size (cherry-pick #23190) (#23191)
Signed-off-by: Michael Crenshaw <[email protected]> Co-authored-by: Michael Crenshaw <[email protected]>
1 parent 0e20cb6 commit fe5869d

File tree

2 files changed

+8
-1
lines changed

2 files changed

+8
-1
lines changed

commitserver/apiclient/clientset.go

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2,6 +2,10 @@ package apiclient
22

33
import (
44
"fmt"
5+
"math"
6+
7+
"github.com/argoproj/argo-cd/v3/common"
8+
"github.com/argoproj/argo-cd/v3/util/env"
59

610
log "github.com/sirupsen/logrus"
711
"google.golang.org/grpc"
@@ -10,6 +14,9 @@ import (
1014
"github.com/argoproj/argo-cd/v3/util/io"
1115
)
1216

17+
// MaxGRPCMessageSize contains max grpc message size
18+
var MaxGRPCMessageSize = env.ParseNumFromEnv(common.EnvGRPCMaxSizeMB, 100, 0, math.MaxInt32) * 1024 * 1024
19+
1320
// Clientset represents commit server api clients
1421
type Clientset interface {
1522
NewCommitServerClient() (io.Closer, CommitServiceClient, error)

commitserver/server.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -25,7 +25,7 @@ func NewServer(gitCredsStore git.CredsStore, metricsServer *metrics.Server) *Arg
2525

2626
// CreateGRPC creates a new gRPC server.
2727
func (a *ArgoCDCommitServer) CreateGRPC() *grpc.Server {
28-
server := grpc.NewServer()
28+
server := grpc.NewServer(grpc.MaxRecvMsgSize(apiclient.MaxGRPCMessageSize))
2929
versionpkg.RegisterVersionServiceServer(server, version.NewServer(nil, func() (bool, error) {
3030
return true, nil
3131
}))

0 commit comments

Comments
 (0)