Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 371 - 380 of 507 for selects (0.05 seconds)

  1. cmd/background-newdisks-heal-ops.go

    	// Perform automatic disk healing when a disk is replaced locally.
    	diskCheckTimer := time.NewTimer(defaultMonitorNewDiskInterval)
    	defer diskCheckTimer.Stop()
    
    	for {
    		select {
    		case <-ctx.Done():
    			return
    		case <-diskCheckTimer.C:
    			healDisks := globalBackgroundHealState.getHealLocalDiskEndpoints()
    			if len(healDisks) == 0 {
    				// Reset for next interval.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 16.5K bytes
    - Click Count (0)
  2. cmd/iam-etcd-store.go

    	// down `ch`
    	go func() {
    		for {
    		outerLoop:
    			watchCh := ies.client.Watch(ctx,
    				keyPath, etcd.WithPrefix(), etcd.WithKeysOnly())
    
    			for {
    				select {
    				case <-ctx.Done():
    					return
    				case watchResp, ok := <-watchCh:
    					if !ok {
    						time.Sleep(1 * time.Second)
    						// Upon an error on watch channel
    						// re-init the watch channel.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 13.9K bytes
    - Click Count (0)
  3. internal/ioutil/ioutil.go

    	ctx, cancel := context.WithTimeout(ctx, timeout)
    	defer cancel()
    
    	c := make(chan ioret[V], 1)
    	go func() {
    		v, err := work(ctx)
    		c <- ioret[V]{val: v, err: err}
    	}()
    
    	select {
    	case v := <-c:
    		return v.val, v.err
    	case <-ctx.Done():
    		var zero V
    		return zero, ctx.Err()
    	}
    }
    
    // DeadlineWorker implements the deadline/timeout resiliency pattern.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Feb 18 16:25:55 GMT 2025
    - 11.1K bytes
    - Click Count (0)
  4. helm-releases/minio-5.4.0.tgz

    .Values.consoleService.nodePort }} {{- else }} targetPort: {{ .Values.minioConsolePort }} {{- end }} {{- if .Values.consoleService.externalIPs }} externalIPs: {{- range $i , $ip := .Values.consoleService.externalIPs }} - {{ $ip }} {{- end }} {{- end }} selector: app: {{ template "minio.name" . }} release: {{ .Release.Name }} minio/templates/deployment.yaml {{- if eq .Values.mode "standalone" }} {{ $scheme := .Values.tls.enabled | ternary "https" "http" }} {{ $bucketRoot := or ($.Values.bucketRoot) ($.Values.mountPath)...
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Jan 03 05:34:47 GMT 2025
    - 21.7K bytes
    - Click Count (0)
  5. cmd/metrics-resource.go

    	resourceMetricsMapMu.Unlock()
    	metricsTimer := time.NewTimer(resourceMetricsCollectionInterval)
    	defer metricsTimer.Stop()
    
    	collectLocalResourceMetrics()
    
    	for {
    		select {
    		case <-GlobalContext.Done():
    			return
    		case <-metricsTimer.C:
    			collectLocalResourceMetrics()
    
    			// Reset the timer for next cycle.
    			metricsTimer.Reset(resourceMetricsCollectionInterval)
    		}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Oct 10 18:57:03 GMT 2025
    - 17.2K bytes
    - Click Count (0)
  6. CHANGELOG/CHANGELOG-1.9.md

    * Surface reasonable error when client detects connection closed. ([#51381](https://github.com/kubernetes/kubernetes/pull/51381), [@mengqiy](https://github.com/mengqiy))
    * Allow PSP's to specify a whitelist of allowed paths for host volume ([#50212](https://github.com/kubernetes/kubernetes/pull/50212), [@jhorwit2](https://github.com/jhorwit2))
    Created: Fri Dec 26 09:05:12 GMT 2025
    - Last Modified: Tue Nov 16 10:46:27 GMT 2021
    - 313.7K bytes
    - Click Count (0)
  7. compat/maven-embedder/src/main/java/org/fusesource/jansi/Ansi.java

                return value + 100;
            }
        }
    
        /**
         * Display attributes, also known as
         * <a href="https://en.wikipedia.org/wiki/ANSI_escape_code#SGR_(Select_Graphic_Rendition)_parameters">SGR
         * (Select Graphic Rendition) parameters</a>.
         */
        public enum Attribute {
            RESET(0, "RESET"),
            INTENSITY_BOLD(1, "INTENSITY_BOLD"),
            INTENSITY_FAINT(2, "INTENSITY_FAINT"),
            ITALIC(3, "ITALIC_ON"),
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Sat Apr 05 11:52:05 GMT 2025
    - 23.1K bytes
    - Click Count (0)
  8. association.go

    			selectedSaveColumns = append(selectedSaveColumns, ref.ForeignKey.Name)
    		}
    	}
    
    	associationDB := association.DB.Session(&Session{}).Model(nil)
    	if !association.DB.FullSaveAssociations {
    		associationDB.Select(selectedSaveColumns)
    	}
    	if len(omitColumns) > 0 {
    		associationDB.Omit(omitColumns...)
    	}
    	associationDB = associationDB.Session(&Session{})
    
    	switch reflectValue.Kind() {
    Created: Sun Dec 28 09:35:17 GMT 2025
    - Last Modified: Sun Oct 26 12:09:12 GMT 2025
    - 23.6K bytes
    - Click Count (0)
  9. cmd/endpoint.go

    		// Retry infinitely on Kubernetes and Docker swarm.
    		// This is needed as the remote hosts are sometime
    		// not available immediately.
    		select {
    		case <-globalOSSignalCh:
    			return fmt.Errorf("The endpoint resolution got interrupted")
    		default:
    			for i, resolved := range resolvedList {
    				if resolved {
    					// Continue if host is already resolved.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 34.5K bytes
    - Click Count (0)
  10. guava/src/com/google/common/collect/Lists.java

       * c, d, e]} with a partition size of 3 yields {@code [[a, b, c], [d, e]]} -- an outer list
       * containing two inner lists of three and two elements, all in the original order.
       *
       * <p>The outer list is unmodifiable, but reflects the latest state of the source list. The inner
       * lists are sublist views of the original list, produced on demand using {@link List#subList(int,
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 42.6K bytes
    - Click Count (0)
Back to Top