- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 14 for logPrefix (0.14 sec)
-
pilot/pkg/serviceregistry/kube/controller/autoserviceexportcontroller.go
c.mcsSupported = false // Do not return the error, so that the queue does not attempt a retry. return nil } } if err != nil { log.Warnf("%s failed creating ServiceExport %s/%s: %v", c.logPrefix(), svc.Namespace, svc.Name, err) return err } log.Debugf("%s created ServiceExport %s/%s", c.logPrefix(), svc.Namespace, svc.Name) return nil
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 28 16:41:38 UTC 2024 - 5.7K bytes - Viewed (0) -
pkg/volume/flexvolume/attacher-defaults.go
klog.Warning(logPrefix(a.plugin.flexVolumePlugin), "using default Attach for volume ", spec.Name(), ", host ", hostName) return "", nil } // WaitForAttach is part of the volume.Attacher interface func (a *attacherDefaults) WaitForAttach(spec *volume.Spec, devicePath string, timeout time.Duration) (string, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Sep 17 04:51:24 UTC 2020 - 2.4K bytes - Viewed (0) -
pkg/volume/flexvolume/plugin-defaults.go
import ( "k8s.io/klog/v2" "k8s.io/kubernetes/pkg/volume" ) type pluginDefaults flexVolumePlugin func logPrefix(plugin *flexVolumePlugin) string { return "flexVolume driver " + plugin.driverName + ": " } func (plugin *pluginDefaults) GetVolumeName(spec *volume.Spec) (string, error) { klog.V(4).Info(logPrefix((*flexVolumePlugin)(plugin)), "using default GetVolumeName for volume ", spec.Name()) return spec.Name(), nil
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 13 13:42:07 UTC 2021 - 1021 bytes - Viewed (0) -
pkg/kubelet/images/image_manager.go
m.logIt(ref, v1.EventTypeWarning, events.FailedToInspectImage, logPrefix, msg, klog.Warning) return "", msg, ErrImageInspect } present := imageRef != "" if !shouldPullImage(container, present) { if present { msg := fmt.Sprintf("Container image %q already present on machine", container.Image) m.logIt(ref, v1.EventTypeNormal, events.PulledImage, logPrefix, msg, klog.Info) return imageRef, "", nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Feb 08 00:30:31 UTC 2024 - 8.9K bytes - Viewed (0) -
cmd/preferredimports/preferredimports.go
regex = flag.String("include-path", "(test/e2e/|test/e2e_node)", "only files with paths matching this regex is touched") isTerminal = term.IsTerminal(int(os.Stdout.Fd())) logPrefix = "" aliases = map[*regexp.Regexp]string{} ) type analyzer struct { fset *token.FileSet // positions are relative to fset ctx build.Context failed bool
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 06:06:44 UTC 2024 - 7.1K bytes - Viewed (0) -
pkg/volume/flexvolume/detacher-defaults.go
klog.Warning(logPrefix(d.plugin.flexVolumePlugin), "using default Detach for volume ", volumeName, ", host ", hostName) return nil } // WaitForDetach is part of the volume.Detacher interface. func (d *detacherDefaults) WaitForDetach(devicePath string, timeout time.Duration) error { klog.Warning(logPrefix(d.plugin.flexVolumePlugin), "using default WaitForDetach for device ", devicePath)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Sep 17 04:51:24 UTC 2020 - 1.6K bytes - Viewed (0) -
pkg/volume/flexvolume/mounter-defaults.go
// This implementation relies on the attacher's device mount path and does a bind mount to dir. func (f *mounterDefaults) SetUpAt(dir string, mounterArgs volume.MounterArgs) error { klog.Warning(logPrefix(f.plugin), "using default SetUpAt to ", dir) src, err := f.plugin.getDeviceMountPath(f.spec) if err != nil { return err } if err := doMount(f.mounter, src, dir, "auto", []string{"bind"}); err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Feb 24 15:56:30 UTC 2022 - 1.5K bytes - Viewed (0) -
pkg/volume/flexvolume/expander-defaults.go
return &expanderDefaults{plugin} } func (e *expanderDefaults) ExpandVolumeDevice(spec *volume.Spec, newSize resource.Quantity, oldSize resource.Quantity) (resource.Quantity, error) { klog.Warning(logPrefix(e.plugin), "using default expand for volume ", spec.Name(), ", to size ", newSize, " from ", oldSize) return newSize, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 16 11:54:27 UTC 2020 - 2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/job/ExecJob.java
throw new IORuntimeException(e); } } protected String getLogName(final String logPrefix) { if (logSuffix.length() > 0) { return logPrefix + "-" + getExecuteType() + "-" + logSuffix; } return logPrefix + "-" + getExecuteType(); }
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 7.2K bytes - Viewed (0) -
pkg/volume/flexvolume/unmounter-defaults.go
*/ package flexvolume import ( "k8s.io/klog/v2" "k8s.io/mount-utils" ) type unmounterDefaults flexVolumeUnmounter func (f *unmounterDefaults) TearDownAt(dir string) error { klog.Warning(logPrefix(f.plugin), "using default TearDownAt for ", dir) return mount.CleanupMountPoint(dir, f.mounter, false)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Sep 17 04:51:24 UTC 2020 - 876 bytes - Viewed (0)