From 8be57295ce898f11953f62755b36b8f2fecc8028 Mon Sep 17 00:00:00 2001 From: Sreevanich16 <87808742+Sreevanich16@users.noreply.github.com> Date: Wed, 24 Jun 2026 12:26:41 +0530 Subject: [PATCH 1/2] Update telemetry.go --- telemetry/telemetry.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/telemetry/telemetry.go b/telemetry/telemetry.go index 3b3c85da..8edd3e8b 100644 --- a/telemetry/telemetry.go +++ b/telemetry/telemetry.go @@ -207,7 +207,7 @@ func setupFlags(fs *flag.FlagSet) (*TelemetryConfig, *gnmi.Config, error) { AuthzPolicyFile: fs.String("authorization_policy_file", "/keys/authorization_policy.json", "Full path name of the JSON authorization policy file."), EnableStreamMultiplexing: fs.Bool("enable_stream_multiplexing", false, "Allow multiple Subscribe RPCs on a single TCP connection via HTTP/2 stream multiplexing"), MaxRecvMsgSize: fs.Int("max_recv_msg_size", 4*1024*1024, "Maximum message size in bytes that the server can receive"), - MaxSendMsgSize: fs.Int("max_send_msg_size", 4*1024*1024, "Maximum message size in bytes that the server can send"), + MaxSendMsgSize: fs.Int("max_send_msg_size", 8*1024*1024, "Maximum message size in bytes that the server can send"), } fs.Var(&telemetryCfg.UserAuth, "client_auth", "Client auth mode(s) - none,cert,password") From e5b61ca270c6a979e243a027e3f899595e9073b2 Mon Sep 17 00:00:00 2001 From: Ubuntu Date: Mon, 29 Jun 2026 10:03:44 +0000 Subject: [PATCH 2/2] increasing grpc recieve msg size limit on gnmi_get client side --- patches/gnmi_get.patch | 15 ++++++++++----- 1 file changed, 10 insertions(+), 5 deletions(-) diff --git a/patches/gnmi_get.patch b/patches/gnmi_get.patch index cf451f3c..6be3d24a 100644 --- a/patches/gnmi_get.patch +++ b/patches/gnmi_get.patch @@ -17,7 +17,7 @@ pb "github.com/openconfig/gnmi/proto/gnmi" ) -@@ -63,16 +64,20 @@ +@@ -63,19 +64,25 @@ xPathFlags arrayFlags pbPathFlags arrayFlags pbModelDataFlags arrayFlags @@ -28,6 +28,7 @@ timeOut = flag.Duration("time_out", 10*time.Second, "Timeout for the Get request, 10 seconds by default") encodingName = flag.String("encoding", "JSON_IETF", "value encoding format to be used") + jwtToken = flag.String("jwt_token", "", "JWT Token if required") ++ maxRecvMsgSize = flag.Int("max_recv_msg_size", 8*1024*1024, "Maximum receive message size in bytes") ) func main() { @@ -38,7 +39,11 @@ flag.Parse() opts := credentials.ClientCredentials(*targetName) -@@ -87,6 +92,10 @@ ++ opts = append(opts, grpc.WithDefaultCallOptions(grpc.MaxCallRecvMsgSize(*maxRecvMsgSize))) + conn, err := grpc.Dial(*targetAddr, opts...) + if err != nil { + log.Exitf("Dialing to %q failed: %v", *targetAddr, err) +@@ -87,6 +94,10 @@ ctx, cancel := context.WithTimeout(context.Background(), *timeOut) defer cancel() @@ -49,7 +54,7 @@ encoding, ok := pb.Encoding_value[*encodingName] if !ok { var gnmiEncodingList []string -@@ -96,12 +105,14 @@ +@@ -96,12 +107,14 @@ log.Exitf("Supported encodings: %s", strings.Join(gnmiEncodingList, ", ")) } @@ -65,7 +70,7 @@ } pbPathList = append(pbPathList, pbPath) } -@@ -120,6 +131,7 @@ +@@ -120,6 +133,7 @@ } getRequest := &pb.GetRequest{ @@ -73,7 +78,7 @@ Encoding: pb.Encoding(encoding), Path: pbPathList, UseModels: pbModelDataList, -@@ -135,4 +147,20 @@ +@@ -135,4 +149,20 @@ fmt.Println("== getResponse:") utils.PrintProto(getResponse)