- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 16 for ending0 (0.17 sec)
-
cmd/bucket-replication-utils_test.go
rs: ReplicationState{ReplicationStatusInternal: "arn1=PENDING;", Targets: map[string]replication.StatusType{"arn1": "PENDING"}}, expStatus: replication.Pending, }, { // 3. replication status for one target - incorrect format name: "replication status for one target", rs: ReplicationState{ReplicationStatusInternal: "arn1=PENDING"}, expStatus: replication.StatusType(""), },
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Aug 08 20:27:40 GMT 2023 - 9.3K bytes - Viewed (0) -
cmd/data-usage-utils.go
// - replicated size for all objects sent to this target // - replica size for all objects received from this target // - replication pending size for all objects pending replication to this target // - replication failed size for all objects failed replication to this target // - replica pending count // - replica failed count type BucketTargetUsageInfo struct { ReplicationPendingSize uint64 `json:"objectsPendingReplicationTotalSize"`
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Mar 10 09:15:15 GMT 2024 - 6.4K bytes - Viewed (0) -
internal/config/cache/remote.go
IfRange string `json:"ifRange,omitempty" msg:",omitempty"` IfPartNumber int `json:"ifPartNumber,omitempty" msg:",omitempty"` } // IsSet tells the cache lookup to avoid sending a request func (r *CondCheck) IsSet() bool { if r == nil { return false } return r.IfMatch != "" || r.IfNoneMatch != "" || r.IfModifiedSince != nil || r.IfUnModifiedSince != nil || r.IfRange != "" }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Nov 22 21:46:17 GMT 2023 - 3.7K bytes - Viewed (0) -
cmd/erasure-server-pool-decom_test.go
}, { meta: nmeta2, pools: pools, name: "Correct-Decom-Pending", expectedErr: false, expectedUpdate: false, }, { meta: nmeta2, pools: reducedPools, name: "Invalid-Decom-Pending-Pool-Removal", expectedErr: false, expectedUpdate: true, }, { meta: nmeta1,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Jul 03 16:47:40 GMT 2023 - 4.8K bytes - Viewed (0) -
cmd/xl-storage-format-utils_test.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Sep 02 14:49:24 GMT 2023 - 6K bytes - Viewed (0) -
cmd/site-replication-metrics.go
srs.Latency.update(st.TransferSize, st.TransferDuration) srs.updateXferRate(st.TransferSize, st.TransferDuration) } case st.Failed: srs.Failed.addsize(st.TransferSize, st.Err) case st.Pending: } sr.M[dID] = srs } func (sr *SRStats) get() map[string]SRMetric { epMap := globalBucketTargetSys.healthStats() sr.lock.RLock() defer sr.lock.RUnlock()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 06 06:00:45 GMT 2024 - 8.2K bytes - Viewed (0) -
internal/event/targetlist.go
// any for the associated TargetID type TargetIDResult struct { // ID where the remove or send were initiated. ID TargetID // Stores any error while removing a target or while sending an event. Err error } // Remove - closes and removes targets by given target IDs. func (list *TargetList) Remove(targetIDSet TargetIDSet) { list.Lock() defer list.Unlock()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 9.2K bytes - Viewed (0) -
internal/bucket/replication/datatypes.go
//go:generate msgp -file=$GOFILE // StatusType of Replication for x-amz-replication-status header type StatusType string // Type - replication type enum type Type int const ( // Pending - replication is pending. Pending StatusType = "PENDING" // Completed - replication completed ok. Completed StatusType = "COMPLETED" // CompletedLegacy was called "COMPLETE" incorrectly. CompletedLegacy StatusType = "COMPLETE"
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Mar 08 19:08:18 GMT 2024 - 1.5K bytes - Viewed (0) -
internal/config/lambda/event/targetlist.go
// any for the associated TargetID type TargetIDResult struct { // ID where the remove or send were initiated. ID TargetID // Stores any error while removing a target or while sending an event. Err error } // Remove - closes and removes targets by given target IDs. func (list *TargetList) Remove(targetIDSet TargetIDSet) { list.Lock() defer list.Unlock() for id := range targetIDSet {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Mar 07 16:12:41 GMT 2023 - 4.3K bytes - Viewed (0) -
internal/event/target/webhook.go
resp, err := target.httpClient.Do(req) if err != nil { return err } defer xhttp.DrainBody(resp.Body) if resp.StatusCode < 200 || resp.StatusCode > 299 { return fmt.Errorf("sending event failed with %v", resp.Status) } return nil } // SendFromStore - reads an event from store and sends it to webhook. func (target *WebhookTarget) SendFromStore(key store.Key) error {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Nov 20 22:40:07 GMT 2023 - 8.5K bytes - Viewed (0)