docker/swarmkit

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

Open

func (m *NodeCertificateStatusResponse) CopyFrom(src interface{}) {

    o := src.(*NodeCertificateStatusResponse)
    *m = *o
    if o.Status != nil {

• Read up
  Read up

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

Open

func (m *SubscribeLogsRequest) CopyFrom(src interface{}) {

    o := src.(*SubscribeLogsRequest)
    *m = *o
    if o.Selector != nil {

• Read up
  Read up

Method HealthCheckResponse.Unmarshal has 12 return statements (exceeds 4 allowed).

Open

func (m *HealthCheckResponse) Unmarshal(dAtA []byte) error {
    l := len(dAtA)
    iNdEx := 0
    for iNdEx < l {
        preIndex := iNdEx

Function ConvertTaskWatch has 12 return statements (exceeds 4 allowed).

Open

func ConvertTaskWatch(action WatchActionKind, filters []*SelectBy) ([]Event, error) {
    var (
        m               Task
        checkFuncs      []TaskCheckFunc
        hasDesiredState bool

Method ReplicatedService.Unmarshal has 12 return statements (exceeds 4 allowed).

Open

func (m *ReplicatedService) Unmarshal(dAtA []byte) error {
    l := len(dAtA)
    iNdEx := 0
    for iNdEx < l {
        preIndex := iNdEx

Method ResolveAddressRequest.Unmarshal has 12 return statements (exceeds 4 allowed).

Open

func (m *ResolveAddressRequest) Unmarshal(dAtA []byte) error {
    l := len(dAtA)
    iNdEx := 0
    for iNdEx < l {
        preIndex := iNdEx

Method Dispatcher.processUpdates has 12 return statements (exceeds 4 allowed).

Open

func (d *Dispatcher) processUpdates(ctx context.Context) {
    var (
        taskUpdates        map[string]*api.TaskStatus
        nodeUpdates        map[string]nodeUpdate
        unpublishedVolumes map[string][]string

Method Dispatcher.Session has 12 return statements (exceeds 4 allowed).

Open

func (d *Dispatcher) Session(r *api.SessionRequest, stream api.Dispatcher_SessionServer) error {
    d.rpcRW.RLock()
    defer d.rpcRW.RUnlock()

    dctx, err := d.isRunningLocked()

Method Server.checkPortConflicts has 12 return statements (exceeds 4 allowed).

Open

func (s *Server) checkPortConflicts(spec *api.ServiceSpec, serviceID string) error {
    if spec.Endpoint == nil {
        return nil
    }

Method Server.RemoveNode has 12 return statements (exceeds 4 allowed).

Open

func (s *Server) RemoveNode(ctx context.Context, request *api.RemoveNodeRequest) (*api.RemoveNodeResponse, error) {
    if request.NodeID == "" {
        return nil, status.Errorf(codes.InvalidArgument, errInvalidArgument.Error())
    }

Method Node.Join has 12 return statements (exceeds 4 allowed).

Open

func (n *Node) Join(ctx context.Context, req *api.JoinRequest) (*api.JoinResponse, error) {
    nodeInfo, err := ca.RemoteNode(ctx)
    if err != nil {
        return nil, err
    }

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

Open

func filterClusters(candidates []*api.Cluster, filters ...func(*api.Cluster) bool) []*api.Cluster {
    result := []*api.Cluster{}

    for _, c := range candidates {
        match := true

• Read up
  Read up

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

Open

func filterServices(candidates []*api.Service, filters ...func(*api.Service) bool) []*api.Service {
    result := []*api.Service{}

    for _, c := range candidates {
        match := true

• Read up
  Read up

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

Open

func filterNodes(candidates []*api.Node, filters ...func(*api.Node) bool) []*api.Node {
    result := []*api.Node{}

    for _, c := range candidates {
        match := true

• Read up
  Read up

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

Open

func filterTasks(candidates []*api.Task, filters ...func(*api.Task) bool) []*api.Task {
    result := []*api.Task{}

    for _, c := range candidates {
        match := true

• Read up
  Read up

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

Open

        case 10:
            if wireType != 0 {
                return fmt.Errorf("proto: wrong wireType = %d for field DesiredState", wireType)
            }
            var v TaskState

• Read up
  Read up

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

Open

        case 11:
            if wireType != 0 {
                return fmt.Errorf("proto: wrong wireType = %d for field Role", wireType)
            }
            var v NodeRole

• Read up
  Read up

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

Open

func filterNetworks(candidates []*api.Network, filters ...func(*api.Network) bool) []*api.Network {
    result := []*api.Network{}

    for _, c := range candidates {
        match := true

• Read up
  Read up

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

Open

func filterVolumes(candidates []*api.Volume, filters ...func(*api.Volume) bool) []*api.Volume {
    result := []*api.Volume{}
    for _, c := range candidates {
        match := true
        for _, f := range filters {

• Read up
  Read up

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

Open

        case 12:
            if wireType != 0 {
                return fmt.Errorf("proto: wrong wireType = %d for field Membership", wireType)
            }
            var v NodeSpec_Membership

• Read up
  Read up