We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 030958a commit c320e03Copy full SHA for c320e03
1 file changed
coconut/client.go
@@ -35,12 +35,17 @@ import (
35
36
var log = logger.New(logrus.StandardLogger(), "coconut")
37
38
+const GrpcMaxCallRecvSize = 10*1024*1024
39
type internalState struct {
-
40
}
41
42
func NewClient(cxt context.Context, cancel context.CancelFunc, endpoint string) *RpcClient {
43
- conn, err := grpc.DialContext(cxt, endpoint, grpc.WithInsecure())
+ conn, err := grpc.DialContext(
44
+ cxt,
45
+ endpoint,
46
+ grpc.WithInsecure(),
47
+ grpc.WithDefaultCallOptions(grpc.MaxCallRecvMsgSize(GrpcMaxCallRecvSize)),
48
+ )
49
if err != nil {
50
log.WithField("error", err.Error()).
51
WithField("endpoint", endpoint).
0 commit comments