docker/swarmkit

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

Open

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

• Read up
  Read up

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

Open

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

• Read up
  Read up

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

Open

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

• Read up
  Read up

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

Open

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

• Read up
  Read up

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

Open

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

• Read up
  Read up

Function Do has 141 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func Do(ctx context.Context, task *api.Task, ctlr Controller) (*api.TaskStatus, error) {
    status := task.Status.Copy()

    // stay in the current state.
    noop := func(errs ...error) (*api.TaskStatus, error) {

Method WatchMessage_Event.Unmarshal has 138 lines of code (exceeds 50 allowed). Consider refactoring.

Open

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

Method Reconciler.ReconcileService has 138 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (r *Reconciler) ReconcileService(id string) error {
    var (
        service *api.Service
        cluster *api.Cluster
        tasks   []*api.Task

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

Open

func reconcileConfigs(ctx context.Context, w *worker, assignments []*api.AssignmentChange, fullSnapshot bool) error {
    var (
        updatedConfigs []api.Config
        removedConfigs []string
    )

• Read up
  Read up

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

Open

func reconcileSecrets(ctx context.Context, w *worker, assignments []*api.AssignmentChange, fullSnapshot bool) error {
    var (
        updatedSecrets []api.Secret
        removedSecrets []string
    )

• Read up
  Read up

Method NodeSpec.Unmarshal has 137 lines of code (exceeds 50 allowed). Consider refactoring.

Open

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

Method WatchRequest.Unmarshal has 137 lines of code (exceeds 50 allowed). Consider refactoring.

Open

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

Method WatchSelectors.MarshalToSizedBuffer has 135 lines of code (exceeds 50 allowed). Consider refactoring.

Open

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

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

Open

func ParseDropCapability(cmd *cobra.Command, spec *api.ServiceSpec, flagName string) error {
    flags := cmd.Flags()

    if !flags.Changed(flagName) {
        return nil

• Read up
  Read up

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

Open

func ParseAddCapability(cmd *cobra.Command, spec *api.ServiceSpec, flagName string) error {
    flags := cmd.Flags()

    if !flags.Changed(flagName) {
        return nil

• Read up
  Read up

SelectBy has 34 methods (exceeds 20 allowed). Consider refactoring.

Open

type SelectBy struct {
    // TODO(aaronl): Are all of these things we want to expose in
    // the API? Exposing them may commit us to maintaining those
    // internal indices going forward.
    //

Function EventFromStoreAction has 133 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func EventFromStoreAction(sa StoreAction, oldObject StoreObject) (Event, error) {
    switch v := sa.Target.(type) {
    case *StoreAction_Node:
        switch sa.Action {
        case StoreActionKindCreate:

Method PublishLogsMessage.Unmarshal has 133 lines of code (exceeds 50 allowed). Consider refactoring.

Open

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

Method Node.Run has 133 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (n *Node) Run(ctx context.Context) error {
    ctx = log.WithLogger(ctx, logrus.WithField("raft_id", fmt.Sprintf("%x", n.Config.ID)))
    ctx, cancel := context.WithCancel(ctx)

    for _, node := range n.bootstrapMembers {

Method Snapshot.Unmarshal has 132 lines of code (exceeds 50 allowed). Consider refactoring.

Open

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