docker/swarmkit

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

Open

    if err := a.store.Batch(func(batch *store.Batch) error {
        for _, node := range allocatedNodes {
            if err := a.commitAllocatedNode(ctx, batch, node); err != nil {
                log.G(ctx).WithError(err).Errorf("Failed to commit allocation of network resources for node %s", node.ID)
            }

• Read up
  Read up

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

Open

    if err := a.store.Batch(func(batch *store.Batch) error {
        for _, n := range allocatedNetworks {
            if err := a.commitAllocatedNetwork(ctx, batch, n); err != nil {
                log.G(ctx).WithError(err).Errorf("failed committing allocation of network %s during init", n.ID)
            }

• Read up
  Read up

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

Open

func (m *Object) MarshalToSizedBuffer(dAtA []byte) (int, error) {
    i := len(dAtA)
    _ = i
    var l int
    _ = l

• Read up
  Read up

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

Open

func (m *SelectBy) MarshalToSizedBuffer(dAtA []byte) (int, error) {
    i := len(dAtA)
    _ = i
    var l int
    _ = l

• Read up
  Read up

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

Open

func (m *Assignment) MarshalToSizedBuffer(dAtA []byte) (int, error) {
    i := len(dAtA)
    _ = i
    var l int
    _ = l

• Read up
  Read up

Method controller.Logs has 58 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (r *controller) Logs(ctx context.Context, publisher exec.LogPublisher, options api.LogSubscriptionOptions) error {
    if err := r.checkClosed(); err != nil {
        return err
    }

Function convertMount has 58 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func convertMount(m api.Mount) enginemount.Mount {
    mount := enginemount.Mount{
        Source:   m.Source,
        Target:   m.Target,
        ReadOnly: m.ReadOnly,

Function ConvertExtensionWatch has 58 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func ConvertExtensionWatch(action WatchActionKind, filters []*SelectBy) ([]Event, error) {
    var (
        m          Extension
        checkFuncs []ExtensionCheckFunc
    )

Function ConvertSecretWatch has 58 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func ConvertSecretWatch(action WatchActionKind, filters []*SelectBy) ([]Event, error) {
    var (
        m          Secret
        checkFuncs []SecretCheckFunc
    )

Function ConvertVolumeWatch has 58 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func ConvertVolumeWatch(action WatchActionKind, filters []*SelectBy) ([]Event, error) {
    var (
        m          Volume
        checkFuncs []VolumeCheckFunc
    )

Function ConvertClusterWatch has 58 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func ConvertClusterWatch(action WatchActionKind, filters []*SelectBy) ([]Event, error) {
    var (
        m          Cluster
        checkFuncs []ClusterCheckFunc
    )

Function ConvertConfigWatch has 58 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func ConvertConfigWatch(action WatchActionKind, filters []*SelectBy) ([]Event, error) {
    var (
        m          Config
        checkFuncs []ConfigCheckFunc
    )

Function ConvertNetworkWatch has 58 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func ConvertNetworkWatch(action WatchActionKind, filters []*SelectBy) ([]Event, error) {
    var (
        m          Network
        checkFuncs []NetworkCheckFunc
    )

Function ConvertServiceWatch has 58 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func ConvertServiceWatch(action WatchActionKind, filters []*SelectBy) ([]Event, error) {
    var (
        m          Service
        checkFuncs []ServiceCheckFunc
    )

Method testSuite.TestIPAMNotNil has 58 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (suite *testSuite) TestIPAMNotNil() {
    s := store.NewMemoryStore(nil)
    suite.NotNil(s)
    defer s.Close()

Method Node.JoinAndStart has 58 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (n *Node) JoinAndStart(ctx context.Context) (err error) {
    ctx, cancel := n.WithContext(ctx)
    defer func() {
        cancel()
        if err != nil {

Method LogBroker.ListenSubscriptions has 58 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (lb *LogBroker) ListenSubscriptions(request *api.ListenSubscriptionsRequest, stream api.LogBroker_ListenSubscriptionsServer) error {
    remote, err := ca.RemoteNode(stream.Context())
    if err != nil {
        return err
    }

Method Collector.Run has 58 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (c *Collector) Run(ctx context.Context) error {
    defer close(c.doneChan)

    watcher, cancel, err := store.ViewAndWatch(c.store, func(readTx store.ReadTx) error {
        nodes, err := store.FindNodes(readTx, store.All)

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

Open

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

• Read up
  Read up

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

Open

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

• Read up
  Read up