Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 283 for Sort (0.11 sec)

  1. pkg/controller/daemon/daemon_controller.go

    		if shouldRun {
    			desiredNumberScheduled++
    			if !scheduled {
    				continue
    			}
    
    			currentNumberScheduled++
    			// Sort the daemon pods by creation time, so that the oldest is first.
    			daemonPods, _ := nodeToDaemonPods[node.Name]
    			sort.Sort(podByCreationTimestampAndPhase(daemonPods))
    			pod := daemonPods[0]
    			if podutil.IsPodReady(pod) {
    				numberReady++
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 51.3K bytes
    - Viewed (0)
  2. pkg/kubelet/nodestatus/setters_test.go

    			expected:  &v1.NodeDaemonEndpoints{KubeletEndpoint: v1.DaemonEndpoint{Port: 0}},
    		},
    		{
    			name:      "daemon endpoints with specific port",
    			endpoints: &v1.NodeDaemonEndpoints{KubeletEndpoint: v1.DaemonEndpoint{Port: 5678}},
    			expected:  &v1.NodeDaemonEndpoints{KubeletEndpoint: v1.DaemonEndpoint{Port: 5678}},
    		},
    	} {
    		t.Run(test.name, func(t *testing.T) {
    			ctx := context.Background()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 25 21:47:24 UTC 2024
    - 76.1K bytes
    - Viewed (0)
  3. cmd/iam-store.go

    		if userPredicate != nil && !userPredicate(user) {
    			return true
    		}
    
    		ps := mappedPolicy.toSlice()
    		sort.Strings(ps)
    		r = append(r, madmin.UserPolicyEntities{
    			User:     user,
    			Policies: ps,
    		})
    		return true
    	})
    
    	sort.Slice(r, func(i, j int) bool {
    		return r[i].User < r[j].User
    	})
    
    	return r
    }
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu Jun 13 22:26:38 UTC 2024
    - 75.8K bytes
    - Viewed (0)
  4. pilot/pkg/model/push_context.go

    		return nil
    	}
    
    	out := make(map[string]sets.Set[int])
    
    	addDestination := func(host string, port *networking.PortSelector) {
    		// Use the value 0 as a sentinel indicating that one of the destinations
    		// in the Virtual Service does not specify a port for this host.
    		pn := 0
    		if port != nil {
    			pn = int(port.Number)
    		}
    		sets.InsertOrNew(out, host, pn)
    	}
    
    	for _, h := range v.Http {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 15 09:02:11 UTC 2024
    - 91.8K bytes
    - Viewed (0)
  5. pilot/pkg/networking/core/listener.go

    		}
    
    		if egressListener.IstioListener != nil &&
    			egressListener.IstioListener.Port != nil {
    			// We have a non catch all listener on some user specified port
    			// The user specified port may or may not match a service port.
    			// If it does not match any service port and the service has only
    			// one port, then we pick a default service port. If service has
    			// multiple ports, we expect the user to provide a virtualService
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon May 06 04:44:06 UTC 2024
    - 55.1K bytes
    - Viewed (0)
  6. pilot/pkg/serviceregistry/serviceentry/controller_test.go

    	})
    }
    
    func sortPorts(ports []*model.Port) {
    	sort.Slice(ports, func(i, j int) bool {
    		if ports[i].Port == ports[j].Port {
    			if ports[i].Name == ports[j].Name {
    				return ports[i].Protocol < ports[j].Protocol
    			}
    			return ports[i].Name < ports[j].Name
    		}
    		return ports[i].Port < ports[j].Port
    	})
    }
    
    func Test_autoAllocateIP_conditions(t *testing.T) {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 29 15:31:09 UTC 2024
    - 92.9K bytes
    - Viewed (0)
  7. cmd/xl-storage-format-v2.go

    }
    
    // sortByModTime will sort versions by modtime in descending order,
    // meaning index 0 will be latest version.
    func (x *xlMetaV2) sortByModTime() {
    	// Quick check
    	if len(x.versions) <= 1 || sort.SliceIsSorted(x.versions, func(i, j int) bool {
    		return x.versions[i].header.sortsBefore(x.versions[j].header)
    	}) {
    		return
    	}
    
    	// We should sort.
    	sort.Slice(x.versions, func(i, j int) bool {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Wed May 29 19:14:09 UTC 2024
    - 63.6K bytes
    - Viewed (0)
  8. pilot/pkg/config/kube/gateway/conversion.go

    			}
    		}
    	} else {
    		// First, check section and port apply. This must come first
    		if parentRef.Port != 0 && parentRef.Port != parent.Port {
    			return &ParentError{
    				Reason:  ParentErrorNotAccepted,
    				Message: fmt.Sprintf("port %v not found", parentRef.Port),
    			}
    		}
    		if len(parentRef.SectionName) > 0 && parentRef.SectionName != parent.SectionName {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jun 14 04:34:37 UTC 2024
    - 84.7K bytes
    - Viewed (0)
  9. src/net/netip/netip_test.go

    			t.Errorf("%d. for (%v, %v) String = %q; want %q", i, tt.in.Addr(), tt.in.Port(), got, tt.want)
    		}
    		mt, err := tt.in.MarshalText()
    		if err != nil {
    			t.Errorf("%d. for (%v, %v) MarshalText error: %v", i, tt.in.Addr(), tt.in.Port(), err)
    			continue
    		}
    		if string(mt) != tt.want {
    			t.Errorf("%d. for (%v, %v) MarshalText = %q; want %q", i, tt.in.Addr(), tt.in.Port(), mt, tt.want)
    		}
    	}
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Jun 04 17:10:01 UTC 2024
    - 54.3K bytes
    - Viewed (0)
  10. src/cmd/go/internal/modget/get.go

    	// nondeterministic order. We want 'go get' to be fully deterministic,
    	// including in which errors it chooses to report, so sort the candidates
    	// into a deterministic-but-arbitrary order.
    	for _, q := range r.patternAllQueries {
    		sort.Slice(q.candidates, func(i, j int) bool {
    			return q.candidates[i].path < q.candidates[j].path
    		})
    	}
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 18:26:32 UTC 2024
    - 66.5K bytes
    - Viewed (0)
Back to top