- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 1,601 for GetWork (0.22 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)