- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 1,315 for _obj (0.04 sec)
-
src/debug/macho/testdata/clang-amd64-darwin.obj.base64
Andrew <******@****.***> 1574269611 -0500
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Nov 21 14:55:12 UTC 2019 - 1K bytes - Viewed (0) -
pkg/proxy/config/config.go
} func (c *ServiceConfig) handleDeleteService(obj interface{}) { service, ok := obj.(*v1.Service) if !ok { tombstone, ok := obj.(cache.DeletedFinalStateUnknown) if !ok { utilruntime.HandleError(fmt.Errorf("unexpected object type: %v", obj)) return } if service, ok = tombstone.Obj.(*v1.Service); !ok { utilruntime.HandleError(fmt.Errorf("unexpected object type: %v", obj)) return } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 22 05:08:41 UTC 2024 - 15.1K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/dynamicresources/structuredparameters.go
} objs := claimAssumeCache.List(nil) for _, obj := range objs { claim, ok := obj.(*resourcev1alpha2.ResourceClaim) if !ok { return nil, fmt.Errorf("got unexpected object of type %T from claim assume cache", obj) } if obj, ok := inFlightAllocations.Load(claim.UID); ok { // If the allocation is in-flight, then we have to use the allocation // from that claim. claim = obj.(*resourcev1alpha2.ResourceClaim) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 22 09:03:22 UTC 2024 - 8.7K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/kuberuntime_sandbox.go
return "", message, err } // Create pod logs directory err = m.osInterface.MkdirAll(podSandboxConfig.LogDirectory, 0755) if err != nil { message := fmt.Sprintf("Failed to create log directory for pod %q: %v", format.Pod(pod), err) klog.ErrorS(err, "Failed to create log directory for pod", "pod", klog.KObj(pod)) return "", message, err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 22:40:29 UTC 2024 - 13.6K bytes - Viewed (0) -
pkg/controller/job/job_controller.go
// have a finalizer. func (jm *Controller) deleteJob(logger klog.Logger, obj interface{}) { jm.enqueueSyncJobImmediately(logger, obj) jobObj, ok := obj.(*batch.Job) if !ok { tombstone, ok := obj.(cache.DeletedFinalStateUnknown) if !ok { utilruntime.HandleError(fmt.Errorf("couldn't get object from tombstone %+v", obj)) return } jobObj, ok = tombstone.Obj.(*batch.Job) if !ok {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 10 23:56:37 UTC 2024 - 77.6K bytes - Viewed (0) -
src/debug/macho/testdata/clang-386-darwin.obj.base64
Andrew <******@****.***> 1574269611 -0500
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Nov 21 14:55:12 UTC 2019 - 621 bytes - Viewed (0) -
pkg/controller/volume/expand/expand_controller.go
if err != nil { logger.Error(err, "Error starting ExpandVolume for pvc", "PVC", klog.KObj(pvc)) return err } } else { pvc, err := util.MarkResizeInProgressWithResizer(pvc, resizerName, expc.kubeClient) if err != nil { logger.Error(err, "Error setting PVC in progress with error", "PVC", klog.KObj(pvc), "err", err) return err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 16.2K bytes - Viewed (0) -
pkg/kube/krt/collection.go
for idx, ev := range items { iKey := GetKey(ev.Latest()) iObj := h.parent.GetKey(iKey) if iObj == nil { ev.Event = controllers.EventDelete if ev.Old == nil { // This was an add, now its a Delete. Make sure we don't have Old and New nil, which we claim to be illegal ev.Old = ev.New } ev.New = nil } else { ev.New = iObj } items[idx] = ev } h.onPrimaryInputEventLocked(items)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 10 23:33:56 UTC 2024 - 19.4K bytes - Viewed (0) -
pkg/kubelet/cm/topologymanager/fake_topology_manager.go
klog.InfoS("AddHintProvider", "hintProvider", h) } func (m *fakeManager) AddContainer(pod *v1.Pod, container *v1.Container, containerID string) { klog.InfoS("AddContainer", "pod", klog.KObj(pod), "containerName", container.Name, "containerID", containerID) } func (m *fakeManager) RemoveContainer(containerID string) error { klog.InfoS("RemoveContainer", "containerID", containerID) return nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Aug 02 18:02:07 UTC 2022 - 2.3K bytes - Viewed (0) -
pkg/controller/endpointslicemirroring/reconciler.go
totalAddressesAdded++ } else { numInvalidAddresses++ logger.Info("Address in Endpoints is not a valid IP, it will not be mirrored to an EndpointSlice", "endpoints", klog.KObj(endpoints), "IP", address.IP) } } for _, address := range subset.NotReadyAddresses { // Break if we've reached the max number of addresses to mirror
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 11 18:08:12 UTC 2023 - 13.1K bytes - Viewed (0)