- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 64 for InfoS (0.04 sec)
-
pkg/proxy/endpointslicecache.go
} // Ensure endpoints are always returned in the same order to simplify diffing. sort.Sort(byEndpoint(endpointsMap[svcPortName])) klog.V(3).InfoS("Setting endpoints for service port name", "portName", svcPortName, "endpoints", formatEndpointsList(endpointsMap[svcPortName])) } } return endpointsMap }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 21:07:21 UTC 2024 - 11.7K bytes - Viewed (1) -
pkg/kubelet/volumemanager/cache/desired_state_of_world.go
} seLinuxFileLabel, pluginSupportsSELinuxContextMount, err := dsw.getSELinuxLabel(volumeSpec, seLinuxContainerContexts) if err != nil { return "", err } klog.V(4).InfoS("expected volume SELinux label context", "volume", volumeSpec.Name(), "label", seLinuxFileLabel) if _, volumeExists := dsw.volumesToMount[volumeName]; !volumeExists { var sizeLimit *resource.Quantity
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 27.1K bytes - Viewed (0) -
operator/pkg/helmreconciler/prune.go
// of istiod as it is typically not recommended in production environments. pids, err := proxy.GetIDsFromProxyInfo(kubeClient, ns) if err != nil { return errStatus, fmt.Errorf("failed to check proxy infos: %v", err) } if len(pids) != 0 { msg := fmt.Sprintf("there are proxies still pointing to the pruned control plane: %s.", strings.Join(pids, " "))
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 02 08:32:06 UTC 2024 - 15.9K bytes - Viewed (0) -
src/cmd/go/internal/modfetch/cache.go
if err != nil { return err } defer func() { if cerr := f.Close(); cerr != nil && err == nil { err = cerr } }() infos, err := os.ReadDir(dir) if err != nil { return err } var list []string for _, info := range infos { // We look for *.mod files on the theory that if we can't supply // the .mod file then there's no point in listing that version,
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 03 18:15:22 UTC 2024 - 24.7K bytes - Viewed (0) -
plugin/pkg/auth/authorizer/node/node_authorizer.go
return authorizer.DecisionNoOpinion, "No Object name found", nil } ok, err := r.hasPathFrom(nodeName, startingType, attrs.GetNamespace(), attrs.GetName()) if err != nil { klog.V(2).InfoS("NODE DENY", "err", err) return authorizer.DecisionNoOpinion, fmt.Sprintf("no relationship found between node '%s' and this object", nodeName), nil } if !ok { klog.V(2).Infof("NODE DENY: '%s' %#v", nodeName, attrs)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 21:22:55 UTC 2024 - 16K bytes - Viewed (0) -
pkg/kubelet/volumemanager/cache/actual_state_of_world.go
devicePath: devicePath, } } else { // If volume object already exists, update the fields such as device path volumeObj.devicePath = devicePath klog.V(2).InfoS("Volume is already added to attachedVolume list, update device path", "volumeName", volumeName, "path", devicePath) } asw.attachedVolumes[volumeName] = volumeObj return nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 09 07:34:33 UTC 2024 - 45.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/options/encryptionconfig/config.go
// it should be logically impossible for the new state to be invalid but check just in case _, errGen = h.getCurrentState() if errGen == nil { klogV6 := klog.V(6) if klogV6.Enabled() { klogV6.InfoS("successfully rotated DEK", "uid", uid, "useSeed", useSeed, "newKeyIDHash", envelopekmsv2.GetHashIfNotEmpty(encObject.KeyID), "oldKeyIDHash", envelopekmsv2.GetHashIfNotEmpty(state.EncryptedObject.KeyID),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 16 16:56:39 UTC 2024 - 41.2K bytes - Viewed (0) -
pkg/volume/emptydir/empty_dir.go
if ed.medium == v1.StorageMediumMemory && !notMnt { return nil } else if ed.medium == v1.StorageMediumDefault { // Further check dir exists if _, err := os.Stat(dir); err == nil { klog.V(6).InfoS("Dir exists, so check and assign quota if the underlying medium supports quotas", "dir", dir) err = ed.assignQuota(dir, mounterArgs.DesiredSize) return err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 10:18:16 UTC 2024 - 19K bytes - Viewed (0) -
tensorflow/compiler/mlir/tensorflow/transforms/host_runtime/tpu_merge_variables_with_execute.cc
// resource access. bool IsResourceSafeForMerge( Value resource, const mlir::TF::ResourceAliasAnalysis::Info& resource_analysis_info, const VariableAccessesForTPUExecute& infos, const llvm::SmallDenseSet<int64_t>& resource_ids, bool previous_unknown_resource_access) { // If we had any unknown resource access before, then we conservatively assume
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Feb 29 17:52:11 UTC 2024 - 27K bytes - Viewed (0) -
pkg/volume/local/local.go
return true, nil case hostutil.FileTypeDirectory: // if the given local volume path is of already filesystem directory, return directly because // we do not want to prevent mount operation from succeeding. klog.InfoS("Expansion of directory based local volumes is NO-OP", "localVolumePath", localDevicePath) return true, nil default: return false, fmt.Errorf("only directory and block device are supported") } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 22.2K bytes - Viewed (0)