- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 77 for tiger (0.12 sec)
-
cmd/tier-handlers.go
) var ( // error returned when remote tier already exists errTierAlreadyExists = AdminError{ Code: "XMinioAdminTierAlreadyExists", Message: "Specified remote tier already exists", StatusCode: http.StatusConflict, } // error returned when remote tier is not found errTierNotFound = AdminError{ Code: "XMinioAdminTierNotFound", Message: "Specified remote tier was not found", StatusCode: http.StatusNotFound,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 15 19:52:44 GMT 2024 - 7.5K bytes - Viewed (0) -
cmd/tier-journal.go
VersionID string `msg:"vid"` TierName string `msg:"tier"` } const ( tierJournalVersion = 1 tierJournalHdrLen = 2 // 2 bytes ) var errUnsupportedJournalVersion = errors.New("unsupported pending deletes journal version") func newTierDiskJournal() *tierDiskJournal { return &tierDiskJournal{} } // NewTierJournal initializes tier deletion journal func NewTierJournal() *TierJournal {
Go - Registered: Sun Feb 25 19:28:16 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 7.4K bytes - Viewed (0) -
cmd/tier-last-day-stats.go
merged.Bins[i] = cl.Bins[i].add(cm.Bins[i]) } return merged } // DailyAllTierStats is used to aggregate last day tier stats across MinIO servers type DailyAllTierStats map[string]lastDayTierStats func (l DailyAllTierStats) merge(m DailyAllTierStats) { for tier, st := range m { l[tier] = l[tier].merge(st) } } func (l DailyAllTierStats) addToTierInfo(tierInfos []madmin.TierInfo) []madmin.TierInfo {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Feb 19 22:54:46 GMT 2024 - 2.8K bytes - Viewed (0) -
internal/http/server.go
// Wait for opened connection to be closed up to Shutdown timeout. shutdownTimeout := srv.ShutdownTimeout shutdownTimer := time.NewTimer(shutdownTimeout) defer shutdownTimer.Stop() timer := time.NewTimer(nextPollInterval()) defer timer.Stop() for { select { case <-shutdownTimer.C: if atomic.LoadInt32(&srv.requestCount) <= 0 { return nil } // Write all running goroutines.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Feb 09 21:25:16 GMT 2024 - 7.7K bytes - Viewed (0) -
cmd/mrf.go
// let recently failed networks to reconnect // making MRF wait for 1s before retrying, // i.e 4 reconnect attempts. time.Sleep(time.Second) } // wait on timer per heal wait := healSleeper.Timer(context.Background()) scan := madmin.HealNormalScan if u.scanMode != 0 { scan = u.scanMode } if u.object == "" { healBucket(u.bucket, scan) } else {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 3.2K bytes - Viewed (0) -
cmd/tier_gen_test.go
Krishnan Parthasarathi <******@****.***> 1618853442 -0700
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 23 18:58:53 GMT 2021 - 2.3K bytes - Viewed (0) -
cmd/license-update.go
for { select { case <-ctx.Done(): return case <-licenseUpdateTimer.C: if globalSubnetConfig.Registered() { performLicenseUpdate(ctx, objAPI) } // Reset the timer for next cycle. licenseUpdateTimer.Reset(licUpdateCycle) } } } func performLicenseUpdate(ctx context.Context, objectAPI ObjectLayer) { // the subnet license renewal api renews the license only
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 3.3K bytes - Viewed (0) -
cmd/erasure-server-pool-rebalance.go
// time. r := rand.New(rand.NewSource(time.Now().UnixNano())) randSleepFor := func() time.Duration { return 5*time.Second + time.Duration(float64(5*time.Second)*r.Float64()) } timer := time.NewTimer(randSleepFor()) defer timer.Stop() var ( quit bool traceMsg string ) for { select { case rebalErr := <-doneCh: quit = true now := time.Now()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 26 19:29:28 GMT 2024 - 27.2K bytes - Viewed (0) -
cmd/admin-handler-utils.go
} case errors.Is(err, kes.ErrKeyExists): apiErr = APIError{ Code: "XMinioKMSKeyExists", Description: err.Error(), HTTPStatusCode: http.StatusConflict, } // Tier admin API errors case errors.Is(err, madmin.ErrTierNameEmpty): apiErr = APIError{ Code: "XMinioAdminTierNameEmpty", Description: err.Error(), HTTPStatusCode: http.StatusBadRequest, }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Mar 01 21:09:42 GMT 2024 - 8.2K bytes - Viewed (0) -
cmd/erasure-object.go
} return tags.ParseObjectTags(oi.UserTags) } // TransitionObject - transition object content to target tier. func (er erasureObjects) TransitionObject(ctx context.Context, bucket, object string, opts ObjectOptions) error { tgtClient, err := globalTierConfigMgr.getDriver(ctx, opts.Transition.Tier) if err != nil { return err } // Acquire write lock before starting to transition the object.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 77.2K bytes - Viewed (2)