- Sort Score
- Result 10 results
- Languages All
Results 321 - 330 of 1,187 for funcs (0.84 sec)
-
callbacks/delete.go
Registered: Sun Dec 28 09:35:17 UTC 2025 - Last Modified: Sun May 25 07:40:40 UTC 2025 - 5.8K bytes - Viewed (0) -
cmd/leak-detect_test.go
// function to be run at the end of tests to see whether any // goroutines leaked. // Usage: `defer DetectTestLeak(t)()` in beginning line of benchmarks or unit tests. func DetectTestLeak(t TestErrHandler) func() { initialStackSnapShot := NewLeakDetect() return func() { initialStackSnapShot.DetectLeak(t) } } // list of functions to be ignored from the stack trace.
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 5.2K bytes - Viewed (0) -
internal/s3select/jstream/decoder.go
func (d *Decoder) Pos() int { return int(d.pos) } // Err returns the most recent decoder error if any, or nil func (d *Decoder) Err() error { return d.err } // MaxDepth will set the maximum recursion depth. // If the maximum depth is exceeded, ErrMaxDepth is returned. // Less than or 0 means no limit (default). func (d *Decoder) MaxDepth(n int) *Decoder { d.maxDepth = n return d }
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 13.4K bytes - Viewed (0) -
lib/wasm/wasm_exec.js
}, // func resetMemoryDataView() "runtime.resetMemoryDataView": (sp) => { sp >>>= 0; this.mem = new DataView(this._inst.exports.mem.buffer); }, // func nanotime1() int64 "runtime.nanotime1": (sp) => { sp >>>= 0; setInt64(sp + 8, (timeOrigin + performance.now()) * 1000000); }, // func walltime() (sec int64, nsec int32)
Registered: Tue Dec 30 11:13:12 UTC 2025 - Last Modified: Sun Dec 08 15:34:47 UTC 2024 - 16.6K bytes - Viewed (0) -
schema/naming_test.go
} } type CustomReplacer struct { f func(string) string } func (r CustomReplacer) Replace(name string) string { return r.f(name) } func TestCustomReplacer(t *testing.T) { ns := NamingStrategy{ TablePrefix: "public.", SingularTable: true, NameReplacer: CustomReplacer{ func(name string) string { replaced := "REPLACED_" + strings.ToUpper(name)Registered: Sun Dec 28 09:35:17 UTC 2025 - Last Modified: Tue May 30 02:00:48 UTC 2023 - 7K bytes - Viewed (0) -
internal/grid/types_test.go
} if !reflect.DeepEqual(v, v2) { t.Errorf("MSS: %v != %v", v, v2) } } func BenchmarkMarshalMsgMSS(b *testing.B) { v := MSS{"abc": "def", "ghi": "jkl"} b.ReportAllocs() for b.Loop() { v.MarshalMsg(nil) } } func BenchmarkAppendMsgMSS(b *testing.B) { v := MSS{"abc": "def", "ghi": "jkl"} bts := make([]byte, 0, v.Msgsize()) bts, _ = v.MarshalMsg(bts[0:0])
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 3.6K bytes - Viewed (0) -
internal/s3select/sql/utils.go
return e.strippedPathExpr } func (e *JSONPathElement) String() string { switch { case e.Key != nil: return e.Key.String() case e.Index != nil: return fmt.Sprintf("[%d]", *e.Index) case e.ObjectWildcard: return ".*" case e.ArrayWildcard: return "[*]" } return "" } // String removes double quotes in quoted identifiers func (i *Identifier) String() string { if i.Unquoted != nil {
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Wed Nov 10 16:12:50 UTC 2021 - 3.6K bytes - Viewed (0) -
cmd/kms-handlers.go
"github.com/minio/minio/internal/auth" "github.com/minio/minio/internal/kms" "github.com/minio/minio/internal/logger" "github.com/minio/pkg/v3/policy" ) // KMSStatusHandler - GET /minio/kms/v1/status func (a kmsAPIHandlers) KMSStatusHandler(w http.ResponseWriter, r *http.Request) { ctx := newContext(r, w, "KMSStatus") defer logger.AuditLog(ctx, w, r, mustGetClaimsFromToken(r))
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Aug 18 06:43:03 UTC 2024 - 10.1K bytes - Viewed (0) -
cmd/tier.go
}, []string{"tier"}), } func (t *tierMetrics) Observe(tier string, dur time.Duration) { t.histogram.With(prometheus.Labels{"tier": tier}).Observe(dur.Seconds()) } func (t *tierMetrics) logSuccess(tier string) { t.Lock() defer t.Unlock() stat := t.requestsCount[tier] stat.success++ t.requestsCount[tier] = stat } func (t *tierMetrics) logFailure(tier string) { t.Lock()Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 15.6K bytes - Viewed (0) -
internal/bucket/replication/rule.go
Status Status `xml:"Status"` // should be set to "Disabled" by default } // IsEmpty returns true if DeleteMarkerReplication is not set func (d DeleteMarkerReplication) IsEmpty() bool { return len(d.Status) == 0 } // Validate validates whether the status is disabled. func (d DeleteMarkerReplication) Validate() error { if d.IsEmpty() { return errDeleteMarkerReplicationMissing }
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 8.3K bytes - Viewed (0)