kotovalexarian-likes-github/moby--moby
1
0
Fork 0
mirror of https://github.com/moby/moby.git synced 2022-11-09 12:21:53 -05:00
Code Releases Activity

Merge pull request #39306 from dperny/increase-swarmkit-grpc

Browse source 
Increase max recv gRPC message size for nodes and secrets
This commit is contained in:
Tibor Vass 2019-06-04 09:32:24 -07:00 • committed by GitHub
commit 18a4498c2d
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
2 changed files with 8 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

5
daemon/cluster/nodes.go
View file

@ -8,6 +8,7 @@ import (
"github.com/docker/docker/daemon/cluster/convert" "github.com/docker/docker/daemon/cluster/convert"
"github.com/docker/docker/errdefs" "github.com/docker/docker/errdefs"
swarmapi "github.com/docker/swarmkit/api" swarmapi "github.com/docker/swarmkit/api"
"google.golang.org/grpc"
) )
// GetNodes returns a list of all nodes known to a cluster. // GetNodes returns a list of all nodes known to a cluster.
@ -30,7 +31,9 @@ func (c *Cluster) GetNodes(options apitypes.NodeListOptions) ([]types.Node, erro
r, err := state.controlClient.ListNodes( r, err := state.controlClient.ListNodes(
ctx, ctx,
&swarmapi.ListNodesRequest{Filters: filters}) &swarmapi.ListNodesRequest{Filters: filters},
grpc.MaxCallRecvMsgSize(defaultRecvSizeForListResponse),
)
if err != nil { if err != nil {
return nil, err return nil, err
} }

5
daemon/cluster/secrets.go
View file

@ -7,6 +7,7 @@ import (
types "github.com/docker/docker/api/types/swarm" types "github.com/docker/docker/api/types/swarm"
"github.com/docker/docker/daemon/cluster/convert" "github.com/docker/docker/daemon/cluster/convert"
swarmapi "github.com/docker/swarmkit/api" swarmapi "github.com/docker/swarmkit/api"
"google.golang.org/grpc"
) )
// GetSecret returns a secret from a managed swarm cluster // GetSecret returns a secret from a managed swarm cluster
@ -44,7 +45,9 @@ func (c *Cluster) GetSecrets(options apitypes.SecretListOptions) ([]types.Secret
defer cancel() defer cancel()
r, err := state.controlClient.ListSecrets(ctx, r, err := state.controlClient.ListSecrets(ctx,
&swarmapi.ListSecretsRequest{Filters: filters}) &swarmapi.ListSecretsRequest{Filters: filters},
grpc.MaxCallRecvMsgSize(defaultRecvSizeForListResponse),
)
if err != nil { if err != nil {
return nil, err return nil, err
} }