- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 129 for Langen (0.21 sec)
-
cmd/copy-part-range.go
apiErr.Description = err.Error() writeErrorResponse(ctx, w, apiErr, url) return } } // Parses x-amz-copy-source-range for CopyObjectPart API. Its behavior // is different from regular HTTP range header. It only supports the // form `bytes=first-last` where first and last are zero-based byte // offsets. See // http://docs.aws.amazon.com/AmazonS3/latest/API/mpUploadUploadPartCopy.html
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Jun 18 03:27:04 GMT 2021 - 2.5K bytes - Viewed (0) -
cmd/copy-part-range_test.go
t.Fatalf("expected: an error, got: <nil> for range %s", rangeString) } } // Test error range strings. errorRangeString := []string{ "bytes=10-10", "bytes=20-30", } for _, rangeString := range errorRangeString { rs, err := parseCopyPartRangeSpec(rangeString) if err == nil { err1 := checkCopyPartRangeWithSize(rs, objectSize) if err1 != errInvalidRangeSource {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 23 18:58:53 GMT 2021 - 2.5K bytes - Viewed (0) -
istioctl/pkg/writer/envoy/configdump/listener.go
for _, rm := range ip.GetRangeMatchers() { for _, r := range rm.Ranges { cidr := r.AddressPrefix pl := r.PrefixLen.GetValue() if pl != 32 && pl != 128 { cidr += fmt.Sprintf("/%d", pl) } m[cidr] = rm.OnMatch } } default: panic("unhandled") } } outputs := []string{} for k, v := range m { switch v := v.GetOnMatch().(type) {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Nov 29 12:37:14 GMT 2023 - 18.1K bytes - Viewed (0) -
cmd/warm-backend.go
"errors" "fmt" "io" "strings" "github.com/minio/madmin-go/v3" xhttp "github.com/minio/minio/internal/http" ) // WarmBackendGetOpts is used to express byte ranges within an object. The zero // value represents the entire byte range of an object. type WarmBackendGetOpts struct { startOffset int64 length int64 } // WarmBackend provides interface to be implemented by remote tier backends
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 21 11:43:18 GMT 2024 - 3.9K bytes - Viewed (0) -
cmd/peer-s3-client.go
for i, client := range sys.peerClients { if slices.Contains(client.GetPools(), poolIdx) { perPoolErrs = append(perPoolErrs, errs[i]) } } quorum := len(perPoolErrs) / 2 if poolErr := reduceWriteQuorumErrs(ctx, perPoolErrs, bucketOpIgnoredErrs, quorum); poolErr != nil { return madmin.HealResultItem{}, poolErr } } for i, err := range errs { if err == nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14.8K bytes - Viewed (0) -
cmd/iam-store.go
policies := make(map[string]MappedPolicy, m.Size()) m.Range(func(k string, v MappedPolicy) bool { policies[k] = v return true }) return policies } // converts a mapped policy into a slice of distinct policies func (mp MappedPolicy) toSlice() []string { var policies []string for _, policy := range strings.Split(mp.Policies, ",") { if strings.TrimSpace(policy) == "" { continue
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Apr 27 10:04:10 GMT 2024 - 75.2K bytes - Viewed (2) -
scan.go
if db.Statement.Schema != nil { for idx, name := range columns { if field := db.Statement.Schema.LookUpField(name); field != nil { values[idx] = reflect.New(reflect.PtrTo(field.FieldType)).Interface() continue } values[idx] = new(interface{}) } } else if len(columnTypes) > 0 { for idx, columnType := range columnTypes { if columnType.ScanType() != nil {
Go - Registered: Sun May 05 09:35:13 GMT 2024 - Last Modified: Fri Apr 26 09:53:11 GMT 2024 - 9.8K bytes - Viewed (0) -
cmd/data-usage.go
// No need to fail upon Update() error, fallback to old value. cachevalue.Opts{ReturnLastGood: true, NoWait: true}, func() (map[string]uint64, error) { m := make(map[string]uint64) for _, pool := range z.serverPools { for _, er := range pool.sets { // Load bucket usage prefixes ctx, done := context.WithTimeout(context.Background(), 2*time.Second) ok := cache.load(ctx, er, bucket+slashSeparator+dataUsageCacheName) == nil
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 5.6K bytes - Viewed (0) -
cmd/format-erasure.go
newFormats := make([][]*formatErasureV3, setCount) for i := range refFormat.Erasure.Sets { newFormats[i] = make([]*formatErasureV3, setDriveCount) } currentDisksInfo := make([][]DiskInfo, setCount) for i := range refFormat.Erasure.Sets { currentDisksInfo[i] = make([]DiskInfo, setDriveCount) } for i := range refFormat.Erasure.Sets { for j := range refFormat.Erasure.Sets[i] {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 15:54:03 GMT 2024 - 23.2K bytes - Viewed (0) -
internal/s3select/sql/value_test.go
wantOk bool } var tests []test for i := range valueBuilders { a := valueBuilders[i]() for j := range valueBuilders { b := valueBuilders[j]() tests = append(tests, test{ name: fmt.Sprint(a.GetTypeString(), "==", b.GetTypeString()), fields: fields{ a: *a, b: *b, }, wantOk: i == j, }) } } for _, tt := range tests { t.Run(tt.name, func(t *testing.T) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 06 16:56:10 GMT 2023 - 12.5K bytes - Viewed (0)