Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for Leer (0.17 sec)

  1. cmd/api-errors.go

    		HTTPStatusCode: http.StatusBadRequest,
    	},
    	ErrSiteReplicationPeerResp: {
    		Code:           "XMinioSiteReplicationPeerResp",
    		Description:    "Error received when contacting a peer site",
    		HTTPStatusCode: http.StatusBadRequest,
    	},
    	ErrSiteReplicationBackendIssue: {
    		Code:           "XMinioSiteReplicationBackendIssue",
    		Description:    "Error when requesting object layer backend",
    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/iam.go

    	}
    	return roleArn, rolePolicy, nil
    }
    
    // DeletePolicy - deletes a canned policy from backend. `notifyPeers` is true
    // whenever this is called via the API. It is false when called via a
    // notification from another peer. This is to avoid infinite loops.
    func (sys *IAMSys) DeletePolicy(ctx context.Context, policyName string, notifyPeers bool) error {
    	if !sys.Initialized() {
    		return errServerNotInitialized
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 25 21:28:16 GMT 2024
    - 71.1K bytes
    - Viewed (1)
  3. cmd/peer-rest-server.go

    	if localMetacacheMgr != nil {
    		localMetacacheMgr.deleteBucketCache(bucketName)
    	}
    	return
    }
    
    // GetAllBucketStatsHandler - fetches bucket replication stats for all buckets from this peer.
    func (s *peerRESTServer) GetAllBucketStatsHandler(mss *grid.MSS) (*BucketStatsMap, *grid.RemoteErr) {
    	replicationStats := globalReplicationStats.GetAll()
    	bucketStatsMap := make(map[string]BucketStats, len(replicationStats))
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 51.8K bytes
    - Viewed (0)
  4. cmd/iam-store.go

    		v, ok := cache.iamGroupPolicyMap.Load(name)
    		return v, ok
    	}
    	return cache.iamUserPolicyMap.Load(name)
    }
    
    // GroupNotificationHandler - updates in-memory cache on notification of
    // change (e.g. peer notification for object storage and etcd watch
    // notification).
    func (store *IAMStoreSys) GroupNotificationHandler(ctx context.Context, group string) error {
    	cache := store.lock()
    	defer store.unlock()
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Apr 27 10:04:10 GMT 2024
    - 75.2K bytes
    - Viewed (2)
  5. cmd/test-utils_test.go

    	testServer.Server = httptest.NewUnstartedServer(setCriticalErrorHandler(corsHandler(httpHandler)))
    
    	globalObjLayerMutex.Lock()
    	globalObjectAPI = objLayer
    	globalObjLayerMutex.Unlock()
    
    	// initialize peer rpc
    	host, port := mustSplitHostPort(testServer.Server.Listener.Addr().String())
    	globalMinioHost = host
    	globalMinioPort = port
    	globalMinioAddr = getEndpointsLocalAddr(testServer.Disks)
    
    	initAllSubsystems(ctx)
    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)
Back to top