feat(firehose); increate call size when fetching from entropy

goto · Oct 5, 2023 · b09967c · b09967c
1 parent f5284fc
commit b09967c
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/internal/server/v1/firehose/crud.go b/internal/server/v1/firehose/crud.go
@@ -12,6 +12,7 @@ import (
 	shieldv1beta1 "buf.build/gen/go/gotocompany/proton/protocolbuffers/go/gotocompany/shield/v1beta1"
 	"github.com/go-chi/chi/v5"
 	"github.com/go-openapi/strfmt"
+	"google.golang.org/grpc"
 	"google.golang.org/grpc/codes"
 	"google.golang.org/grpc/metadata"
 	"google.golang.org/grpc/status"
@@ -171,7 +172,8 @@ func (api *firehoseAPI) handleList(w http.ResponseWriter, r *http.Request) {
 		Labels:  labelFilter,
 	}
 
-	rpcResp, err := api.Entropy.ListResources(r.Context(), rpcReq)
+	maxBytes := 20000000 // 2,000,000 bytes
+	rpcResp, err := api.Entropy.ListResources(r.Context(), rpcReq, grpc.MaxCallRecvMsgSize(maxBytes))
 	if err != nil {
 		utils.WriteErr(w, err)
 		return