docker/swarmkit

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

Open

    hasNoIPOverlapServices := func(fakeT assert.TestingT, service *api.Service) bool {
        assert.NotEqual(fakeT, len(service.Endpoint.VirtualIPs), 0)
        assert.NotEqual(fakeT, len(service.Endpoint.VirtualIPs[0].Addr), 0)
        assignedVIP := service.Endpoint.VirtualIPs[0].Addr
        if assignedIPs[assignedVIP] {

• Read up
  Read up

Method ServiceSpec.MarshalToSizedBuffer has 84 lines of code (exceeds 50 allowed). Consider refactoring.

Open

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

Method Scheduler.Run has 84 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (s *Scheduler) Run(pctx context.Context) error {
    ctx := log.WithModule(pctx, "scheduler")
    defer close(s.doneChan)

    s.pipeline.AddFilter(&VolumesFilter{vs: s.volumes})

containerConfig has 22 methods (exceeds 20 allowed). Consider refactoring.

Open

type containerConfig struct {
    task                *api.Task
    networksAttachments map[string]*api.NetworkAttachment
}

Method ClusterSnapshot.Unmarshal has 26 return statements (exceeds 4 allowed).

Open

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

Assignment has 22 methods (exceeds 20 allowed). Consider refactoring.

Open

type Assignment struct {
    // Types that are valid to be assigned to Item:
    //    *Assignment_Task
    //    *Assignment_Secret
    //    *Assignment_Config

Method Snapshot.Unmarshal has 26 return statements (exceeds 4 allowed).

Open

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

Method WatchRequest.Unmarshal has 26 return statements (exceeds 4 allowed).

Open

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

ServiceSpec has 22 methods (exceeds 20 allowed). Consider refactoring.

Open

type ServiceSpec struct {
    Annotations Annotations `protobuf:"bytes,1,opt,name=annotations,proto3" json:"annotations"`
    // Task defines the task template this service will spawn.
    Task TaskSpec `protobuf:"bytes,2,opt,name=task,proto3" json:"task"`
    // Types that are valid to be assigned to Mode:

Method WatchMessage_Event.Unmarshal has 26 return statements (exceeds 4 allowed).

Open

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

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

Open

func (s *Server) GetExtension(ctx context.Context, request *api.GetExtensionRequest) (*api.GetExtensionResponse, error) {
    if request.ExtensionID == "" {
        return nil, status.Errorf(codes.InvalidArgument, "extension ID must be provided")
    }

• Read up
  Read up

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

Open

func (s *Server) GetConfig(ctx context.Context, request *api.GetConfigRequest) (*api.GetConfigResponse, error) {
    if request.ConfigID == "" {
        return nil, status.Errorf(codes.InvalidArgument, "config ID must be provided")
    }

• Read up
  Read up

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

Open

func (s *Server) GetResource(ctx context.Context, request *api.GetResourceRequest) (*api.GetResourceResponse, error) {
    if request.ResourceID == "" {
        return nil, status.Errorf(codes.InvalidArgument, "resource ID must be present")
    }
    var resource *api.Resource

• Read up
  Read up

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

Open

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

    o := src.(*LogSelector)
    *m = *o
    if o.ServiceIDs != nil {

• Read up
  Read up

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

Open

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

    o := src.(*ContainerSpec_DNSConfig)
    *m = *o
    if o.Nameservers != nil {

• Read up
  Read up

Method LeaveRequest.Unmarshal has 83 lines of code (exceeds 50 allowed). Consider refactoring.

Open

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

Method StreamRaftMessageRequest.Unmarshal has 83 lines of code (exceeds 50 allowed). Consider refactoring.

Open

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

Method ProcessRaftMessageRequest.Unmarshal has 83 lines of code (exceeds 50 allowed). Consider refactoring.

Open

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

Method TaskReaper.tick has 82 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (tr *TaskReaper) tick() {
    // this signals that a tick has occurred. it exists solely for testing.
    if tr.tickSignal != nil {
        // try writing to this channel, but if it's full, fall straight through
        // and ignore it.

Method PublishLogsMessage.Unmarshal has 25 return statements (exceeds 4 allowed).

Open

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