Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for active (0.15 sec)

  1. cmd/metrics-v2.go

    		for i := range globalScannerMetrics.actions {
    			action := lifecycle.Action(i)
    			v := globalScannerMetrics.lifetimeActions(action)
    			if v == 0 {
    				continue
    			}
    			metrics = append(metrics, MetricV2{
    				Description: MetricDescription{
    					Namespace: nodeMetricNamespace,
    					Subsystem: ilmSubsystem,
    					Name:      MetricName("action_count_" + toSnake(action.String())),
    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)
  2. cmd/object-handlers.go

    			proxytgts := getProxyTargets(ctx, bucket, object, opts)
    			if !proxytgts.Empty() {
    				globalReplicationStats.incProxy(bucket, getObjectAPI, false)
    				// proxy to replication target if active-active replication is in place.
    				reader, proxy, perr = proxyGetToReplicationTarget(ctx, bucket, object, rs, r.Header, opts, proxytgts)
    				if perr != nil {
    					globalReplicationStats.incProxy(bucket, getObjectAPI, true)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu May 02 20:15:54 GMT 2024
    - 125.2K bytes
    - Viewed (0)
  3. cmd/bucket-replication.go

    	}
    }
    
    // proxyTaggingToRepTarget proxies tagging requests to remote targets for
    // active-active replicated setups
    func proxyTaggingToRepTarget(ctx context.Context, bucket, object string, tags *tags.Tags, opts ObjectOptions, proxyTargets *madmin.BucketTargets) (proxy proxyResult) {
    	// this option is set when active-active replication is in place between site A -> B,
    	// and request hits site B that does not have the object yet.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:09:56 GMT 2024
    - 112.2K bytes
    - Viewed (1)
  4. cmd/server_test.go

    func (s *TestSuiteCommon) TestBucketPolicy(c *check) {
    	// Sample bucket policy.
    	bucketPolicyBuf := `{"Version":"2012-10-17","Statement":[{"Action":["s3:GetBucketLocation","s3:ListBucket"],"Effect":"Allow","Principal":{"AWS":["*"]},"Resource":["arn:aws:s3:::%s"]},{"Action":["s3:GetObject"],"Effect":"Allow","Principal":{"AWS":["*"]},"Resource":["arn:aws:s3:::%s/this*"]}]}`
    
    	// generate a random bucket Name.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 108K bytes
    - Viewed (0)
  5. docs/screenshots/Minio_Cloud_Native_Arch.jpg

    Minio_Cloud_Native_Arch.jpg...
    JPEG Image
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jun 29 16:10:47 GMT 2017
    - 137.1K bytes
    - Viewed (0)
  6. cmd/site-replication.go

    	// until peers are synced in site replication setup.
    	MarkDelete SRBucketDeleteOp = "MarkDelete"
    
    	// Purge deletes the .minio.sys/buckets/.deleted/<bucket> vol entry
    	Purge SRBucketDeleteOp = "Purge"
    	// NoOp no action needed
    	NoOp SRBucketDeleteOp = "NoOp"
    )
    
    // Empty returns true if this Op is not set
    func (s SRBucketDeleteOp) Empty() bool {
    	return string(s) == "" || string(s) == string(NoOp)
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:09:56 GMT 2024
    - 184.2K bytes
    - Viewed (1)
  7. cmd/admin-handlers.go

    	lambdaMap := make(map[string][]madmin.TargetIDStatus)
    
    	for _, tgt := range globalEventNotifier.Targets() {
    		targetIDStatus := make(map[string]madmin.Status)
    		active, _ := tgt.IsActive()
    		targetID := tgt.ID()
    		if active {
    			targetIDStatus[targetID.ID] = madmin.Status{Status: string(madmin.ItemOnline)}
    		} else {
    			targetIDStatus[targetID.ID] = madmin.Status{Status: string(madmin.ItemOffline)}
    		}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Apr 29 17:39:04 GMT 2024
    - 97.8K bytes
    - Viewed (2)
Back to top