Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 67 for poll (0.12 sec)

  1. cmd/api-errors.go

    	},
    	ErrAdminRebalanceAlreadyStarted: {
    		Code:           "XMinioAdminRebalanceAlreadyStarted",
    		Description:    "Pool rebalance is already started",
    		HTTPStatusCode: http.StatusConflict,
    	},
    	ErrAdminRebalanceNotStarted: {
    		Code:           "XMinioAdminRebalanceNotStarted",
    		Description:    "Pool rebalance is not started",
    		HTTPStatusCode: http.StatusNotFound,
    	},
    	ErrMaximumExpires: {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 91.4K bytes
    - Viewed (7)
  2. cmd/update.go

    	if IsKubernetes() {
    		return kubernetesDeploymentDoc
    	}
    
    	// Check if we are docker environment, return docker update command
    	if IsDocker() {
    		// Construct release tag name.
    		return fmt.Sprintf("podman pull quay.io/minio/minio:%s", releaseTag)
    	}
    
    	// For binary only installations, we return link to the latest binary.
    	if runtime.GOOS == "windows" {
    		return MinioReleaseURL + "minio.exe"
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 24 04:08:47 GMT 2024
    - 18.7K bytes
    - Viewed (0)
  3. cmd/metrics-v2.go

    		cacheInterval:    1 * time.Minute,
    		metricsGroupOpts: opts,
    	}
    	mg.RegisterRead(func(_ context.Context) []MetricV2 {
    		ml := []MetricV2{}
    
    		// metrics pertinent to site replication - overall roll up.
    		if globalSiteReplicationSys.isEnabled() {
    			m, err := globalSiteReplicationSys.getSiteMetrics(GlobalContext)
    			if err != nil {
    				metricsLogIf(GlobalContext, err)
    				return ml
    			}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 25 22:01:31 GMT 2024
    - 132.6K bytes
    - Viewed (0)
  4. cmd/erasure-server-pool-decom_test.go

    			name:           "Invalid-Decom-Pending-Pool-Removal",
    			expectedErr:    false,
    			expectedUpdate: true,
    		},
    		{
    			meta:           nmeta1,
    			pools:          reducedPools,
    			name:           "Correct-Decom-Pool-Removed",
    			expectedErr:    false,
    			expectedUpdate: true,
    		},
    		{
    			meta:           poolMeta{}, // no-pool info available fresh setup.
    			pools:          pools,
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Jul 03 16:47:40 GMT 2023
    - 4.8K bytes
    - Viewed (0)
  5. cmd/metacache-server-pool.go

    	// Use ID as the object name...
    	o.pool = z.getAvailablePoolIdx(ctx, minioMetaBucket, o.ID, 10<<20)
    	if o.pool < 0 {
    		// No space or similar, don't persist the listing.
    		o.pool = 0
    		o.Create = false
    		o.ID = ""
    		o.Transient = true
    		return entries, errDiskFull
    	}
    	o.set = z.serverPools[o.pool].getHashedSetIndex(o.ID)
    	saver := z.serverPools[o.pool].sets[o.set]
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 12.8K bytes
    - Viewed (0)
  6. cmd/erasure-server-pool-decom.go

    			CmdLine:    pool.endpoints.CmdLine,
    			ID:         idx,
    			LastUpdate: UTCNow(),
    		})
    	}
    	return newMeta
    }
    
    func (z *erasureServerPools) IsDecommissionRunning() bool {
    	z.poolMetaMutex.RLock()
    	defer z.poolMetaMutex.RUnlock()
    	meta := z.poolMeta
    	for _, pool := range meta.Pools {
    		if pool.Decommission != nil &&
    			!pool.Decommission.Complete &&
    			!pool.Decommission.Failed &&
    			!pool.Decommission.Canceled {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 15:18:21 GMT 2024
    - 41.5K bytes
    - Viewed (1)
  7. internal/bpool/bpool.go

    	}
    	select {
    	case bp.c <- b:
    		// buffer went back into pool
    	default:
    		// buffer didn't go back into pool, just discard
    	}
    }
    
    // Width returns the width of the byte arrays in this pool.
    func (bp *BytePoolCap) Width() (n int) {
    	if bp == nil {
    		return 0
    	}
    	return bp.w
    }
    
    // WidthCap returns the cap width of the byte arrays in this pool.
    func (bp *BytePoolCap) WidthCap() (n int) {
    	if bp == nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 19 16:44:59 GMT 2024
    - 2.6K bytes
    - Viewed (0)
  8. internal/s3select/csv/reader.go

    	queue        chan *queueItem  // output from workers in order
    	err          error            // global error state, only touched by Reader.Read
    	bufferPool   sync.Pool        // pool of []byte objects for input
    	csvDstPool   sync.Pool        // pool of [][]string used for output
    	close        chan struct{}    // used for shutting down the splitter before end of stream
    	readerWg     sync.WaitGroup   // used to keep track of async reader.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 8.9K bytes
    - Viewed (0)
  9. cmd/admin-router.go

    			adminRouter.Methods(http.MethodPost).Path(adminVersion+"/pools/cancel").HandlerFunc(adminMiddleware(adminAPI.CancelDecommission, traceAllFlag)).Queries("pool", "{pool:.*}")
    
    			// Rebalance operations
    			adminRouter.Methods(http.MethodPost).Path(adminVersion + "/rebalance/start").HandlerFunc(adminMiddleware(adminAPI.RebalanceStart, traceAllFlag))
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Mar 10 21:09:36 GMT 2024
    - 25.5K bytes
    - Viewed (0)
  10. internal/grid/handlers.go

    			if r != rZero {
    				if rc, ok := any(r).(Recycler); ok {
    					rc.Recycle()
    				}
    			}
    		}
    	}
    	pool := sync.Pool{
    		New: func() interface{} {
    			return newRT()
    		},
    	}
    	return func() RT { return pool.Get().(RT) },
    		func(r RT) {
    			if r != rZero {
    				pool.Put(r)
    			}
    		}
    }
    
    // NewSingleHandler creates a typed handler that can provide Marshal/Unmarshal.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 23 17:15:52 GMT 2024
    - 27.1K bytes
    - Viewed (0)
Back to top