- Sort Score
- Num 10 results
- Language All
Results 381 - 390 of 1,168 for rfunc (0.01 seconds)
-
logger/sql.go
func ExplainSQL(sql string, numericPlaceholder *regexp.Regexp, escaper string, avars ...interface{}) string { var ( convertParams func(interface{}, int) vars = make([]string, len(avars)) ) convertParams = func(v interface{}, idx int) { switch v := v.(type) { case bool: vars[idx] = strconv.FormatBool(v)
Created: Sun Dec 28 09:35:17 GMT 2025 - Last Modified: Thu Mar 21 08:00:02 GMT 2024 - 5K bytes - Click Count (0) -
internal/bucket/encryption/bucket-sse-config.go
// Algo returns the SSE algorithm specified by the SSE configuration. func (b *BucketSSEConfig) Algo() Algorithm { for _, rule := range b.Rules { return rule.DefaultEncryptionAction.Algorithm } return "" } // KeyID returns the KMS key ID specified by the SSE configuration. // If the SSE configuration does not specify SSE-KMS it returns an // empty key ID. func (b *BucketSSEConfig) KeyID() string { for _, rule := range b.Rules {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue Oct 25 00:44:15 GMT 2022 - 4.9K bytes - Click Count (0) -
internal/config/heal/heal.go
// - '-1' for not enabled // - '0' for continuous bitrot scanning // - '> 0' interval duration between cycles func (opts Config) BitrotScanCycle() (d time.Duration) { configMutex.RLock() defer configMutex.RUnlock() return opts.cache.bitrotCycle } // Clone safely the heal configuration func (opts Config) Clone() (int, time.Duration, string) { configMutex.RLock() defer configMutex.RUnlock()
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Mon Nov 04 19:06:02 GMT 2024 - 4.9K bytes - Click Count (0) -
cmd/data-scanner_test.go
) item.applyActions(t.Context(), objAPI, test.objInfos, test.lr, &sizeS, func(oi ObjectInfo, sz, _ int64, _ *sizeSummary) { if sz != 0 { gots = append(gots, oi) } }) if len(gots) != len(test.wants) { t.Fatalf("Expected %d objects but got %d", len(test.wants), len(gots)) } if slices.CompareFunc(gots, test.wants, func(g, w ObjectInfo) int { if g.VersionID == w.VersionID { return 0
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 12K bytes - Click Count (0) -
src/cmd/asm/internal/asm/endtoend_test.go
testEndToEnd(t, "riscv64", "riscv64") }) } func TestRISCV64Errors(t *testing.T) { testRISCV64AllProfiles(t, func(t *testing.T) { testErrors(t, "riscv64", "riscv64error") }) } func TestRISCV64Validation(t *testing.T) { testRISCV64AllProfiles(t, func(t *testing.T) { testErrors(t, "riscv64", "riscv64validation") }) } func TestS390XEndToEnd(t *testing.T) {
Created: Tue Dec 30 11:13:12 GMT 2025 - Last Modified: Tue Dec 23 18:45:48 GMT 2025 - 12.5K bytes - Click Count (0) -
internal/kms/stub.go
} // Version returns the type of the KMS. func (s StubKMS) Version(ctx context.Context) (string, error) { return "stub", nil } // APIs returns supported APIs func (s StubKMS) APIs(ctx context.Context) ([]madmin.KMSAPI, error) { return []madmin.KMSAPI{ {Method: http.MethodGet, Path: "stub/path"}, }, nil } // Status returns a set of endpoints and their KMS status.
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Aug 18 06:43:03 GMT 2024 - 3.6K bytes - Click Count (0) -
internal/etag/reader.go
uuid []byte } // Write - implement hash.Hash Write func (u UUIDHash) Write(p []byte) (n int, err error) { return len(p), nil } // Sum - implement md5.Sum func (u UUIDHash) Sum(b []byte) []byte { return u.uuid } // Reset - implement hash.Hash Reset func (u UUIDHash) Reset() {} // Size - implement hash.Hash Size func (u UUIDHash) Size() int { return len(u.uuid) }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Mar 30 00:56:02 GMT 2025 - 4.8K bytes - Click Count (0) -
internal/event/targetlist_test.go
sendErr bool closeErr bool } func (target ExampleTarget) ID() TargetID { return target.id } // Save - Sends event directly without persisting. func (target ExampleTarget) Save(eventData Event) error { return target.send(eventData) } // Store - Returns a nil store. func (target ExampleTarget) Store() TargetStore { return nil } func (target ExampleTarget) send(eventData Event) error {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Wed Apr 09 14:28:39 GMT 2025 - 6K bytes - Click Count (0) -
cmd/api-resources.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package cmd import ( "encoding/base64" "net/url" "strconv" ) // Parse bucket url queries func getListObjectsV1Args(values url.Values) (prefix, marker, delimiter string, maxkeys int, encodingType string, errCode APIErrorCode) { errCode = ErrNone if values.Get("max-keys") != "" { var err error
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 5.2K bytes - Click Count (0) -
internal/s3select/sql/timestampfuncs.go
layoutDay, layoutMinute, layoutSecond, layoutNanosecond, } func parseSQLTimestamp(s string) (t time.Time, err error) { for _, f := range tformats { t, err = time.Parse(f, s) if err == nil { break } } return t, err } // FormatSQLTimestamp - returns the a string representation of the // timestamp as used in S3 Select func FormatSQLTimestamp(t time.Time) string { _, zoneOffset := t.Zone()
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 4.8K bytes - Click Count (0)