- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 71 for MONITOR (0.14 sec)
-
pkg/kubelet/images/image_gc_manager.go
return im, nil } func (im *realImageGCManager) Start() { ctx := context.Background() go wait.Until(func() { _, err := im.detectImages(ctx, time.Now()) if err != nil { klog.InfoS("Failed to monitor images", "err", err) } }, 5*time.Minute, wait.NeverStop) // Start a goroutine periodically updates image cache. go wait.Until(func() { images, err := im.runtime.ListImages(ctx) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 19.4K bytes - Viewed (0) -
pkg/kubelet/volumemanager/populator/desired_state_of_world_populator.go
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License. */ /* Package populator implements interfaces that monitor and keep the states of the caches in sync with the "ground truth". */ package populator import ( "context" "errors" "fmt" "sync" "time" "k8s.io/klog/v2" v1 "k8s.io/api/core/v1"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 11 09:02:45 UTC 2024 - 23.8K bytes - Viewed (0) -
manifests/addons/dashboards/istio-mesh-dashboard.json
"mode": "html" }, "pluginVersion": "10.1.5",
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Mar 28 02:28:01 UTC 2024 - 46.4K bytes - Viewed (0) -
pkg/controller/garbagecollector/garbagecollector.go
// client. This is a leaky abstraction and assumes behavior about the REST // mapper, but we'll deal with it for now. gc.restMapper.Reset() logger.V(4).Info("reset restmapper") // Perform the monitor resync and wait for controllers to report cache sync. // // NOTE: It's possible that newResources will diverge from the resources // discovered by restMapper during the call to Reset, since they are
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 32.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/metrics/metrics.go
} // MonitorRequest handles standard transformations for client and the reported verb and then invokes Monitor to record // a request. verb must be uppercase to be backwards compatible with existing monitoring tooling.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Sep 27 07:29:19 UTC 2023 - 35K bytes - Viewed (0) -
cmd/server-main.go
if globalBucketMetadataSys == nil { globalBucketMetadataSys = NewBucketMetadataSys() } else { // Reinitialize safely when testing. globalBucketMetadataSys.Reset() } // Create the bucket bandwidth monitor globalBucketMonitor = bandwidth.NewMonitor(ctx, uint64(totalNodeCount())) // Create a new config system. globalConfigSys = NewConfigSys() // Create new IAM system. globalIAMSys = NewIAMSys()
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Jun 04 15:12:57 UTC 2024 - 34.5K bytes - Viewed (1) -
pkg/kubelet/server/server.go
) // ServeHTTP responds to HTTP requests on the Kubelet. func (s *Server) ServeHTTP(w http.ResponseWriter, req *http.Request) { handler := httplog.WithLogging(s.restfulCont, statusesNoTracePred) // monitor http requests var serverType string if s.auth == nil { serverType = "readonly" } else { serverType = "readwrite" }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 40.1K bytes - Viewed (0) -
src/net/lookup_test.go
defer dnsWaitGroup.Wait() var N = 5000 if runtime.GOOS == "darwin" || runtime.GOOS == "ios" { // On Darwin this test consumes kernel threads much // than other platforms for some reason. // When we monitor the number of allocated Ms by // observing on runtime.newm calls, we can see that it // easily reaches the per process ceiling // kern.num_threads when CGO_ENABLED=1 and // GODEBUG=netdns=go. N = 500 }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 41.4K bytes - Viewed (0) -
pilot/pkg/bootstrap/server.go
} // Monitoring Server. if err := s.initMonitor(args.ServerOptions.MonitoringAddr); err != nil { return fmt.Errorf("error initializing monitor: %v", err) } // Readiness Handler. s.httpMux.HandleFunc("/ready", s.istiodReadyHandler) return nil } // initDiscoveryService initializes discovery server on plain text port.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 17:48:28 UTC 2024 - 46.3K bytes - Viewed (0) -
internal/grid/connection.go
} atomic.StoreUint32((*uint32)(&c.state), uint32(s)) if debugPrint { fmt.Println(c.Local, "updateState:", gotState, "->", s) } c.connChange.Broadcast() } // monitorState will monitor the state of the connection and close the net.Conn if it changes. func (c *Connection) monitorState(conn net.Conn, cancel context.CancelCauseFunc) { c.connChange.L.Lock() defer c.connChange.L.Unlock() for {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 44.8K bytes - Viewed (0)