- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 477 for Starting (0.47 sec)
-
staging/src/k8s.io/apiserver/pkg/authentication/request/headerrequest/requestheader_controller.go
defer utilruntime.HandleCrash() defer c.queue.ShutDown() klog.Infof("Starting %s", c.name) defer klog.Infof("Shutting down %s", c.name) go c.configmapInformer.Run(ctx.Done()) // wait for caches to fill before starting your work if !cache.WaitForNamedCacheSync(c.name, ctx.Done(), c.configmapInformerSynced) { return }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 10.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/dynamiccertificates/tlsconfig.go
c.currentlyServedContent = newContent // this is single threaded, so we have no locking issue return nil } // RunOnce runs a single sync step to ensure that we have a valid starting configuration. func (c *DynamicServingCertificateController) RunOnce() error { return c.syncCerts() } // Run starts the kube-apiserver and blocks until stopCh is closed.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 10.3K bytes - Viewed (0) -
android/guava/src/com/google/common/graph/Graphs.java
// Graph query methods /** * Returns true if {@code graph} has at least one cycle. A cycle is defined as a non-empty subset * of edges in a graph arranged to form a path (a sequence of adjacent outgoing edges) starting * and ending with the same node. * * <p>This method will detect any non-empty cycle, including self-loops (a cycle of length 1). */ public static <N> boolean hasCycle(Graph<N> graph) {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Apr 01 16:15:01 UTC 2024 - 21.2K bytes - Viewed (0) -
maven-artifact/src/test/java/org/apache/maven/artifact/versioning/ComparableVersionTest.java
checkVersionsOrder(a, c); checkVersionsOrder(c, d); checkVersionsOrder(b, d); checkVersionsOrder(a, d); } /** * Test all versions are equal when starting with many leading zeroes regardless of string length * (related to MNG-6572 optimization) */ @Test void testVersionEqualWithLeadingZeroes() { // versions with string lengths from 1 to 19
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Tue Jan 09 06:39:47 UTC 2024 - 14K bytes - Viewed (0) -
src/net/http/cgi/host.go
// This file implements the host side of CGI (being the webserver // parent process). // Package cgi implements CGI (Common Gateway Interface) as specified // in RFC 3875. // // Note that using CGI means starting a new process to handle each // request, which is typically less efficient than using a // long-running server. This package is intended primarily for // compatibility with existing systems. package cgi import (
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Mar 07 20:46:32 UTC 2024 - 10.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/handlers/rest_test.go
type patchTestCase struct { name string // admission chain to use, nil is fine admissionMutation mutateObjectUpdateFunc admissionValidation rest.ValidateObjectUpdateFunc // startingPod is used as the starting point for the first Update startingPod *example.Pod // changedPod can be set as the "destination" pod for the patch, and the test will compute a patch from the startingPod to the changedPod,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 28 08:48:22 UTC 2024 - 41.8K bytes - Viewed (0) -
cmd/kube-scheduler/app/server.go
func Run(ctx context.Context, cc *schedulerserverconfig.CompletedConfig, sched *scheduler.Scheduler) error { logger := klog.FromContext(ctx) // To help debugging, immediately log version logger.Info("Starting Kubernetes Scheduler", "version", version.Get()) logger.Info("Golang settings", "GOGC", os.Getenv("GOGC"), "GOMAXPROCS", os.Getenv("GOMAXPROCS"), "GOTRACEBACK", os.Getenv("GOTRACEBACK")) // Configz registration.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 27 19:11:24 UTC 2024 - 14.3K bytes - Viewed (0) -
pkg/controlplane/apiserver/aggregator.go
if crdAPIEnabled { go crdRegistrationController.Run(5, context.Done()) } go func() { // let the CRD controller process the initial set of CRDs before starting the autoregistration controller. // this prevents the autoregistration controller's initial sync from deleting APIServices for CRDs that still exist.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 01 18:08:20 UTC 2024 - 15.3K bytes - Viewed (0) -
src/text/scanner/scanner.go
// A position is valid if Line > 0. type Position struct { Filename string // filename, if any Offset int // byte offset, starting at 0 Line int // line number, starting at 1 Column int // column number, starting at 1 (character count per line) } // IsValid reports whether the position is valid. func (pos *Position) IsValid() bool { return pos.Line > 0 }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Feb 26 20:57:51 UTC 2024 - 20.3K bytes - Viewed (0) -
cni/pkg/cmd/root.go
if cfg.InstallConfig.AmbientEnabled { // Start ambient controller // node agent will spawn a goroutine and watch the K8S API for events, // as well as listen for messages from the CNI binary. log.Info("Starting ambient node agent with inpod redirect mode") ambientAgent, err := nodeagent.NewServer(ctx, watchServerReady, cfg.InstallConfig.CNIEventAddress, nodeagent.AmbientArgs{ SystemNamespace: nodeagent.SystemNamespace,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 16:26:35 UTC 2024 - 13K bytes - Viewed (0)