- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 5,571 for info1 (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) -
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) -
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) -
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) -
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) -
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) -
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) -
pilot/cmd/pilot-agent/app/cmd.go
if err != nil { return fmt.Errorf("failed to get proxy config: %v", err) } if out, err := protomarshal.ToYAML(proxyConfig); err != nil { log.Infof("Failed to serialize to YAML: %v", err) } else { log.Infof("Effective config: %s", out) } secOpts, err := options.NewSecurityOptions(proxyConfig, proxyArgs.StsPort, proxyArgs.TokenManagerPlugin) if err != nil { return err
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 16 22:12:28 UTC 2024 - 11.9K bytes - Viewed (0)