- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 415 for Case (0.15 sec)
-
internal/s3select/simdj/reader.go
func (r *Reader) startReader() { defer r.onReaderExit() var tmpObj simdjson.Object for { var in simdjson.Stream select { case in = <-r.input: case <-r.exitReader: return } if in.Error != nil && in.Error != io.EOF { r.err = &in.Error return } if in.Value == nil { if in.Error == io.EOF { return }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue May 30 17:02:22 GMT 2023 - 4.9K bytes - Viewed (0) -
cmd/utils_test.go
path string bucket, object string }{ // Test case 1 normal case. { path: "/bucket/object", bucket: "bucket", object: "object", }, // Test case 2 where url only has separator. { path: SlashSeparator, bucket: "", object: "", }, // Test case 3 only bucket is present. { path: "/bucket", bucket: "bucket",
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Feb 23 21:28:14 GMT 2024 - 10.2K bytes - Viewed (0) -
cmd/bootstrap-peer-server_gen.go
field, err = dc.ReadMapKeyPtr() if err != nil { err = msgp.WrapError(err) return } switch msgp.UnsafeString(field) { case "NEndpoints": z.NEndpoints, err = dc.ReadInt() if err != nil { err = msgp.WrapError(err, "NEndpoints") return } case "CmdLines": var zb0002 uint32 zb0002, err = dc.ReadArrayHeader() if err != nil { err = msgp.WrapError(err, "CmdLines") return
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Wed Jan 24 21:36:44 GMT 2024 - 6.4K bytes - Viewed (0) -
cmd/metacache-walk.go
objsReturned++ } } send := func(entry metaCacheEntry) error { objReturned(entry.metadata) select { case <-ctx.Done(): return ctx.Err() case out <- entry: } return nil } // Fast exit track to check if we are listing an object with // a trailing slash, this will avoid to list the object content.
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Apr 15 08:25:46 GMT 2024 - 12.4K bytes - Viewed (0) -
cmd/bucket-metadata-sys.go
} } updatedAt = UTCNow() switch configFile { case bucketPolicyConfig: meta.PolicyConfigJSON = configData meta.PolicyConfigUpdatedAt = updatedAt case bucketNotificationConfig: meta.NotificationConfigXML = configData case bucketLifecycleConfig: meta.LifecycleConfigXML = configData meta.LifecycleConfigUpdatedAt = updatedAt case bucketSSEConfig: meta.EncryptionConfigXML = configData
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Apr 22 17:49:30 GMT 2024 - 19.8K bytes - Viewed (0) -
cmd/sftp-server-driver.go
_ = w.w.CloseWithError(err) _ = w.r.CloseWithError(err) w.err = err } func (w *writerAt) Close() (err error) { switch { case len(w.buffer) > 0: err = errors.New("some file segments were not flushed from the queue") _ = w.w.CloseWithError(err) case w.err != nil: // No need to close here since both pipes were // closing inside TransferError() err = w.err default: err = w.w.Close() }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 19 12:23:42 GMT 2024 - 12.9K bytes - Viewed (0) -
internal/bucket/object/lock/lock.go
) // Valid - returns if retention mode is valid func (r RetMode) Valid() bool { switch r { case RetGovernance, RetCompliance: return true } return false } func parseRetMode(modeStr string) (mode RetMode) { switch strings.ToUpper(modeStr) { case "GOVERNANCE": mode = RetGovernance case "COMPLIANCE": mode = RetCompliance } return mode } // LegalHoldStatus - object legal hold status.
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 17.1K bytes - Viewed (0) -
internal/bucket/lifecycle/lifecycle.go
break } return err } if se, ok := t.(xml.StartElement); ok { switch se.Name.Local { case "Rule": var r Rule if err = d.DecodeElement(&r, &se); err != nil { return err } lc.Rules = append(lc.Rules, r) case "ExpiryUpdatedAt": var t time.Time if err = d.DecodeElement(&t, &start); err != nil { return err }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sat Mar 09 06:41:22 GMT 2024 - 17K bytes - Viewed (0) -
internal/dsync/drwmutex.go
dm.startContinuousLockRefresh(lockLossCallback, id, source, quorum) return locked } switch { case opts.RetryInterval < 0: return false case opts.RetryInterval > 0: time.Sleep(opts.RetryInterval) default: attempt++ time.Sleep(lockRetryBackOff(dm.rng, attempt)) } } } }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 19.7K bytes - Viewed (0) -
internal/s3select/sql/stringfuncs_test.go
{`a%__%\`, `a\%\_\_%`, '\\', true, nil}, {`a%__%\`, `a?%?_?_?%\`, '?', true, nil}, } for i, tc := range evalCases { // fmt.Println("Case:", i) res, err := evalSQLLike(tc.iText, tc.iPat, tc.iEsc) if res != tc.matchExpected || err != tc.errExpected { t.Errorf("Eval Case %d failed: %v %v", i, res, err) } }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Jun 01 21:59:40 GMT 2021 - 3.1K bytes - Viewed (0)