docker/swarmkit

Method Node.LeaderConn has 6 return statements (exceeds 4 allowed).

Open

func (n *Node) LeaderConn(ctx context.Context) (*grpc.ClientConn, error) {
    cc, err := n.getLeaderConn()
    if err == nil {
        return cc, nil
    }

Method LogBroker.SubscribeLogs has 6 return statements (exceeds 4 allowed).

Open

func (lb *LogBroker) SubscribeLogs(request *api.SubscribeLogsRequest, stream api.Logs_SubscribeLogsServer) error {
    ctx := stream.Context()

    if err := validateSelector(request.Selector); err != nil {
        return err

Function RestoreTable has 6 return statements (exceeds 4 allowed).

Open

func RestoreTable(tx Tx, table string, newObjects []api.StoreObject) error {
    checkType := func(by By) error {
        return nil
    }
    var oldObjects []api.StoreObject

Method ResourceAllocator.AttachNetwork has 6 return statements (exceeds 4 allowed).

Open

func (ra *ResourceAllocator) AttachNetwork(ctx context.Context, request *api.AttachNetworkRequest) (*api.AttachNetworkResponse, error) {
    nodeInfo, err := ca.RemoteNode(ctx)
    if err != nil {
        return nil, err
    }

Method Node.ChangesBetween has 6 return statements (exceeds 4 allowed).

Open

func (n *Node) ChangesBetween(from, to api.Version) ([]state.Change, error) {
    n.stopMu.RLock()
    defer n.stopMu.RUnlock()

    if from.Index > to.Index {

Method Cluster.ValidateConfigurationChange has 6 return statements (exceeds 4 allowed).

Open

func (c *Cluster) ValidateConfigurationChange(cc raftpb.ConfChange) error {
    c.mu.Lock()
    defer c.mu.Unlock()

    if c.removed[cc.NodeID] {

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

Open

        sp2 := &api.Service{
            ID: "predServiceID2",
            Spec: api.ServiceSpec{
                Annotations: api.Annotations{
                    Name: "predService2",

• Read up
  Read up

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

Open

func (c *raftClient) StreamRaftMessage(ctx context.Context, opts ...grpc.CallOption) (Raft_StreamRaftMessageClient, error) {
    stream, err := c.cc.NewStream(ctx, &_Raft_serviceDesc.Streams[0], "/docker.swarmkit.v1.Raft/StreamRaftMessage", opts...)
    if err != nil {
        return nil, err
    }

• Read up
  Read up

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

Open

        sp1 := &api.Service{
            ID: "predServiceID1",
            Spec: api.ServiceSpec{
                Annotations: api.Annotations{
                    Name: "predService1",

• Read up
  Read up

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

Open

        if configRef.GetFile() != nil {
            fileName := configRef.GetFile().Name
            // Validate the file name
            if fileName == "" {
                return status.Errorf(codes.InvalidArgument, "malformed file config reference, invalid target file name provided")

• Read up
  Read up

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

Open

func (c *logBrokerClient) PublishLogs(ctx context.Context, opts ...grpc.CallOption) (LogBroker_PublishLogsClient, error) {
    stream, err := c.cc.NewStream(ctx, &_LogBroker_serviceDesc.Streams[1], "/docker.swarmkit.v1.LogBroker/PublishLogs", opts...)
    if err != nil {
        return nil, err
    }

• Read up
  Read up

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

Open

        if secretRef.GetFile() != nil {
            fileName := secretRef.GetFile().Name
            if fileName == "" {
                return status.Errorf(codes.InvalidArgument, "malformed file secret reference, invalid target file name provided")
            }

• Read up
  Read up

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

Open

func (s *secrets) Get(secretID string) (*api.Secret, error) {
    s.mu.RLock()
    defer s.mu.RUnlock()
    if s, ok := s.m[secretID]; ok {
        return s, nil

• Read up
  Read up

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

Open

    if len(ctr.Secrets) > 0 {
        fmt.Fprintln(w, "  Secrets:")
        for _, sr := range ctr.Secrets {
            var targetName, mode string
            if sr.GetFile() != nil {

• Read up
  Read up

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

Open

func (r *configs) Get(configID string) (*api.Config, error) {
    r.mu.RLock()
    defer r.mu.RUnlock()
    if r, ok := r.m[configID]; ok {
        return r, nil

• Read up
  Read up

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

Open

    if len(ctr.Configs) > 0 {
        fmt.Fprintln(w, "  Configs:")
        for _, cr := range ctr.Configs {
            var targetName, mode string
            if cr.GetFile() != nil {

• Read up
  Read up

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

Open

func (m *ServiceSpec_GlobalJob) Size() (n int) {
    if m == nil {
        return 0
    }
    var l int

• Read up
  Read up

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

Open

func (m *StoreAction_Volume) Size() (n int) {
    if m == nil {
        return 0
    }
    var l int

• Read up
  Read up

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

Open

func (m *Object_Network) Size() (n int) {
    if m == nil {
        return 0
    }
    var l int

• Read up
  Read up

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

Open

func (m *Object_Task) Size() (n int) {
    if m == nil {
        return 0
    }
    var l int

• Read up
  Read up