Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 50 for goOffline (0.06 sec)

  1. internal/rest/client.go

    	// If not set the client will not keep track of health.
    	// Calling this returns true or false if the target
    	// is online or offline.
    	HealthCheckFn func() bool
    
    	// HealthCheckRetryUnit will be used to calculate the exponential
    	// backoff when trying to reconnect to an offline node
    	HealthCheckReconnectUnit time.Duration
    
    	// HealthCheckTimeout determines timeout for each call.
    	HealthCheckTimeout time.Duration
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 14.7K bytes
    - Viewed (0)
  2. cmd/bucket-targets.go

    					var lastOnline time.Time
    					var offline time.Duration
    					//	var deploymentID string
    					sys.hMutex.RLock()
    					prev, ok := sys.hc[result.Endpoint.Host]
    					sys.hMutex.RUnlock()
    					if ok {
    						if prev.Online != result.Online || !result.Online {
    							if !prev.lastHCAt.IsZero() {
    								offline = time.Since(prev.lastHCAt) + prev.offlineDuration
    							} else {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 20.9K bytes
    - Viewed (0)
  3. cmd/erasure.go

    		if di.RootDisk {
    			rootDiskCount++
    		}
    	}
    
    	// Count offline disks as well to ensure consistent
    	// reportability of offline drives on local setups.
    	if len(disksInfo) == (rootDiskCount + offlineDisks.Sum()) {
    		// Success.
    		return onlineDisks, offlineDisks
    	}
    
    	// Root disk should be considered offline
    	for i := range disksInfo {
    		ep := disksInfo[i].Endpoint
    		if disksInfo[i].RootDisk {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 16.1K bytes
    - Viewed (0)
  4. compat/maven-embedder/src/main/java/org/apache/maven/cli/CLIManager.java

                    .valueSeparator('=')
                    .desc("Define a user property")
                    .build());
            options.addOption(Option.builder(Character.toString(OFFLINE))
                    .longOpt("offline")
                    .desc("Work offline")
                    .build());
            options.addOption(Option.builder(Character.toString(VERSION))
                    .longOpt("version")
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Wed Aug 06 04:56:48 UTC 2025
    - 17.8K bytes
    - Viewed (0)
  5. cmd/erasure-multipart-conditional_test.go

    	if err != nil {
    		t.Fatal(err)
    	}
    	existingETag := objInfo.ETag
    
    	// Simulate read quorum failure by taking enough disks offline
    	// With 16 disks (EC 8+8), read quorum is 9. Taking 8 disks offline leaves only 8,
    	// which is below read quorum.
    	erasureDisks := xl.getDisks()
    	z.serverPools[0].erasureDisksMu.Lock()
    	xl.getDisks = func() []StorageAPI {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Oct 24 04:05:31 UTC 2025
    - 6.9K bytes
    - Viewed (0)
  6. cmd/metrics.go

    			nil, nil),
    		prometheus.GaugeValue,
    		float64(GetTotalUsableCapacityFree(server.Disks, sinfo)),
    	)
    
    	// MinIO Offline Disks per node
    	ch <- prometheus.MustNewConstMetric(
    		prometheus.NewDesc(
    			prometheus.BuildFQName(minioNamespace, "disks", "offline"),
    			"Total number of offline drives in current MinIO server instance",
    			nil, nil),
    		prometheus.GaugeValue,
    		float64(offlineDisks.Sum()),
    	)
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Oct 24 04:06:31 UTC 2025
    - 16.7K bytes
    - Viewed (0)
  7. internal/rest/client_test.go

    	}{
    		{
    			name:   "url.Error",
    			err:    &url.Error{Op: "PUT", URL: "http://localhost/1234", Err: restError("remote server offline")},
    			target: &url.Error{},
    			want:   true,
    		},
    		{
    			name: "net.Error",
    			err:  &url.Error{Op: "PUT", URL: "http://localhost/1234", Err: restError("remote server offline")},
    			want: true,
    		},
    		{
    			name: "net.Error-unmatched",
    			err:  errors.New("something"),
    			want: false,
    		},
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 1.9K bytes
    - Viewed (0)
  8. impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/CommonsCliOptions.java

                        .desc("Defines the color mode of the output. Supported are 'auto', 'always', 'never'.")
                        .get());
                options.addOption(Option.builder(OFFLINE)
                        .longOpt("offline")
                        .desc("Work offline")
                        .get());
    
                // Parameters handled by script
                options.addOption(Option.builder()
                        .longOpt(DEBUG)
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Wed Oct 08 07:36:42 UTC 2025
    - 21.3K bytes
    - Viewed (0)
  9. cmd/erasure-object-conditional_test.go

    	if err != nil {
    		t.Fatal(err)
    	}
    	existingETag := objInfo.ETag
    
    	// Simulate read quorum failure by taking enough disks offline
    	// With 16 disks (EC 8+8), read quorum is 9. Taking 8 disks offline leaves only 8,
    	// which is below read quorum.
    	erasureDisks := xl.getDisks()
    	z.serverPools[0].erasureDisksMu.Lock()
    	xl.getDisks = func() []StorageAPI {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Oct 24 04:05:31 UTC 2025
    - 4.9K bytes
    - Viewed (0)
  10. internal/dsync/drwmutex.go

    		go func(index int, c NetLocker) {
    			defer wg.Done()
    
    			if c == nil {
    				ch <- refreshResult{offline: true}
    				return
    			}
    
    			ctx, cancel := context.WithTimeout(ctx, ds.Timeouts.RefreshCall)
    			defer cancel()
    
    			refreshed, err := c.Refresh(ctx, args)
    			if err != nil {
    				ch <- refreshResult{offline: true}
    				log("dsync: Unable to call Refresh failed with %s for %#v at %s\n", err, args, c)
    			} else {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 20.3K bytes
    - Viewed (0)
Back to top