Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 13 for welches (0.16 sec)

  1. 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{}
    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)
  2. cmd/metrics-v2.go

    		metrics = append(metrics, MetricV2{
    			Description: getMinIOGORoutineCountMD(),
    			Value:       float64(runtime.NumGoroutine()),
    		})
    		return
    	})
    	return mg
    }
    
    // getHistogramMetrics fetches histogram metrics and returns it in a []Metric
    // Note: Typically used in MetricGroup.RegisterRead
    //
    // The last parameter is added for compatibility - if true it lowercases the
    // `api` label values.
    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)
  3. internal/store/batch.go

    	b.Lock()
    	defer b.Unlock()
    
    	if b.isFull() {
    		return ErrBatchFull
    	}
    
    	if _, ok := b.items[key]; !ok {
    		b.keys = append(b.keys, key)
    	}
    	b.items[key] = item
    
    	return nil
    }
    
    // GetAll fetches the items and resets the batch
    // Returned items are not referenced by the batch
    func (b *Batch[K, T]) GetAll() (orderedKeys []K, orderedItems []T, err error) {
    	b.Lock()
    	defer b.Unlock()
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Oct 07 15:07:38 GMT 2023
    - 2.5K bytes
    - Viewed (0)
  4. cmd/iam-store.go

    	return ok
    }
    
    // GetUser - fetches credential from memory.
    func (store *IAMStoreSys) GetUser(user string) (UserIdentity, bool) {
    	cache := store.rlock()
    	defer store.runlock()
    
    	u, ok := cache.iamUsersMap[user]
    	if !ok {
    		// Check the sts map
    		u, ok = cache.iamSTSAccountsMap[user]
    	}
    	return u, ok
    }
    
    // GetMappedPolicy - fetches mapped policy from memory.
    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. internal/http/dial_dnscache.go

    type LookupHost func(ctx context.Context, host string) (addrs []string, err error)
    
    // DialContextWithLookupHost is a helper function which returns `net.DialContext` function.
    // It randomly fetches an IP via custom LookupHost function and dials it by the given dial
    // function. LookupHost may implement an internal DNS caching implementation, lookupHost
    // input if nil then net.DefaultResolver.LookupHost is used.
    //
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Jul 03 19:30:51 GMT 2023
    - 2.6K bytes
    - Viewed (0)
  6. cmd/peer-rest-server.go

    	globalBucketHTTPStats.delete(bucketName)
    	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()
    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)
  7. cmd/erasure-metadata.go

    	m1 := make(map[string]string, len(m))
    	for k, v := range m {
    		m1[k] = string(v)
    	}
    	return getInternalReplicationState(m1)
    }
    
    // getInternalReplicationState fetches internal replication state from the map m
    func getInternalReplicationState(m map[string]string) ReplicationState {
    	d := ReplicationState{}
    	for k, v := range m {
    		switch {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 19.2K bytes
    - Viewed (1)
  8. cmd/admin-heal-ops.go

    		StartTime:     h.startTime,
    	})
    	if err != nil {
    		bugLogIf(h.ctx, err)
    		return nil, toAdminAPIErr(h.ctx, err), ""
    	}
    	return b, noError, ""
    }
    
    // PopHealStatusJSON - Called by heal-status API. It fetches the heal
    // status results from global state and returns its JSON
    // representation. The clientToken helps ensure there aren't
    // conflicting clients fetching status.
    func (ahs *allHealState) PopHealStatusJSON(hpath string,
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 25.1K bytes
    - Viewed (1)
  9. cmd/test-utils_test.go

    			if endpoint.IsLocal && endpoint.Type() == URLEndpointType {
    				return endpoint.Host
    			}
    		}
    	}
    
    	return net.JoinHostPort(globalMinioHost, globalMinioPort)
    }
    
    // fetches a random number between range min-max.
    func getRandomRange(min, max int, seed int64) int {
    	// special value -1 means no explicit seeding.
    	if seed != -1 {
    		rand.Seed(seed)
    	}
    	return rand.Intn(max-min) + min
    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)
  10. cmd/bucket-policy-handlers_test.go

    func TestGetBucketPolicyHandler(t *testing.T) {
    	ExecObjectLayerAPITest(t, testGetBucketPolicyHandler, []string{"PutBucketPolicy", "GetBucketPolicy"})
    }
    
    // testGetBucketPolicyHandler - Test for end point which fetches the access policy json of the given bucket.
    func testGetBucketPolicyHandler(obj ObjectLayer, instanceType, bucketName string, apiRouter http.Handler,
    	credentials auth.Credentials, t *testing.T,
    ) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 32.7K bytes
    - Viewed (0)
Back to top