- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 123 for updateStats (0.16 sec)
-
tensorflow/cc/training/queue_runner.h
// The Run function for each thread. void Run(Session* sess, const string& enqueue_op); // Updates the internal status; it only keeps OK or the first unexpected error // status. void UpdateStatus(const Status& status); bool IsQueueClosed(Status status) const { return queue_closed_exception_types_.count( static_cast<int>(status.code())) > 0; }
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed Aug 31 18:27:00 UTC 2022 - 5K bytes - Viewed (0) -
pkg/controller/replication/conversion.go
}, rs) } func (c conversionClient) UpdateStatus(ctx context.Context, rs *apps.ReplicaSet, opts metav1.UpdateOptions) (*apps.ReplicaSet, error) { return convertCall(func(rc *v1.ReplicationController) (*v1.ReplicationController, error) { return c.ReplicationControllerInterface.UpdateStatus(ctx, rc, opts) }, rs) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Dec 14 18:43:33 UTC 2022 - 12.7K bytes - Viewed (0) -
pilot/pkg/config/kube/crdclient/client_test.go
}); err != nil { t.Errorf("Unexpected Error in Update -> %v", err) } if r.StatusKind() != "" { stat, err := r.Status() if err != nil { t.Fatal(err) } if _, err := store.UpdateStatus(config.Config{ Meta: configMeta, Status: stat, }); err != nil { t.Errorf("Unexpected Error in Update -> %v", err) } } var cfg *config.Config // validate it is updated
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 10 02:58:52 UTC 2024 - 14.1K bytes - Viewed (0) -
pilot/pkg/controllers/untaint/nodeuntainter_test.go
if markReady { setPodReady(newPod) } newPod.Status.PodIP = ip newPod.Status.Phase = corev1.PodRunning newPod.Status.PodIPs = []corev1.PodIP{ { IP: ip, }, } s.pc.UpdateStatus(newPod) } else { s.pc.Update(pod) } } func generateNode(name string, labels map[string]string) *corev1.Node { return &corev1.Node{ TypeMeta: metav1.TypeMeta{ Kind: "Node",
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Apr 13 00:50:31 UTC 2024 - 6.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/resourcequota/resource_access.go
updatedQuotas: updatedCache, }, nil } func (e *quotaAccessor) UpdateQuotaStatus(newQuota *corev1.ResourceQuota) error { updatedQuota, err := e.client.CoreV1().ResourceQuotas(newQuota.Namespace).UpdateStatus(context.TODO(), newQuota, metav1.UpdateOptions{}) if err != nil { return err } key := newQuota.Namespace + "/" + newQuota.Name e.updatedQuotas.Add(key, updatedQuota) return nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 10 13:54:56 UTC 2024 - 5.6K bytes - Viewed (0) -
pkg/kube/kubetypes/types.go
} // WriteAPI exposes a generic API for a client go type for status operations. // Not all types have status, so they need to be split out type WriteStatusAPI[T runtime.Object] interface { UpdateStatus(ctx context.Context, object T, opts metav1.UpdateOptions) (T, error) } // ReadAPI exposes a generic API for a client go type for read operations. type ReadAPI[T runtime.Object, TL runtime.Object] interface {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 28 16:41:38 UTC 2024 - 6.1K bytes - Viewed (0) -
pilot/pkg/config/memory/store.go
delete(cfg.Annotations, ResourceVersion) } else { cfg.ResourceVersion = time.Now().String() } ns[cfg.Name] = cfg return cfg.ResourceVersion, nil } func (cr *store) UpdateStatus(cfg config.Config) (string, error) { return cr.Update(cfg) } func (cr *store) Patch(orig config.Config, patchFn config.PatchFunc) (string, error) { cr.mutex.Lock() defer cr.mutex.Unlock()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Dec 26 01:14:27 UTC 2023 - 6.3K bytes - Viewed (0) -
pilot/pkg/config/kube/ingress/status.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 28 16:41:38 UTC 2024 - 7.9K bytes - Viewed (0) -
pkg/controller/testutil/test_utils.go
} m.UpdatedNodes[i] = &nodeCopy return node, nil } } m.UpdatedNodes = append(m.UpdatedNodes, &nodeCopy) return node, nil } // UpdateStatus updates a status of a Node in the fake store. func (m *FakeNodeHandler) UpdateStatus(_ context.Context, node *v1.Node, _ metav1.UpdateOptions) (*v1.Node, error) { m.lock.Lock() defer func() { m.RequestCount++ m.lock.Unlock() }()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 28 08:48:22 UTC 2024 - 15.6K bytes - Viewed (0) -
pkg/controller/replicaset/replica_set_utils.go
fmt.Sprintf("sequence No: %v->%v", rs.Status.ObservedGeneration, newStatus.ObservedGeneration)) rs.Status = newStatus updatedRS, updateErr = c.UpdateStatus(context.TODO(), rs, metav1.UpdateOptions{}) if updateErr == nil { return updatedRS, nil } // Stop retrying if we exceed statusUpdateRetries - the replicaSet will be requeued with a rate limit.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 07 12:19:51 UTC 2023 - 7.1K bytes - Viewed (0)