Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 24 for globalEndpoints (0.08 sec)

  1. cmd/admin-handlers-pools.go

    		if i, err := strconv.Atoi(v); err == nil && i >= 0 && i < len(globalEndpoints) {
    			idx = i
    		}
    	} else {
    		idx = globalEndpoints.GetPoolIdx(v)
    	}
    
    	if idx == -1 {
    		// We didn't find any matching pools, invalid input
    		writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, errInvalidArgument), r.URL)
    		return
    	}
    
    	if !proxyDecommissionRequest(ctx, globalEndpoints[idx].Endpoints[0], w, r) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 28 00:22:30 UTC 2024
    - 10.9K bytes
    - Viewed (0)
  2. cmd/server-main.go

    	}
    
    	// Register root CAs for remote ENVs
    	env.RegisterGlobalCAs(globalRootCAs)
    
    	globalEndpoints, setupType, err = createServerEndpoints(globalMinioAddr, ctxt.Layout.pools, ctxt.Layout.legacy)
    	logger.FatalIf(err, "Invalid command line arguments")
    	globalNodes = globalEndpoints.GetNodes()
    
    	globalIsErasure = (setupType == ErasureSetupType)
    	globalIsDistErasure = (setupType == DistErasureSetupType)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 24 21:50:11 UTC 2024
    - 35.2K bytes
    - Viewed (1)
  3. cmd/speedtest.go

    			// complete in total time of 10s.
    			if globalEndpoints.NEndpoints() < concurrency {
    				concurrency = globalEndpoints.NEndpoints()
    			}
    
    			// Check if we have local disks per pool less than
    			// the concurrency make sure we choose only the "start"
    			// concurrency to be equal to the lowest number of
    			// local disks per server.
    			for _, localDiskCount := range globalEndpoints.NLocalDisksPathsPerPool() {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon May 06 09:45:10 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  4. cmd/listen-notification-handlers.go

    	// Use buffered channel to take care of burst sends or slow w.Write()
    	mergeCh := make(chan []byte, globalAPIConfig.getRequestsPoolCapacity()*len(globalEndpoints.Hostnames()))
    	localCh := make(chan event.Event, globalAPIConfig.getRequestsPoolCapacity())
    
    	// Convert local messages to JSON and send to mergeCh
    	go func() {
    		buf := bytes.NewBuffer(grid.GetByteBuffer()[:0])
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 6K bytes
    - Viewed (0)
  5. cmd/bootstrap-peer-server.go

    		if _, ok := skipEnvs[envK]; ok {
    			continue
    		}
    		envValues[envK] = logger.HashString(env.Get(envK, ""))
    	}
    	scfg := &ServerSystemConfig{NEndpoints: globalEndpoints.NEndpoints(), MinioEnv: envValues, Checksum: binaryChecksum}
    	var cmdLines []string
    	for _, ep := range globalEndpoints {
    		cmdLines = append(cmdLines, ep.CmdLine)
    	}
    	scfg.CmdLines = cmdLines
    	return scfg
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  6. cmd/prepare-storage.go

    			if errors.Is(err, errDiskNotFound) && verboseLogging {
    				if globalEndpoints.NEndpoints() > 1 {
    					logger.Info("Unable to connect to %s: %v, will be retried", endpoints[i], isServerResolvable(endpoints[i], time.Second))
    				} else {
    					logger.Fatal(err, "Unable to connect to %s: %v", endpoints[i], isServerResolvable(endpoints[i], time.Second))
    				}
    			} else {
    				if globalEndpoints.NEndpoints() > 1 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 20:51:54 UTC 2024
    - 11.1K bytes
    - Viewed (1)
  7. cmd/admin-server-info.go

    		props.State = string(madmin.ItemOnline)
    		props.Disks = storageInfo.Disks
    	} else {
    		props.State = string(madmin.ItemInitializing)
    		props.Disks = getOfflineDisks("", globalEndpoints)
    	}
    
    	return props
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 4.9K bytes
    - Viewed (1)
  8. cmd/metrics-realtime.go

    	if types == madmin.MetricsNone {
    		return
    	}
    
    	byHostName := globalMinioAddr
    	if len(opts.hosts) > 0 {
    		server := getLocalServerProperty(globalEndpoints, &http.Request{
    			Host: globalLocalNodeName,
    		}, false)
    		if _, ok := opts.hosts[server.Endpoint]; ok {
    			byHostName = server.Endpoint
    		} else {
    			return
    		}
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Jun 01 05:16:24 UTC 2024
    - 6.3K bytes
    - Viewed (0)
  9. cmd/admin-handlers.go

    	// Keep 100k buffered channel.
    	// If receiver cannot keep up with that we drop events.
    	traceCh := make(chan []byte, 100000)
    	peers, _ := newPeerRestClients(globalEndpoints)
    	err = globalTrace.SubscribeJSON(traceOpts.TraceTypes(), traceCh, ctx.Done(), func(entry madmin.TraceInfo) bool {
    		return shouldTrace(entry, traceOpts)
    	}, nil)
    	if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 11:32:32 UTC 2024
    - 99.7K bytes
    - Viewed (0)
  10. cmd/admin-handlers_test.go

    	// Initialize minio server config.
    	if err := newTestConfig(globalMinioDefaultRegion, objLayer); err != nil {
    		cancel()
    		return nil, err
    	}
    
    	// Initialize boot time
    	globalBootTime = UTCNow()
    
    	globalEndpoints = mustGetPoolEndpoints(0, erasureDirs...)
    
    	initAllSubsystems(ctx)
    
    	initConfigSubsystem(ctx, objLayer)
    
    	globalIAMSys.Init(ctx, objLayer, globalEtcdClient, 2*time.Second)
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 24 10:24:01 UTC 2024
    - 13.9K bytes
    - Viewed (0)
Back to top