- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 46 for updateIPs (0.36 sec)
-
pkg/controller/endpointslice/endpointslice_controller_test.go
batchPeriod time.Duration podsCount int updates []podUpdate finalDelay time.Duration wantRequestCount int }{ { name: "three updates with no batching", batchPeriod: 0 * time.Second, podsCount: 10, updates: []podUpdate{ { // endpoints.Run needs ~100 ms to start processing updates. delay: 200 * time.Millisecond, podName: "pod0",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 08:33:32 UTC 2024 - 65.5K bytes - Viewed (0) -
tensorflow/compiler/mlir/tensorflow/tests/decompose_resource_ops.mlir
"tf.ResourceScatterAdd"(%resource, %indices, %updates) : (tensor<*x!tf_type.resource<tensor<*xi32>>>, tensor<?xi32>, tensor<?x?x?xi32>) -> () tf_device.return }) : () -> () func.return } // Test that tf.ResourceScatterAdd operation is decomposed to // tf.TensorScatterAdd. Updates is scalar. // CHECK-LABEL: @decompose_ResourceScatterAdd_op_with_scalar_updates
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed May 22 19:47:48 UTC 2024 - 51.3K bytes - Viewed (0) -
pkg/kubelet/pod_workers_test.go
if len(processed) != 1 { t.Fatalf("Not all pods processed: %v", processed) } updates := processed["1"] if len(updates) != 1 { t.Fatalf("unexpected updates: %v", updates) } if updates[0].runningPod == nil || updates[0].updateType != kubetypes.SyncPodKill || updates[0].name != "1" { t.Fatalf("unexpected update: %v", updates) } } func TestUpdatePodForTerminatedRuntimePod(t *testing.T) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 75.6K bytes - Viewed (0) -
cmd/iam-store.go
return mp.UpdatedAt, nil } // PolicyNotificationHandler - loads given policy from storage. If not present, // deletes from cache. This notification only reads from storage, and updates // cache. When the notification is for a policy deletion, it updates the // user-policy and group-policy maps as well. func (store *IAMStoreSys) PolicyNotificationHandler(ctx context.Context, policy string) error { if policy == "" {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 22:26:38 UTC 2024 - 75.8K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/dynamicresources/dynamicresources_test.go
func update(t *testing.T, objects []metav1.Object, updates change) []metav1.Object { var updated []metav1.Object for _, obj := range objects { switch in := obj.(type) { case *resourcev1alpha2.ResourceClaim: if updates.claim != nil { obj = updates.claim(in) } case *resourcev1alpha2.PodSchedulingContext: if updates.scheduling != nil { obj = updates.scheduling(in) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 27 07:57:10 UTC 2024 - 61.9K bytes - Viewed (0) -
cmd/erasure-server-pool.go
return globalNotificationSys.StorageInfo(ctx, z, metrics) } func (z *erasureServerPools) NSScanner(ctx context.Context, updates chan<- DataUsageInfo, wantCycle uint32, healScanMode madmin.HealScanMode) error { // Updates must be closed before we return. defer xioutil.SafeClose(updates) ctx, cancel := context.WithCancel(ctx) defer cancel() var wg sync.WaitGroup var mu sync.Mutex
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu May 30 11:58:12 UTC 2024 - 82.5K bytes - Viewed (0) -
src/cmd/go/internal/modload/init.go
if cfg.BuildModExplicit { return fmt.Sprintf("updates to go.mod needed, disabled by -mod=%v; to update it:\n\tgo mod tidy", cfg.BuildMod) } if cfg.BuildModReason != "" { return fmt.Sprintf("updates to go.mod needed, disabled by -mod=%s\n\t(%s)\n\tto update it:\n\tgo mod tidy", cfg.BuildMod, cfg.BuildModReason) } return "updates to go.mod needed; to update it:\n\tgo mod tidy" }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jun 06 18:36:30 UTC 2024 - 69.8K bytes - Viewed (0) -
cmd/iam.go
type IAMUserType int const ( unknownIAMUserType IAMUserType = iota - 1 regUser stsUser svcUser ) // LoadGroup - loads a specific group from storage, and updates the // memberships cache. If the specified group does not exist in // storage, it is removed from in-memory maps as well - this // simplifies the implementation for group removal. This is called // only via IAM notifications.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 22:26:38 UTC 2024 - 71.9K bytes - Viewed (0) -
pkg/controller/job/job_controller.go
return } // Don't check if oldPod has the finalizer, as during ownership transfer // finalizers might be re-added and removed again in behalf of the new owner. // If all those Pod updates collapse into a single event, the finalizer // might be removed in oldPod and curPod. We want to record the latest // state. finalizerRemoved := !hasJobTrackingFinalizer(curPod)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 10 23:56:37 UTC 2024 - 77.6K bytes - Viewed (0) -
cmd/xl-storage.go
defer func() { res := make(map[string]string) if err != nil { res["err"] = err.Error() } stopFn(res) }() // Updates must be closed before we return. defer xioutil.SafeClose(updates) var lc *lifecycle.Lifecycle // Check if the current bucket has a configured lifecycle policy if globalLifecycleSys != nil { lc, err = globalLifecycleSys.Get(cache.Info.Name)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 85.3K bytes - Viewed (2)