Set containerd grpc.MaxCallRecvMsgSize to 16MB

gjkim42 · dims · commit 4bed26300595 · 2023-04-19T19:27:57.000-04:00
diff --git a/container/containerd/client.go b/container/containerd/client.go
@@ -59,6 +59,7 @@ const (
 	maxBackoffDelay   = 3 * time.Second
 	baseBackoffDelay  = 100 * time.Millisecond
 	connectionTimeout = 2 * time.Second
+	maxMsgSize        = 16 * 1024 * 1024 // 16MB
 )
 
 // Client creates a containerd client
@@ -82,6 +83,7 @@ func Client(address, namespace string) (ContainerdClient, error) {
 			grpc.WithContextDialer(dialer.ContextDialer),
 			grpc.WithBlock(),
 			grpc.WithConnectParams(connParams),
+			grpc.WithDefaultCallOptions(grpc.MaxCallRecvMsgSize(maxMsgSize)),
 		}
 		unary, stream := newNSInterceptors(namespace)
 		gopts = append(gopts,

Original file line number	Diff line number	Diff line change
`@@ -59,6 +59,7 @@ const (`
`59`	`59`	`maxBackoffDelay = 3 * time.Second`
`60`	`60`	`baseBackoffDelay = 100 * time.Millisecond`
`61`	`61`	`connectionTimeout = 2 * time.Second`
	`62`	`+ maxMsgSize = 16 * 1024 * 1024 // 16MB`
`62`	`63`	`)`
`63`	`64`
`64`	`65`	`// Client creates a containerd client`
`@@ -82,6 +83,7 @@ func Client(address, namespace string) (ContainerdClient, error) {`
`82`	`83`	`grpc.WithContextDialer(dialer.ContextDialer),`
`83`	`84`	`grpc.WithBlock(),`
`84`	`85`	`grpc.WithConnectParams(connParams),`
	`86`	`+ grpc.WithDefaultCallOptions(grpc.MaxCallRecvMsgSize(maxMsgSize)),`
`85`	`87`	`}`
`86`	`88`	`unary, stream := newNSInterceptors(namespace)`
`87`	`89`	`gopts = append(gopts,`