- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for tm (0.14 sec)
-
internal/amztime/parse.go
// will try time.RFC3339Nano when parse http.TimeFormat failed func ParseReplicationTS(str string) (time.Time, error) { tm, err := time.Parse(http.TimeFormat, str) if tm.IsZero() || err != nil { tm, err = time.Parse(time.RFC3339Nano, str) } return tm, err
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 2.5K bytes - Viewed (0) -
cmd/site-replication.go
} // Replicate bucket policy if present. policyJSON, tm := meta.PolicyConfigJSON, meta.PolicyConfigUpdatedAt if len(policyJSON) > 0 { err = c.BucketMetaHook(ctx, madmin.SRBucketMeta{ Type: madmin.SRBucketMetaTypePolicy, Bucket: bucket, Policy: policyJSON, UpdatedAt: tm, }) if err != nil { return errSRBucketMetaError(err) } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 184.2K bytes - Viewed (1) -
internal/bucket/bandwidth/monitor.go
return m } func (m *Monitor) updateMeasurement(opts BucketOptions, bytes uint64) { m.mlock.Lock() defer m.mlock.Unlock() tm, ok := m.bucketsMeasurement[opts] if !ok { tm = &bucketMeasurement{} } tm.incrementBytes(bytes) m.bucketsMeasurement[opts] = tm } // SelectionFunction for buckets type SelectionFunction func(bucket string) bool // SelectBuckets will select all the buckets passed in.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Feb 19 22:54:46 GMT 2024 - 6K bytes - Viewed (0) -
cmd/xl-storage-format-v2-legacy.go
tm, err := time.Parse(time.RFC3339Nano, string(val)) if err == nil { j.DeleteMarker.MetaSys[ReservedMetadataPrefixLower+ReplicationTimestamp] = []byte(tm.UTC().Format(time.RFC3339Nano)) } } if val, ok := j.DeleteMarker.MetaSys[ReservedMetadataPrefixLower+ReplicaTimestamp]; ok { tm, err := time.Parse(time.RFC3339Nano, string(val)) if err == nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 16:43:43 GMT 2024 - 5.7K bytes - Viewed (0) -
cmd/bucket-replication.go
tgtStatuses := replicationStatusesMap(oi.ReplicationStatusInternal) purgeStatuses := versionPurgeStatusesMap(oi.VersionPurgeStatusInternal) tm, _ := time.Parse(time.RFC3339Nano, oi.UserDefined[ReservedMetadataPrefixLower+ReplicationTimestamp]) rstate := oi.ReplicationState() rstate.ReplicateDecisionStr = dsc.String() asz, _ := oi.GetActualSize()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 112.2K bytes - Viewed (1) -
cmd/bucket-replication-utils.go
} tgtStatuses := replicationStatusesMap(oi.ReplicationStatusInternal) purgeStatuses := versionPurgeStatusesMap(oi.VersionPurgeStatusInternal) existingObjResync := rcfg.Resync(GlobalContext, oi, dsc, tgtStatuses) tm, _ := time.Parse(time.RFC3339Nano, userDefined[ReservedMetadataPrefixLower+ReplicationTimestamp]) rstate := oi.ReplicationState() rstate.ReplicateDecisionStr = dsc.String() asz, _ := oi.GetActualSize()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 26.2K bytes - Viewed (0)