Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 60 for global (0.18 sec)

  1. cmd/global-heal.go

    		healedItemsMap:     make(map[madmin.HealItemType]int64),
    		healFailedItemsMap: make(map[string]int64),
    	}
    }
    
    // getLocalBackgroundHealStatus will return the heal status of the local node
    func getLocalBackgroundHealStatus(ctx context.Context, o ObjectLayer) (madmin.BgHealState, bool) {
    	if globalBackgroundHealState == nil {
    		return madmin.BgHealState{}, false
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 26 06:32:14 GMT 2024
    - 15K bytes
    - Viewed (1)
  2. cmd/globals.go

    	globalNodes []Node
    
    	// The name of this local node, fetched from arguments
    	globalLocalNodeName    string
    	globalLocalNodeNameHex string
    	globalNodeNamesHex     = make(map[string]struct{})
    
    	// The global subnet config
    	globalSubnetConfig subnet.Config
    
    	// The global callhome config
    	globalCallhomeConfig callhome.Config
    
    	// The global drive config
    	globalDriveConfig drive.Config
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 24 04:08:47 GMT 2024
    - 16.5K bytes
    - Viewed (0)
  3. cmd/signals.go

    	"github.com/minio/minio/internal/logger"
    )
    
    func handleSignals() {
    	// Custom exit function
    	exit := func(success bool) {
    		if globalLoggerOutput != nil {
    			globalLoggerOutput.Close()
    		}
    
    		// If global profiler is set stop before we exit.
    		globalProfilerMu.Lock()
    		defer globalProfilerMu.Unlock()
    		for _, p := range globalProfiler {
    			p.Stop()
    		}
    
    		if success {
    			os.Exit(0)
    		}
    
    		os.Exit(1)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 17:57:52 GMT 2024
    - 2.8K bytes
    - Viewed (0)
  4. cmd/mrf.go

    	versions            []byte
    	setIndex, poolIndex int
    	queued              time.Time
    	scanMode            madmin.HealScanMode
    }
    
    // mrfState sncapsulates all the information
    // related to the global background MRF.
    type mrfState struct {
    	opCh chan partialOperation
    }
    
    // Add a partial S3 operation (put/delete) when one or more disks are offline.
    func (m *mrfState) addPartialOp(op partialOperation) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 23 17:15:52 GMT 2024
    - 3.2K bytes
    - Viewed (0)
  5. internal/config/browser/browser.go

    		config.KV{
    			Key:   browserHSTSPreload,
    			Value: config.EnableOff,
    		},
    		config.KV{
    			Key:   browserReferrerPolicy,
    			Value: "strict-origin-when-cross-origin",
    		},
    	}
    )
    
    // configLock is a global lock for browser config
    var configLock sync.RWMutex
    
    // Config storage class configuration
    type Config struct {
    	CSPPolicy             string `json:"csp_policy"`
    	HSTSSeconds           int    `json:"hsts_seconds"`
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 11 01:10:30 GMT 2024
    - 5.8K bytes
    - Viewed (0)
  6. cmd/erasure-object_test.go

    		Standard: storageclass.StorageClass{
    			Parity: 6,
    		},
    	}
    
    	// Object for test case 5 - RRS StorageClass defined as Parity 2, MetaData in PutObject requesting RRS Class
    	// Reset global storage class flags
    	object5 := "object5"
    	metadata5 := make(map[string]string)
    	metadata5["x-amz-storage-class"] = storageclass.RRS
    	globalStorageClass.Update(storageclass.Config{
    		RRS: storageclass.StorageClass{
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Jan 30 20:43:25 GMT 2024
    - 36.8K bytes
    - Viewed (0)
  7. cmd/grid.go

    	"github.com/minio/minio/internal/rest"
    )
    
    // globalGrid is the global grid manager.
    var globalGrid atomic.Pointer[grid.Manager]
    
    // globalGridStart is a channel that will block startup of grid connections until closed.
    var globalGridStart = make(chan struct{})
    
    func initGlobalGrid(ctx context.Context, eps EndpointServerPools) error {
    	hosts, local := eps.GridHosts()
    	g, err := grid.NewManager(ctx, grid.ManagerOptions{
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Mar 26 15:00:38 GMT 2024
    - 2K bytes
    - Viewed (0)
  8. cmd/test-utils_test.go

    	globalIAMSys = nil
    }
    
    // Resets all the globals used modified in tests.
    // Resetting ensures that the changes made to globals by one test doesn't affect others.
    func resetTestGlobals() {
    	// set globalObjectAPI to `nil`.
    	resetGlobalObjectAPI()
    	// Reset config path set.
    	resetGlobalConfigPath()
    	// Reset Global server config.
    	resetGlobalConfig()
    	// Reset global endpoints.
    	resetGlobalEndpoints()
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 17:26:51 GMT 2024
    - 76.2K bytes
    - Viewed (0)
  9. cmd/bucket-replication-stats.go

    		if s.hasReplicationUsage() {
    			return true
    		}
    	}
    	return false
    }
    
    // ReplicationStats holds the global in-memory replication stats
    type ReplicationStats struct {
    	// map of site deployment ID to site replication status
    	// for site replication - maintain stats at global level
    	srStats *SRStats
    	// active worker stats
    	workers *ActiveWorkerStat
    	// queue stats cache
    	qCache queueCache
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 13.4K bytes
    - Viewed (0)
  10. cmd/config-current.go

    				}
    			}
    		}
    	}
    
    	// Bucket federation is 'true' only when IAM assets are not namespaced
    	// per tenant and all tenants interested in globally available users
    	// if namespace was requested such as specifying etcdPathPrefix then
    	// we assume that users are interested in global bucket support
    	// but not federation.
    	globalBucketFederation = etcdCfg.PathPrefix == "" && etcdCfg.Enabled
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 30.8K bytes
    - Viewed (0)
Back to top