- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 1,286 for GetWork (0.24 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) -
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) -
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) -
releasenotes/notes/network-gw-metadata.yaml
apiVersion: release-notes/v2 kind: bug-fix area: telemetry releaseNotes: - | **Fixed** a bug where `destination_cluster` reported by client proxies may be wrong
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jan 02 03:59:34 UTC 2024 - 220 bytes - Viewed (0) -
cluster/addons/kube-network-policies/kube-network-policies-rbac.yaml
metadata: name: kube-network-policies labels: addonmanager.kubernetes.io/mode: Reconcile roleRef: apiGroup: rbac.authorization.k8s.io kind: ClusterRole name: system:network-policies subjects: - kind: ServiceAccount name: kube-network-policies namespace: kube-system --- apiVersion: v1 kind: ServiceAccount metadata: name: kube-network-policies namespace: kube-system labels:
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Apr 21 10:01:31 UTC 2024 - 1.1K bytes - Viewed (0)