Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 50 for siteb (0.18 sec)

  1. cmd/site-replication-metrics_gen.go

    Poorna <******@****.***> 1707199245 -0800
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Feb 06 06:00:45 GMT 2024
    - 40.6K bytes
    - Viewed (0)
  2. cmd/config-current_test.go

    	}
    
    	// Set new region and verify.
    	config.SetRegion(globalServerConfig, "us-west-1")
    	site, err := config.LookupSite(
    		globalServerConfig[config.SiteSubSys][config.Default],
    		globalServerConfig[config.RegionSubSys][config.Default],
    	)
    	if err != nil {
    		t.Fatal(err)
    	}
    	if site.Region != "us-west-1" {
    		t.Errorf("Expecting region `us-west-1` found %s", globalSite.Region)
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Dec 19 19:10:14 GMT 2022
    - 2K bytes
    - Viewed (0)
  3. cmd/api-errors.go

    		Code:           "XMinioSiteReplicationConfigMissingError",
    		Description:    "Site not found in site replication configuration",
    		HTTPStatusCode: http.StatusBadRequest,
    	},
    	ErrSiteReplicationIAMConfigMismatch: {
    		Code:           "XMinioSiteReplicationIAMConfigMismatch",
    		Description:    "IAM configuration mismatch between sites",
    		HTTPStatusCode: http.StatusBadRequest,
    	},
    	ErrAdminRebalanceAlreadyStarted: {
    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)
  4. cmd/bucket-policy-handlers.go

    	}
    
    	updatedAt, err := globalBucketMetadataSys.Update(ctx, bucket, bucketPolicyConfig, configData)
    	if err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    	// Call site replication hook.
    	replLogIf(ctx, globalSiteReplicationSys.BucketMetaHook(ctx, madmin.SRBucketMeta{
    		Type:      madmin.SRBucketMetaTypePolicy,
    		Bucket:    bucket,
    		Policy:    bucketPolicyBytes,
    		UpdatedAt: updatedAt,
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 6.1K bytes
    - Viewed (0)
  5. cmd/object-handlers.go

    		return
    	}
    
    	ot, err := objAPI.GetObjectTags(ctx, bucket, object, opts)
    	if err != nil {
    		// if object/version is not found locally, but exists on peer site - proxy
    		// the tagging request to peer site. The response to client will
    		// return tags from peer site.
    		if isErrObjectNotFound(err) || isErrVersionNotFound(err) {
    			proxytgts := getProxyTargets(ctx, bucket, object, opts)
    			if !proxytgts.Empty() {
    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)
  6. cmd/bucket-targets.go

    			return tgt.Arn, true
    		}
    	}
    	if !target.Type.IsValid() {
    		return
    	}
    	return generateARN(target, deplID), false
    }
    
    // getRemoteARNForPeer returns the remote target for a peer site in site replication
    func (sys *BucketTargetSys) getRemoteARNForPeer(bucket string, peer madmin.PeerInfo) string {
    	sys.RLock()
    	defer sys.RUnlock()
    	tgts := sys.targetsMap[bucket]
    	for _, target := range tgts {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:09:56 GMT 2024
    - 20.9K bytes
    - Viewed (0)
  7. cmd/globals.go

    	globalBrowserConfig browser.Config
    
    	// This flag is set to 'true' when MINIO_UPDATE env is set to 'off'. Default is false.
    	globalInplaceUpdateDisabled = false
    
    	globalSite = config.Site{
    		Region: globalMinioDefaultRegion,
    	}
    
    	// MinIO local server address (in `host:port` format)
    	globalMinioAddr = ""
    
    	// MinIO default port, can be changed through command line.
    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)
  8. internal/config/identity/openid/openid.go

    		}
    	}
    
    	return res, nil
    }
    
    // Enabled returns if configURL is enabled.
    func Enabled(kvs config.KVS) bool {
    	return kvs.Get(ConfigURL) != ""
    }
    
    // GetSettings - fetches OIDC settings for site-replication related validation.
    // NOTE that region must be populated by caller as this package does not know.
    func (r *Config) GetSettings() madmin.OpenIDSettings {
    	res := madmin.OpenIDSettings{}
    	if !r.Enabled {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Nov 16 04:42:31 GMT 2023
    - 16.5K bytes
    - Viewed (0)
  9. cmd/metrics-v2.go

    	})
    	return mg
    }
    
    // replication metrics for site replication
    func getReplicationSiteMetrics(opts MetricsGroupOpts) *MetricsGroupV2 {
    	mg := &MetricsGroupV2{
    		cacheInterval:    1 * time.Minute,
    		metricsGroupOpts: opts,
    	}
    	mg.RegisterRead(func(_ context.Context) []MetricV2 {
    		ml := []MetricV2{}
    
    		// metrics pertinent to site replication - overall roll up.
    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)
  10. cmd/auth-handler.go

    		nsecret, err := getTokenSigningKey()
    		if err != nil {
    			return nil, toAPIErrorCode(r.Context(), err)
    		}
    		// sign root's temporary accounts also with site replicator creds
    		if cred.ParentUser != globalActiveCred.AccessKey || cred.IsTemp() {
    			secret = nsecret
    		}
    	}
    	if cred.IsServiceAccount() {
    		token = cred.SessionToken
    		secret = cred.SecretKey
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 26K bytes
    - Viewed (0)
Back to top