- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 1,214 for Func (0.05 sec)
-
cmd/batch-job-common-types_gen.go
return } // Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message func (z BatchJobKV) Msgsize() (s int) { s = 1 + 4 + msgp.StringPrefixSize + len(z.Key) + 6 + msgp.StringPrefixSize + len(z.Value) return } // DecodeMsg implements msgp.Decodable func (z *BatchJobNotification) DecodeMsg(dc *msgp.Reader) (err error) { var field []byte _ = field var zb0001 uint32
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sat Dec 02 10:51:33 UTC 2023 - 21.9K bytes - Viewed (0) -
tests/preload_test.go
sort.Slice(users2, func(i, j int) bool { return users2[i].ID < users2[j].ID }) for idx, user := range users2[1:2] { if user.Account.Number != "" { t.Errorf("No account should found for user %v but got %v", idx+2, user.Account.Number) } } CheckUser(t, users2[0], users[0]) var users3 []User if err := DB.Preload("Account", func(tx *gorm.DB) *gorm.DB {
Registered: Sun Nov 03 09:35:10 UTC 2024 - Last Modified: Wed Jun 12 10:00:47 UTC 2024 - 15.9K bytes - Viewed (0) -
cmd/storage-datatypes_gen_test.go
t.Fatal(err) } if len(left) > 0 { t.Errorf("%d bytes left over after Skip(): %q", len(left), left) } } func BenchmarkMarshalMsgBaseOptions(b *testing.B) { v := BaseOptions{} b.ReportAllocs() b.ResetTimer() for i := 0; i < b.N; i++ { v.MarshalMsg(nil) } } func BenchmarkAppendMsgBaseOptions(b *testing.B) { v := BaseOptions{} bts := make([]byte, 0, v.Msgsize()) bts, _ = v.MarshalMsg(bts[0:0])
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Aug 12 08:38:15 UTC 2024 - 73.9K bytes - Viewed (0) -
internal/config/lambda/event/targetlist.go
} // Remove - closes and removes targets by given target IDs. func (list *TargetList) Remove(targetIDSet TargetIDSet) { list.Lock() defer list.Unlock() for id := range targetIDSet { target, ok := list.targets[id] if ok { target.Close() delete(list.targets, id) } } } // Targets - list all targets func (list *TargetList) Targets() []Target { if list == nil {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Mar 07 16:12:41 UTC 2023 - 4.3K bytes - Viewed (0) -
cmd/data-scanner-metric.go
func (p *scannerMetrics) currentPathUpdater(disk, initial string) (update func(path string), done func()) { initialPtr := unsafe.Pointer(&initial) tracker := ¤tPathTracker{ name: &initialPtr, } p.currentPaths.Store(disk, tracker) return func(path string) { atomic.StorePointer(tracker.name, unsafe.Pointer(&path)) }, func() { p.currentPaths.Delete(disk) } }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Sep 25 05:15:31 UTC 2023 - 9.1K bytes - Viewed (0) -
internal/s3select/sql/analysis.go
for _, ex := range e.Expressions { result.combine(ex.analyze(s)) } return } func (e *AliasedExpression) analyze(s *Select) qProp { return e.Expression.analyze(s) } func (e *Expression) analyze(s *Select) (result qProp) { for _, ac := range e.And { result.combine(ac.analyze(s)) } return } func (e *AndCondition) analyze(s *Select) (result qProp) { for _, ac := range e.Condition {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sat Dec 23 07:19:11 UTC 2023 - 8.5K bytes - Viewed (0) -
src/bytes/bytes_test.go
} func bmIndexByte(index func([]byte, byte) int) func(b *testing.B, n int) { return func(b *testing.B, n int) { buf := bmbuf[0:n] buf[n-1] = 'x' for i := 0; i < b.N; i++ { j := index(buf, 'x') if j != n-1 { b.Fatal("bad index", j) } } buf[n-1] = '\x00' } } func BenchmarkIndexRune(b *testing.B) {
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Mon Aug 19 19:09:04 UTC 2024 - 61.2K bytes - Viewed (0) -
tests/associations_test.go
Field *schema.Field } ) func (myType) QueryClauses(f *schema.Field) []clause.Interface { return []clause.Interface{emptyQueryClause{Field: f}} } func (sd emptyQueryClause) Name() string { return "empty" } func (sd emptyQueryClause) Build(clause.Builder) { } func (sd emptyQueryClause) MergeClause(*clause.Clause) { } func (sd emptyQueryClause) ModifyStatement(stmt *gorm.Statement) {
Registered: Sun Nov 03 09:35:10 UTC 2024 - Last Modified: Wed Feb 08 08:29:09 UTC 2023 - 10.9K bytes - Viewed (0) -
cmd/os-instrumented.go
Duration: duration, Path: path, Error: errStr, } } func updateOSMetrics(s osMetric, paths ...string) func(err error) { if globalTrace.NumSubscribers(madmin.TraceOS) == 0 { osAction := globalOSMetrics.time(s) return func(err error) { osAction() } } startTime := time.Now() return func(err error) { duration := time.Since(startTime) globalOSMetrics.incTime(s, duration)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Feb 15 01:09:38 UTC 2024 - 6.3K bytes - Viewed (0) -
cmd/event-notification.go
func NewEventNotifier(ctx context.Context) *EventNotifier { // targetList/bucketRulesMap/bucketRemoteTargetRulesMap are populated by NotificationSys.InitBucketTargets() return &EventNotifier{ targetList: event.NewTargetList(ctx), bucketRulesMap: make(map[string]event.RulesMap), } } // GetARNList - returns available ARNs. func (evnot *EventNotifier) GetARNList() []string {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jun 21 22:22:24 UTC 2024 - 7.7K bytes - Viewed (0)