Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 1,601 for GetWork (0.22 sec)

  1. pkg/kubelet/util/queue/work_queue_test.go

    	expected := []types.UID{types.UID("foo1"), types.UID("foo2")}
    	compareResults(t, expected, q.GetWork())
    	compareResults(t, []types.UID{}, q.GetWork())
    	// Dial the time to 1 hour ahead.
    	clock.Step(time.Hour)
    	expected = []types.UID{types.UID("foo3"), types.UID("foo4")}
    	compareResults(t, expected, q.GetWork())
    	compareResults(t, []types.UID{}, q.GetWork())
    }
    
    func TestNewBasicWorkQueue(t *testing.T) {
    	tests := []struct {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 2.4K bytes
    - Viewed (0)
  2. pkg/kubelet/util/queue/work_queue.go

    	"k8s.io/utils/clock"
    )
    
    // WorkQueue allows queuing items with a timestamp. An item is
    // considered ready to process if the timestamp has expired.
    type WorkQueue interface {
    	// GetWork dequeues and returns all ready items.
    	GetWork() []types.UID
    	// Enqueue inserts a new item or overwrites an existing item.
    	Enqueue(item types.UID, delay time.Duration)
    }
    
    type basicWorkQueue struct {
    	clock clock.Clock
    	lock  sync.Mutex
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Sep 10 10:20:09 UTC 2021
    - 1.7K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/admission/plugin/resourcequota/controller.go

    	delete(e.dirtyWork, ns)
    	e.inProgress.Delete(ns)
    }
    
    // getWork returns a namespace, a list of work items in that
    // namespace, and a shutdown boolean.  If not shutdown then the return
    // must eventually be followed by a call on completeWork for the
    // returned namespace (regardless of whether the work item list is
    // empty).
    func (e *quotaEvaluator) getWork() (string, []*admissionWaiter, bool) {
    	ns, shutdown := e.queue.Get()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 25.8K bytes
    - Viewed (0)
  4. pkg/kubelet/pod_workers_test.go

    	if e, a := sets.New[string]("3-static"), newUIDSet(podWorkers.workQueue.GetWork()...); !reflect.DeepEqual(e, a) {
    		t.Fatalf("unexpected queued items: %s", cmp.Diff(e, a))
    	}
    
    	// mark 3-static as deleted while 2-static is still running
    	podWorkers.workQueue.GetWork()
    	podWorkers.UpdatePod(UpdatePodOptions{
    		Pod:        newNamedPod("3-static", "test1", "pod1", true),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 75.6K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/graph/Network.java

     * subtype of {@code Network} that provides methods for adding and removing nodes and edges. If you
     * do not need to mutate a network (e.g. if you write a method than runs a read-only algorithm on
     * the network), you should use the non-mutating {@link Network} interface, or an {@link
     * ImmutableNetwork}.
     *
     * <p>You can create an immutable copy of an existing {@code Network} using {@link
     * ImmutableNetwork#copyOf(Network)}:
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Mon Jan 22 17:29:38 UTC 2024
    - 21.1K bytes
    - Viewed (0)
  6. guava/src/com/google/common/graph/Network.java

     * subtype of {@code Network} that provides methods for adding and removing nodes and edges. If you
     * do not need to mutate a network (e.g. if you write a method than runs a read-only algorithm on
     * the network), you should use the non-mutating {@link Network} interface, or an {@link
     * ImmutableNetwork}.
     *
     * <p>You can create an immutable copy of an existing {@code Network} using {@link
     * ImmutableNetwork#copyOf(Network)}:
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Mon Jan 22 17:29:38 UTC 2024
    - 22.3K bytes
    - Viewed (0)
  7. pilot/pkg/serviceregistry/kube/controller/network.go

    type namedRangerEntry struct {
    	name    network.ID
    	network net.IPNet
    }
    
    // Network returns the IPNet for the network
    func (n namedRangerEntry) Network() net.IPNet {
    	return n.network
    }
    
    // onNetworkChange is fired if the default network is changed either via the namespace label or mesh-networks
    func (c *Controller) onNetworkChange() {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri May 31 22:23:22 UTC 2024
    - 15.4K bytes
    - Viewed (0)
  8. pilot/pkg/model/network.go

    	"istio.io/istio/pkg/cluster"
    	"istio.io/istio/pkg/network"
    	"istio.io/istio/pkg/slices"
    	"istio.io/istio/pkg/util/istiomultierror"
    	netutil "istio.io/istio/pkg/util/net"
    	"istio.io/istio/pkg/util/sets"
    )
    
    // NetworkGateway is the gateway of a network
    type NetworkGateway struct {
    	// Network is the ID of the network where this Gateway resides.
    	Network network.ID
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Oct 24 03:31:28 UTC 2023
    - 16.9K bytes
    - Viewed (0)
  9. releasenotes/notes/network-label.yaml

    apiVersion: release-notes/v2
    kind: feature
    area: installation
    issue:
    - 25500
    releaseNotes:
    - |
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Sep 01 20:02:28 UTC 2020
    - 360 bytes
    - Viewed (0)
  10. cluster/addons/kube-network-policies/kube-network-policies.yaml

    kind: DaemonSet
    metadata:
      name: kube-network-policies
      namespace: kube-system
      labels:
        tier: node
        app: kube-network-policies
        k8s-app: kube-network-policies
        addonmanager.kubernetes.io/mode: Reconcile
    spec:
      selector:
        matchLabels:
          app: kube-network-policies
      template:
        metadata:
          labels:
            tier: node
            app: kube-network-policies
            k8s-app: kube-network-policies
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 25 14:27:59 UTC 2024
    - 1.3K bytes
    - Viewed (0)
Back to top