- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 5,573 for info2 (0.05 sec)
-
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) -
pilot/test/xdstest/grpc.go
func (w *slowClientStream) RecvMsg(m any) error { if w.recv > 0 { sleep.UntilContext(w.Context(), w.recv) log.Infof("delayed recv for %v", w.recv) } return w.ClientStream.RecvMsg(m) } func (w *slowClientStream) SendMsg(m any) error { if w.send > 0 { sleep.UntilContext(w.Context(), w.send) log.Infof("delayed send for %v", w.send) } return w.ClientStream.SendMsg(m) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 2.4K bytes - Viewed (0) -
pkg/volume/csi/csi_attacher.go
} klog.V(4).Infof("attacher.GetDeviceMountPath succeeded, deviceMountPath: %s", deviceMountPath) return deviceMountPath, nil } func (c *csiAttacher) MountDevice(spec *volume.Spec, devicePath string, deviceMountPath string, deviceMounterArgs volume.DeviceMounterArgs) error { klog.V(4).Infof(log("attacher.MountDevice(%s, %s)", devicePath, deviceMountPath))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 03 07:38:14 UTC 2023 - 25.9K 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) -
subprojects/core/src/test/groovy/org/gradle/api/internal/project/taskfactory/DefaultTaskClassInfoStoreTest.groovy
@SuppressWarnings("GrMethodMayBeStatic") String getValue() { "test" } } def "class infos are cached"() { def info = taskClassInfoStore.getTaskClassInfo(NonAnnotatedTask) expect: info.is(taskClassInfoStore.getTaskClassInfo(NonAnnotatedTask)) }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Sep 03 06:55:11 UTC 2018 - 1.8K 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) -
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) -
cni/pkg/install/install.go
return err } installLog.Info("Istio CNI configuration and binaries validated/reinstalled.") } } // Cleanup remove Istio CNI's config, kubeconfig file, and binaries. func (in *Installer) Cleanup() error { installLog.Info("Cleaning up.") if len(in.cniConfigFilepath) > 0 && file.Exists(in.cniConfigFilepath) { if in.cfg.ChainedCNIPlugin {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 31 21:45:18 UTC 2024 - 10.7K bytes - Viewed (0) -
tools/bug-report/pkg/content/content.go
if err != nil { return nil, err } if len(result.SkippedAnalyzers) > 0 { log.Infof("Skipped analyzers:") for _, a := range result.SkippedAnalyzers { log.Infof("\t: %s", a) } } if len(result.ExecutedAnalyzers) > 0 { log.Infof("Executed analyzers:") for _, a := range result.ExecutedAnalyzers { log.Infof("\t: %s", a) } } // Get messages for output
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Dec 05 18:47:53 UTC 2023 - 9.7K bytes - Viewed (0) -
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)