- Sort Score
- Num 10 results
- Language All
Results 281 - 290 of 1,262 for Func (0.06 seconds)
-
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 }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 13.4K bytes - Click Count (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)
Created: Tue Apr 07 11:13:11 GMT 2026 - Last Modified: Sun Dec 08 15:34:47 GMT 2024 - 16.6K bytes - Click Count (0) -
cmd/object-api-utils_test.go
return rs } func benchmark(b *testing.B, data []string) { b.Run("concat naive", func(b *testing.B) { b.ResetTimer() b.ReportAllocs() for b.Loop() { concatNaive(data...) } }) b.Run("concat fast", func(b *testing.B) { b.ResetTimer() b.ReportAllocs() for b.Loop() { concat(data...) } }) } func BenchmarkConcatImplementation(b *testing.B) { data := make([]string, 2)
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 24.1K bytes - Click Count (0) -
cmd/dynamic-timeouts.go
} // Timeout returns the current timeout value func (dt *dynamicTimeout) Timeout() time.Duration { return time.Duration(atomic.LoadInt64(&dt.timeout)) } func (dt *dynamicTimeout) RetryInterval() time.Duration { return dt.retryInterval } // LogSuccess logs the duration of a successful action that // did not hit the timeout func (dt *dynamicTimeout) LogSuccess(duration time.Duration) { dt.logEntry(duration)
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 4.5K bytes - Click Count (0) -
internal/jwt/parser_test.go
) var ( defaultKeyFunc = func(claim *MapClaims) ([]byte, error) { return []byte("HelloSecret"), nil } emptyKeyFunc = func(claim *MapClaims) ([]byte, error) { return nil, nil } errorKeyFunc = func(claim *MapClaims) ([]byte, error) { return nil, fmt.Errorf("error loading key") } ) var jwtTestData = []struct { name string tokenString string keyfunc func(*MapClaims) ([]byte, error) claims jwt.ClaimsCreated: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 6K bytes - Click Count (0) -
internal/bucket/versioning/versioning.go
default: return Errorf("unsupported Versioning status %s", v.Status) } return nil } // Enabled - returns true if versioning is enabled func (v Versioning) Enabled() bool { return v.Status == Enabled } // Versioned returns if 'prefix' has versioning enabled or suspended. func (v Versioning) Versioned(prefix string) bool { return v.PrefixEnabled(prefix) || v.PrefixSuspended(prefix) }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri May 24 23:05:23 GMT 2024 - 4.6K bytes - Click Count (0) -
internal/bucket/replication/destination.go
} func (d Destination) isValidStorageClass() bool { if d.StorageClass == "" { return true } return d.StorageClass == "STANDARD" || d.StorageClass == "REDUCED_REDUNDANCY" } // IsValid - checks whether Destination is valid or not. func (d Destination) IsValid() bool { return d.Bucket != "" || !d.isValidStorageClass() } func (d Destination) String() string { return d.ARN }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri May 24 23:05:23 GMT 2024 - 4K bytes - Click Count (0) -
cmd/admin-handlers-site-replication.go
} writeSuccessResponseJSON(w, body) } func getSRAddOptions(r *http.Request) (opts madmin.SRAddOptions) { opts.ReplicateILMExpiry = r.Form.Get("replicateILMExpiry") == "true" return opts } // SRPeerJoin - PUT /minio/admin/v3/site-replication/join // // used internally to tell current cluster to enable SR with // the provided peer clusters and service account.
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 19.4K bytes - Click Count (0) -
cmd/config-dir.go
type ConfigDir struct { path string } func getDefaultConfigDir() string { homeDir, err := homedir.Dir() if err != nil { return "" } return filepath.Join(homeDir, defaultMinioConfigDir) } func getDefaultCertsDir() string { return filepath.Join(getDefaultConfigDir(), certsDir) } func getDefaultCertsCADir() string { return filepath.Join(getDefaultCertsDir(), certsCADir)Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Jan 02 17:15:06 GMT 2022 - 3K bytes - Click Count (0) -
cmd/metrics-v2_gen.go
func (z MetricName) Msgsize() (s int) { s = msgp.StringPrefixSize + len(string(z)) return } // MarshalMsg implements msgp.Marshaler func (z MetricNamespace) MarshalMsg(b []byte) (o []byte, err error) { o = msgp.Require(b, z.Msgsize()) o = msgp.AppendString(o, string(z)) return } // UnmarshalMsg implements msgp.Unmarshaler
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 19K bytes - Click Count (0)