- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 136 for newNode (0.18 sec)
-
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher_testing_utils_test.go
metav1.AddToGroupVersion(scheme, metav1.SchemeGroupVersion) utilruntime.Must(example.AddToScheme(scheme)) utilruntime.Must(examplev1.AddToScheme(scheme)) utilruntime.Must(example2v1.AddToScheme(scheme)) } func newPod() runtime.Object { return &example.Pod{} } func newPodList() runtime.Object { return &example.PodList{} } func newEtcdTestStorage(t *testing.T, prefix string) (*etcd3testing.EtcdTestServer, storage.Interface) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Oct 20 20:43:52 UTC 2023 - 3.8K bytes - Viewed (0) -
pkg/controller/job/tracking_utils.go
if fin == batch.JobTrackingFinalizer { return true } } return false } func recordFinishedPodWithTrackingFinalizer(oldPod, newPod *v1.Pod) { was := isFinishedPodWithTrackingFinalizer(oldPod) is := isFinishedPodWithTrackingFinalizer(newPod) if was == is { return } var event = metrics.Delete if is { event = metrics.Add }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 14 05:40:02 UTC 2023 - 4.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/watch_test.go
watchServer := &handlers.WatchServer{ Scope: &handlers.RequestScope{}, Watching: watcher, MediaType: "testcase/json", Framer: serializer.Framer, Encoder: newCodec, EmbeddedEncoder: newCodec, TimeoutFactory: &fakeTimeoutFactory{timeoutCh, done}, } s := httptest.NewServer(serveWatch(watcher, watchServer, nil)) defer s.Close() // Setup a client
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Nov 30 17:27:39 UTC 2023 - 30K bytes - Viewed (0) -
pkg/scheduler/internal/queue/scheduling_queue.go
func (p *PriorityQueue) AssignedPodUpdated(logger klog.Logger, oldPod, newPod *v1.Pod) { p.lock.Lock() if isPodResourcesResizedDown(newPod) { p.moveAllToActiveOrBackoffQueue(logger, AssignedPodUpdate, oldPod, newPod, nil) } else { p.movePodsToActiveOrBackoffQueue(logger, p.getUnschedulablePodsWithMatchingAffinityTerm(logger, newPod), AssignedPodUpdate, oldPod, newPod) } p.lock.Unlock() }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 61.4K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/runtime/serializer/versioning/versioning.go
decoder runtime.Decoder, encodeVersion runtime.GroupVersioner, decodeVersion runtime.GroupVersioner, ) runtime.Codec { return NewCodec(encoder, decoder, runtime.UnsafeObjectConvertor(scheme), scheme, scheme, scheme, encodeVersion, decodeVersion, scheme.Name()) } // NewCodec takes objects in their internal versions and converts them to external versions before
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 03 06:51:04 UTC 2023 - 9.8K bytes - Viewed (0) -
src/cmd/covdata/metamerge.go
mm.pod.mfr = mfr // Record file hash. mm.pod.fileHash = mfr.FileHash() // Counter mode and granularity -- detect and record clashes here. newgran := mfr.CounterGranularity() newmode := mfr.CounterMode() if err := mm.SetModeAndGranularity(mdf, newmode, newgran); err != nil { fatal("%v", err) } } func (mm *metaMerge) beginCounterDataFile(cdr *decodecounter.CounterDataReader) { state := argvalues{
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Mar 12 17:17:47 UTC 2024 - 12.1K bytes - Viewed (0) -
src/cmd/compile/internal/ir/const.go
panic("unreachable") } var ( intZero = constant.MakeInt64(0) floatZero = constant.ToFloat(intZero) complexZero = constant.ToComplex(intZero) ) // NewOne returns an OLITERAL representing 1 with the given type. func NewOne(pos src.XPos, typ *types.Type) Node { var val constant.Value switch { case typ.IsInteger(): val = intOne case typ.IsFloat(): val = floatOne case typ.IsComplex():
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Sep 12 18:53:26 UTC 2023 - 4K bytes - Viewed (0) -
pkg/kubelet/status/status_manager_test.go
expectFn func(t *testing.T, status v1.PodStatus) }{ {pod: newPod(0, 1, func(pod *v1.Pod) { pod.Status.Phase = v1.PodFailed })}, { pod: newPod(0, 1, func(pod *v1.Pod) { pod.Status.Phase = v1.PodRunning }), expectFn: func(t *testing.T, status v1.PodStatus) { status.Phase = v1.PodFailed }, }, { pod: newPod(0, 1, func(pod *v1.Pod) { pod.Status.Phase = v1.PodRunning
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 02 16:27:19 UTC 2024 - 68.1K bytes - Viewed (0) -
pkg/controller/replicaset/replica_set_test.go
pendingDeletionRS.ObjectMeta.OwnerReferences[0].UID = "789" now := metav1.Now() pendingDeletionRS.DeletionTimestamp = &now pod1 := newPod("pod1", someRS, v1.PodRunning, nil, true) pod2 := newPod("pod2", someRS, v1.PodRunning, nil, true) pod3 := newPod("pod3", relatedRS, v1.PodRunning, nil, true) pod4 := newPod("pod4", unrelatedRS, v1.PodRunning, nil, true) logger, _ := ktesting.NewTestContext(t) stopCh := make(chan struct{})
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 69.2K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/runtime/codec.go
"k8s.io/apimachinery/pkg/runtime/schema" "k8s.io/klog/v2" ) // codec binds an encoder and decoder. type codec struct { Encoder Decoder } // NewCodec creates a Codec from an Encoder and Decoder. func NewCodec(e Encoder, d Decoder) Codec { return codec{e, d} } // Encode is a convenience wrapper for encoding to a []byte from an Encoder func Encode(e Encoder, obj Object) ([]byte, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 12 03:20:30 UTC 2023 - 12.1K bytes - Viewed (0)