docker/swarmkit

Method Supervisor.Restart has 5 arguments (exceeds 4 allowed). Consider refactoring.

Open

func (r *Supervisor) Restart(ctx context.Context, tx store.Tx, cluster *api.Cluster, service *api.Service, t api.Task) error {

Function CheckTasks has 5 arguments (exceeds 4 allowed). Consider refactoring.

Open

func CheckTasks(ctx context.Context, s *store.MemoryStore, readTx store.ReadTx, initHandler InitHandler, startSupervisor restart.SupervisorInterface) error {

Function validateHasAtLeastOneExternalCA has 5 arguments (exceeds 4 allowed). Consider refactoring.

Open

func validateHasAtLeastOneExternalCA(ctx context.Context, externalCAs map[string][]*api.ExternalCA, securityConfig *ca.SecurityConfig,
    wantedCert []byte, desc string) ([]*api.ExternalCA, error) {

Function watchTask has 5 arguments (exceeds 4 allowed). Consider refactoring.

Open

func watchTask(t *testing.T, s *store.MemoryStore, watch chan events.Event, expectTimeout bool, fn func(t assert.TestingT, s *store.MemoryStore, n *api.Task) bool) {

Method nodeSet.tree has 5 arguments (exceeds 4 allowed). Consider refactoring.

Open

func (ns *nodeSet) tree(serviceID string, preferences []*api.PlacementPreference, maxAssignments int, meetsConstraints func(*NodeInfo) bool, nodeLess func(*NodeInfo, *NodeInfo) bool) decisionTree {

Function NewServer has 5 arguments (exceeds 4 allowed). Consider refactoring.

Open

func NewServer(store *store.MemoryStore, raft *raft.Node, securityConfig *ca.SecurityConfig, nv networkallocator.DriverValidator, dr *drivers.DriverProvider) *Server {

Function NewJoinNode has 5 arguments (exceeds 4 allowed). Consider refactoring.

Open

func NewJoinNode(t *testing.T, clockSource *fakeclock.FakeClock, join string, tc *cautils.TestCA, opts ...raft.NodeOptions) *TestNode {

Function CheckValuesOnNodes has 5 arguments (exceeds 4 allowed). Consider refactoring.

Open

func CheckValuesOnNodes(t *testing.T, clockSource *fakeclock.FakeClock, checkNodes map[uint64]*TestNode, ids []string, values []*api.Node) {

Function CopyNode has 5 arguments (exceeds 4 allowed). Consider refactoring.

Open

func CopyNode(t *testing.T, clockSource *fakeclock.FakeClock, oldNode *TestNode, forceNewCluster bool, kr *SimpleKeyRotator) (*TestNode, context.Context) {

Function AddRaftNode has 5 arguments (exceeds 4 allowed). Consider refactoring.

Open

func AddRaftNode(t *testing.T, clockSource *fakeclock.FakeClock, nodes map[uint64]*TestNode, tc *cautils.TestCA, opts ...raft.NodeOptions) {

Method Node.saveToStorage has 5 arguments (exceeds 4 allowed). Consider refactoring.

Open

    ctx context.Context,
    raftConfig *api.RaftConfig,
    hardState raftpb.HardState,
    entries []raftpb.Entry,
    snapshot raftpb.Snapshot,

Similar blocks of code found in 14 locations. Consider refactoring.

Open

func (c *dispatcherClient) UpdateVolumeStatus(ctx context.Context, in *UpdateVolumeStatusRequest, opts ...grpc.CallOption) (*UpdateVolumeStatusResponse, error) {
    out := new(UpdateVolumeStatusResponse)
    err := c.cc.Invoke(ctx, "/docker.swarmkit.v1.Dispatcher/UpdateVolumeStatus", in, out, opts...)
    if err != nil {
        return nil, err

• Read up
  Read up

Similar blocks of code found in 14 locations. Consider refactoring.

Open

func (c *cAClient) GetRootCACertificate(ctx context.Context, in *GetRootCACertificateRequest, opts ...grpc.CallOption) (*GetRootCACertificateResponse, error) {
    out := new(GetRootCACertificateResponse)
    err := c.cc.Invoke(ctx, "/docker.swarmkit.v1.CA/GetRootCACertificate", in, out, opts...)
    if err != nil {
        return nil, err

• Read up
  Read up

Similar blocks of code found in 14 locations. Consider refactoring.

Open

func (c *cAClient) GetUnlockKey(ctx context.Context, in *GetUnlockKeyRequest, opts ...grpc.CallOption) (*GetUnlockKeyResponse, error) {
    out := new(GetUnlockKeyResponse)
    err := c.cc.Invoke(ctx, "/docker.swarmkit.v1.CA/GetUnlockKey", in, out, opts...)
    if err != nil {
        return nil, err

• Read up
  Read up

Similar blocks of code found in 14 locations. Consider refactoring.

Open

func (c *dispatcherClient) UpdateTaskStatus(ctx context.Context, in *UpdateTaskStatusRequest, opts ...grpc.CallOption) (*UpdateTaskStatusResponse, error) {
    out := new(UpdateTaskStatusResponse)
    err := c.cc.Invoke(ctx, "/docker.swarmkit.v1.Dispatcher/UpdateTaskStatus", in, out, opts...)
    if err != nil {
        return nil, err

• Read up
  Read up

Similar blocks of code found in 14 locations. Consider refactoring.

Open

func (c *healthClient) Check(ctx context.Context, in *HealthCheckRequest, opts ...grpc.CallOption) (*HealthCheckResponse, error) {
    out := new(HealthCheckResponse)
    err := c.cc.Invoke(ctx, "/docker.swarmkit.v1.Health/Check", in, out, opts...)
    if err != nil {
        return nil, err

• Read up
  Read up

Similar blocks of code found in 14 locations. Consider refactoring.

Open

func (c *nodeCAClient) NodeCertificateStatus(ctx context.Context, in *NodeCertificateStatusRequest, opts ...grpc.CallOption) (*NodeCertificateStatusResponse, error) {
    out := new(NodeCertificateStatusResponse)
    err := c.cc.Invoke(ctx, "/docker.swarmkit.v1.NodeCA/NodeCertificateStatus", in, out, opts...)
    if err != nil {
        return nil, err

• Read up
  Read up

Similar blocks of code found in 14 locations. Consider refactoring.

Open

func (c *nodeCAClient) IssueNodeCertificate(ctx context.Context, in *IssueNodeCertificateRequest, opts ...grpc.CallOption) (*IssueNodeCertificateResponse, error) {
    out := new(IssueNodeCertificateResponse)
    err := c.cc.Invoke(ctx, "/docker.swarmkit.v1.NodeCA/IssueNodeCertificate", in, out, opts...)
    if err != nil {
        return nil, err

• Read up
  Read up

Similar blocks of code found in 14 locations. Consider refactoring.

Open

func (c *raftMembershipClient) Join(ctx context.Context, in *JoinRequest, opts ...grpc.CallOption) (*JoinResponse, error) {
    out := new(JoinResponse)
    err := c.cc.Invoke(ctx, "/docker.swarmkit.v1.RaftMembership/Join", in, out, opts...)
    if err != nil {
        return nil, err

• Read up
  Read up

Similar blocks of code found in 14 locations. Consider refactoring.

Open

func (c *raftClient) ResolveAddress(ctx context.Context, in *ResolveAddressRequest, opts ...grpc.CallOption) (*ResolveAddressResponse, error) {
    out := new(ResolveAddressResponse)
    err := c.cc.Invoke(ctx, "/docker.swarmkit.v1.Raft/ResolveAddress", in, out, opts...)
    if err != nil {
        return nil, err

• Read up
  Read up