Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 40 for goOffline (0.05 seconds)

  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
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 14.7K bytes
    - Click Count (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 {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 20.9K bytes
    - Click Count (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 {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 16.1K bytes
    - Click Count (0)
  4. 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,
    		},
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 1.9K bytes
    - Click Count (0)
  5. 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)
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Wed Oct 08 07:36:42 GMT 2025
    - 21.3K bytes
    - Click Count (0)
  6. 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 {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Oct 24 04:05:31 GMT 2025
    - 6.9K bytes
    - Click Count (0)
  7. 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()),
    	)
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Oct 24 04:06:31 GMT 2025
    - 16.7K bytes
    - Click Count (0)
  8. .github/workflows/check-markdown-links.yml

              # - notes.md and notes-templates.md - because they are a part of user guide
              # - Kotlin's Module.md - because it's a part of the Kotlin DSL docs
              args: >
                --no-progress --offline '**/*.md' --include-fragments
                --exclude-path 'platforms/documentation/docs/src/docs/release/notes.md'
                --exclude-path 'platforms/documentation/docs/src/docs/release/notes-template.md'
    Created: Wed Dec 31 11:36:14 GMT 2025
    - Last Modified: Thu Nov 20 22:15:20 GMT 2025
    - 920 bytes
    - Click Count (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 {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Oct 24 04:05:31 GMT 2025
    - 4.9K bytes
    - Click Count (0)
  10. internal/config/lambda/parse.go

    	logger.LogOnceIf(ctx, logSubsys, err, id, errKind...)
    }
    
    // ErrTargetsOffline - Indicates single/multiple target failures.
    var ErrTargetsOffline = errors.New("one or more targets are offline. Please use `mc admin info --json` to check the offline targets")
    
    // TestSubSysLambdaTargets - tests notification targets of given subsystem
    func TestSubSysLambdaTargets(ctx context.Context, cfg config.Config, subSys string, transport *http.Transport) error {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 6K bytes
    - Click Count (0)
Back to Top