- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 58 for Marshall (0.16 sec)
-
cmd/batch-handlers.go
ctx context.Context `msg:"-"` } func notifyEndpoint(ctx context.Context, ri *batchJobInfo, endpoint, token string) error { if endpoint == "" { return nil } buf, err := json.Marshal(ri) if err != nil { return err } ctx, cancel := context.WithTimeout(ctx, 10*time.Second) defer cancel() req, err := http.NewRequestWithContext(ctx, http.MethodPost, endpoint, bytes.NewReader(buf))
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 55.2K bytes - Viewed (0) -
cmd/xl-storage-format-v2_test.go
t.Fatal(err) } vers = append(vers, xl.versions) } for _, v2 := range vers { for _, ver := range v2 { b, _ := json.Marshal(ver.header) t.Log(string(b)) var x xlMetaV2Version _, _ = x.unmarshalV(0, ver.meta) b, _ = json.Marshal(x) t.Log(string(b), x.getSignature()) } } for i := range vers { t.Run(fmt.Sprintf("non-strict-q%d", i), func(t *testing.T) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Mar 08 17:50:48 GMT 2024 - 36.4K bytes - Viewed (0) -
cmd/data-usage-cache.go
for k, v := range r.Targets { dst.Targets[k] = v } return &dst } //msgp:encode ignore dataUsageEntryV2 dataUsageEntryV3 dataUsageEntryV4 dataUsageEntryV5 dataUsageEntryV6 dataUsageEntryV7 //msgp:marshal ignore dataUsageEntryV2 dataUsageEntryV3 dataUsageEntryV4 dataUsageEntryV5 dataUsageEntryV6 dataUsageEntryV7 //msgp:tuple dataUsageEntryV2 type dataUsageEntryV2 struct { // These fields do no include any children.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 22 17:49:30 GMT 2024 - 41.4K bytes - Viewed (1) -
cmd/bucket-metadata-sys.go
var cfgData []byte if expiryRuleRemoved { var lcCfg lifecycle.Lifecycle currtime := time.Now() lcCfg.ExpiryUpdatedAt = &currtime cfgData, err = xml.Marshal(lcCfg) if err != nil { return updatedAt, err } } return sys.updateAndParse(ctx, bucket, configFile, cfgData, false) } return sys.updateAndParse(ctx, bucket, configFile, nil, false) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 22 17:49:30 GMT 2024 - 19.8K bytes - Viewed (0) -
cmd/admin-handlers-pools.go
writeErrorResponseJSON(ctx, w, toAPIError(ctx, err), r.URL) return } // Rebalance routine is run on the first node of any pool participating in rebalance. pools.StartRebalance() b, err := json.Marshal(struct { ID string `json:"id"` }{ID: id}) if err != nil { writeErrorResponseJSON(ctx, w, toAPIError(ctx, err), r.URL) return } writeSuccessResponseJSON(w, b)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 10.9K bytes - Viewed (0) -
cmd/bucket-handlers.go
if err != nil { apiErr := errorCodes.ToAPIErr(ErrInvalidArgument) apiErr.Description = err.Error() writeErrorResponse(ctx, w, apiErr, r.URL) return } configData, err := xml.Marshal(config) if err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } // Deny object locking configuration settings on existing buckets without object lock enabled.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 16:27:27 GMT 2024 - 61.6K bytes - Viewed (0) -
cmd/iam-object-store.go
return iamOS.usersSysType } func (iamOS *IAMObjectStore) saveIAMConfig(ctx context.Context, item interface{}, objPath string, opts ...options) error { json := jsoniter.ConfigCompatibleWithStandardLibrary data, err := json.Marshal(item) if err != nil { return err } if GlobalKMS != nil { data, err = config.EncryptBytes(GlobalKMS, data, kms.Context{ minioMetaBucket: path.Join(minioMetaBucket, objPath), }) if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 05 21:26:41 GMT 2024 - 19.9K bytes - Viewed (0) -
cmd/xl-storage-format-v2.go
} return fi, nil } // Signature will return a signature that is expected to be the same across all disks. func (j *xlMetaV2DeleteMarker) Signature() [4]byte { // Shallow copy c := *j // Marshal metadata crc := hashDeterministicBytes(c.MetaSys) c.MetaSys = nil if bts, err := c.MarshalMsg(metaDataPoolGet()); err == nil { crc ^= xxhash.Sum64(bts) metaDataPoolPut(bts) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 05:07:37 GMT 2024 - 63.6K bytes - Viewed (1) -
internal/store/queuestore.go
store.entries[key] = time.Now().UnixNano() return nil } // write - writes an item to the directory. func (store *QueueStore[I]) write(key string, item I) error { // Marshalls the item. eventData, err := json.Marshal(item) if err != nil { return err } path := filepath.Join(store.directory, key+store.fileExt) if err := os.WriteFile(path, eventData, os.FileMode(0o770)); err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 25 16:44:20 GMT 2024 - 7.1K bytes - Viewed (0) -
internal/bucket/lifecycle/filter_test.go
string: "doc/", set: true, Unused: struct{}{}, }, ObjectSizeGreaterThan: 100 * humanize.MiByte, ObjectSizeLessThan: 100 * humanize.GiByte, } b, err := xml.Marshal(f1) if err != nil { t.Fatalf("Failed to marshal %v", f1) } var f2 Filter err = xml.Unmarshal(b, &f2) if err != nil { t.Fatalf("Failed to unmarshal %s", string(b)) } if f1.ObjectSizeLessThan != f2.ObjectSizeLessThan {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 27 00:01:20 GMT 2024 - 7.2K bytes - Viewed (0)