- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 1,417 for startm (0.22 sec)
-
staging/src/k8s.io/api/apps/v1/types_swagger_doc_generated.go
"start": "start is the number representing the first replica's index. It may be used to number replicas from an alternate index (eg: 1-indexed) over the default 0-indexed names, or to orchestrate progressive movement of replicas from one StatefulSet to another. If set, replica indices will be in the range:\n [.spec.ordinals.start, .spec.ordinals.start + .spec.replicas).\nIf unset, defaults to 0. Replica indices will be in the...
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 07:14:59 UTC 2024 - 32.5K bytes - Viewed (0) -
src/strings/strings.go
start := -1 // valid span start if >= 0 for end, rune := range s { if f(rune) { if start >= 0 { spans = append(spans, span{start, end}) // Set start to a negative value. // Note: using -1 here consistently and reproducibly // slows down this code by a several percent on amd64. start = ^start } } else { if start < 0 { start = end } } }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 03 16:48:16 UTC 2024 - 31.2K bytes - Viewed (0) -
pkg/controller/nodeipam/node_ipam_controller.go
ic.nodeLister = nodeInformer.Lister() ic.nodeInformerSynced = nodeInformer.Informer().HasSynced return ic, nil } // Run starts an asynchronous loop that monitors the status of cluster nodes. func (nc *Controller) Run(ctx context.Context) { defer utilruntime.HandleCrash() // Start event processing pipeline. nc.eventBroadcaster.StartStructuredLogging(3)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 16:18:38 UTC 2024 - 5.4K bytes - Viewed (0) -
pilot/pkg/bootstrap/server.go
} } return clusterID } // Start starts all components of the error serving tap http serverPilot discovery service on the port specified in DiscoveryServerOptions. // If Port == 0, a port number is automatically chosen. Content serving is started by this method, // but is executed asynchronously. Serving can be canceled at any time by closing the provided stop channel. func (s *Server) Start(stop <-chan struct{}) error {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 17:48:28 UTC 2024 - 46.3K bytes - Viewed (0) -
pkg/kubelet/certificate/kubelet.go
func (m *kubeletServerCertificateDynamicFileManager) Current() *tls.Certificate { return m.currentTLSCertificate.Load() } // Start starts watching the certificate and key files func (m *kubeletServerCertificateDynamicFileManager) Start() { var ctx context.Context ctx, m.cancelFn = context.WithCancel(context.Background()) go m.dynamicCertificateContent.Run(ctx, 1) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 03:07:16 UTC 2024 - 10.3K bytes - Viewed (0) -
cni/pkg/log/uds.go
} l.loggingServer = loggingServer pluginLog.SetOutputLevel(level) return l } // StartUDSLogServer starts up a UDS server which receives log reported from CNI network plugin. func (l *UDSLogger) StartUDSLogServer(sockAddress string, stop <-chan struct{}) error { if sockAddress == "" { return nil } log.Info("Start a UDS server for CNI plugin logs") unixListener, err := uds.NewListener(sockAddress) if err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 16:26:28 UTC 2024 - 4.7K bytes - Viewed (0) -
cmd/consolelogger.go
if err != nil { logger.FatalIf(err, "Unable to start console logging subsystem") } sys.nodeName = host.Name } // HasLogListeners returns true if console log listeners are registered // for this node or peers func (sys *HTTPConsoleLoggerSys) HasLogListeners() bool { return sys != nil && sys.pubsub.Subscribers() > 0 } // Subscribe starts console logging for this node.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 5.5K bytes - Viewed (0) -
pkg/kubelet/cm/dra/plugin/noderesources.go
} } // run is running in the background. It handles blocking initialization (like // syncing the informer) and then syncs the actual with the desired state. func (c *nodeResourcesController) run(ctx context.Context) { logger := klog.FromContext(ctx) // When kubelet starts, we have two choices: // - Sync immediately, which in practice will delete all ResourceSlices
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 27 20:12:53 UTC 2024 - 16.6K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ClosingFuture.java
} } private void checkAndUpdateState(State oldState, State newState) { checkState( compareAndUpdateState(oldState, newState), "Expected state to be %s, but it was %s", oldState, newState); } private boolean compareAndUpdateState(State oldState, State newState) { return state.compareAndSet(oldState, newState); }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue May 07 12:37:15 UTC 2024 - 98.3K bytes - Viewed (0) -
pkg/kubelet/kubelet.go
if kl.makeIPTablesUtilChains { kl.initNetworkUtil() } // Start component sync loops. kl.statusManager.Start() // Start syncing RuntimeClasses if enabled. if kl.runtimeClassManager != nil { kl.runtimeClassManager.Start(wait.NeverStop) } // Start the pod lifecycle event generator. kl.pleg.Start() // Start eventedPLEG only if EventedPLEG feature gate is enabled.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 126.1K bytes - Viewed (0)