Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for depIdx (0.12 sec)

  1. cmd/site-replication.go

    	depIDs := make([]string, 0, len(c.state.Peers))
    	for d := range c.state.Peers {
    		depIDs = append(depIDs, d)
    	}
    	errs := make([]error, len(c.state.Peers))
    	var wg sync.WaitGroup
    	wg.Add(len(depIDs))
    	for i := range depIDs {
    		go func(i int) {
    			defer wg.Done()
    			if depIDs[i] == globalDeploymentID() {
    				if selfActionFn != nil {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 184.3K bytes
    - Viewed (0)
  2. platforms/software/dependency-management/src/integTest/groovy/org/gradle/integtests/resolve/platforms/PlatformResolveIntegrationTest.groovy

            def depE = mavenHttpRepo.module('org.test', 'depE', '1.0').dependsOn(depF).publish()
            def depD = mavenHttpRepo.module('org.test', 'depD', '1.0').dependsOn(depE).publish()
    
            depExcluded.allowAll()
            depA.allowAll()
            depB.allowAll()
            depC.allowAll()
            depD.allowAll()
            depE.allowAll()
            depF.allowAll()
            platform.allowAll()
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Wed Mar 13 19:52:38 UTC 2024
    - 25.9K bytes
    - Viewed (0)
  3. platforms/ide/tooling-api/src/crossVersionTest/groovy/org/gradle/plugins/ide/tooling/r56/ToolingApiEclipseModelTestSourcesCrossVersionSpec.groovy

            depC.classpathAttributes.find { it.name == 'test' && it.value == 'true' }
            depC.classpathAttributes.find { it.name == 'without_test_code' && it.value == 'true' }
            depD.classpathAttributes.find { it.name == 'test' && it.value == 'true' }
            depD.classpathAttributes.find { it.name == 'without_test_code' && it.value == 'false' }
        }
    
        @TargetGradleVersion(">=7.5")
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu May 16 10:10:39 UTC 2024
    - 8.5K bytes
    - Viewed (0)
  4. cmd/metrics-realtime.go

    	c "github.com/shirou/gopsutil/v3/cpu"
    	"github.com/shirou/gopsutil/v3/load"
    )
    
    type collectMetricsOpts struct {
    	hosts map[string]struct{}
    	disks map[string]struct{}
    	jobID string
    	depID string
    }
    
    func collectLocalMetrics(types madmin.MetricType, opts collectMetricsOpts) (m madmin.RealtimeMetrics) {
    	if types == madmin.MetricsNone {
    		return
    	}
    
    	byHostName := globalMinioAddr
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Sat Jun 01 05:16:24 UTC 2024
    - 6.3K bytes
    - Viewed (0)
  5. cmd/peer-rest-common.go

    	peerRESTAccessKey       = "access-key"
    	peerRESTMetricsTypes    = "types"
    	peerRESTDisk            = "disk"
    	peerRESTHost            = "host"
    	peerRESTJobID           = "job-id"
    	peerRESTDepID           = "depID"
    	peerRESTStartRebalance  = "start-rebalance"
    	peerRESTMetrics         = "metrics"
    	peerRESTDryRun          = "dry-run"
    
    	peerRESTURL         = "url"
    	peerRESTSha256Sum   = "sha256sum"
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon May 06 09:45:10 UTC 2024
    - 2.8K bytes
    - Viewed (0)
  6. kotlin-js-store/yarn.lock

      integrity sha512-9iE1PgSik9HeIIw2JO94IidnE3eBoQrFJ3w7sFuzSX4DpmZ3v5sZpUiV5Swcf6mQEF+Y0ru8Neo+p+nyh2J+hQ==
    
    depd@2.0.0:
      version "2.0.0"
      resolved "https://registry.yarnpkg.com/depd/-/depd-2.0.0.tgz#b696163cc757560d09cf22cc8fad1571b79e76df"
      integrity sha512-g7nH6P6dyDioJogAAGprGpCtVImJhpPk/roCzdb3fIh61/s/nPsfR6onyMwkCAR/OlC3yBC0lESvUoQEAssIrw==
    
    destroy@1.2.0:
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Sat Jul 22 12:28:51 UTC 2023
    - 87.4K bytes
    - Viewed (0)
  7. cmd/peer-rest-client.go

    	for disk := range opts.disks {
    		values.Add(peerRESTDisk, disk)
    	}
    	for host := range opts.hosts {
    		values.Add(peerRESTHost, host)
    	}
    	values.Set(peerRESTJobID, opts.jobID)
    	values.Set(peerRESTDepID, opts.depID)
    	v, err := getMetricsRPC.Call(ctx, client.gridConn(), grid.NewURLValuesWith(values))
    	return v.ValueOrZero(), err
    }
    
    // GetProcInfo - fetch MinIO process information for a remote node.
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 26.1K bytes
    - Viewed (0)
  8. cmd/admin-handlers.go

    			}
    		}
    	}
    	dID := r.Form.Get("by-depID")
    	done := ctx.Done()
    	ticker := time.NewTicker(interval)
    	defer ticker.Stop()
    	w.Header().Set(xhttp.ContentType, string(mimeJSON))
    
    	enc := json.NewEncoder(w)
    	for n > 0 {
    		var m madmin.RealtimeMetrics
    		mLocal := collectLocalMetrics(types, collectMetricsOpts{
    			hosts: hostMap,
    			disks: diskMap,
    			jobID: jobID,
    			depID: dID,
    		})
    		m.Merge(&mLocal)
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 98K bytes
    - Viewed (0)
  9. cmd/peer-rest-server.go

    		hostMap[host] = struct{}{}
    	}
    
    	info := collectLocalMetrics(types, collectMetricsOpts{
    		disks: diskMap,
    		hosts: hostMap,
    		jobID: values.Get(peerRESTJobID),
    		depID: values.Get(peerRESTDepID),
    	})
    	return madminRealtimeMetrics.NewJSONWith(&info), nil
    }
    
    // GetSysConfigHandler - returns system config information.
    // (only the config that are of concern to minio)
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 52.1K bytes
    - Viewed (0)
Back to top