- Sort Score
- Num 10 results
- Language All
Results 541 - 550 of 939 for func_ (0.02 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
cmd/admin-heal-ops.go
return func() error { // NOTE: Healing on meta is run regardless // of any bucket being selected, this is to ensure that // meta are always upto date and correct. h.settings.Recursive = true return objAPI.HealObjects(h.ctx, minioMetaBucket, metaPrefix, h.settings, func(bucket, object, versionID string, scanMode madmin.HealScanMode) error { if h.isQuitting() { return errHealStopSignalled }Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 25.4K bytes - Click Count (0) -
cmd/bucket-replication-stats.go
qTimer *time.Ticker // ticker for calculating queue stats } func (r *ReplicationStats) trackEWMA() { for { select { case <-r.movingAvgTicker.C: r.updateMovingAvg() case <-GlobalContext.Done(): return } } } func (r *ReplicationStats) updateMovingAvg() { r.RLock() for _, s := range r.Cache { for _, st := range s.Stats {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue Feb 18 16:25:55 GMT 2025 - 13.6K bytes - Click Count (0) -
internal/hash/checksum.go
} // Is returns if c is all of t. func (c ChecksumType) Is(t ChecksumType) bool { if t == ChecksumNone { return c == ChecksumNone } return c&t == t } // Base returns the base checksum (if any) func (c ChecksumType) Base() ChecksumType { return c & baseTypeMask } // Key returns the header key. // returns empty string if invalid or none. func (c ChecksumType) Key() string { switch {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 22 14:15:21 GMT 2025 - 18.3K bytes - Click Count (0) -
logger/logger.go
} // New trace recorder func (l *traceRecorder) New() *traceRecorder { return &traceRecorder{Interface: l.Interface, BeginAt: time.Now()} } // Trace implement logger interface func (l *traceRecorder) Trace(ctx context.Context, begin time.Time, fc func() (string, int64), err error) { l.BeginAt = begin l.SQL, l.RowsAffected = fc() l.Err = err }
Created: Sun Dec 28 09:35:17 GMT 2025 - Last Modified: Sun Jan 12 10:19:28 GMT 2025 - 6.3K bytes - Click Count (0) -
cmd/erasure-healing_test.go
if err != nil { t.Fatal(err) } } func TestHealingDanglingObject(t *testing.T) { ctx, cancel := context.WithCancel(t.Context()) defer cancel() resetGlobalHealState() defer resetGlobalHealState() // Set globalStorageClass.STANDARD to EC:4 for this test saveSC := globalStorageClass defer func() { globalStorageClass.Update(saveSC) }()Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 48.5K bytes - Click Count (0) -
src/archive/tar/reader_test.go
} } } func TestReadOldGNUSparseMap(t *testing.T) { populateSparseMap := func(sa sparseArray, sps []string) []string { for i := 0; len(sps) > 0 && i < sa.maxEntries(); i++ { copy(sa.entry(i), sps[0]) sps = sps[1:] } if len(sps) > 0 { copy(sa.isExtended(), "\x80") } return sps }
Created: Tue Dec 30 11:13:12 GMT 2025 - Last Modified: Mon Dec 15 16:34:13 GMT 2025 - 47.5K bytes - Click Count (0) -
src/cmd/api/main_test.go
} func (w *Walker) emitFunc(f *types.Func) { sig := f.Signature() if sig.Recv() != nil { panic("method considered a regular function: " + f.String()) } if w.isDeprecated(f) { w.emitf("func %s //deprecated", f.Name()) } w.emitf("func %s%s", f.Name(), w.signatureString(sig)) } func (w *Walker) emitMethod(m *types.Selection) {
Created: Tue Dec 30 11:13:12 GMT 2025 - Last Modified: Thu Feb 20 03:25:33 GMT 2025 - 31.4K bytes - Click Count (0) -
tests/lru_test.go
"testing" "time" "gorm.io/gorm/internal/lru" ) func TestLRU_Add_ExistingKey_UpdatesValueAndExpiresAt(t *testing.T) { lru := lru.NewLRU[string, int](10, nil, time.Hour) lru.Add("key1", 1) lru.Add("key1", 2) if value, ok := lru.Get("key1"); !ok || value != 2 { t.Errorf("Expected value to be updated to 2, got %v", value) } } func TestLRU_Add_NewKey_AddsEntry(t *testing.T) {
Created: Sun Dec 28 09:35:17 GMT 2025 - Last Modified: Mon Sep 08 09:19:22 GMT 2025 - 10.4K bytes - Click Count (0) -
schema/naming.go
// RelationshipFKName generate fk name for relation func (ns NamingStrategy) RelationshipFKName(rel Relationship) string { return ns.formatName("fk", rel.Schema.Table, ns.toDBName(rel.Name)) } // CheckerName generate checker name func (ns NamingStrategy) CheckerName(table, column string) string { return ns.formatName("chk", table, column) } // IndexName generate index name func (ns NamingStrategy) IndexName(table, column string) string {
Created: Sun Dec 28 09:35:17 GMT 2025 - Last Modified: Wed Jun 12 03:46:59 GMT 2024 - 5.3K bytes - Click Count (0) -
clause/group_by_test.go
package clause_test import ( "fmt" "testing" "gorm.io/gorm/clause" ) func TestGroupBy(t *testing.T) { results := []struct { Clauses []clause.Interface Result string Vars []interface{} }{ { []clause.Interface{clause.Select{}, clause.From{}, clause.GroupBy{ Columns: []clause.Column{{Name: "role"}}, Having: []clause.Expression{clause.Eq{"role", "admin"}}, }},
Created: Sun Dec 28 09:35:17 GMT 2025 - Last Modified: Thu Jan 06 07:02:53 GMT 2022 - 1.1K bytes - Click Count (0)