- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 29 for refreshedAt (0.22 sec)
-
cmd/tier.go
tierConfigVersion = 2 ) // tierConfigPath refers to remote tier config object name var tierConfigPath = path.Join(minioConfigPrefix, tierConfigFile) const tierCfgRefreshAtHdr = "X-MinIO-TierCfg-RefreshedAt" // TierConfigMgr holds the collection of remote tiers configured in this deployment. type TierConfigMgr struct { sync.RWMutex `msg:"-"` drivercache map[string]WarmBackend `msg:"-"`
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Wed Apr 17 05:09:58 GMT 2024 - 15.5K bytes - Viewed (0) -
cmd/tier-handlers.go
data, err := json.Marshal(tiers) if err != nil { writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL) return } w.Header().Set(tierCfgRefreshAtHdr, globalTierConfigMgr.refreshedAt().String()) writeSuccessResponseJSON(w, data) } func (api adminAPIHandlers) EditTierHandler(w http.ResponseWriter, r *http.Request) { ctx := r.Context()
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Feb 15 19:52:44 GMT 2024 - 7.5K bytes - Viewed (0) -
internal/dsync/drwmutex.go
ctx, cancel := context.WithTimeout(ctx, ds.Timeouts.RefreshCall) defer cancel() refreshed, err := c.Refresh(ctx, args) if err != nil { ch <- refreshResult{offline: true} log("dsync: Unable to call Refresh failed with %s for %#v at %s\n", err, args, c) } else { ch <- refreshResult{refreshed: refreshed} log("dsync: Refresh returned false for %#v at %s\n", args, c) } }(index, c) }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 19.7K bytes - Viewed (0) -
cmd/lock-rest-server.go
func (l *lockRESTServer) RefreshHandler(args *dsync.LockArgs) (*dsync.LockResp, *grid.RemoteErr) { resp := lockRPCRefresh.NewResponse() refreshed, err := l.ll.Refresh(context.Background(), *args) if err != nil { return l.makeResp(resp, err) } if !refreshed { return l.makeResp(resp, errLockNotFound) } return l.makeResp(resp, err) } // LockHandler - Acquires a lock.
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 5.9K bytes - Viewed (0) -
internal/dsync/dsync-server_test.go
lockNotFound bool // Set to true if you want peers servers to do not respond responseDelay int64 } func (l *lockServer) setRefreshReply(refreshed bool) { l.mutex.Lock() defer l.mutex.Unlock() l.lockNotFound = !refreshed } func (l *lockServer) setResponseDelay(responseDelay time.Duration) { atomic.StoreInt64(&l.responseDelay, int64(responseDelay)) }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Jan 23 16:46:37 GMT 2023 - 8.3K bytes - Viewed (0) -
internal/dsync/dsync-client_test.go
return restClient.Call("/v1/unlock", args) } func (restClient *ReconnectRESTClient) Refresh(ctx context.Context, args LockArgs) (refreshed bool, err error) { return restClient.Call("/v1/refresh", args) } func (restClient *ReconnectRESTClient) ForceUnlock(ctx context.Context, args LockArgs) (reply bool, err error) {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Jan 20 17:36:09 GMT 2022 - 4.4K bytes - Viewed (0) -
internal/config/identity/openid/provider/keycloak.go
type KeycloakProvider struct { sync.Mutex oeConfig DiscoveryDoc client http.Client adminURL string realm string // internal value refreshed accessToken Token } // LoginWithUser authenticates username/password, not needed for Keycloak func (k *KeycloakProvider) LoginWithUser(username, password string) error { return ErrNotImplemented }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 29 01:27:09 GMT 2022 - 4.6K bytes - Viewed (0) -
src/test/java/jcifs/tests/KerberosTest.java
try { System.out.println("Refreshing"); setSubject(getInitiatorSubject(getTestUser(), getTestUserPassword(), getTestUserDomainRequired(), null)); System.out.println("Refreshed"); } catch ( Exception e ) { throw new CIFSException("Failed to refresh credentials", e); } } @Override
Java - Registered: Sun Apr 28 00:10:09 GMT 2024 - Last Modified: Sun Mar 01 09:46:04 GMT 2020 - 11.5K bytes - Viewed (0) -
guava/src/com/google/common/cache/CacheLoader.java
*/ public abstract V load(K key) throws Exception; /** * Computes or retrieves a replacement value corresponding to an already-cached {@code key}. This * method is called when an existing cache entry is refreshed by {@link * CacheBuilder#refreshAfterWrite}, or through a call to {@link LoadingCache#refresh}. * * <p>This implementation synchronously delegates to {@link #load}. It is recommended that it be
Java - Registered: Fri Apr 05 12:43:09 GMT 2024 - Last Modified: Mon Dec 19 20:20:14 GMT 2022 - 9.5K bytes - Viewed (0) -
internal/config/identity/openid/jwt.go
return fmt.Errorf("Role %s does not exist", arn) } jwtToken, err := jp.ParseWithClaims(token, &claims, keyFuncCallback) if err != nil { // Re-populate the public key in-case the JWKS // pubkeys are refreshed if err = r.PopulatePublicKey(arn); err != nil { return err } jwtToken, err = jwtgo.ParseWithClaims(token, &claims, keyFuncCallback) if err != nil { return err } }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Nov 16 04:42:31 GMT 2023 - 8.3K bytes - Viewed (5)