- Sort Score
- Result 10 results
- Languages All
Results 161 - 170 of 1,192 for slog (0.13 sec)
-
pkg/volume/util/atomic_writer.go
klog.V(4).Infof("%s: write required for target directory %v", w.logContext, w.targetDir) } } if shouldWrite { // (5) tsDir, err := w.newTimestampDir() if err != nil { klog.V(4).Infof("%s: error creating new ts data directory: %v", w.logContext, err) return err } tsDirName := filepath.Base(tsDir) // (6) if err = w.writePayloadToDir(cleanPayload, tsDir); err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 31 12:32:15 UTC 2024 - 16.6K bytes - Viewed (0) -
pkg/scheduler/framework/runtime/framework.go
}() logger := klog.FromContext(ctx) verboseLogs := logger.V(4).Enabled() if verboseLogs { logger = klog.LoggerWithName(logger, "PreBind") logger = klog.LoggerWithValues(logger, "node", klog.ObjectRef{Name: nodeName}) } for _, pl := range f.preBindPlugins { ctx := ctx if verboseLogs { logger := klog.LoggerWithName(logger, pl.Name())
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 17 09:07:27 UTC 2024 - 60.9K bytes - Viewed (0) -
pkg/controller/volume/pvcprotection/pvc_protection_controller.go
return true } func (c *Controller) processPVC(ctx context.Context, pvcNamespace, pvcName string) error { logger := klog.FromContext(ctx) logger.V(4).Info("Processing PVC", "PVC", klog.KRef(pvcNamespace, pvcName)) startTime := time.Now() defer func() { logger.V(4).Info("Finished processing PVC", "PVC", klog.KRef(pvcNamespace, pvcName), "duration", time.Since(startTime)) }()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 14K bytes - Viewed (0) -
pkg/kubelet/config/apiserver.go
// the node sync with the apiserver has completed. klog.InfoS("Waiting for node sync before watching apiserver pods") go func() { for { if nodeHasSynced() { klog.V(4).InfoS("node sync completed") break } time.Sleep(WaitForAPIServerSyncPeriod) klog.V(4).InfoS("node sync has not completed yet") } klog.InfoS("Watching apiserver") newSourceApiserverFromLW(lw, updates) }() }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 21 19:46:27 UTC 2021 - 2.4K bytes - Viewed (0) -
pkg/volume/util/operationexecutor/operation_generator.go
simpleMsg, detailedMsg := volumeToMount.GenerateMsg("MapVolume.MapPodDevice succeeded", fmt.Sprintf("globalMapPath %q", globalMapPath)) verbosity := klog.Level(4) og.recorder.Eventf(volumeToMount.Pod, v1.EventTypeNormal, kevents.SuccessfulMountVolume, simpleMsg) klog.V(verbosity).InfoS(detailedMsg, "pod", klog.KObj(volumeToMount.Pod)) // Device mapping for pod device map path succeeded
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 101.4K 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 }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 09 21:21:12 UTC 2023 - 15K bytes - Viewed (0) -
cmd/kubeadm/app/util/etcd/etcd.go
for i := 0; i < retries; i++ { if i > 0 { klog.V(1).Infof("[etcd] Waiting %v until next retry\n", retryInterval) time.Sleep(retryInterval) } klog.V(2).Infof("[etcd] attempting to see if all cluster endpoints (%s) are available %d/%d", c.Endpoints, i+1, retries) _, err := c.getClusterStatus() if err != nil { switch err { case context.DeadlineExceeded: klog.V(1).Infof("[etcd] Attempt timed out") default:
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 11:04:08 UTC 2024 - 21.2K bytes - Viewed (0) -
pkg/kubelet/cm/devicemanager/plugin/v1beta1/handler.go
f.Close() klog.V(4).InfoS("Created deprecation file", "path", f.Name()) } return s } func (s *server) RegisterPlugin(pluginName string, endpoint string, versions []string, pluginClientTimeout *time.Duration) error { klog.V(2).InfoS("Registering plugin at endpoint", "plugin", pluginName, "endpoint", endpoint) return s.connectClient(pluginName, endpoint) } func (s *server) DeRegisterPlugin(pluginName string) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 16 14:21:15 UTC 2024 - 3.3K bytes - Viewed (0) -
pkg/proxy/serviceport.go
} } if len(invalidIPs) > 0 { klog.V(4).InfoS("Service change tracker ignored the following load balancer ingress IPs for given Service as they don't match the IP Family", "ipFamily", ipFamily, "loadBalancerIngressIPs", invalidIPs, "service", klog.KObj(service)) } if apiservice.NeedsHealthCheck(service) { p := service.Spec.HealthCheckNodePort if p == 0 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jan 09 08:17:56 UTC 2024 - 10.7K bytes - Viewed (0) -
pkg/kubelet/cm/cpumanager/state/state_mem.go
*/ package state import ( "sync" "k8s.io/klog/v2" "k8s.io/utils/cpuset" ) type stateMemory struct { sync.RWMutex assignments ContainerCPUAssignments defaultCPUSet cpuset.CPUSet } var _ State = &stateMemory{} // NewMemoryState creates new State for keeping track of cpu/pod assignment func NewMemoryState() State { klog.InfoS("Initialized new in-memory state store") return &stateMemory{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 03 16:26:09 UTC 2023 - 2.9K bytes - Viewed (0)