docker/swarmkit

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

Open

func (m *ConfigSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
    if deterministic {
        return xxx_messageInfo_ConfigSpec.Marshal(b, m, deterministic)
    } else {
        b = b[:cap(b)]

• Read up
  Read up

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

Open

func (m *Object) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
    if deterministic {
        return xxx_messageInfo_Object.Marshal(b, m, deterministic)
    } else {
        b = b[:cap(b)]

• Read up
  Read up

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

Open

func (m *Extension) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
    if deterministic {
        return xxx_messageInfo_Extension.Marshal(b, m, deterministic)
    } else {
        b = b[:cap(b)]

• Read up
  Read up

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

Open

func (m *LogAttr) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
    if deterministic {
        return xxx_messageInfo_LogAttr.Marshal(b, m, deterministic)
    } else {
        b = b[:cap(b)]

• Read up
  Read up

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

Open

func (m *EndpointSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
    if deterministic {
        return xxx_messageInfo_EndpointSpec.Marshal(b, m, deterministic)
    } else {
        b = b[:cap(b)]

• Read up
  Read up

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

Open

func (m *TLSAuthorization) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
    if deterministic {
        return xxx_messageInfo_TLSAuthorization.Marshal(b, m, deterministic)
    } else {
        b = b[:cap(b)]

• 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 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

    for _, configRef := range configs {
        configID := configRef.ConfigID
        mapKey := typeAndID{objType: api.ResourceType_CONFIG, id: configID}
        assignment := &api.Assignment{
            Item: &api.Assignment_Config{

• Read up
  Read up

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

Open

    for _, secretRef := range secrets {
        secretID := secretRef.SecretID
        mapKey := typeAndID{objType: api.ResourceType_SECRET, id: secretID}
        assignment := &api.Assignment{
            Item: &api.Assignment_Secret{

• Read up
  Read up

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

Open

    if flags.Changed("rollback-delay") {
        delay, err := flags.GetString("rollback-delay")
        if err != nil {
            return err
        }

• Read up
  Read up

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

Open

    if flags.Changed("update-delay") {
        delay, err := flags.GetString("update-delay")
        if err != nil {
            return err
        }

• Read up
  Read up

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

Open

func fromArgs(args ...interface{}) ([]byte, error) {
    if len(args) != 1 {
        return nil, fmt.Errorf("must provide only a single argument")
    }
    arg, ok := args[0].(string)

• Read up
  Read up

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

Open

func fromArgs(args ...interface{}) ([]byte, error) {
    if len(args) != 1 {
        return nil, fmt.Errorf("must provide only a single argument")
    }
    arg, ok := args[0].(string)

• Read up
  Read up

Method session.logSubscriptions has 6 return statements (exceeds 4 allowed).

Open

func (s *session) logSubscriptions(ctx context.Context) error {
    logger := log.G(ctx).WithFields(log.Fields{"method": "(*session).logSubscriptions"})
    logger.Debugf("")

    client := api.NewLogBrokerClient(s.conn.ClientConn)

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

Open

func parsePortConfig(portConfig string) (string, api.PortConfig_Protocol, uint32, uint32, error) {
    protocol := api.ProtocolTCP
    parts := strings.Split(portConfig, ":")
    if len(parts) < 2 {
        return "", protocol, 0, 0, errors.New("insufficient parameters in port configuration")

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

Open

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

    if flags.Changed(flagName) {
        secrets, err := flags.GetStringSlice(flagName)

Method session.sendTaskStatuses has 6 return statements (exceeds 4 allowed).

Open

func (s *session) sendTaskStatuses(ctx context.Context, updates ...*api.UpdateTaskStatusRequest_TaskStatusUpdate) ([]*api.UpdateTaskStatusRequest_TaskStatusUpdate, error) {
    if len(updates) < 1 {
        return nil, nil
    }

Method nodePlugin.init has 6 return statements (exceeds 4 allowed).

Open

func (np *nodePlugin) init(ctx context.Context) error {
    probe, err := np.idClient.Probe(ctx, &csi.ProbeRequest{})
    if err != nil {
        return err
    }

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

Open

func changeNodeRole(cmd *cobra.Command, args []string, role api.NodeRole) error {
    if len(args) == 0 {
        return errors.New("missing node ID")
    }