- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 1,729 for info2 (0.04 sec)
-
pkg/registry/flowcontrol/ensurer/strategy.go
klog.V(2).InfoS(fmt.Sprintf("Successfully created %s", bootstrap.GetObjectKind().GroupVersionKind().Kind), "type", configurationType, "name", name) return nil } if !apierrors.IsAlreadyExists(err) { return fmt.Errorf("cannot create %s type=%s name=%q error=%w", bootstrap.GetObjectKind().GroupVersionKind().Kind, configurationType, name, err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:40 UTC 2023 - 14K bytes - Viewed (0) -
pkg/registry/rbac/validation/rule.go
// can be made on the basis of those rules that are found. RulesFor(user user.Info, namespace string) ([]rbacv1.PolicyRule, error) // VisitRulesFor invokes visitor() with each rule that applies to a given user in a given namespace, and each error encountered resolving those rules. // If visitor() returns false, visiting is short-circuited.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Nov 02 16:51:16 UTC 2020 - 11.6K bytes - Viewed (0) -
pkg/test/framework/suite.go
return err } scopes.Framework.Infof("=== Test Framework Settings ===") scopes.Framework.Info(settings.String()) scopes.Framework.Infof("===============================") // Ensure that the work dir is set. if err := os.MkdirAll(settings.RunDir(), os.ModePerm); err != nil { return fmt.Errorf("error creating rundir %q: %v", settings.RunDir(), err) } scopes.Framework.Infof("Test run dir: %v", settings.RunDir())
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 17.2K bytes - Viewed (0) -
pkg/kubelet/cm/devicemanager/topology_hints.go
for resource, requested := range accumulatedResourceRequests { // Only consider devices that actually contain topology information. if aligned := m.deviceHasTopologyAlignment(resource); !aligned { klog.InfoS("Resource does not have a topology preference", "resource", resource) deviceHints[resource] = nil continue } // Short circuit to regenerate the same hints if there are already
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jan 27 02:10:25 UTC 2024 - 9.9K bytes - Viewed (0) -
pkg/kubelet/certificate/bootstrap/bootstrap.go
ok, err := isClientConfigStillValid(kubeconfigPath) if err != nil { return err } if ok { klog.V(2).InfoS("Kubeconfig exists and is valid, skipping bootstrap", "path", kubeconfigPath) return nil } klog.V(2).InfoS("Using bootstrap kubeconfig to generate TLS client cert, key and kubeconfig file") bootstrapClientConfig, err := loadRESTClientConfig(bootstrapPath)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Dec 27 08:04:25 UTC 2022 - 14.2K bytes - Viewed (0) -
pkg/proxy/winkernel/hns.go
ready: true, serving: true, terminating: false, } endpointInfos[ep.IpConfigurations[1].IpAddress] = endpointDualstack } klog.V(3).InfoS("Queried endpoints from network", "network", networkName) klog.V(5).InfoS("Queried endpoints details", "network", networkName, "endpointInfos", endpointInfos) return endpointInfos, nil } func (hns hns) getEndpointByID(id string) (*endpointInfo, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 09 21:21:12 UTC 2023 - 15K bytes - Viewed (0) -
pkg/volume/util/fsquota/quota_linux.go
// we explicitly have to check in this case. klog.V(4).Infof("clearQuotaOnDir %s", path) supportsQuotas, err := SupportsQuotas(m, path) if err != nil { // Log-and-continue instead of returning an error for now // due to unspecified backwards compatibility concerns (a subject to revise) klog.V(3).Infof("Attempt to check for quota support failed: %v", err) } if !supportsQuotas { return nil
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 07 08:07:51 UTC 2023 - 14.1K bytes - Viewed (0) -
tensorflow/compiler/mlir/tensorflow/transforms/host_runtime/tpu_merge_variables_with_execute.cc
for (const auto& entry : var_access_info.per_resource_info) { const auto& info = entry.getSecond(); if (info.assign) info.assign->erase(); } // Remove the read ops if they have no more uses. for (const auto& entry : var_access_info.per_resource_info) { const auto& info = entry.getSecond(); if (info.read->use_empty()) info.read->erase(); } return success(); }
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Feb 29 17:52:11 UTC 2024 - 27K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/controller/status/naming_controller.go
castObj := obj.(*apiextensionsv1.CustomResourceDefinition) klog.V(4).Infof("Adding %s", castObj.Name) c.enqueue(castObj) } func (c *NamingConditionController) updateCustomResourceDefinition(obj, _ interface{}) { castObj := obj.(*apiextensionsv1.CustomResourceDefinition) klog.V(4).Infof("Updating %s", castObj.Name) c.enqueue(castObj) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 13.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/peerproxy/peerproxy_handler.go
} // Allow non-resource requests if !requestInfo.IsResourceRequest { klog.V(3).Infof("Not a resource request skipping proxying") handler.ServeHTTP(w, r) return } // Request has already been proxied once, it must be served locally if r.Header.Get(PeerProxiedHeader) == "true" { klog.V(3).Infof("Already rerouted once, skipping proxying to peer") handler.ServeHTTP(w, r) return }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 19 00:36:22 UTC 2023 - 11.5K bytes - Viewed (0)