Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 708 for startm (0.11 sec)

  1. pkg/controller/resourcequota/resource_quota_monitor.go

    	}
    
    	// we're waiting until after the informer start that happens once all the controllers are initialized.  This ensures
    	// that they don't get unexpected events on their work queues.
    	<-qm.informersStarted
    
    	monitors := qm.monitors
    	started := 0
    	for _, monitor := range monitors {
    		if monitor.stopCh == nil {
    			monitor.stopCh = make(chan struct{})
    			qm.informerFactory.Start(qm.stopCh)
    			go monitor.Run()
    			started++
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 11.6K bytes
    - Viewed (0)
  2. src/cmd/doc/main.go

    	// work.
    	var period int
    	// slash+1: if there's no slash, the value is -1 and start is 0; otherwise
    	// start is the byte after the slash.
    	for start := slash + 1; start < len(arg); start = period + 1 {
    		period = strings.Index(arg[start:], ".")
    		symbol := ""
    		if period < 0 {
    			period = len(arg)
    		} else {
    			period += start
    			symbol = arg[period+1:]
    		}
    		// Have we identified a package already?
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue May 14 19:41:17 UTC 2024
    - 12.2K bytes
    - Viewed (0)
  3. src/internal/trace/internal/oldtrace/parser.go

    			g := gs[ev.G]
    			p := ps[ev.P]
    			if g.state != gRunnable {
    				return fmt.Errorf("g %d is not runnable before start (time %d)", ev.G, ev.Ts)
    			}
    			if p.g != 0 {
    				return fmt.Errorf("p %d is already running g %d while start g %d (time %d)", ev.P, p.g, ev.G, ev.Ts)
    			}
    			g.state = gRunning
    			g.evStart = ev
    			p.g = ev.G
    			if g.evCreate != nil {
    				ev.StkID = uint32(g.evCreate.Args[1])
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 24 21:15:28 UTC 2024
    - 46.8K bytes
    - Viewed (0)
  4. pkg/volume/util/operationexecutor/operation_executor_test.go

    	ch, quit := make(chan interface{}), make(chan interface{})
    	return ch, quit, NewOperationExecutor(newFakeOperationGenerator(ch, quit))
    }
    
    // This function starts by writing to ch and blocks on the quit channel
    // until it is closed by the currently running test
    func startOperationAndBlock(ch chan<- interface{}, quit <-chan interface{}) {
    	ch <- nil
    	<-quit
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 26.9K bytes
    - Viewed (0)
  5. docs/en/docs/deployment/concepts.md

    Here are some possible ideas:
    
    * An "Init Container" in Kubernetes that runs before your app container
    * A bash script that runs the previous steps and then starts your application
        * You would still need a way to start/restart *that* bash script, detect errors, etc.
    
    !!! tip
    Registered: Mon Jun 17 08:32:26 UTC 2024
    - Last Modified: Thu May 02 22:37:31 UTC 2024
    - 18K bytes
    - Viewed (0)
  6. pkg/kubelet/cm/container_manager_linux.go

    		err := cm.draManager.Start(dra.ActivePodsFunc(activePods), sourcesReady)
    		if err != nil {
    			return fmt.Errorf("start dra manager error: %w", err)
    		}
    	}
    
    	// Initialize CPU manager
    	err := cm.cpuManager.Start(cpumanager.ActivePodsFunc(activePods), sourcesReady, podStatusProvider, runtimeService, containerMap)
    	if err != nil {
    		return fmt.Errorf("start cpu manager error: %v", err)
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 21 10:18:16 UTC 2024
    - 35.1K bytes
    - Viewed (0)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top