- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 2,217 for info1 (0.17 sec)
-
pkg/volume/csi/csi_plugin.go
dir := mounter.GetPath() mounter.MetricsProvider = NewMetricsCsi(volumeHandle, dir, csiDriverName(driverName)) klog.V(4).Info(log("mounter created successfully")) return mounter, nil } func (p *csiPlugin) NewUnmounter(specName string, podUID types.UID) (volume.Unmounter, error) { klog.V(4).Infof(log("setting up unmounter for [name=%v, podUID=%v]", specName, podUID)) kvh, ok := p.host.(volume.KubeletVolumeHost) if !ok {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 29.2K bytes - Viewed (0) -
plugin/pkg/auth/authorizer/node/node_authorizer.go
switch attrs.GetVerb() { case "update", "patch": // ok default: klog.V(2).Infof("NODE DENY: '%s' %#v", nodeName, attrs) return authorizer.DecisionNoOpinion, "can only get/update/patch this type", nil } if attrs.GetSubresource() != "status" { klog.V(2).Infof("NODE DENY: '%s' %#v", nodeName, attrs) return authorizer.DecisionNoOpinion, "can only update status subresource", nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 21:22:55 UTC 2024 - 16K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/apf_controller.go
if plState == nil { klog.V(7).Infof("plName=%s, plState==nil", plName) return } useless := plState.quiescing && plState.numPending == 0 && plState.queues.IsIdle() klog.V(7).Infof("plState.quiescing=%v, plState.numPending=%d, useless=%v", plState.quiescing, plState.numPending, useless) if !useless { return }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 48.8K bytes - Viewed (0) -
src/log/slog/doc.go
pairs, where the keys are strings and the values may be of any type. As an example, slog.Info("hello", "count", 3) creates a record containing the time of the call, a level of Info, the message "hello", and a single pair with key "count" and value 3. The [Info] top-level function calls the [Logger.Info] method on the default Logger. In addition to [Logger.Info], there are methods for Debug, Warn and Error levels.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Feb 15 14:35:48 UTC 2024 - 12.3K bytes - Viewed (0) -
pkg/test/framework/components/registryredirector/kube.go
} c.id = ctx.TrackResource(c) var err error scopes.Framework.Info("=== BEGIN: Deploy registry redirector server ===") defer func() { if err != nil { err = fmt.Errorf("container registry deployment failed: %v", err) scopes.Framework.Infof("=== FAILED: Deploy registry redirector server ===") _ = c.Close() } else { scopes.Framework.Info("=== SUCCEEDED: Deploy registry redirector server ===") } }()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Mar 12 00:53:57 UTC 2024 - 4.6K bytes - Viewed (0) -
cmd/kubeadm/app/cmd/phases/init/kubeletfinalize.go
} info, ok := kubeconfig.AuthInfos[userName] if !ok { return errors.Errorf("the file %q does not contain authentication for user %q", kubeconfigPath, cfg.NodeRegistration.Name) } // Update the client certificate and key of the node authorizer to point to the PEM symbolic link. info.ClientKeyData = []byte{} info.ClientCertificateData = []byte{} info.ClientKey = pemPath
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 23 10:54:51 UTC 2024 - 6.8K bytes - Viewed (0) -
security/pkg/nodeagent/test/mock/caserver.go
*pb.IstioCertificateResponse, error, ) { caServerLog.Infof("received CSR request") if s.shouldReject() { caServerLog.Info("force rejecting CSR request") return nil, status.Error(codes.Unavailable, "CA server is not available") } if s.sendEmpty() { caServerLog.Info("force sending empty cert chain in CSR response") response := &pb.IstioCertificateResponse{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 5.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/groupversion.go
} func removeNonPersistedResources(infos []*storageversion.ResourceInfo) []*storageversion.ResourceInfo { var filtered []*storageversion.ResourceInfo for _, info := range infos { // if EncodingVersion is empty, then the apiserver does not // need to register this resource via the storage version API, // thus we can remove it. if info != nil && len(info.EncodingVersion) > 0 { filtered = append(filtered, info)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 18:15:22 UTC 2024 - 5.9K bytes - Viewed (0) -
cmd/kubeadm/app/phases/etcd/local.go
klog.V(5).Infof("[etcd] member was already removed, because no member id exists for peer %s", etcdPeerAddress) return nil } return err } klog.V(1).Infof("[etcd] removing etcd member: %s, id: %d", etcdPeerAddress, id) members, err = etcdClient.RemoveMember(id) if err != nil { return err } klog.V(1).Infof("[etcd] Updated etcd member list: %v", members)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 23 14:07:27 UTC 2024 - 13.8K bytes - Viewed (1) -
pkg/kubelet/cm/dra/manager.go
// Add the prepared CDI devices to the claim info err := m.cache.withLock(func() error { info, exists := m.cache.get(claim.Name, claim.Namespace) if !exists { return fmt.Errorf("unable to get claim info for claim %s in namespace %s", claim.Name, claim.Namespace) } if err := info.setCDIDevices(pluginName, result.GetCDIDevices()); err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 03 13:23:29 UTC 2024 - 19.4K bytes - Viewed (0)