- Sort Score
- Num 10 results
- Language All
Results 151 - 160 of 242 for encoded (0.03 seconds)
-
internal/event/targetid.go
func (tid TargetID) String() string { return tid.ID + ":" + tid.Name } // ToARN - converts to ARN. func (tid TargetID) ToARN(region string) ARN { return ARN{TargetID: tid, region: region} } // MarshalJSON - encodes to JSON data. func (tid TargetID) MarshalJSON() ([]byte, error) { return json.Marshal(tid.String()) } // UnmarshalJSON - decodes JSON data. func (tid *TargetID) UnmarshalJSON(data []byte) error { var s string
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue Jun 01 21:59:40 GMT 2021 - 1.8K bytes - Click Count (0) -
internal/grid/trace.go
switch typed := v.(type) { case *MSS: trace.Path += typed.ToQuery() case map[string]string: m := MSS(typed) trace.Path += m.ToQuery() case *URLValues: trace.Path += typed.Values().Encode() case *NoPayload, *Bytes: trace.Path = fmt.Sprintf("%s?payload=%T", trace.Path, typed) case string: trace.Path = fmt.Sprintf("%s?%s", trace.Path, typed) default: } trace.HTTP.ReqInfo.Path = trace.PathCreated: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sat Jun 01 05:17:37 GMT 2024 - 4.1K bytes - Click Count (0) -
cmd/bucket-replication-handlers.go
st.CurrentBandwidthInBytesPerSecond = bw.CurrentBandwidthInBytesPerSecond stats.ReplicationStats.Stats[arn] = st } } } if err := enc.Encode(stats.ReplicationStats); err != nil { writeErrorResponseJSON(ctx, w, toAPIError(ctx, err), r.URL) return } } // GetBucketReplicationMetricsV2Handler - GET Bucket replication metrics. // ----------
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Thu Aug 15 12:04:40 GMT 2024 - 23.3K bytes - Click Count (0) -
internal/kms/context.go
switch b { case '\\', '"': dst.WriteByte(b) case '\n': dst.WriteByte('n') case '\r': dst.WriteByte('r') case '\t': dst.WriteByte('t') default: // This encodes bytes < 0x20 except for \t, \n and \r. // If escapeHTML is set, it also escapes <, >, and & // because they can lead to security holes when // user-controlled strings are rendered into JSONCreated: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Jan 02 17:15:06 GMT 2022 - 6K bytes - Click Count (0) -
internal/bucket/lifecycle/filter.go
cachedTags map[string]string } // MarshalXML - produces the xml representation of the Filter struct // only one of Prefix, And and Tag should be present in the output. func (f Filter) MarshalXML(e *xml.Encoder, start xml.StartElement) error { if !f.set { return nil } if err := e.EncodeToken(start); err != nil { return err } switch { case !f.And.isEmpty():
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Wed Sep 04 17:01:26 GMT 2024 - 6.2K bytes - Click Count (0) -
cmd/bucket-encryption-handlers.go
if err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } // Call site replication hook. // // We encode the xml bytes as base64 to ensure there are no encoding // errors. cfgStr := base64.StdEncoding.EncodeToString(configData) replLogIf(ctx, globalSiteReplicationSys.BucketMetaHook(ctx, madmin.SRBucketMeta{Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri May 24 23:05:23 GMT 2024 - 6.4K bytes - Click Count (0) -
cmd/metacache_gen.go
zb0001-- field, err = dc.ReadMapKeyPtr() if err != nil { err = msgp.WrapError(err) return } switch msgp.UnsafeString(field) { case "end": z.ended, err = dc.ReadTime() if err != nil { err = msgp.WrapError(err, "ended") return } case "st": z.started, err = dc.ReadTime() if err != nil { err = msgp.WrapError(err, "started") return } case "lh":
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 10K bytes - Click Count (0) -
cmd/object-handlers_test.go
if testCase.copySourceHeader != "" { if values.Encode() != "" && !strings.Contains(testCase.copySourceHeader, "?") { req.Header.Set("X-Amz-Copy-Source", testCase.copySourceHeader+"?"+values.Encode()) } else { req.Header.Set("X-Amz-Copy-Source", testCase.copySourceHeader) } } if testCase.copyModifiedHeader != "" {Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 163.1K bytes - Click Count (0) -
cmd/erasure-decode_test.go
for i, disk := range disks { writers[i] = newBitrotWriter(disk, "", "testbucket", "object", erasure.ShardFileSize(test.data), writeAlgorithm, erasure.ShardSize()) } n, err := erasure.Encode(t.Context(), bytes.NewReader(data), writers, buffer, erasure.dataBlocks+1) closeBitrotWriters(writers) if err != nil { t.Fatalf("Test %d: failed to create erasure test file: %v", i, err) } if n != test.data {Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 21K bytes - Click Count (0) -
cmd/metacache_test.go
bucket: "bucket", root: "folder/prefix", recursive: false, status: scanStateSuccess, fileNotFound: false, error: "", started: metaCacheTestsetTimestamp, ended: metaCacheTestsetTimestamp.Add(time.Minute), lastUpdate: metaCacheTestsetTimestamp.Add(time.Minute), lastHandout: metaCacheTestsetTimestamp, dataVersion: metacacheStreamVersion, }, 1: {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Wed Sep 08 18:06:45 GMT 2021 - 6.8K bytes - Click Count (0)