- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 24 for Geresh (0.14 sec)
-
cmd/warm-backend-azure.go
if err != nil { return nil, err } // Refresh obtains a fresh token err = spt.Refresh() if err != nil { return nil, err } tc := azblob.NewTokenCredential(spt.Token().AccessToken, func(tc azblob.TokenCredential) time.Duration { err := spt.Refresh() if err != nil { return 0 } // set the new token value
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Mar 05 16:44:08 GMT 2024 - 7.8K bytes - Viewed (1) -
cmd/storage-datatypes_gen.go
return } z.SuccessorModTime, err = dc.ReadTime() if err != nil { err = msgp.WrapError(err, "SuccessorModTime") return } z.Fresh, err = dc.ReadBool() if err != nil { err = msgp.WrapError(err, "Fresh") return } z.Idx, err = dc.ReadInt() if err != nil { err = msgp.WrapError(err, "Idx") return } if dc.IsNil() { err = dc.ReadNil()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 127.5K bytes - Viewed (0) -
cmd/admin-heal-ops.go
} } else { oh, exists := ahs.getHealSequence(pathJoin(h.bucket, h.object)) if exists && !oh.hasEnded() { errMsg = "Heal is already running on the given path " + "(use force-start option to stop and start afresh). " + fmt.Sprintf("The heal was started by IP %s at %s, token is %s", h.clientAddress, h.startTime.Format(http.TimeFormat), h.clientToken) return nil, errorCodes.ToAPIErr(ErrHealAlreadyRunning), errMsg } }
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) -
cmd/site-replication.go
took := time.Since(refreshStart).Seconds() if took > maxRefreshDurationSecondsForLog { // Log if we took a lot of time. logger.Info("Site replication healing refresh took %.2fs", took) } // wait for 200 millisecond, if we are experience lot of I/O waitForLowIO(runtime.GOMAXPROCS(0), 200*time.Millisecond, currentHTTPIO) }
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) -
cmd/format-erasure.go
Version string `json:"version"` // Version of 'xl' format. Disk string `json:"drive"` // Disk field carries assigned disk uuid. // JBOD field carries the input disk order generated the first // time when fresh disks were supplied. JBOD []string `json:"jbod"` } `json:"xl"` // Erasure field holds xl format. } // Represents the V2 backend disk structure version // under `.minio.sys` and actual data namespace.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 15:54:03 GMT 2024 - 23.2K bytes - Viewed (0) -
cmd/common-main.go
} else { dnsTTL = 10 * time.Minute } } // Call to refresh will refresh names in cache. go func() { // Baremetal setups set DNS refresh window up to dnsTTL duration. t := time.NewTicker(dnsTTL) defer t.Stop() for { select { case <-t.C: globalDNSCache.Refresh() case <-GlobalContext.Done(): return } } }() }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat May 04 00:17:57 GMT 2024 - 35.8K bytes - Viewed (2) -
cmd/storage-datatypes.go
Data []byte `msg:"d,allownil"` // optionally carries object data NumVersions int `msg:"nv"` SuccessorModTime time.Time `msg:"smt"` Fresh bool `msg:"fr"` // indicates this is a first time call to write FileInfo. // Position of this version or object in a multi-object delete call, // no other caller must set this value other than multi-object delete call.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 15.3K bytes - Viewed (0) -
cmd/tier.go
defer config.Unlock() switch err { case nil: break case errConfigNotFound: // nothing to reload // To maintain the invariance that lastRefreshedAt records the // timestamp of last successful refresh config.lastRefreshedAt = UTCNow() return nil default: return err } // Reset drivercache built using current config for k := range config.drivercache { delete(config.drivercache, k)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 17 05:09:58 GMT 2024 - 15.5K bytes - Viewed (0) -
cmd/erasure-server-pool-decom.go
} } }() } return nil } func newPoolMeta(z *erasureServerPools, prevMeta poolMeta) poolMeta { newMeta := poolMeta{} // to update write poolMeta fresh. // looks like new pool was added we need to update, // or this is a fresh installation (or an existing // installation with pool removed) newMeta.Version = poolMetaVersion for idx, pool := range z.serverPools { var skip bool
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 15:18:21 GMT 2024 - 41.5K bytes - Viewed (1) -
cmd/storage-rest-client.go
// transport is already down. return "", errDiskNotFound } // This call should never be over the network, this is always // a cached value - caller should make sure to use this // function on a fresh disk or make sure to look at the error // from a different networked call to validate the GetDiskID() return *client.diskID.Load(), nil } func (client *storageRESTClient) SetDiskID(id string) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 26.1K bytes - Viewed (0)